Method CreatePushConsumer

jetstream/stream.go:147–147

CreatePushConsumer creates a push consumer on a given stream with given config. If consumer already exists and the provided configuration differs from its configuration, ErrConsumerExists is returned. If the provided configuration is the same as the existing consumer, the existing consumer is return

(ctx context.Context, cfg ConsumerConfig)

		// existing consumer is returned. Consumer interface is returned,
		// allowing to consume messages.
		CreatePushConsumer(ctx context.Context, cfg ConsumerConfig) (PushConsumer, error)

		// UpdatePushConsumer updates an existing push consumer. If consumer does not
		// exist, ErrConsumerDoesNotExist is returned. Consumer interface is