mocks

package
v0.0.0-...-5485e49 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 7, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Index

Constants

View Source 
const (

	// ConsumerName is the durable name of the NATS JetStream consumer.
	ConsumerName = "osapi"
	// StreamName represents the NATS JetStream stream to consume from.
	StreamName = "TASKS"
	// SubjectName represents the NATS JetStream subject within the "TASKS" stream.
	SubjectName = "tasks"
)

Variables

View Source 
var (
	// FixedStoredAt used throughout test suite for fixed time assertions.
	FixedStoredAt = GetFixedTime()
)

Functions

func GetFixedTime 

func GetFixedTime() time.Time

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

func NewMockConsumerWithInfo 

func NewMockConsumerWithInfo(mockConsumer *MockConsumer)

NewMockConsumerWithInfo sets up the consumer to return default info.

func NewMockStreamWithConsumer 

func NewMockStreamWithConsumer(
	ctrl *gomock.Controller,
) (*MockJetStream, *MockStream, *MockConsumer)

NewMockStreamWithConsumer sets up a mock stream with a consumer.

func NewMockStreamWithDeleteMessageSetup 

func NewMockStreamWithDeleteMessageSetup(
	ctrl *gomock.Controller,
	getMsgErr error,
) (*MockJetStream, *MockStream)

NewMockStreamWithDeleteMessageSetup sets up a stream with message retrieval and deletion.

func NewMockStreamWithGetMessageSetup 

func NewMockStreamWithGetMessageSetup(
	ctrl *gomock.Controller,
	getMsgErr error,
) (*MockJetStream, *MockStream)

NewMockStreamWithGetMessageSetup sets up a stream with message retrieval.

Types

type MockConsumer 

type MockConsumer struct {
	// contains filtered or unexported fields
}

MockConsumer is a mock of Consumer interface.

func NewMockConsumer 

func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer

NewMockConsumer creates a new mock instance.

func (*MockConsumer) CachedInfo 

func (m *MockConsumer) CachedInfo() *jetstream.ConsumerInfo

CachedInfo mocks base method.

func (*MockConsumer) Consume 

func (m *MockConsumer) Consume(arg0 jetstream.MessageHandler, arg1 ...jetstream.PullConsumeOpt) (jetstream.ConsumeContext, error)

Consume mocks base method.

func (*MockConsumer) EXPECT 

func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockConsumer) Fetch 

func (m *MockConsumer) Fetch(arg0 int, arg1 ...jetstream.FetchOpt) (jetstream.MessageBatch, error)

Fetch mocks base method.

func (*MockConsumer) FetchBytes 

func (m *MockConsumer) FetchBytes(arg0 int, arg1 ...jetstream.FetchOpt) (jetstream.MessageBatch, error)

FetchBytes mocks base method.

func (*MockConsumer) FetchNoWait 

func (m *MockConsumer) FetchNoWait(arg0 int) (jetstream.MessageBatch, error)

FetchNoWait mocks base method.

func (*MockConsumer) Info 

func (m *MockConsumer) Info(arg0 context.Context) (*jetstream.ConsumerInfo, error)

Info mocks base method.

func (*MockConsumer) Messages 

func (m *MockConsumer) Messages(arg0 ...jetstream.PullMessagesOpt) (jetstream.MessagesContext, error)

Messages mocks base method.

func (*MockConsumer) Next 

func (m *MockConsumer) Next(arg0 ...jetstream.FetchOpt) (jetstream.Msg, error)

Next mocks base method.

type MockConsumerMockRecorder 

type MockConsumerMockRecorder struct {
	// contains filtered or unexported fields
}

MockConsumerMockRecorder is the mock recorder for MockConsumer.

func (*MockConsumerMockRecorder) CachedInfo 

func (mr *MockConsumerMockRecorder) CachedInfo() *gomock.Call

CachedInfo indicates an expected call of CachedInfo.

func (*MockConsumerMockRecorder) Consume 

