- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewDefaultWatcher (0.36 sec)
-
pkg/revisions/default_watcher_test.go
client := kube.NewFakeClient() w := NewDefaultWatcher(client, "default") client.RunAndWait(stop) go w.Run(stop) // if have no default tag for some reason, should return "" expectRevision(t, w, "") close(stop) } func TestDefaultRevisionChanges(t *testing.T) { stop := test.NewStop(t) client := kube.NewFakeClient() w := NewDefaultWatcher(client, "default").(*defaultWatcher) client.RunAndWait(stop)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 23 17:46:59 UTC 2023 - 3.2K bytes - Viewed (0) -
pkg/revisions/default_watcher.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 09 02:22:47 UTC 2023 - 3.1K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection.go
var watcher revisions.DefaultWatcher if features.EnableLeaderElection { watcher = revisions.NewDefaultWatcher(client, revision) } if name == "" { hn, _ := os.Hostname() name = fmt.Sprintf("unknown-%s", hn) } if perRevision && revision != "" { electionID += "-" + revision }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 9.7K bytes - Viewed (0)