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

Method Stream

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

Stream fetches [StreamInfo] and returns a [Stream] interface for a given stream name. If stream does not exist, ErrStreamNotFound is returned.

(ctx context.Context, stream string)

Source from the content-addressed store, hash-verified

146 // Stream fetches [StreamInfo] and returns a [Stream] interface for a given stream name.
147 // If stream does not exist, ErrStreamNotFound is returned.
148 Stream(ctx context.Context, stream string) (Stream, error)
149
150 // StreamNameBySubject returns the name of the stream that listens on the given
151 // subject. If no stream is bound to given subject, ErrStreamNotFound

Callers 15

TestConsumerInfoFunction · 0.65
TestCreateStreamMirrorCrossDomainsFunction · 0.65
TestStreamFunction · 0.65
TestKeyValueDeleteTombstonesFunction · 0.65
TestKeyValueCrossAccountsFunction · 0.65
TestKeyValueDuplicatesWindowFunction · 0.65
TestKeyValueMirrorCrossDomainsFunction · 0.65
TestKeyValueRePublishFunction · 0.65
TestKeyValueCreateFunction · 0.65
TestKeyValueCompressionFunction · 0.65
TestKeyValueCreateRepairOldKVFunction · 0.65
TestKeyValueLimitMarkerTTLFunction · 0.65

Implementers 1

jetStreamjetstream/jetstream.go

Calls

no outgoing calls

Tested by 15

TestConsumerInfoFunction · 0.52
TestCreateStreamMirrorCrossDomainsFunction · 0.52
TestStreamFunction · 0.52
TestKeyValueDeleteTombstonesFunction · 0.52
TestKeyValueCrossAccountsFunction · 0.52
TestKeyValueDuplicatesWindowFunction · 0.52
TestKeyValueMirrorCrossDomainsFunction · 0.52
TestKeyValueRePublishFunction · 0.52
TestKeyValueCreateFunction · 0.52
TestKeyValueCompressionFunction · 0.52
TestKeyValueCreateRepairOldKVFunction · 0.52
TestKeyValueLimitMarkerTTLFunction · 0.52