- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for RegisterHasSyncedHandler (0.16 sec)
-
pilot/pkg/config/memory/controller.go
func NewSyncController(cs model.ConfigStore) *Controller { out := &Controller{ configStore: cs, monitor: NewSyncMonitor(cs), } return out } func (c *Controller) RegisterHasSyncedHandler(cb func() bool) { c.hasSynced = cb } func (c *Controller) RegisterEventHandler(kind config.GroupVersionKind, f model.EventHandler) { c.monitor.AppendEventHandler(kind, f) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 26 13:54:32 UTC 2023 - 4.7K bytes - Viewed (0) -
pilot/pkg/bootstrap/configcontroller.go
} store := memory.Make(collections.Pilot) // TODO: enable namespace filter for memory controller configController := memory.NewController(store) configController.RegisterHasSyncedHandler(xdsMCP.HasSynced) xdsMCP.Store = configController err = xdsMCP.Run() if err != nil { return fmt.Errorf("MCP: failed running %v", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 14.1K bytes - Viewed (0)