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

Method Watch

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

Watch for any updates to keys that match the keys argument which could include wildcards. By default, the watcher will send the latest value for each key and all future updates. Watch will send a nil entry when it has received all initial values. There are a few ways to configure the watcher: - Inc

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

Source from the content-addressed store, hash-verified

162 // - ResumeFromRevision instructs the key watcher to resume from a
163 // specific revision number.
164 Watch(ctx context.Context, keys string, opts ...WatchOpt) (KeyWatcher, error)
165
166 // WatchAll will watch for any updates to all keys. It can be configured
167 // with the same options as Watch.

Callers 10

TestKeyValueWatchFunction · 0.65
TestObjectWatchFunction · 0.65
TestObjectStoreMirrorFunction · 0.65
TestKeyValueWatchFunction · 0.65
TestObjectWatchFunction · 0.65
TestObjectStoreMirrorFunction · 0.65

Implementers 1

kvsjetstream/kv.go

Calls

no outgoing calls

Tested by 10

TestKeyValueWatchFunction · 0.52
TestObjectWatchFunction · 0.52
TestObjectStoreMirrorFunction · 0.52
TestKeyValueWatchFunction · 0.52
TestObjectWatchFunction · 0.52
TestObjectStoreMirrorFunction · 0.52