GetFixedTime parses and returns the fixedTime constant as a time.Time value.

NewDefaultMockManager creates a Mock with defaults.

NewJetStreamWithCount creates a JetStream mock with Count functionality.

NewJetStreamWithPublish creates a JetStream mock that simulates a successful publish.

NewJetStreamWithPublishError creates a JetStream mock that simulates publish errors.

NewJetStreamWithStreamError creates a jetstream Mock with Stream error.

NewMockConsumer creates a new mock instance.

NewMockConsumerWithCountInfoError sets up a mock consumer that returns an Info error.

NewMockConsumerWithInfo sets up the consumer to return default info.

NewMockFetchResult creates a mock fetch result with messages.

NewMockJetStream creates a new mock instance.

NewMockJetStreamWithConsumerAndFetchError sets up a mock where ephemeralConsumer.Fetch fails.

NewMockJetStreamWithConsumerInfoError creates a JetStream mock where Consumer.Info() returns an error.

NewMockJetStreamWithCreateConsumerError sets up a mock where CreateOrUpdateConsumer fails.

NewMockJetStreamWithEphemeralConsumer sets up a mock with an ephemeral consumer.

NewMockJetStreamWithMetadataError sets up a mock where metadata retrieval fails.

NewMockManager creates a new mock instance.

NewMockMessageBatch creates a new mock instance.

NewMockMessagesContext creates a new mock instance.

NewMockMsg creates a new mock instance.

NewMockPublisher creates a new mock instance.

NewMockStream creates a new mock instance.

NewMockStreamConsumerManager creates a new mock instance.

NewMockStreamManager creates a new mock instance.

NewMockStreamWithConsumer sets up a mock stream with a consumer.

NewMockStreamWithConsumerError sets up a mock stream that returns a consumer error.

NewMockStreamWithDelete creates a mock where deletion succeeds.

NewMockStreamWithDeleteError creates a mock where message deletion fails.

NewMockStreamWithDeleteGetMsgError creates a mock where GetMessageBySeq returns a generic error.

NewMockStreamWithDeleteMessageNotFound creates a mock where message retrieval fails with 404.

NewMockStreamWithDeleteMessageSetup sets up a stream with message retrieval and deletion.

NewMockStreamWithDeleteStreamError creates a mock where Stream returns a generic error.

NewMockStreamWithGet creates a mock where get succeeds.

NewMockStreamWithGetMessageSetup sets up a stream with message retrieval.

NewMockStreamWithGetMsgError creates a mock where GetMessageBySeq returns a generic error.

NewMockStreamWithMessageIterator sets up a stream with a message iterator.

NewMockStreamWithMessageIteratorError sets up a stream where message iterator returns an error.

NewMockStreamWithMessageNotFound creates a mock where message retrieval fails with 404.

NewPlainJetStream creates a jetstream Mock without defaults.

NewPlainMockManager creates a Mock without defaults.

ConsumerName is the durable name of the NATS JetStream consumer.

StreamName represents the NATS JetStream stream to consume from.

SubjectName represents the NATS JetStream subject within the "TASKS" stream.

FixedStoredAt used throughout test suite for fixed time assertions.

MockConsumer is a mock of Consumer interface.

MockConsumerMockRecorder is the mock recorder for MockConsumer.

MockJetStream is a mock of JetStream interface.

MockJetStreamMockRecorder is the mock recorder for MockJetStream.

MockManager is a mock of Manager interface.

MockManagerMockRecorder is the mock recorder for MockManager.

MockMessageBatch is a mock of MessageBatch interface.

MockMessageBatchMockRecorder is the mock recorder for MockMessageBatch.

MockMessagesContext is a mock of MessagesContext interface.

MockMessagesContextMockRecorder is the mock recorder for MockMessagesContext.

MockMsg is a mock of Msg interface.

MockMsgMockRecorder is the mock recorder for MockMsg.

MockPublisher is a mock of Publisher interface.

MockPublisherMockRecorder is the mock recorder for MockPublisher.

MockStream is a mock of Stream interface.

MockStreamConsumerManager is a mock of StreamConsumerManager interface.

MockStreamConsumerManagerMockRecorder is the mock recorder for MockStreamConsumerManager.

MockStreamManager is a mock of StreamManager interface.

MockStreamManagerMockRecorder is the mock recorder for MockStreamManager.

MockStreamMockRecorder is the mock recorder for MockStream.