From dd8e23aaddbc2ff56b4e936541eea8e64e3cdb89 Mon Sep 17 00:00:00 2001 From: matst80 Date: Tue, 18 Nov 2025 17:06:30 +0100 Subject: [PATCH] Update k8s-host-discovery.go --- cmd/cart/k8s-host-discovery.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) 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) }