diff --git a/cmd/cart/k8s-host-discovery.go b/cmd/cart/k8s-host-discovery.go index bf552ab..5e54e87 100644 --- a/cmd/cart/k8s-host-discovery.go +++ b/cmd/cart/k8s-host-discovery.go @@ -6,7 +6,6 @@ import ( "git.tornberg.me/go-cart-actor/pkg/actor" "git.tornberg.me/go-cart-actor/pkg/cart" "git.tornberg.me/go-cart-actor/pkg/discovery" - "k8s.io/apimachinery/pkg/watch" "k8s.io/client-go/kubernetes" "k8s.io/client-go/rest" ) @@ -44,8 +43,8 @@ func UseDiscovery(pool actor.GrainPool[*cart.CartGrain]) { if evt.Host == "" { continue } - switch evt.Type { - case watch.Deleted: + switch evt.IsReady { + case false: if pool.IsKnown(evt.Host) { pool.RemoveHost(evt.Host) }