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

Method Info

jetstream/test/stream_test.go:163–163  ·  view source on GitHub ↗
(context.Context)

Source from the content-addressed store, hash-verified

161type consInfoConstraint interface {
162 CachedInfo() *jetstream.ConsumerInfo
163 Info(context.Context) (*jetstream.ConsumerInfo, error)
164}
165
166func TestCreateConsumer(t *testing.T) {

Callers 15

TestConsumerInfoFunction · 0.95
TestPublishAsyncRetryInErrHandlerFunction · 0.65
TestCreateStreamMirrorCrossDomainsFunction · 0.65
TestCreateOrUpdateStreamFunction · 0.65
TestUpdateStreamFunction · 0.65
TestListStreamsFunction · 0.65
TestCreateOrUpdateStreamCrossDomainsFunction · 0.65
TestPromoteMirrorToStreamFunction · 0.65
TestStreamSourceWithConsumerFunction · 0.65
TestStreamInfoFunction · 0.65
TestSubjectsFilterPagingFunction · 0.65
TestListConsumersFunction · 0.65

Implementers 4

pullConsumerjetstream/pull.go
pushConsumerjetstream/push.go
streamjetstream/stream.go
orderedConsumerjetstream/ordered.go

Calls

no outgoing calls

Tested by 15

TestConsumerInfoFunction · 0.76
TestPublishAsyncRetryInErrHandlerFunction · 0.52
TestCreateStreamMirrorCrossDomainsFunction · 0.52
TestCreateOrUpdateStreamFunction · 0.52
TestUpdateStreamFunction · 0.52
TestListStreamsFunction · 0.52
TestCreateOrUpdateStreamCrossDomainsFunction · 0.52
TestPromoteMirrorToStreamFunction · 0.52
TestStreamSourceWithConsumerFunction · 0.52
TestStreamInfoFunction · 0.52
TestSubjectsFilterPagingFunction · 0.52
TestListConsumersFunction · 0.52