Method WatchPrefix

kv/memberlist/memberlist_client.go:114–121

WatchPrefix calls f whenever any value stored under prefix changes. Part of kv.Client interface.

(ctx context.Context, prefix string, f func(string, interface{}) bool)

// WatchPrefix calls f whenever any value stored under prefix changes.
// Part of kv.Client interface.
func (c *Client) WatchPrefix(ctx context.Context, prefix string, f func(string, interface{}) bool) {
	err := c.awaitKVRunningOrStopping(ctx)
	if err != nil {
		return
	}

	c.kv.WatchPrefix(ctx, prefix, c.codec, f)
}

// We want to use KV in Running and Stopping states.
func (c *Client) awaitKVRunningOrStopping(ctx context.Context) error {