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

Method CreateStream

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

CreateStream creates a new stream with the given config and returns an interface to operate on it. If stream with given name already exists and its configuration differs from the provided one, ErrStreamNameAlreadyInUse is returned.

(ctx context.Context, cfg StreamConfig)

Source from the content-addressed store, hash-verified

134 // and its configuration differs from the provided one,
135 // ErrStreamNameAlreadyInUse is returned.
136 CreateStream(ctx context.Context, cfg StreamConfig) (Stream, error)
137
138 // UpdateStream updates an existing stream. If stream does not exist,
139 // ErrStreamNotFound is returned.

Callers 15

TestConsumerInfoFunction · 0.65
TestConsumerOverflowFunction · 0.65
TestConsumerPinnedFunction · 0.65
TestConsumerUnpinFunction · 0.65
TestConsumerPrioritizedFunction · 0.65
TestConsumerCachedInfoFunction · 0.65
TestJetStreamPauseAndResumeConsumerFunction · 0.65
TestJetStreamResetConsumerFunction · 0.65
TestMessageDetailsFunction · 0.65
TestAckVariantsFunction · 0.65
TestPushConsumerConsumeFunction · 0.65
TestPushConsumerConsume_WithQueueFunction · 0.65

Implementers 1

jetStreamjetstream/jetstream.go

Calls

no outgoing calls

Tested by 15

TestConsumerInfoFunction · 0.52
TestConsumerOverflowFunction · 0.52
TestConsumerPinnedFunction · 0.52
TestConsumerUnpinFunction · 0.52
TestConsumerPrioritizedFunction · 0.52
TestConsumerCachedInfoFunction · 0.52
TestJetStreamPauseAndResumeConsumerFunction · 0.52
TestJetStreamResetConsumerFunction · 0.52
TestMessageDetailsFunction · 0.52
TestAckVariantsFunction · 0.52
TestPushConsumerConsumeFunction · 0.52
TestPushConsumerConsume_WithQueueFunction · 0.52