Function mustCreateWatcher

tests/integration/proxy/grpcproxy/register_test.go:59–69

(t *testing.T, c *clientv3.Client, prefix string)

}

func mustCreateWatcher(t *testing.T, c *clientv3.Client, prefix string) endpoints.WatchChannel {
	em, err := endpoints.NewManager(c, prefix)
	if err != nil {
		t.Fatalf("failed to create endpoints.Manager: %v", err)
	}
	wc, err := em.NewWatchChannel(c.Ctx())
	if err != nil {
		t.Fatalf("failed to resolve %q (%v)", prefix, err)
	}
	return wc
}