func (mr *MockConsumerMockRecorder) Consume(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Consume indicates an expected call of Consume.

func (*MockConsumerMockRecorder) Fetch 

func (mr *MockConsumerMockRecorder) Fetch(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Fetch indicates an expected call of Fetch.

func (*MockConsumerMockRecorder) FetchBytes 

func (mr *MockConsumerMockRecorder) FetchBytes(arg0 interface{}, arg1 ...interface{}) *gomock.Call

FetchBytes indicates an expected call of FetchBytes.

func (*MockConsumerMockRecorder) FetchNoWait 

func (mr *MockConsumerMockRecorder) FetchNoWait(arg0 interface{}) *gomock.Call

FetchNoWait indicates an expected call of FetchNoWait.

func (*MockConsumerMockRecorder) Info 

func (mr *MockConsumerMockRecorder) Info(arg0 interface{}) *gomock.Call

Info indicates an expected call of Info.

func (*MockConsumerMockRecorder) Messages 

func (mr *MockConsumerMockRecorder) Messages(arg0 ...interface{}) *gomock.Call

Messages indicates an expected call of Messages.

func (*MockConsumerMockRecorder) Next 

func (mr *MockConsumerMockRecorder) Next(arg0 ...interface{}) *gomock.Call

Next indicates an expected call of Next.

type MockJetStream 

type MockJetStream struct {
	// contains filtered or unexported fields
}

MockJetStream is a mock of JetStream interface.

func NewJetStreamWithCount 

func NewJetStreamWithCount(ctrl *gomock.Controller) *MockJetStream

NewJetStreamWithCount creates a JetStream mock with Count functionality.

func NewJetStreamWithPublish 

func NewJetStreamWithPublish(ctrl *gomock.Controller) *MockJetStream

NewJetStreamWithPublish creates a JetStream mock that simulates a successful publish.

func NewJetStreamWithPublishError 

func NewJetStreamWithPublishError(ctrl *gomock.Controller) *MockJetStream

NewJetStreamWithPublishError creates a JetStream mock that simulates publish errors.

func NewJetStreamWithStreamError 

func NewJetStreamWithStreamError(ctrl *gomock.Controller) *MockJetStream

NewJetStreamWithStreamError creates a jetstream Mock with Stream error.

func NewMockConsumerWithCountInfoError 

func NewMockConsumerWithCountInfoError(ctrl *gomock.Controller) *MockJetStream

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

func NewMockJetStream 

func NewMockJetStream(ctrl *gomock.Controller) *MockJetStream

NewMockJetStream creates a new mock instance.

func NewMockJetStreamWithConsumerAndFetchError 

func NewMockJetStreamWithConsumerAndFetchError(ctrl *gomock.Controller) *MockJetStream

NewMockJetStreamWithConsumerAndFetchError sets up a mock where ephemeralConsumer.Fetch fails.

func NewMockJetStreamWithConsumerInfoError 

func NewMockJetStreamWithConsumerInfoError(ctrl *gomock.Controller) *MockJetStream

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

func NewMockJetStreamWithCreateConsumerError 

func NewMockJetStreamWithCreateConsumerError(ctrl *gomock.Controller) *MockJetStream

NewMockJetStreamWithCreateConsumerError sets up a mock where CreateOrUpdateConsumer fails.

func NewMockJetStreamWithEphemeralConsumer 

func NewMockJetStreamWithEphemeralConsumer(ctrl *gomock.Controller) *MockJetStream

NewMockJetStreamWithEphemeralConsumer sets up a mock with an ephemeral consumer.

func NewMockJetStreamWithMetadataError 

func NewMockJetStreamWithMetadataError(ctrl *gomock.Controller) *MockJetStream

NewMockJetStreamWithMetadataError sets up a mock where metadata retrieval fails.

func NewMockStreamWithConsumerError 

func NewMockStreamWithConsumerError(
	ctrl *gomock.Controller,
) *MockJetStream

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

func NewMockStreamWithDelete 

func NewMockStreamWithDelete(ctrl *gomock.Controller) *MockJetStream

NewMockStreamWithDelete creates a mock where deletion succeeds.

func NewMockStreamWithDeleteError 

func NewMockStreamWithDeleteError(ctrl *gomock.Controller) *MockJetStream

NewMockStreamWithDeleteError creates a mock where message deletion fails.

func NewMockStreamWithDeleteGetMsgError 

func NewMockStreamWithDeleteGetMsgError(ctrl *gomock.Controller) *MockJetStream

NewMockStreamWithDeleteGetMsgError creates a mock where GetMessageBySeq returns a generic error.

func NewMockStreamWithDeleteMessageNotFound 

func NewMockStreamWithDeleteMessageNotFound(ctrl *gomock.Controller) *MockJetStream

NewMockStreamWithDeleteMessageNotFound creates a mock where message retrieval fails with 404.

func NewMockStreamWithDeleteStreamError 

func NewMockStreamWithDeleteStreamError(ctrl *gomock.Controller) *MockJetStream

NewMockStreamWithDeleteStreamError creates a mock where Stream returns a generic error.

func NewMockStreamWithGet 

func NewMockStreamWithGet(ctrl *gomock.Controller) *MockJetStream

NewMockStreamWithGet creates a mock where get succeeds.

func NewMockStreamWithGetMsgError 

func NewMockStreamWithGetMsgError(ctrl *gomock.Controller) *MockJetStream

NewMockStreamWithGetMsgError creates a mock where GetMessageBySeq returns a generic error.

func NewMockStreamWithMessageIterator 

func NewMockStreamWithMessageIterator(ctrl *gomock.Controller) *MockJetStream

NewMockStreamWithMessageIterator sets up a stream with a message iterator.

func NewMockStreamWithMessageIteratorError 

func NewMockStreamWithMessageIteratorError(ctrl *gomock.Controller) *MockJetStream

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

func NewMockStreamWithMessageNotFound 

func NewMockStreamWithMessageNotFound(ctrl *gomock.Controller) *MockJetStream

NewMockStreamWithMessageNotFound creates a mock where message retrieval fails with 404.

func NewPlainJetStream 

func NewPlainJetStream(ctrl *gomock.Controller) *MockJetStream

NewPlainJetStream creates a jetstream Mock without defaults.

func (*MockJetStream) AccountInfo 

func (m *MockJetStream) AccountInfo(arg0 context.Context) (*jetstream.AccountInfo, error)

AccountInfo mocks base method.

func (*MockJetStream) CleanupPublisher 

func (m *MockJetStream) CleanupPublisher()

CleanupPublisher mocks base method.

func (*MockJetStream) Conn 

func (m *MockJetStream) Conn() *nats.Conn

Conn mocks base method.

func (*MockJetStream) Consumer 

func (m *MockJetStream) Consumer(arg0 context.Context, arg1, arg2 string) (jetstream.Consumer, error)

Consumer mocks base method.

func (*MockJetStream) CreateConsumer 

func (m *MockJetStream) CreateConsumer(arg0 context.Context, arg1 string, arg2 jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateConsumer mocks base method.

func (*MockJetStream) CreateKeyValue 

func (m *MockJetStream) CreateKeyValue(arg0 context.Context, arg1 jetstream.KeyValueConfig) (jetstream.KeyValue, error)

CreateKeyValue mocks base method.

func (*MockJetStream) CreateObjectStore 

func (m *MockJetStream) CreateObjectStore(arg0 context.Context, arg1 jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)

CreateObjectStore mocks base method.

func (*MockJetStream) CreateOrUpdateConsumer 

func (m *MockJetStream) CreateOrUpdateConsumer(arg0 context.Context, arg1 string, arg2 jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateOrUpdateConsumer mocks base method.

func (*MockJetStream) CreateOrUpdateKeyValue 

func (m *MockJetStream) CreateOrUpdateKeyValue(arg0 context.Context, arg1 jetstream.KeyValueConfig) (jetstream.KeyValue, error)

CreateOrUpdateKeyValue mocks base method.

func (*MockJetStream) CreateOrUpdateObjectStore 

func (m *MockJetStream) CreateOrUpdateObjectStore(arg0 context.Context, arg1 jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)

CreateOrUpdateObjectStore mocks base method.

func (*MockJetStream) CreateOrUpdateStream 

func (m *MockJetStream) CreateOrUpdateStream(arg0 context.Context, arg1 jetstream.StreamConfig) (jetstream.Stream, error)

CreateOrUpdateStream mocks base method.

func (*MockJetStream) CreateStream 

func (m *MockJetStream) CreateStream(arg0 context.Context, arg1 jetstream.StreamConfig) (jetstream.Stream, error)

CreateStream mocks base method.

func (*MockJetStream) DeleteConsumer 

func (m *MockJetStream) DeleteConsumer(arg0 context.Context, arg1, arg2 string) error

DeleteConsumer mocks base method.

func (*MockJetStream) DeleteKeyValue 

func (m *MockJetStream) DeleteKeyValue(arg0 context.Context, arg1 string) error

DeleteKeyValue mocks base method.

func (*MockJetStream) DeleteObjectStore 

func (m *MockJetStream) DeleteObjectStore(arg0 context.Context, arg1 string) error

DeleteObjectStore mocks base method.

func (*MockJetStream) DeleteStream 

func (m *MockJetStream) DeleteStream(arg0 context.Context, arg1 string) error

DeleteStream mocks base method.

func (*MockJetStream) EXPECT 

func (m *MockJetStream) EXPECT() *MockJetStreamMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockJetStream) KeyValue 

func (m *MockJetStream) KeyValue(arg0 context.Context, arg1 string) (jetstream.KeyValue, error)

KeyValue mocks base method.

func (*MockJetStream) KeyValueStoreNames 

func (m *MockJetStream) KeyValueStoreNames(arg0 context.Context) jetstream.KeyValueNamesLister

KeyValueStoreNames mocks base method.

func (*MockJetStream) KeyValueStores 

func (m *MockJetStream) KeyValueStores(arg0 context.Context) jetstream.KeyValueLister

KeyValueStores mocks base method.

func (*MockJetStream) ListStreams 

func (m *MockJetStream) ListStreams(arg0 context.Context, arg1 ...jetstream.StreamListOpt) jetstream.StreamInfoLister

ListStreams mocks base method.

func (*MockJetStream) ObjectStore 

func (m *MockJetStream) ObjectStore(arg0 context.Context, arg1 string) (jetstream.ObjectStore, error)

ObjectStore mocks base method.

func (*MockJetStream) ObjectStoreNames 

func (m *MockJetStream) ObjectStoreNames(arg0 context.Context) jetstream.ObjectStoreNamesLister

ObjectStoreNames mocks base method.

func (*MockJetStream) ObjectStores 

func (m *MockJetStream) ObjectStores(arg0 context.Context) jetstream.ObjectStoresLister

ObjectStores mocks base method.

func (*MockJetStream) Options 

func (m *MockJetStream) Options() jetstream.JetStreamOptions

Options mocks base method.

func (*MockJetStream) OrderedConsumer 

func (m *MockJetStream) OrderedConsumer(arg0 context.Context, arg1 string, arg2 jetstream.OrderedConsumerConfig) (jetstream.Consumer, error)

OrderedConsumer mocks base method.

func (*MockJetStream) Publish 

func (m *MockJetStream) Publish(arg0 context.Context, arg1 string, arg2 []byte, arg3 ...jetstream.PublishOpt) (*jetstream.PubAck, error)

Publish mocks base method.

func (*MockJetStream) PublishAsync 

func (m *MockJetStream) PublishAsync(arg0 string, arg1 []byte, arg2 ...jetstream.PublishOpt) (jetstream.PubAckFuture, error)

PublishAsync mocks base method.

func (*MockJetStream) PublishAsyncComplete 

func (m *MockJetStream) PublishAsyncComplete() <-chan struct{}

PublishAsyncComplete mocks base method.

func (*MockJetStream) PublishAsyncPending 

func (m *MockJetStream) PublishAsyncPending() int

PublishAsyncPending mocks base method.

func (*MockJetStream) PublishMsg 

func (m *MockJetStream) PublishMsg(arg0 context.Context, arg1 *nats.Msg, arg2 ...jetstream.PublishOpt) (*jetstream.PubAck, error)

PublishMsg mocks base method.

func (*MockJetStream) PublishMsgAsync 

func (m *MockJetStream) PublishMsgAsync(arg0 *nats.Msg, arg1 ...jetstream.PublishOpt) (jetstream.PubAckFuture, error)

PublishMsgAsync mocks base method.

func (*MockJetStream) Stream 

func (m *MockJetStream) Stream(arg0 context.Context, arg1 string) (jetstream.Stream, error)

Stream mocks base method.

func (*MockJetStream) StreamNameBySubject 

func (m *MockJetStream) StreamNameBySubject(arg0 context.Context, arg1 string) (string, error)

StreamNameBySubject mocks base method.

func (*MockJetStream) StreamNames 

func (m *MockJetStream) StreamNames(arg0 context.Context, arg1 ...jetstream.StreamListOpt) jetstream.StreamNameLister

StreamNames mocks base method.

func (*MockJetStream) UpdateConsumer 

func (m *MockJetStream) UpdateConsumer(arg0 context.Context, arg1 string, arg2 jetstream.ConsumerConfig) (jetstream.Consumer, error)

UpdateConsumer mocks base method.

func (*MockJetStream) UpdateKeyValue 

func (m *MockJetStream) UpdateKeyValue(arg0 context.Context, arg1 jetstream.KeyValueConfig) (jetstream.KeyValue, error)

UpdateKeyValue mocks base method.

func (*MockJetStream) UpdateObjectStore 

func (m *MockJetStream) UpdateObjectStore(arg0 context.Context, arg1 jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)

UpdateObjectStore mocks base method.

func (*MockJetStream) UpdateStream 

func (m *MockJetStream) UpdateStream(arg0 context.Context, arg1 jetstream.StreamConfig) (jetstream.Stream, error)

UpdateStream mocks base method.

type MockJetStreamMockRecorder 

type MockJetStreamMockRecorder struct {
	// contains filtered or unexported fields
}

MockJetStreamMockRecorder is the mock recorder for MockJetStream.

func (*MockJetStreamMockRecorder) AccountInfo 

func (mr *MockJetStreamMockRecorder) AccountInfo(arg0 interface{}) *gomock.Call

AccountInfo indicates an expected call of AccountInfo.

func (*MockJetStreamMockRecorder) CleanupPublisher 

func (mr *MockJetStreamMockRecorder) CleanupPublisher() *gomock.Call

CleanupPublisher indicates an expected call of CleanupPublisher.

func (*MockJetStreamMockRecorder) Conn 

func (mr *MockJetStreamMockRecorder) Conn() *gomock.Call

Conn indicates an expected call of Conn.

func (*MockJetStreamMockRecorder) Consumer 

func (mr *MockJetStreamMockRecorder) Consumer(arg0, arg1, arg2 interface{}) *gomock.Call

Consumer indicates an expected call of Consumer.

func (*MockJetStreamMockRecorder) CreateConsumer 

func (mr *MockJetStreamMockRecorder) CreateConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

CreateConsumer indicates an expected call of CreateConsumer.

func (*MockJetStreamMockRecorder) CreateKeyValue 

func (mr *MockJetStreamMockRecorder) CreateKeyValue(arg0, arg1 interface{}) *gomock.Call

CreateKeyValue indicates an expected call of CreateKeyValue.

func (*MockJetStreamMockRecorder) CreateObjectStore 

func (mr *MockJetStreamMockRecorder) CreateObjectStore(arg0, arg1 interface{}) *gomock.Call

CreateObjectStore indicates an expected call of CreateObjectStore.

func (*MockJetStreamMockRecorder) CreateOrUpdateConsumer 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

CreateOrUpdateConsumer indicates an expected call of CreateOrUpdateConsumer.

func (*MockJetStreamMockRecorder) CreateOrUpdateKeyValue 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateKeyValue(arg0, arg1 interface{}) *gomock.Call

CreateOrUpdateKeyValue indicates an expected call of CreateOrUpdateKeyValue.

func (*MockJetStreamMockRecorder) CreateOrUpdateObjectStore 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateObjectStore(arg0, arg1 interface{}) *gomock.Call

CreateOrUpdateObjectStore indicates an expected call of CreateOrUpdateObjectStore.

func (*MockJetStreamMockRecorder) CreateOrUpdateStream 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateStream(arg0, arg1 interface{}) *gomock.Call

CreateOrUpdateStream indicates an expected call of CreateOrUpdateStream.

func (*MockJetStreamMockRecorder) CreateStream 

func (mr *MockJetStreamMockRecorder) CreateStream(arg0, arg1 interface{}) *gomock.Call

CreateStream indicates an expected call of CreateStream.

func (*MockJetStreamMockRecorder) DeleteConsumer 

func (mr *MockJetStreamMockRecorder) DeleteConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

DeleteConsumer indicates an expected call of DeleteConsumer.

func (*MockJetStreamMockRecorder) DeleteKeyValue 

func (mr *MockJetStreamMockRecorder) DeleteKeyValue(arg0, arg1 interface{}) *gomock.Call

DeleteKeyValue indicates an expected call of DeleteKeyValue.

func (*MockJetStreamMockRecorder) DeleteObjectStore 

func (mr *MockJetStreamMockRecorder) DeleteObjectStore(arg0, arg1 interface{}) *gomock.Call

DeleteObjectStore indicates an expected call of DeleteObjectStore.

func (*MockJetStreamMockRecorder) DeleteStream 

func (mr *MockJetStreamMockRecorder) DeleteStream(arg0, arg1 interface{}) *gomock.Call

DeleteStream indicates an expected call of DeleteStream.

func (*MockJetStreamMockRecorder) KeyValue 

func (mr *MockJetStreamMockRecorder) KeyValue(arg0, arg1 interface{}) *gomock.Call

KeyValue indicates an expected call of KeyValue.

func (*MockJetStreamMockRecorder) KeyValueStoreNames 

func (mr *MockJetStreamMockRecorder) KeyValueStoreNames(arg0 interface{}) *gomock.Call

KeyValueStoreNames indicates an expected call of KeyValueStoreNames.

func (*MockJetStreamMockRecorder) KeyValueStores 

func (mr *MockJetStreamMockRecorder) KeyValueStores(arg0 interface{}) *gomock.Call

KeyValueStores indicates an expected call of KeyValueStores.

func (*MockJetStreamMockRecorder) ListStreams 

func (mr *MockJetStreamMockRecorder) ListStreams(arg0 interface{}, arg1 ...interface{}) *gomock.Call

ListStreams indicates an expected call of ListStreams.

func (*MockJetStreamMockRecorder) ObjectStore 

func (mr *MockJetStreamMockRecorder) ObjectStore(arg0, arg1 interface{}) *gomock.Call

ObjectStore indicates an expected call of ObjectStore.

func (*MockJetStreamMockRecorder) ObjectStoreNames 

func (mr *MockJetStreamMockRecorder) ObjectStoreNames(arg0 interface{}) *gomock.Call

ObjectStoreNames indicates an expected call of ObjectStoreNames.

func (*MockJetStreamMockRecorder) ObjectStores 

func (mr *MockJetStreamMockRecorder) ObjectStores(arg0 interface{}) *gomock.Call

ObjectStores indicates an expected call of ObjectStores.

func (*MockJetStreamMockRecorder) Options 

func (mr *MockJetStreamMockRecorder) Options() *gomock.Call

Options indicates an expected call of Options.

func (*MockJetStreamMockRecorder) OrderedConsumer 

func (mr *MockJetStreamMockRecorder) OrderedConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

OrderedConsumer indicates an expected call of OrderedConsumer.

func (*MockJetStreamMockRecorder) Publish 

func (mr *MockJetStreamMockRecorder) Publish(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockJetStreamMockRecorder) PublishAsync 

func (mr *MockJetStreamMockRecorder) PublishAsync(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PublishAsync indicates an expected call of PublishAsync.

func (*MockJetStreamMockRecorder) PublishAsyncComplete 

func (mr *MockJetStreamMockRecorder) PublishAsyncComplete() *gomock.Call

PublishAsyncComplete indicates an expected call of PublishAsyncComplete.

func (*MockJetStreamMockRecorder) PublishAsyncPending 

func (mr *MockJetStreamMockRecorder) PublishAsyncPending() *gomock.Call

PublishAsyncPending indicates an expected call of PublishAsyncPending.

func (*MockJetStreamMockRecorder) PublishMsg 

func (mr *MockJetStreamMockRecorder) PublishMsg(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PublishMsg indicates an expected call of PublishMsg.

func (*MockJetStreamMockRecorder) PublishMsgAsync 

func (mr *MockJetStreamMockRecorder) PublishMsgAsync(arg0 interface{}, arg1 ...interface{}) *gomock.Call

PublishMsgAsync indicates an expected call of PublishMsgAsync.

func (*MockJetStreamMockRecorder) Stream 

func (mr *MockJetStreamMockRecorder) Stream(arg0, arg1 interface{}) *gomock.Call

Stream indicates an expected call of Stream.

func (*MockJetStreamMockRecorder) StreamNameBySubject 

func (mr *MockJetStreamMockRecorder) StreamNameBySubject(arg0, arg1 interface{}) *gomock.Call

StreamNameBySubject indicates an expected call of StreamNameBySubject.

func (*MockJetStreamMockRecorder) StreamNames 

func (mr *MockJetStreamMockRecorder) StreamNames(arg0 interface{}, arg1 ...interface{}) *gomock.Call

StreamNames indicates an expected call of StreamNames.

func (*MockJetStreamMockRecorder) UpdateConsumer 

func (mr *MockJetStreamMockRecorder) UpdateConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

UpdateConsumer indicates an expected call of UpdateConsumer.

func (*MockJetStreamMockRecorder) UpdateKeyValue 

func (mr *MockJetStreamMockRecorder) UpdateKeyValue(arg0, arg1 interface{}) *gomock.Call

UpdateKeyValue indicates an expected call of UpdateKeyValue.

func (*MockJetStreamMockRecorder) UpdateObjectStore 

func (mr *MockJetStreamMockRecorder) UpdateObjectStore(arg0, arg1 interface{}) *gomock.Call

UpdateObjectStore indicates an expected call of UpdateObjectStore.

func (*MockJetStreamMockRecorder) UpdateStream 

func (mr *MockJetStreamMockRecorder) UpdateStream(arg0, arg1 interface{}) *gomock.Call

UpdateStream indicates an expected call of UpdateStream.

type MockManager 

type MockManager struct {
	// contains filtered or unexported fields
}

MockManager is a mock of Manager interface.

func NewDefaultMockManager 

func NewDefaultMockManager(ctrl *gomock.Controller) *MockManager

NewDefaultMockManager creates a Mock with defaults.

func NewMockManager 

func NewMockManager(ctrl *gomock.Controller) *MockManager

NewMockManager creates a new mock instance.

func NewPlainMockManager 

func NewPlainMockManager(ctrl *gomock.Controller) *MockManager

NewPlainMockManager creates a Mock without defaults.

func (*MockManager) Connect 

func (m *MockManager) Connect() error

Connect mocks base method.

func (*MockManager) CountStreamMessages 

func (m *MockManager) CountStreamMessages(ctx context.Context) (int, error)

CountStreamMessages mocks base method.

func (*MockManager) DeleteMessageBySeq 

func (m *MockManager) DeleteMessageBySeq(ctx context.Context, seq uint64) error

DeleteMessageBySeq mocks base method.

func (*MockManager) EXPECT 

func (m *MockManager) EXPECT() *MockManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockManager) GetMessageBySeq 

func (m *MockManager) GetMessageBySeq(ctx context.Context, seq uint64) (*client.MessageItem, error)

GetMessageBySeq mocks base method.

func (*MockManager) GetMessageIterator 

func (m *MockManager) GetMessageIterator(ctx context.Context) (jetstream.MessagesContext, error)

GetMessageIterator mocks base method.

func (*MockManager) ListUndeliveredMessages 

func (m *MockManager) ListUndeliveredMessages(ctx context.Context) ([]client.MessageItem, error)

ListUndeliveredMessages mocks base method.

func (*MockManager) PublishToStream 

func (m *MockManager) PublishToStream(ctx context.Context, data []byte) (uint64, error)

PublishToStream mocks base method.

type MockManagerMockRecorder 

type MockManagerMockRecorder struct {
	// contains filtered or unexported fields
}

MockManagerMockRecorder is the mock recorder for MockManager.

func (*MockManagerMockRecorder) Connect 

func (mr *MockManagerMockRecorder) Connect() *gomock.Call

Connect indicates an expected call of Connect.

func (*MockManagerMockRecorder) CountStreamMessages 

func (mr *MockManagerMockRecorder) CountStreamMessages(ctx interface{}) *gomock.Call

CountStreamMessages indicates an expected call of CountStreamMessages.

func (*MockManagerMockRecorder) DeleteMessageBySeq 

func (mr *MockManagerMockRecorder) DeleteMessageBySeq(ctx, seq interface{}) *gomock.Call

DeleteMessageBySeq indicates an expected call of DeleteMessageBySeq.

func (*MockManagerMockRecorder) GetMessageBySeq 

func (mr *MockManagerMockRecorder) GetMessageBySeq(ctx, seq interface{}) *gomock.Call

GetMessageBySeq indicates an expected call of GetMessageBySeq.

func (*MockManagerMockRecorder) GetMessageIterator 

func (mr *MockManagerMockRecorder) GetMessageIterator(ctx interface{}) *gomock.Call

GetMessageIterator indicates an expected call of GetMessageIterator.

func (*MockManagerMockRecorder) ListUndeliveredMessages 

func (mr *MockManagerMockRecorder) ListUndeliveredMessages(ctx interface{}) *gomock.Call

ListUndeliveredMessages indicates an expected call of ListUndeliveredMessages.

func (*MockManagerMockRecorder) PublishToStream 

func (mr *MockManagerMockRecorder) PublishToStream(ctx, data interface{}) *gomock.Call

PublishToStream indicates an expected call of PublishToStream.

type MockMessageBatch 

type MockMessageBatch struct {
	// contains filtered or unexported fields
}

MockMessageBatch is a mock of MessageBatch interface.

func NewMockFetchResult 

func NewMockFetchResult(ctrl *gomock.Controller) *MockMessageBatch

NewMockFetchResult creates a mock fetch result with messages.

func NewMockMessageBatch 

func NewMockMessageBatch(ctrl *gomock.Controller) *MockMessageBatch

NewMockMessageBatch creates a new mock instance.

func (*MockMessageBatch) EXPECT 

func (m *MockMessageBatch) EXPECT() *MockMessageBatchMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMessageBatch) Error 

func (m *MockMessageBatch) Error() error

Error mocks base method.

func (*MockMessageBatch) Messages 

func (m *MockMessageBatch) Messages() <-chan jetstream.Msg

Messages mocks base method.

type MockMessageBatchMockRecorder 

type MockMessageBatchMockRecorder struct {
	// contains filtered or unexported fields
}

MockMessageBatchMockRecorder is the mock recorder for MockMessageBatch.

func (*MockMessageBatchMockRecorder) Error 

func (mr *MockMessageBatchMockRecorder) Error() *gomock.Call

Error indicates an expected call of Error.

func (*MockMessageBatchMockRecorder) Messages 

func (mr *MockMessageBatchMockRecorder) Messages() *gomock.Call

Messages indicates an expected call of Messages.

type MockMessagesContext 

type MockMessagesContext struct {
	// contains filtered or unexported fields
}

MockMessagesContext is a mock of MessagesContext interface.

func NewMockMessagesContext 

func NewMockMessagesContext(ctrl *gomock.Controller) *MockMessagesContext

NewMockMessagesContext creates a new mock instance.

func (*MockMessagesContext) Drain 

func (m *MockMessagesContext) Drain()

Drain mocks base method.

func (*MockMessagesContext) EXPECT 

func (m *MockMessagesContext) EXPECT() *MockMessagesContextMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMessagesContext) Next 

func (m *MockMessagesContext) Next() (jetstream.Msg, error)

Next mocks base method.

func (*MockMessagesContext) Stop 

func (m *MockMessagesContext) Stop()

Stop mocks base method.

type MockMessagesContextMockRecorder 

type MockMessagesContextMockRecorder struct {
	// contains filtered or unexported fields
}

MockMessagesContextMockRecorder is the mock recorder for MockMessagesContext.

func (*MockMessagesContextMockRecorder) Drain 

func (mr *MockMessagesContextMockRecorder) Drain() *gomock.Call

Drain indicates an expected call of Drain.

func (*MockMessagesContextMockRecorder) Next 

func (mr *MockMessagesContextMockRecorder) Next() *gomock.Call

Next indicates an expected call of Next.

func (*MockMessagesContextMockRecorder) Stop 

func (mr *MockMessagesContextMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

type MockMsg 

type MockMsg struct {
	// contains filtered or unexported fields
}

MockMsg is a mock of Msg interface.

func NewMockMsg 

func NewMockMsg(ctrl *gomock.Controller) *MockMsg

NewMockMsg creates a new mock instance.

func (*MockMsg) Ack 

func (m *MockMsg) Ack() error

Ack mocks base method.

func (*MockMsg) Data 

func (m *MockMsg) Data() []byte

Data mocks base method.

func (*MockMsg) DoubleAck 

func (m *MockMsg) DoubleAck(arg0 context.Context) error

DoubleAck mocks base method.

func (*MockMsg) EXPECT 

func (m *MockMsg) EXPECT() *MockMsgMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMsg) Headers 

func (m *MockMsg) Headers() nats.Header

Headers mocks base method.

func (*MockMsg) InProgress 

func (m *MockMsg) InProgress() error

InProgress mocks base method.

func (*MockMsg) Metadata 

func (m *MockMsg) Metadata() (*jetstream.MsgMetadata, error)

Metadata mocks base method.

func (*MockMsg) Nak 

func (m *MockMsg) Nak() error

Nak mocks base method.

func (*MockMsg) NakWithDelay 

func (m *MockMsg) NakWithDelay(arg0 time.Duration) error

NakWithDelay mocks base method.

func (*MockMsg) Reply 

func (m *MockMsg) Reply() string

Reply mocks base method.

func (*MockMsg) Subject 

func (m *MockMsg) Subject() string

Subject mocks base method.

func (*MockMsg) Term 

func (m *MockMsg) Term() error

Term mocks base method.

func (*MockMsg) TermWithReason 

func (m *MockMsg) TermWithReason(arg0 string) error

TermWithReason mocks base method.

type MockMsgMockRecorder 

type MockMsgMockRecorder struct {
	// contains filtered or unexported fields
}

MockMsgMockRecorder is the mock recorder for MockMsg.

func (*MockMsgMockRecorder) Ack 

func (mr *MockMsgMockRecorder) Ack() *gomock.Call

Ack indicates an expected call of Ack.

func (*MockMsgMockRecorder) Data 

func (mr *MockMsgMockRecorder) Data() *gomock.Call

Data indicates an expected call of Data.

func (*MockMsgMockRecorder) DoubleAck 

func (mr *MockMsgMockRecorder) DoubleAck(arg0 interface{}) *gomock.Call

DoubleAck indicates an expected call of DoubleAck.

func (*MockMsgMockRecorder) Headers 

func (mr *MockMsgMockRecorder) Headers() *gomock.Call

Headers indicates an expected call of Headers.

func (*MockMsgMockRecorder) InProgress 

func (mr *MockMsgMockRecorder) InProgress() *gomock.Call

InProgress indicates an expected call of InProgress.

func (*MockMsgMockRecorder) Metadata 

func (mr *MockMsgMockRecorder) Metadata() *gomock.Call

Metadata indicates an expected call of Metadata.

func (*MockMsgMockRecorder) Nak 

func (mr *MockMsgMockRecorder) Nak() *gomock.Call

Nak indicates an expected call of Nak.

func (*MockMsgMockRecorder) NakWithDelay 

func (mr *MockMsgMockRecorder) NakWithDelay(arg0 interface{}) *gomock.Call

NakWithDelay indicates an expected call of NakWithDelay.

func (*MockMsgMockRecorder) Reply 

func (mr *MockMsgMockRecorder) Reply() *gomock.Call

Reply indicates an expected call of Reply.

func (*MockMsgMockRecorder) Subject 

func (mr *MockMsgMockRecorder) Subject() *gomock.Call

Subject indicates an expected call of Subject.

func (*MockMsgMockRecorder) Term 

func (mr *MockMsgMockRecorder) Term() *gomock.Call

Term indicates an expected call of Term.

func (*MockMsgMockRecorder) TermWithReason 

func (mr *MockMsgMockRecorder) TermWithReason(arg0 interface{}) *gomock.Call

TermWithReason indicates an expected call of TermWithReason.

type MockPublisher 

type MockPublisher struct {
	// contains filtered or unexported fields
}

MockPublisher is a mock of Publisher interface.

func NewMockPublisher 

func NewMockPublisher(ctrl *gomock.Controller) *MockPublisher

NewMockPublisher creates a new mock instance.

func (*MockPublisher) CleanupPublisher 

func (m *MockPublisher) CleanupPublisher()

CleanupPublisher mocks base method.

func (*MockPublisher) EXPECT 

func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPublisher) Publish 

func (m *MockPublisher) Publish(arg0 context.Context, arg1 string, arg2 []byte, arg3 ...jetstream.PublishOpt) (*jetstream.PubAck, error)

Publish mocks base method.

func (*MockPublisher) PublishAsync 

func (m *MockPublisher) PublishAsync(arg0 string, arg1 []byte, arg2 ...jetstream.PublishOpt) (jetstream.PubAckFuture, error)

PublishAsync mocks base method.

func (*MockPublisher) PublishAsyncComplete 

func (m *MockPublisher) PublishAsyncComplete() <-chan struct{}

PublishAsyncComplete mocks base method.

func (*MockPublisher) PublishAsyncPending 

func (m *MockPublisher) PublishAsyncPending() int

PublishAsyncPending mocks base method.

func (*MockPublisher) PublishMsg 

func (m *MockPublisher) PublishMsg(arg0 context.Context, arg1 *nats.Msg, arg2 ...jetstream.PublishOpt) (*jetstream.PubAck, error)

PublishMsg mocks base method.

func (*MockPublisher) PublishMsgAsync 

func (m *MockPublisher) PublishMsgAsync(arg0 *nats.Msg, arg1 ...jetstream.PublishOpt) (jetstream.PubAckFuture, error)

PublishMsgAsync mocks base method.

type MockPublisherMockRecorder 

type MockPublisherMockRecorder struct {
	// contains filtered or unexported fields
}

MockPublisherMockRecorder is the mock recorder for MockPublisher.

func (*MockPublisherMockRecorder) CleanupPublisher 

func (mr *MockPublisherMockRecorder) CleanupPublisher() *gomock.Call

CleanupPublisher indicates an expected call of CleanupPublisher.

func (*MockPublisherMockRecorder) Publish 

func (mr *MockPublisherMockRecorder) Publish(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockPublisherMockRecorder) PublishAsync 

func (mr *MockPublisherMockRecorder) PublishAsync(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PublishAsync indicates an expected call of PublishAsync.

func (*MockPublisherMockRecorder) PublishAsyncComplete 

func (mr *MockPublisherMockRecorder) PublishAsyncComplete() *gomock.Call

PublishAsyncComplete indicates an expected call of PublishAsyncComplete.

func (*MockPublisherMockRecorder) PublishAsyncPending 

func (mr *MockPublisherMockRecorder) PublishAsyncPending() *gomock.Call

PublishAsyncPending indicates an expected call of PublishAsyncPending.

func (*MockPublisherMockRecorder) PublishMsg 

func (mr *MockPublisherMockRecorder) PublishMsg(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PublishMsg indicates an expected call of PublishMsg.

func (*MockPublisherMockRecorder) PublishMsgAsync 

func (mr *MockPublisherMockRecorder) PublishMsgAsync(arg0 interface{}, arg1 ...interface{}) *gomock.Call

PublishMsgAsync indicates an expected call of PublishMsgAsync.

type MockStream 

type MockStream struct {
	// contains filtered or unexported fields
}

MockStream is a mock of Stream interface.

func NewMockStream 

func NewMockStream(ctrl *gomock.Controller) *MockStream

NewMockStream creates a new mock instance.

func (*MockStream) CachedInfo 

func (m *MockStream) CachedInfo() *jetstream.StreamInfo

CachedInfo mocks base method.

func (*MockStream) Consumer 

func (m *MockStream) Consumer(arg0 context.Context, arg1 string) (jetstream.Consumer, error)

Consumer mocks base method.

func (*MockStream) ConsumerNames 

func (m *MockStream) ConsumerNames(arg0 context.Context) jetstream.ConsumerNameLister

ConsumerNames mocks base method.

func (*MockStream) CreateConsumer 

func (m *MockStream) CreateConsumer(arg0 context.Context, arg1 jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateConsumer mocks base method.

func (*MockStream) CreateOrUpdateConsumer 

func (m *MockStream) CreateOrUpdateConsumer(arg0 context.Context, arg1 jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateOrUpdateConsumer mocks base method.

func (*MockStream) DeleteConsumer 

func (m *MockStream) DeleteConsumer(arg0 context.Context, arg1 string) error

DeleteConsumer mocks base method.

func (*MockStream) DeleteMsg 

func (m *MockStream) DeleteMsg(arg0 context.Context, arg1 uint64) error

DeleteMsg mocks base method.

func (*MockStream) EXPECT 

func (m *MockStream) EXPECT() *MockStreamMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStream) GetLastMsgForSubject 

func (m *MockStream) GetLastMsgForSubject(arg0 context.Context, arg1 string) (*jetstream.RawStreamMsg, error)

GetLastMsgForSubject mocks base method.

func (*MockStream) GetMsg 

func (m *MockStream) GetMsg(arg0 context.Context, arg1 uint64, arg2 ...jetstream.GetMsgOpt) (*jetstream.RawStreamMsg, error)

GetMsg mocks base method.

func (*MockStream) Info 

func (m *MockStream) Info(arg0 context.Context, arg1 ...jetstream.StreamInfoOpt) (*jetstream.StreamInfo, error)

Info mocks base method.

func (*MockStream) ListConsumers 

func (m *MockStream) ListConsumers(arg0 context.Context) jetstream.ConsumerInfoLister

ListConsumers mocks base method.

func (*MockStream) OrderedConsumer 

func (m *MockStream) OrderedConsumer(arg0 context.Context, arg1 jetstream.OrderedConsumerConfig) (jetstream.Consumer, error)

OrderedConsumer mocks base method.

func (*MockStream) Purge 

func (m *MockStream) Purge(arg0 context.Context, arg1 ...jetstream.StreamPurgeOpt) error

Purge mocks base method.

func (*MockStream) SecureDeleteMsg 

func (m *MockStream) SecureDeleteMsg(arg0 context.Context, arg1 uint64) error

SecureDeleteMsg mocks base method.

func (*MockStream) UpdateConsumer 

func (m *MockStream) UpdateConsumer(arg0 context.Context, arg1 jetstream.ConsumerConfig) (jetstream.Consumer, error)

UpdateConsumer mocks base method.

type MockStreamConsumerManager 

type MockStreamConsumerManager struct {
	// contains filtered or unexported fields
}

MockStreamConsumerManager is a mock of StreamConsumerManager interface.

func NewMockStreamConsumerManager 

func NewMockStreamConsumerManager(ctrl *gomock.Controller) *MockStreamConsumerManager

NewMockStreamConsumerManager creates a new mock instance.

func (*MockStreamConsumerManager) Consumer 

func (m *MockStreamConsumerManager) Consumer(arg0 context.Context, arg1, arg2 string) (jetstream.Consumer, error)

Consumer mocks base method.

func (*MockStreamConsumerManager) CreateConsumer 

func (m *MockStreamConsumerManager) CreateConsumer(arg0 context.Context, arg1 string, arg2 jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateConsumer mocks base method.

func (*MockStreamConsumerManager) CreateOrUpdateConsumer 

func (m *MockStreamConsumerManager) CreateOrUpdateConsumer(arg0 context.Context, arg1 string, arg2 jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateOrUpdateConsumer mocks base method.

func (*MockStreamConsumerManager) DeleteConsumer 

func (m *MockStreamConsumerManager) DeleteConsumer(arg0 context.Context, arg1, arg2 string) error

DeleteConsumer mocks base method.

func (*MockStreamConsumerManager) EXPECT 

func (m *MockStreamConsumerManager) EXPECT() *MockStreamConsumerManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStreamConsumerManager) OrderedConsumer 

func (m *MockStreamConsumerManager) OrderedConsumer(arg0 context.Context, arg1 string, arg2 jetstream.OrderedConsumerConfig) (jetstream.Consumer, error)

OrderedConsumer mocks base method.

func (*MockStreamConsumerManager) UpdateConsumer 

func (m *MockStreamConsumerManager) UpdateConsumer(arg0 context.Context, arg1 string, arg2 jetstream.ConsumerConfig) (jetstream.Consumer, error)

UpdateConsumer mocks base method.

type MockStreamConsumerManagerMockRecorder 

type MockStreamConsumerManagerMockRecorder struct {
	// contains filtered or unexported fields
}

MockStreamConsumerManagerMockRecorder is the mock recorder for MockStreamConsumerManager.

func (*MockStreamConsumerManagerMockRecorder) Consumer 

func (mr *MockStreamConsumerManagerMockRecorder) Consumer(arg0, arg1, arg2 interface{}) *gomock.Call

Consumer indicates an expected call of Consumer.

func (*MockStreamConsumerManagerMockRecorder) CreateConsumer 

func (mr *MockStreamConsumerManagerMockRecorder) CreateConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

CreateConsumer indicates an expected call of CreateConsumer.

func (*MockStreamConsumerManagerMockRecorder) CreateOrUpdateConsumer 

func (mr *MockStreamConsumerManagerMockRecorder) CreateOrUpdateConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

CreateOrUpdateConsumer indicates an expected call of CreateOrUpdateConsumer.

func (*MockStreamConsumerManagerMockRecorder) DeleteConsumer 

func (mr *MockStreamConsumerManagerMockRecorder) DeleteConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

DeleteConsumer indicates an expected call of DeleteConsumer.

func (*MockStreamConsumerManagerMockRecorder) OrderedConsumer 

func (mr *MockStreamConsumerManagerMockRecorder) OrderedConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

OrderedConsumer indicates an expected call of OrderedConsumer.

func (*MockStreamConsumerManagerMockRecorder) UpdateConsumer 

func (mr *MockStreamConsumerManagerMockRecorder) UpdateConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

UpdateConsumer indicates an expected call of UpdateConsumer.

type MockStreamManager 

type MockStreamManager struct {
	// contains filtered or unexported fields
}

MockStreamManager is a mock of StreamManager interface.

func NewMockStreamManager 

func NewMockStreamManager(ctrl *gomock.Controller) *MockStreamManager

NewMockStreamManager creates a new mock instance.

func (*MockStreamManager) CreateOrUpdateStream 

func (m *MockStreamManager) CreateOrUpdateStream(arg0 context.Context, arg1 jetstream.StreamConfig) (jetstream.Stream, error)

CreateOrUpdateStream mocks base method.

func (*MockStreamManager) CreateStream 

func (m *MockStreamManager) CreateStream(arg0 context.Context, arg1 jetstream.StreamConfig) (jetstream.Stream, error)

CreateStream mocks base method.

func (*MockStreamManager) DeleteStream 

func (m *MockStreamManager) DeleteStream(arg0 context.Context, arg1 string) error

DeleteStream mocks base method.

func (*MockStreamManager) EXPECT 

func (m *MockStreamManager) EXPECT() *MockStreamManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStreamManager) ListStreams 

func (m *MockStreamManager) ListStreams(arg0 context.Context, arg1 ...jetstream.StreamListOpt) jetstream.StreamInfoLister

ListStreams mocks base method.

func (*MockStreamManager) Stream 

func (m *MockStreamManager) Stream(arg0 context.Context, arg1 string) (jetstream.Stream, error)

Stream mocks base method.

func (*MockStreamManager) StreamNameBySubject 

func (m *MockStreamManager) StreamNameBySubject(arg0 context.Context, arg1 string) (string, error)

StreamNameBySubject mocks base method.

func (*MockStreamManager) StreamNames 

func (m *MockStreamManager) StreamNames(arg0 context.Context, arg1 ...jetstream.StreamListOpt) jetstream.StreamNameLister

StreamNames mocks base method.

func (*MockStreamManager) UpdateStream 

func (m *MockStreamManager) UpdateStream(arg0 context.Context, arg1 jetstream.StreamConfig) (jetstream.Stream, error)

UpdateStream mocks base method.

type MockStreamManagerMockRecorder 

type MockStreamManagerMockRecorder struct {
	// contains filtered or unexported fields
}

MockStreamManagerMockRecorder is the mock recorder for MockStreamManager.

func (*MockStreamManagerMockRecorder) CreateOrUpdateStream 

func (mr *MockStreamManagerMockRecorder) CreateOrUpdateStream(arg0, arg1 interface{}) *gomock.Call

CreateOrUpdateStream indicates an expected call of CreateOrUpdateStream.

func (*MockStreamManagerMockRecorder) CreateStream 

func (mr *MockStreamManagerMockRecorder) CreateStream(arg0, arg1 interface{}) *gomock.Call

CreateStream indicates an expected call of CreateStream.

func (*MockStreamManagerMockRecorder) DeleteStream 

func (mr *MockStreamManagerMockRecorder) DeleteStream(arg0, arg1 interface{}) *gomock.Call

DeleteStream indicates an expected call of DeleteStream.

func (*MockStreamManagerMockRecorder) ListStreams 

func (mr *MockStreamManagerMockRecorder) ListStreams(arg0 interface{}, arg1 ...interface{}) *gomock.Call

ListStreams indicates an expected call of ListStreams.

func (*MockStreamManagerMockRecorder) Stream 

func (mr *MockStreamManagerMockRecorder) Stream(arg0, arg1 interface{}) *gomock.Call

Stream indicates an expected call of Stream.

func (*MockStreamManagerMockRecorder) StreamNameBySubject 

func (mr *MockStreamManagerMockRecorder) StreamNameBySubject(arg0, arg1 interface{}) *gomock.Call

StreamNameBySubject indicates an expected call of StreamNameBySubject.

func (*MockStreamManagerMockRecorder) StreamNames 

func (mr *MockStreamManagerMockRecorder) StreamNames(arg0 interface{}, arg1 ...interface{}) *gomock.Call

StreamNames indicates an expected call of StreamNames.

func (*MockStreamManagerMockRecorder) UpdateStream 

func (mr *MockStreamManagerMockRecorder) UpdateStream(arg0, arg1 interface{}) *gomock.Call

UpdateStream indicates an expected call of UpdateStream.

type MockStreamMockRecorder 

type MockStreamMockRecorder struct {
	// contains filtered or unexported fields
}

MockStreamMockRecorder is the mock recorder for MockStream.

func (*MockStreamMockRecorder) CachedInfo 

func (mr *MockStreamMockRecorder) CachedInfo() *gomock.Call

CachedInfo indicates an expected call of CachedInfo.

func (*MockStreamMockRecorder) Consumer 

func (mr *MockStreamMockRecorder) Consumer(arg0, arg1 interface{}) *gomock.Call

Consumer indicates an expected call of Consumer.

func (*MockStreamMockRecorder) ConsumerNames 

func (mr *MockStreamMockRecorder) ConsumerNames(arg0 interface{}) *gomock.Call

ConsumerNames indicates an expected call of ConsumerNames.

func (*MockStreamMockRecorder) CreateConsumer 

func (mr *MockStreamMockRecorder) CreateConsumer(arg0, arg1 interface{}) *gomock.Call

CreateConsumer indicates an expected call of CreateConsumer.

func (*MockStreamMockRecorder) CreateOrUpdateConsumer 

func (mr *MockStreamMockRecorder) CreateOrUpdateConsumer(arg0, arg1 interface{}) *gomock.Call

CreateOrUpdateConsumer indicates an expected call of CreateOrUpdateConsumer.

func (*MockStreamMockRecorder) DeleteConsumer 

func (mr *MockStreamMockRecorder) DeleteConsumer(arg0, arg1 interface{}) *gomock.Call

DeleteConsumer indicates an expected call of DeleteConsumer.

func (*MockStreamMockRecorder) DeleteMsg 

func (mr *MockStreamMockRecorder) DeleteMsg(arg0, arg1 interface{}) *gomock.Call

DeleteMsg indicates an expected call of DeleteMsg.

func (*MockStreamMockRecorder) GetLastMsgForSubject 

func (mr *MockStreamMockRecorder) GetLastMsgForSubject(arg0, arg1 interface{}) *gomock.Call

GetLastMsgForSubject indicates an expected call of GetLastMsgForSubject.

func (*MockStreamMockRecorder) GetMsg 

func (mr *MockStreamMockRecorder) GetMsg(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetMsg indicates an expected call of GetMsg.

func (*MockStreamMockRecorder) Info 

func (mr *MockStreamMockRecorder) Info(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Info indicates an expected call of Info.

func (*MockStreamMockRecorder) ListConsumers 

func (mr *MockStreamMockRecorder) ListConsumers(arg0 interface{}) *gomock.Call

ListConsumers indicates an expected call of ListConsumers.

func (*MockStreamMockRecorder) OrderedConsumer 

func (mr *MockStreamMockRecorder) OrderedConsumer(arg0, arg1 interface{}) *gomock.Call

OrderedConsumer indicates an expected call of OrderedConsumer.

func (*MockStreamMockRecorder) Purge 

func (mr *MockStreamMockRecorder) Purge(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Purge indicates an expected call of Purge.

func (*MockStreamMockRecorder) SecureDeleteMsg 

func (mr *MockStreamMockRecorder) SecureDeleteMsg(arg0, arg1 interface{}) *gomock.Call

SecureDeleteMsg indicates an expected call of SecureDeleteMsg.

func (*MockStreamMockRecorder) UpdateConsumer 

func (mr *MockStreamMockRecorder) UpdateConsumer(arg0, arg1 interface{}) *gomock.Call

UpdateConsumer indicates an expected call of UpdateConsumer.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.