MCPcopy
hub / github.com/nats-io/nats.go / WatchAll

Method WatchAll

jetstream/kv.go:168–168  ·  view source on GitHub ↗

WatchAll will watch for any updates to all keys. It can be configured with the same options as Watch.

(ctx context.Context, opts ...WatchOpt)

Source from the content-addressed store, hash-verified

166 // WatchAll will watch for any updates to all keys. It can be configured
167 // with the same options as Watch.
168 WatchAll(ctx context.Context, opts ...WatchOpt) (KeyWatcher, error)
169
170 // WatchFiltered will watch for any updates to keys that match the keys
171 // argument. It can be configured with the same options as Watch.

Callers 11

TestKeyValueWatchFunction · 0.65
TestKeyValueWatchContextFunction · 0.65
TestKeyValueWatchContextUpdatesFunction · 0.65
TestKeyValueMirrorCrossDomainsFunction · 0.65
TestKeyValueWatcherStopTimerFunction · 0.65
TestKeyValueTTLFunction · 0.65
TestKeyValueWatchFunction · 0.65
TestKeyValueWatchContextFunction · 0.65
TestKeyValueWatchContextUpdatesFunction · 0.65
TestKeyValueMirrorCrossDomainsFunction · 0.65
TestKeyValueLimitMarkerTTLFunction · 0.65

Implementers 1

kvsjetstream/kv.go

Calls

no outgoing calls

Tested by 11

TestKeyValueWatchFunction · 0.52
TestKeyValueWatchContextFunction · 0.52
TestKeyValueWatchContextUpdatesFunction · 0.52
TestKeyValueMirrorCrossDomainsFunction · 0.52
TestKeyValueWatcherStopTimerFunction · 0.52
TestKeyValueTTLFunction · 0.52
TestKeyValueWatchFunction · 0.52
TestKeyValueWatchContextFunction · 0.52
TestKeyValueWatchContextUpdatesFunction · 0.52
TestKeyValueMirrorCrossDomainsFunction · 0.52
TestKeyValueLimitMarkerTTLFunction · 0.52