Method Consumer

jetstream/stream.go:100–100

Consumer returns an interface to an existing consumer, allowing processing of messages. If consumer does not exist, ErrConsumerNotFound is returned. It returns ErrNotPullConsumer if the consumer is not a pull consumer (deliver subject is not set).

(ctx context.Context, consumer string)

		//
		// It returns ErrNotPullConsumer if the consumer is not a pull consumer (deliver subject is not set).
		Consumer(ctx context.Context, consumer string) (Consumer, error)

		// DeleteConsumer removes a consumer with given name from a stream.
		// If consumer does not exist, ErrConsumerNotFound is returned.