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

Method Context

kv.go:120–120  ·  view source on GitHub ↗

Context returns watcher context optionally provided by nats.Context option.

()

Source from the content-addressed store, hash-verified

118type KeyWatcher interface {
119 // Context returns watcher context optionally provided by nats.Context option.
120 Context() context.Context
121 // Updates returns a channel to read any updates to entries.
122 Updates() <-chan KeyValueEntry
123 // Stop will stop this watcher.

Callers 15

ExampleJetStreamFunction · 0.65
ExampleJetStreamManagerFunction · 0.65
ExamplePubOptFunction · 0.65
ExampleAckOptFunction · 0.65
ExamplePullOptFunction · 0.65
ExampleContextFunction · 0.65
TestNoRaceObjectContextOptFunction · 0.65
TestJetStreamPublishFunction · 0.65
TestPullSubscribeFetchWithHeartbeatFunction · 0.65
TestPullSubscribeFetchBatchWithHeartbeatFunction · 0.65
TestPullSubscribeFetchBatchFunction · 0.65
TestJetStreamManagementFunction · 0.65

Implementers 1

watcherkv.go

Calls

no outgoing calls

Tested by 15

ExampleJetStreamFunction · 0.52
ExampleJetStreamManagerFunction · 0.52
ExamplePubOptFunction · 0.52
ExampleAckOptFunction · 0.52
ExamplePullOptFunction · 0.52
ExampleContextFunction · 0.52
TestNoRaceObjectContextOptFunction · 0.52
TestJetStreamPublishFunction · 0.52
TestPullSubscribeFetchWithHeartbeatFunction · 0.52
TestPullSubscribeFetchBatchWithHeartbeatFunction · 0.52
TestPullSubscribeFetchBatchFunction · 0.52
TestJetStreamManagementFunction · 0.52