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

Function ResumeFromRevision

jetstream/kv_options.go:70–75  ·  view source on GitHub ↗

ResumeFromRevision instructs the key watcher to resume from a specific revision number.

(revision uint64)

Source from the content-addressed store, hash-verified

68// ResumeFromRevision instructs the key watcher to resume from a specific
69// revision number.
70func ResumeFromRevision(revision uint64) WatchOpt {
71 return watchOptFn(func(opts *watchOpts) error {
72 opts.resumeFromRevision = revision
73 return nil
74 })
75}
76
77// DeleteMarkersOlderThan indicates that delete or purge markers older than that
78// will be deleted as part of [KeyValue.PurgeDeletes] operation, otherwise, only the data

Callers 1

TestKeyValueWatchFunction · 0.92

Calls 1

watchOptFnFuncType · 0.70

Tested by 1

TestKeyValueWatchFunction · 0.74