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

Method DeleteStream

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

DeleteStream removes a stream with given name. If stream does not exist, ErrStreamNotFound is returned.

(ctx context.Context, stream string)

Source from the content-addressed store, hash-verified

155 // DeleteStream removes a stream with given name. If stream does not
156 // exist, ErrStreamNotFound is returned.
157 DeleteStream(ctx context.Context, stream string) error
158
159 // ListStreams returns StreamInfoLister, enabling iteration over a
160 // channel of stream infos.

Callers 11

TestConsumerInfoFunction · 0.65
TestConsumerCachedInfoFunction · 0.65
TestDeleteStreamFunction · 0.65
TestJetStream_CreateOrUpdateConsumerFunction · 0.65
TestJetStream_CreateConsumerFunction · 0.65
TestJetStream_UpdateConsumerFunction · 0.65
TestJetStream_ConsumerFunction · 0.65
TestCreateOrUpdateConsumerFunction · 0.65
TestCreateConsumerFunction · 0.65
TestUpdateConsumerFunction · 0.65
TestConsumerFunction · 0.65

Implementers 1

jetStreamjetstream/jetstream.go

Calls

no outgoing calls

Tested by 11

TestConsumerInfoFunction · 0.52
TestConsumerCachedInfoFunction · 0.52
TestDeleteStreamFunction · 0.52
TestJetStream_CreateOrUpdateConsumerFunction · 0.52
TestJetStream_CreateConsumerFunction · 0.52
TestJetStream_UpdateConsumerFunction · 0.52
TestJetStream_ConsumerFunction · 0.52
TestCreateOrUpdateConsumerFunction · 0.52
TestCreateConsumerFunction · 0.52
TestUpdateConsumerFunction · 0.52
TestConsumerFunction · 0.52