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

Interface ObjectWatcher

object.go:115–120  ·  object.go::ObjectWatcher

ObjectWatcher is what is returned when doing a watch.

Source from the content-addressed store, hash-verified

113
114// ObjectWatcher is what is returned when doing a watch.
115type ObjectWatcher interface {
116 // Updates returns a channel to read any updates to entries.
117 Updates() <-chan *ObjectInfo
118 // Stop will stop this watcher.
119 Stop() error
120}
121
122var (
123 ErrObjectConfigRequired = errors.New("nats: object-store config required")

Callers

nothing calls this directly

Implementers 4

watcherkv.go
objWatcherobject.go
watcherjetstream/kv.go
objWatcherjetstream/object.go

Calls

no outgoing calls

Tested by

no test coverage detected