- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for NewFileWatcher (0.43 sec)
-
pkg/config/mesh/watcher_test.go
"istio.io/istio/pkg/filewatcher" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/util/protomarshal" ) func TestNewWatcherWithBadInputShouldFail(t *testing.T) { g := NewWithT(t) _, err := mesh.NewFileWatcher(filewatcher.NewWatcher(), "", false) g.Expect(err).ToNot(BeNil()) } func TestWatcherShouldNotifyHandlers(t *testing.T) { watcherShouldNotifyHandlers(t, false) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 3K bytes - Viewed (0) -
pkg/kube/inject/watcher.go
client kube.Client namespace string name string configKey string valuesKey string handler func(*Config, string) error } // NewFileWatcher creates a Watcher for local config and values files. func NewFileWatcher(configFile, valuesFile string) (Watcher, error) { watcher, err := fsnotify.NewWatcher() if err != nil { return nil, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/config/mesh/watcher.go
func NewFixedWatcher(mesh *meshconfig.MeshConfig) Watcher { iw := internalWatcher{} iw.MeshConfig.Store(mesh) return &iw } // NewFileWatcher creates a new Watcher for changes to the given mesh config file. Returns an error // if the given file does not exist or failed during parsing. func NewFileWatcher(fileWatcher filewatcher.FileWatcher, filename string, multiWatch bool) (Watcher, error) { meshConfigYaml, err := ReadMeshConfigData(filename)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 7.4K bytes - Viewed (0) -
pilot/pkg/bootstrap/mesh.go
multiWatch := features.SharedMeshConfig != "" var err error if _, err = os.Stat(args.MeshConfigFile); !os.IsNotExist(err) { s.environment.Watcher, err = mesh.NewFileWatcher(fileWatcher, args.MeshConfigFile, multiWatch) if err == nil { if multiWatch && s.kubeClient != nil { kubemesh.AddUserMeshConfig(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4.5K bytes - Viewed (0) -
pilot/pkg/bootstrap/sidecarinjector.go
if _, err := os.Stat(filepath.Join(injectPath, "config")); !os.IsNotExist(err) { configFile := filepath.Join(injectPath, "config") valuesFile := filepath.Join(injectPath, "values") watcher, err = inject.NewFileWatcher(configFile, valuesFile) if err != nil { return nil, err } } else if s.kubeClient != nil { configMapName := getInjectorConfigMapName(args.Revision)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 04 20:39:38 UTC 2024 - 4K bytes - Viewed (0) -
pkg/kube/inject/webhook_test.go
Watcher: mesh.NewFixedWatcher(m), ConfigStore: store, } env.SetPushContext(&model.PushContext{ ProxyConfigs: pcs, }) watcher, err := NewFileWatcher(configFile, valuesFile) if err != nil { t.Fatalf("NewFileWatcher() failed: %v", err) } wh, err := NewWebhook(WebhookParameters{ Watcher: watcher, Port: port, Env: &env, Mux: http.NewServeMux(), })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 39K bytes - Viewed (1)