- Sort Score
- Result 10 results
- Languages All
Results 41 - 42 of 42 for Messages (0.13 sec)
-
pkg/kube/multicluster/secretcontroller.go
// Intentionally no lock. The controller today requires that handlers are registered before execution and not in parallel. c.handlers = append(c.handlers, h) } // Run starts the controller until it receives a message over stopCh func (c *Controller) Run(stopCh <-chan struct{}) error { // run handlers for the config cluster; do not store this *Cluster in the ClusterStore or give it a SyncTimeout
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
Healthy: true, }) checkHealthOrFail(t, store, p, true) }) t.Run("auto registered unhealthy health", func(t *testing.T) { ig.QueueWorkloadEntryHealth(p, HealthEvent{ Healthy: false, Message: "lol health bad", }) checkHealthOrFail(t, store, p, false) }) } func TestWorkloadEntryFromGroup(t *testing.T) { group := config.Config{ Meta: config.Meta{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K bytes - Viewed (0)