Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewMultiWatcher (0.13 sec)

  1. 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)
  2. 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)
Back to top