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

Method DeleteConsumer

jsm.go:83–83  ·  view source on GitHub ↗

DeleteConsumer deletes a consumer.

(stream, consumer string, opts ...JSOpt)

Source from the content-addressed store, hash-verified

81
82 // DeleteConsumer deletes a consumer.
83 DeleteConsumer(stream, consumer string, opts ...JSOpt) error
84
85 // ConsumerInfo retrieves information of a consumer from a stream.
86 ConsumerInfo(stream, name string, opts ...JSOpt) (*ConsumerInfo, error)

Callers 13

deleteConsumerMethod · 0.65
resetOrderedConsumerMethod · 0.65
ExampleJetStreamManagerFunction · 0.65
TestPullSubscribeFetchWithHeartbeatFunction · 0.65
TestPullSubscribeConsumerDoesNotExistFunction · 0.65
TestPullSubscribeFetchBatchWithHeartbeatFunction · 0.65
TestPullSubscribeFetchBatchFunction · 0.65
TestPullSubscribeConsumerDeletedFunction · 0.65
TestJetStreamManagementFunction · 0.65
TestJetStream_UnsubscribeFunction · 0.65
TestJetStreamDrainFailsToDeleteConsumerFunction · 0.65
TestJetStreamOrderedConsumerDeleteAssetsFunction · 0.65

Implementers 1

jsjs.go

Calls

no outgoing calls

Tested by 11

ExampleJetStreamManagerFunction · 0.52
TestPullSubscribeFetchWithHeartbeatFunction · 0.52
TestPullSubscribeConsumerDoesNotExistFunction · 0.52
TestPullSubscribeFetchBatchWithHeartbeatFunction · 0.52
TestPullSubscribeFetchBatchFunction · 0.52
TestPullSubscribeConsumerDeletedFunction · 0.52
TestJetStreamManagementFunction · 0.52
TestJetStream_UnsubscribeFunction · 0.52
TestJetStreamDrainFailsToDeleteConsumerFunction · 0.52
TestJetStreamOrderedConsumerDeleteAssetsFunction · 0.52
TestPullConsumerFetchRaceFunction · 0.52