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

Method Updates

jetstream/kv.go:349–349  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

347 // Stop is called or connection is closed.
348 KeyWatcher interface {
349 Updates() <-chan KeyValueEntry
350 Stop() error
351 }
352

Callers 15

PurgeDeletesMethod · 0.65
KeysMethod · 0.65
ListKeysMethod · 0.65
HistoryMethod · 0.65
ListMethod · 0.65
TestCompatibilityObjectStoreWatchFunction · 0.65
TestCompatibilityObjectStoreWatchUpdatesFunction · 0.65
TestKeyValueWatchFunction · 0.65
TestKeyValueWatchContextUpdatesFunction · 0.65
TestKeyValueCrossAccountsFunction · 0.65
TestObjectWatchFunction · 0.65
TestObjectStoreMirrorFunction · 0.65

Implementers 1

watcherkv.go

Calls

no outgoing calls

Tested by 14

TestCompatibilityObjectStoreWatchFunction · 0.52
TestCompatibilityObjectStoreWatchUpdatesFunction · 0.52
TestKeyValueWatchFunction · 0.52
TestKeyValueWatchContextUpdatesFunction · 0.52
TestKeyValueCrossAccountsFunction · 0.52
TestObjectWatchFunction · 0.52
TestObjectStoreMirrorFunction · 0.52
TestKeyValueTTLFunction · 0.52
TestKeyValueWatchFunction · 0.52
TestKeyValueWatchContextUpdatesFunction · 0.52
TestKeyValueCrossAccountsFunction · 0.52
TestKeyValueLimitMarkerTTLFunction · 0.52