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

Method ResetConsumer

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

ResetConsumer resets a consumer's delivery state without deleting and recreating it. The consumer is reset to deliver from ack_floor + 1.

(ctx context.Context, consumer string)

Source from the content-addressed store, hash-verified

125 // and recreating it. The consumer is reset to deliver from
126 // ack_floor + 1.
127 ResetConsumer(ctx context.Context, consumer string) (*ConsumerResetResponse, error)
128
129 // ResetConsumerToSequence resets a consumer's delivery state to the
130 // given stream sequence. The seq must be compatible with the

Callers 2

TestStreamResetConsumerFunction · 0.65

Implementers 1

streamjetstream/stream.go

Calls

no outgoing calls

Tested by 2

TestStreamResetConsumerFunction · 0.52