WatchKey is a part of kv.Client interface.
(ctx context.Context, key string, f func(any) bool)
| 321 | |
| 322 | // WatchKey is a part of kv.Client interface. |
| 323 | func (m *MultiClient) WatchKey(ctx context.Context, key string, f func(any) bool) { |
| 324 | _ = m.runWithPrimaryClient(ctx, func(newCtx context.Context, primary kvclient) error { |
| 325 | primary.client.WatchKey(newCtx, key, f) |
| 326 | return newCtx.Err() |
| 327 | }) |
| 328 | } |
| 329 | |
| 330 | // WatchPrefix is a part of kv.Client interface. |
| 331 | func (m *MultiClient) WatchPrefix(ctx context.Context, prefix string, f func(string, any) bool) { |
nothing calls this directly
no test coverage detected