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

Method UpdateConsumer

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

UpdateConsumer updates an existing pull consumer. If consumer does not exist, ErrConsumerDoesNotExist is returned. Consumer interface is returned, allowing to operate on a consumer (e.g. fetch messages).

(ctx context.Context, cfg ConsumerConfig)

Source from the content-addressed store, hash-verified

85 // exist, ErrConsumerDoesNotExist is returned. Consumer interface is
86 // returned, allowing to operate on a consumer (e.g. fetch messages).
87 UpdateConsumer(ctx context.Context, cfg ConsumerConfig) (Consumer, error)
88
89 // OrderedConsumer returns an OrderedConsumer instance. OrderedConsumer
90 // are managed by the library and provide a simple way to consume

Callers 2

TestUpdateConsumerFunction · 0.65

Implementers 1

streamjetstream/stream.go

Calls

no outgoing calls

Tested by 2

TestUpdateConsumerFunction · 0.52