Method WatchPrefix

pkg/ring/kv/multi.go:331–336

WatchPrefix is a part of kv.Client interface.

(ctx context.Context, prefix string, f func(string, any) bool)

// WatchPrefix is a part of kv.Client interface.
func (m *MultiClient) WatchPrefix(ctx context.Context, prefix string, f func(string, any) bool) {
	_ = m.runWithPrimaryClient(ctx, func(newCtx context.Context, primary kvclient) error {
		primary.client.WatchPrefix(newCtx, prefix, f)
		return newCtx.Err()
	})
}

func (m *MultiClient) LastUpdateTime(key string) time.Time {
	_, kv := m.getPrimaryClient()