- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NewMultiWatcher (0.19 sec)
-
pkg/config/mesh/kubemesh/watcher.go
// NewConfigMapWatcher creates a new Watcher for changes to the given ConfigMap. func NewConfigMapWatcher(client kube.Client, namespace, name, key string, multiWatch bool, stop <-chan struct{}) *mesh.MultiWatcher { w := mesh.NewMultiWatcher(mesh.DefaultMeshConfig()) c := configmapwatcher.NewController(client, namespace, name, func(cm *v1.ConfigMap) { meshNetworks, err := ReadNetworksConfigMap(cm, "meshNetworks") if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 25 20:54:46 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/config/mesh/watcher.go
HandleUserMeshConfig(string) } // MultiWatcher is a struct wrapping the internal injector to let users know that both type MultiWatcher struct { *internalWatcher internalNetworkWatcher } func NewMultiWatcher(config *meshconfig.MeshConfig) *MultiWatcher { iw := &internalWatcher{} iw.MeshConfig.Store(config) return &MultiWatcher{ internalWatcher: iw, } } var _ Watcher = &internalWatcher{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 7.4K bytes - Viewed (0)