mocks

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Oct 1, 2026 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Package mocks provides generated mock implementations for testing.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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(handler jetstream.MessageHandler, opts ...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(batch int, opts ...jetstream.FetchOpt) (jetstream.MessageBatch, error)

Fetch mocks base method.

func (*MockConsumer) FetchBytes 

func (m *MockConsumer) FetchBytes(maxBytes int, opts ...jetstream.FetchOpt) (jetstream.MessageBatch, error)

FetchBytes mocks base method.

func (*MockConsumer) FetchNoWait 

func (m *MockConsumer) FetchNoWait(batch 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(opts ...jetstream.PullMessagesOpt) (jetstream.MessagesContext, error)

Messages mocks base method.

func (*MockConsumer) Next 

func (m *MockConsumer) Next(opts ...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(handler any, opts ...any) *gomock.Call

Consume indicates an expected call of Consume.

func (*MockConsumerMockRecorder) Fetch 

func (mr *MockConsumerMockRecorder) Fetch(batch any, opts ...any) *gomock.Call

Fetch indicates an expected call of Fetch.

func (*MockConsumerMockRecorder) FetchBytes 

func (mr *MockConsumerMockRecorder) FetchBytes(maxBytes any, opts ...any) *gomock.Call

FetchBytes indicates an expected call of FetchBytes.

func (*MockConsumerMockRecorder) FetchNoWait 

func (mr *MockConsumerMockRecorder) FetchNoWait(batch any) *gomock.Call

FetchNoWait indicates an expected call of FetchNoWait.

func (*MockConsumerMockRecorder) Info 

func (mr *MockConsumerMockRecorder) Info(arg0 any) *gomock.Call

Info indicates an expected call of Info.

func (*MockConsumerMockRecorder) Messages 

func (mr *MockConsumerMockRecorder) Messages(opts ...any) *gomock.Call

Messages indicates an expected call of Messages.

func (*MockConsumerMockRecorder) Next 

func (mr *MockConsumerMockRecorder) Next(opts ...any) *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 NewMockJetStream 

func NewMockJetStream(ctrl *gomock.Controller) *MockJetStream

NewMockJetStream creates a new mock instance.

func (*MockJetStream) AccountInfo 

func (m *MockJetStream) AccountInfo(ctx 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(ctx context.Context, stream, consumer string) (jetstream.Consumer, error)

Consumer mocks base method.

func (*MockJetStream) CreateConsumer 

func (m *MockJetStream) CreateConsumer(ctx context.Context, stream string, cfg jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateConsumer mocks base method.

func (*MockJetStream) CreateKeyValue 

func (m *MockJetStream) CreateKeyValue(ctx context.Context, cfg jetstream.KeyValueConfig) (jetstream.KeyValue, error)

CreateKeyValue mocks base method.

func (*MockJetStream) CreateObjectStore 

func (m *MockJetStream) CreateObjectStore(ctx context.Context, cfg jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)

CreateObjectStore mocks base method.

func (*MockJetStream) CreateOrUpdateConsumer 

func (m *MockJetStream) CreateOrUpdateConsumer(ctx context.Context, stream string, cfg jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateOrUpdateConsumer mocks base method.

func (*MockJetStream) CreateOrUpdateKeyValue 

func (m *MockJetStream) CreateOrUpdateKeyValue(ctx context.Context, cfg jetstream.KeyValueConfig) (jetstream.KeyValue, error)

CreateOrUpdateKeyValue mocks base method.

func (*MockJetStream) CreateOrUpdateObjectStore 

func (m *MockJetStream) CreateOrUpdateObjectStore(ctx context.Context, cfg jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)

CreateOrUpdateObjectStore mocks base method.

func (*MockJetStream) CreateOrUpdatePushConsumer 

func (m *MockJetStream) CreateOrUpdatePushConsumer(ctx context.Context, stream string, cfg jetstream.ConsumerConfig) (jetstream.PushConsumer, error)

CreateOrUpdatePushConsumer mocks base method.

func (*MockJetStream) CreateOrUpdateStream 

func (m *MockJetStream) CreateOrUpdateStream(ctx context.Context, cfg jetstream.StreamConfig) (jetstream.Stream, error)

CreateOrUpdateStream mocks base method.

func (*MockJetStream) CreatePushConsumer 

func (m *MockJetStream) CreatePushConsumer(ctx context.Context, stream string, cfg jetstream.ConsumerConfig) (jetstream.PushConsumer, error)

CreatePushConsumer mocks base method.

func (*MockJetStream) CreateStream 

func (m *MockJetStream) CreateStream(ctx context.Context, cfg jetstream.StreamConfig) (jetstream.Stream, error)

CreateStream mocks base method.

func (*MockJetStream) DeleteConsumer 

func (m *MockJetStream) DeleteConsumer(ctx context.Context, stream, consumer string) error

DeleteConsumer mocks base method.

func (*MockJetStream) DeleteKeyValue 

func (m *MockJetStream) DeleteKeyValue(ctx context.Context, bucket string) error

DeleteKeyValue mocks base method.

func (*MockJetStream) DeleteObjectStore 

func (m *MockJetStream) DeleteObjectStore(ctx context.Context, bucket string) error

DeleteObjectStore mocks base method.

func (*MockJetStream) DeleteStream 

func (m *MockJetStream) DeleteStream(ctx context.Context, stream 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(ctx context.Context, bucket string) (jetstream.KeyValue, error)

KeyValue mocks base method.

func (*MockJetStream) KeyValueStoreNames 

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

KeyValueStoreNames mocks base method.

func (*MockJetStream) KeyValueStores 

func (m *MockJetStream) KeyValueStores(ctx 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(ctx context.Context, bucket string) (jetstream.ObjectStore, error)

ObjectStore mocks base method.

func (*MockJetStream) ObjectStoreNames 

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

ObjectStoreNames mocks base method.

func (*MockJetStream) ObjectStores 

func (m *MockJetStream) ObjectStores(ctx 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(ctx context.Context, stream string, cfg jetstream.OrderedConsumerConfig) (jetstream.Consumer, error)

OrderedConsumer mocks base method.

func (*MockJetStream) PauseConsumer 

func (m *MockJetStream) PauseConsumer(ctx context.Context, stream, consumer string, pauseUntil time.Time) (*jetstream.ConsumerPauseResponse, error)

PauseConsumer mocks base method.

func (*MockJetStream) Publish 

func (m *MockJetStream) Publish(ctx context.Context, subject string, payload []byte, opts ...jetstream.PublishOpt) (*jetstream.PubAck, error)

Publish mocks base method.

func (*MockJetStream) PublishAsync 

func (m *MockJetStream) PublishAsync(subject string, payload []byte, opts ...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(ctx context.Context, msg *nats.Msg, opts ...jetstream.PublishOpt) (*jetstream.PubAck, error)

PublishMsg mocks base method.

func (*MockJetStream) PublishMsgAsync 

func (m *MockJetStream) PublishMsgAsync(msg *nats.Msg, opts ...jetstream.PublishOpt) (jetstream.PubAckFuture, error)

PublishMsgAsync mocks base method.

func (*MockJetStream) PushConsumer 

func (m *MockJetStream) PushConsumer(ctx context.Context, stream, consumer string) (jetstream.PushConsumer, error)

PushConsumer mocks base method.

func (*MockJetStream) ResetConsumer 

func (m *MockJetStream) ResetConsumer(ctx context.Context, stream, consumer string) (*jetstream.ConsumerResetResponse, error)

ResetConsumer mocks base method.

func (*MockJetStream) ResetConsumerToSequence 

func (m *MockJetStream) ResetConsumerToSequence(ctx context.Context, stream, consumer string, seq uint64) (*jetstream.ConsumerResetResponse, error)

ResetConsumerToSequence mocks base method.

func (*MockJetStream) ResumeConsumer 

func (m *MockJetStream) ResumeConsumer(ctx context.Context, stream, consumer string) (*jetstream.ConsumerPauseResponse, error)

ResumeConsumer mocks base method.

func (*MockJetStream) Stream 

func (m *MockJetStream) Stream(ctx context.Context, stream string) (jetstream.Stream, error)

Stream mocks base method.

func (*MockJetStream) StreamNameBySubject 

func (m *MockJetStream) StreamNameBySubject(ctx context.Context, subject 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(ctx context.Context, stream string, cfg jetstream.ConsumerConfig) (jetstream.Consumer, error)

UpdateConsumer mocks base method.

func (*MockJetStream) UpdateKeyValue 

func (m *MockJetStream) UpdateKeyValue(ctx context.Context, cfg jetstream.KeyValueConfig) (jetstream.KeyValue, error)

UpdateKeyValue mocks base method.

func (*MockJetStream) UpdateObjectStore 

func (m *MockJetStream) UpdateObjectStore(ctx context.Context, cfg jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)

UpdateObjectStore mocks base method.

func (*MockJetStream) UpdatePushConsumer 

func (m *MockJetStream) UpdatePushConsumer(ctx context.Context, stream string, cfg jetstream.ConsumerConfig) (jetstream.PushConsumer, error)

UpdatePushConsumer mocks base method.

func (*MockJetStream) UpdateStream 

func (m *MockJetStream) UpdateStream(ctx context.Context, cfg 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(ctx any) *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(ctx, stream, consumer any) *gomock.Call

Consumer indicates an expected call of Consumer.

func (*MockJetStreamMockRecorder) CreateConsumer 

func (mr *MockJetStreamMockRecorder) CreateConsumer(ctx, stream, cfg any) *gomock.Call

CreateConsumer indicates an expected call of CreateConsumer.

func (*MockJetStreamMockRecorder) CreateKeyValue 

func (mr *MockJetStreamMockRecorder) CreateKeyValue(ctx, cfg any) *gomock.Call

CreateKeyValue indicates an expected call of CreateKeyValue.

func (*MockJetStreamMockRecorder) CreateObjectStore 

func (mr *MockJetStreamMockRecorder) CreateObjectStore(ctx, cfg any) *gomock.Call

CreateObjectStore indicates an expected call of CreateObjectStore.

func (*MockJetStreamMockRecorder) CreateOrUpdateConsumer 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateConsumer(ctx, stream, cfg any) *gomock.Call

CreateOrUpdateConsumer indicates an expected call of CreateOrUpdateConsumer.

func (*MockJetStreamMockRecorder) CreateOrUpdateKeyValue 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateKeyValue(ctx, cfg any) *gomock.Call

CreateOrUpdateKeyValue indicates an expected call of CreateOrUpdateKeyValue.

func (*MockJetStreamMockRecorder) CreateOrUpdateObjectStore 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateObjectStore(ctx, cfg any) *gomock.Call

CreateOrUpdateObjectStore indicates an expected call of CreateOrUpdateObjectStore.

func (*MockJetStreamMockRecorder) CreateOrUpdatePushConsumer 

func (mr *MockJetStreamMockRecorder) CreateOrUpdatePushConsumer(ctx, stream, cfg any) *gomock.Call

CreateOrUpdatePushConsumer indicates an expected call of CreateOrUpdatePushConsumer.

func (*MockJetStreamMockRecorder) CreateOrUpdateStream 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateStream(ctx, cfg any) *gomock.Call

CreateOrUpdateStream indicates an expected call of CreateOrUpdateStream.

func (*MockJetStreamMockRecorder) CreatePushConsumer 

func (mr *MockJetStreamMockRecorder) CreatePushConsumer(ctx, stream, cfg any) *gomock.Call

CreatePushConsumer indicates an expected call of CreatePushConsumer.

func (*MockJetStreamMockRecorder) CreateStream 

func (mr *MockJetStreamMockRecorder) CreateStream(ctx, cfg any) *gomock.Call

CreateStream indicates an expected call of CreateStream.

func (*MockJetStreamMockRecorder) DeleteConsumer 

func (mr *MockJetStreamMockRecorder) DeleteConsumer(ctx, stream, consumer any) *gomock.Call

DeleteConsumer indicates an expected call of DeleteConsumer.

func (*MockJetStreamMockRecorder) DeleteKeyValue 

func (mr *MockJetStreamMockRecorder) DeleteKeyValue(ctx, bucket any) *gomock.Call

DeleteKeyValue indicates an expected call of DeleteKeyValue.

func (*MockJetStreamMockRecorder) DeleteObjectStore 

func (mr *MockJetStreamMockRecorder) DeleteObjectStore(ctx, bucket any) *gomock.Call

DeleteObjectStore indicates an expected call of DeleteObjectStore.

func (*MockJetStreamMockRecorder) DeleteStream 

func (mr *MockJetStreamMockRecorder) DeleteStream(ctx, stream any) *gomock.Call

DeleteStream indicates an expected call of DeleteStream.

func (*MockJetStreamMockRecorder) KeyValue 

func (mr *MockJetStreamMockRecorder) KeyValue(ctx, bucket any) *gomock.Call

KeyValue indicates an expected call of KeyValue.

func (*MockJetStreamMockRecorder) KeyValueStoreNames 

func (mr *MockJetStreamMockRecorder) KeyValueStoreNames(ctx any) *gomock.Call

KeyValueStoreNames indicates an expected call of KeyValueStoreNames.

func (*MockJetStreamMockRecorder) KeyValueStores 

func (mr *MockJetStreamMockRecorder) KeyValueStores(ctx any) *gomock.Call

KeyValueStores indicates an expected call of KeyValueStores.

func (*MockJetStreamMockRecorder) ListStreams 

func (mr *MockJetStreamMockRecorder) ListStreams(arg0 any, arg1 ...any) *gomock.Call

ListStreams indicates an expected call of ListStreams.

func (*MockJetStreamMockRecorder) ObjectStore 

func (mr *MockJetStreamMockRecorder) ObjectStore(ctx, bucket any) *gomock.Call

ObjectStore indicates an expected call of ObjectStore.

func (*MockJetStreamMockRecorder) ObjectStoreNames 

func (mr *MockJetStreamMockRecorder) ObjectStoreNames(ctx any) *gomock.Call

ObjectStoreNames indicates an expected call of ObjectStoreNames.

func (*MockJetStreamMockRecorder) ObjectStores 

func (mr *MockJetStreamMockRecorder) ObjectStores(ctx any) *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(ctx, stream, cfg any) *gomock.Call

OrderedConsumer indicates an expected call of OrderedConsumer.

func (*MockJetStreamMockRecorder) PauseConsumer 

func (mr *MockJetStreamMockRecorder) PauseConsumer(ctx, stream, consumer, pauseUntil any) *gomock.Call

PauseConsumer indicates an expected call of PauseConsumer.

func (*MockJetStreamMockRecorder) Publish 

func (mr *MockJetStreamMockRecorder) Publish(ctx, subject, payload any, opts ...any) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockJetStreamMockRecorder) PublishAsync 

func (mr *MockJetStreamMockRecorder) PublishAsync(subject, payload any, opts ...any) *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(ctx, msg any, opts ...any) *gomock.Call

PublishMsg indicates an expected call of PublishMsg.

func (*MockJetStreamMockRecorder) PublishMsgAsync 

func (mr *MockJetStreamMockRecorder) PublishMsgAsync(msg any, opts ...any) *gomock.Call

PublishMsgAsync indicates an expected call of PublishMsgAsync.

func (*MockJetStreamMockRecorder) PushConsumer 

func (mr *MockJetStreamMockRecorder) PushConsumer(ctx, stream, consumer any) *gomock.Call

PushConsumer indicates an expected call of PushConsumer.

func (*MockJetStreamMockRecorder) ResetConsumer 

func (mr *MockJetStreamMockRecorder) ResetConsumer(ctx, stream, consumer any) *gomock.Call

ResetConsumer indicates an expected call of ResetConsumer.

func (*MockJetStreamMockRecorder) ResetConsumerToSequence 

func (mr *MockJetStreamMockRecorder) ResetConsumerToSequence(ctx, stream, consumer, seq any) *gomock.Call

ResetConsumerToSequence indicates an expected call of ResetConsumerToSequence.

func (*MockJetStreamMockRecorder) ResumeConsumer 

func (mr *MockJetStreamMockRecorder) ResumeConsumer(ctx, stream, consumer any) *gomock.Call

ResumeConsumer indicates an expected call of ResumeConsumer.

func (*MockJetStreamMockRecorder) Stream 

func (mr *MockJetStreamMockRecorder) Stream(ctx, stream any) *gomock.Call

Stream indicates an expected call of Stream.

func (*MockJetStreamMockRecorder) StreamNameBySubject 

func (mr *MockJetStreamMockRecorder) StreamNameBySubject(ctx, subject any) *gomock.Call

StreamNameBySubject indicates an expected call of StreamNameBySubject.

func (*MockJetStreamMockRecorder) StreamNames 

func (mr *MockJetStreamMockRecorder) StreamNames(arg0 any, arg1 ...any) *gomock.Call

StreamNames indicates an expected call of StreamNames.

func (*MockJetStreamMockRecorder) UpdateConsumer 

func (mr *MockJetStreamMockRecorder) UpdateConsumer(ctx, stream, cfg any) *gomock.Call

UpdateConsumer indicates an expected call of UpdateConsumer.

func (*MockJetStreamMockRecorder) UpdateKeyValue 

func (mr *MockJetStreamMockRecorder) UpdateKeyValue(ctx, cfg any) *gomock.Call

UpdateKeyValue indicates an expected call of UpdateKeyValue.

func (*MockJetStreamMockRecorder) UpdateObjectStore 

func (mr *MockJetStreamMockRecorder) UpdateObjectStore(ctx, cfg any) *gomock.Call

UpdateObjectStore indicates an expected call of UpdateObjectStore.

func (*MockJetStreamMockRecorder) UpdatePushConsumer 

func (mr *MockJetStreamMockRecorder) UpdatePushConsumer(ctx, stream, cfg any) *gomock.Call

UpdatePushConsumer indicates an expected call of UpdatePushConsumer.

func (*MockJetStreamMockRecorder) UpdateStream 

func (mr *MockJetStreamMockRecorder) UpdateStream(ctx, cfg any) *gomock.Call

UpdateStream indicates an expected call of UpdateStream.

type MockKeyLister 

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

MockKeyLister is a mock of KeyLister interface.

func NewMockKeyLister 

func NewMockKeyLister(ctrl *gomock.Controller) *MockKeyLister

NewMockKeyLister creates a new mock instance.

func (*MockKeyLister) EXPECT 

func (m *MockKeyLister) EXPECT() *MockKeyListerMockRecorder

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

func (*MockKeyLister) Keys 

func (m *MockKeyLister) Keys() <-chan string

Keys mocks base method.

func (*MockKeyLister) Stop 

func (m *MockKeyLister) Stop() error

Stop mocks base method.

type MockKeyListerMockRecorder 

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

MockKeyListerMockRecorder is the mock recorder for MockKeyLister.

func (*MockKeyListerMockRecorder) Keys 

func (mr *MockKeyListerMockRecorder) Keys() *gomock.Call

Keys indicates an expected call of Keys.

func (*MockKeyListerMockRecorder) Stop 

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

Stop indicates an expected call of Stop.

type MockKeyPair 

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

MockKeyPair is a mock of KeyPair interface.

func NewMockKeyPair 

func NewMockKeyPair(ctrl *gomock.Controller) *MockKeyPair

NewMockKeyPair creates a new mock instance.

func (*MockKeyPair) EXPECT 

func (m *MockKeyPair) EXPECT() *MockKeyPairMockRecorder

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

func (*MockKeyPair) Open 

func (m *MockKeyPair) Open(input []byte, sender string) ([]byte, error)

Open mocks base method.

func (*MockKeyPair) PrivateKey 

func (m *MockKeyPair) PrivateKey() ([]byte, error)

PrivateKey mocks base method.

func (*MockKeyPair) PublicKey 

func (m *MockKeyPair) PublicKey() (string, error)

PublicKey mocks base method.

func (*MockKeyPair) Seal 

func (m *MockKeyPair) Seal(input []byte, recipient string) ([]byte, error)

Seal mocks base method.

func (*MockKeyPair) SealWithRand 

func (m *MockKeyPair) SealWithRand(input []byte, recipient string, rr io.Reader) ([]byte, error)

SealWithRand mocks base method.

func (*MockKeyPair) Seed 

func (m *MockKeyPair) Seed() ([]byte, error)

Seed mocks base method.

func (*MockKeyPair) Sign 

func (m *MockKeyPair) Sign(input []byte) ([]byte, error)

Sign mocks base method.

func (*MockKeyPair) Verify 

func (m *MockKeyPair) Verify(input, sig []byte) error

Verify mocks base method.

func (*MockKeyPair) Wipe 

func (m *MockKeyPair) Wipe()

Wipe mocks base method.

type MockKeyPairMockRecorder 

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

MockKeyPairMockRecorder is the mock recorder for MockKeyPair.

func (*MockKeyPairMockRecorder) Open 

func (mr *MockKeyPairMockRecorder) Open(input, sender any) *gomock.Call

Open indicates an expected call of Open.

func (*MockKeyPairMockRecorder) PrivateKey 

func (mr *MockKeyPairMockRecorder) PrivateKey() *gomock.Call

PrivateKey indicates an expected call of PrivateKey.

func (*MockKeyPairMockRecorder) PublicKey 

func (mr *MockKeyPairMockRecorder) PublicKey() *gomock.Call

PublicKey indicates an expected call of PublicKey.

func (*MockKeyPairMockRecorder) Seal 

func (mr *MockKeyPairMockRecorder) Seal(input, recipient any) *gomock.Call

Seal indicates an expected call of Seal.

func (*MockKeyPairMockRecorder) SealWithRand 

func (mr *MockKeyPairMockRecorder) SealWithRand(input, recipient, rr any) *gomock.Call

SealWithRand indicates an expected call of SealWithRand.

func (*MockKeyPairMockRecorder) Seed 

func (mr *MockKeyPairMockRecorder) Seed() *gomock.Call

Seed indicates an expected call of Seed.

func (*MockKeyPairMockRecorder) Sign 

func (mr *MockKeyPairMockRecorder) Sign(input any) *gomock.Call

Sign indicates an expected call of Sign.

func (*MockKeyPairMockRecorder) Verify 

func (mr *MockKeyPairMockRecorder) Verify(input, sig any) *gomock.Call

Verify indicates an expected call of Verify.

func (*MockKeyPairMockRecorder) Wipe 

func (mr *MockKeyPairMockRecorder) Wipe() *gomock.Call

Wipe indicates an expected call of Wipe.

type MockKeyValue 

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

MockKeyValue is a mock of KeyValue interface.

func NewMockKeyValue 

func NewMockKeyValue(ctrl *gomock.Controller) *MockKeyValue

NewMockKeyValue creates a new mock instance.

func (*MockKeyValue) Bucket 

func (m *MockKeyValue) Bucket() string

Bucket mocks base method.

func (*MockKeyValue) Create 

func (m *MockKeyValue) Create(ctx context.Context, key string, value []byte, opts ...jetstream.KVCreateOpt) (uint64, error)

Create mocks base method.

func (*MockKeyValue) Delete 

func (m *MockKeyValue) Delete(ctx context.Context, key string, opts ...jetstream.KVDeleteOpt) error

Delete mocks base method.

func (*MockKeyValue) EXPECT 

func (m *MockKeyValue) EXPECT() *MockKeyValueMockRecorder

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

func (*MockKeyValue) Get 

func (m *MockKeyValue) Get(ctx context.Context, key string) (jetstream.KeyValueEntry, error)

Get mocks base method.

func (*MockKeyValue) GetRevision 

func (m *MockKeyValue) GetRevision(ctx context.Context, key string, revision uint64) (jetstream.KeyValueEntry, error)

GetRevision mocks base method.

func (*MockKeyValue) History 

func (m *MockKeyValue) History(ctx context.Context, key string, opts ...jetstream.WatchOpt) ([]jetstream.KeyValueEntry, error)

History mocks base method.

func (*MockKeyValue) Keys 

func (m *MockKeyValue) Keys(ctx context.Context, opts ...jetstream.WatchOpt) ([]string, error)

Keys mocks base method.

func (*MockKeyValue) ListKeys 

func (m *MockKeyValue) ListKeys(ctx context.Context, opts ...jetstream.WatchOpt) (jetstream.KeyLister, error)

ListKeys mocks base method.

func (*MockKeyValue) ListKeysFiltered 

func (m *MockKeyValue) ListKeysFiltered(ctx context.Context, filters ...string) (jetstream.KeyLister, error)

ListKeysFiltered mocks base method.

func (*MockKeyValue) Purge 

func (m *MockKeyValue) Purge(ctx context.Context, key string, opts ...jetstream.KVDeleteOpt) error

Purge mocks base method.

func (*MockKeyValue) PurgeDeletes 

func (m *MockKeyValue) PurgeDeletes(ctx context.Context, opts ...jetstream.KVPurgeOpt) error

PurgeDeletes mocks base method.

func (*MockKeyValue) Put 

func (m *MockKeyValue) Put(ctx context.Context, key string, value []byte) (uint64, error)

Put mocks base method.

func (*MockKeyValue) PutString 

func (m *MockKeyValue) PutString(ctx context.Context, key, value string) (uint64, error)

PutString mocks base method.

func (*MockKeyValue) Status 

func (m *MockKeyValue) Status(ctx context.Context) (jetstream.KeyValueStatus, error)

Status mocks base method.

func (*MockKeyValue) Update 

func (m *MockKeyValue) Update(ctx context.Context, key string, value []byte, revision uint64) (uint64, error)

Update mocks base method.

func (*MockKeyValue) Watch 

func (m *MockKeyValue) Watch(ctx context.Context, keys string, opts ...jetstream.WatchOpt) (jetstream.KeyWatcher, error)

Watch mocks base method.

func (*MockKeyValue) WatchAll 

func (m *MockKeyValue) WatchAll(ctx context.Context, opts ...jetstream.WatchOpt) (jetstream.KeyWatcher, error)

WatchAll mocks base method.

func (*MockKeyValue) WatchFiltered 

func (m *MockKeyValue) WatchFiltered(ctx context.Context, keys []string, opts ...jetstream.WatchOpt) (jetstream.KeyWatcher, error)

WatchFiltered mocks base method.

type MockKeyValueEntry 

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

MockKeyValueEntry is a mock of KeyValueEntry interface.

func NewMockKeyValueEntry 

func NewMockKeyValueEntry(ctrl *gomock.Controller) *MockKeyValueEntry

NewMockKeyValueEntry creates a new mock instance.

func (*MockKeyValueEntry) Bucket 

func (m *MockKeyValueEntry) Bucket() string

Bucket mocks base method.

func (*MockKeyValueEntry) Created 

func (m *MockKeyValueEntry) Created() time.Time

Created mocks base method.

func (*MockKeyValueEntry) Delta 

func (m *MockKeyValueEntry) Delta() uint64

Delta mocks base method.

func (*MockKeyValueEntry) EXPECT 

func (m *MockKeyValueEntry) EXPECT() *MockKeyValueEntryMockRecorder

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

func (*MockKeyValueEntry) Key 

func (m *MockKeyValueEntry) Key() string

Key mocks base method.

func (*MockKeyValueEntry) Operation 

func (m *MockKeyValueEntry) Operation() jetstream.KeyValueOp

Operation mocks base method.

func (*MockKeyValueEntry) Revision 

func (m *MockKeyValueEntry) Revision() uint64

Revision mocks base method.

func (*MockKeyValueEntry) Value 

func (m *MockKeyValueEntry) Value() []byte

Value mocks base method.

type MockKeyValueEntryMockRecorder 

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

MockKeyValueEntryMockRecorder is the mock recorder for MockKeyValueEntry.

func (*MockKeyValueEntryMockRecorder) Bucket 

func (mr *MockKeyValueEntryMockRecorder) Bucket() *gomock.Call

Bucket indicates an expected call of Bucket.

func (*MockKeyValueEntryMockRecorder) Created 

func (mr *MockKeyValueEntryMockRecorder) Created() *gomock.Call

Created indicates an expected call of Created.

func (*MockKeyValueEntryMockRecorder) Delta 

func (mr *MockKeyValueEntryMockRecorder) Delta() *gomock.Call

Delta indicates an expected call of Delta.

func (*MockKeyValueEntryMockRecorder) Key 

func (mr *MockKeyValueEntryMockRecorder) Key() *gomock.Call

Key indicates an expected call of Key.

func (*MockKeyValueEntryMockRecorder) Operation 

func (mr *MockKeyValueEntryMockRecorder) Operation() *gomock.Call

Operation indicates an expected call of Operation.

func (*MockKeyValueEntryMockRecorder) Revision 

func (mr *MockKeyValueEntryMockRecorder) Revision() *gomock.Call

Revision indicates an expected call of Revision.

func (*MockKeyValueEntryMockRecorder) Value 

func (mr *MockKeyValueEntryMockRecorder) Value() *gomock.Call

Value indicates an expected call of Value.

type MockKeyValueMockRecorder 

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

MockKeyValueMockRecorder is the mock recorder for MockKeyValue.

func (*MockKeyValueMockRecorder) Bucket 

func (mr *MockKeyValueMockRecorder) Bucket() *gomock.Call

Bucket indicates an expected call of Bucket.

func (*MockKeyValueMockRecorder) Create 

func (mr *MockKeyValueMockRecorder) Create(ctx, key, value any, opts ...any) *gomock.Call

Create indicates an expected call of Create.

func (*MockKeyValueMockRecorder) Delete 

func (mr *MockKeyValueMockRecorder) Delete(ctx, key any, opts ...any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockKeyValueMockRecorder) Get 

func (mr *MockKeyValueMockRecorder) Get(ctx, key any) *gomock.Call

Get indicates an expected call of Get.

func (*MockKeyValueMockRecorder) GetRevision 

func (mr *MockKeyValueMockRecorder) GetRevision(ctx, key, revision any) *gomock.Call

GetRevision indicates an expected call of GetRevision.

func (*MockKeyValueMockRecorder) History 

func (mr *MockKeyValueMockRecorder) History(ctx, key any, opts ...any) *gomock.Call

History indicates an expected call of History.

func (*MockKeyValueMockRecorder) Keys 

func (mr *MockKeyValueMockRecorder) Keys(ctx any, opts ...any) *gomock.Call

Keys indicates an expected call of Keys.

func (*MockKeyValueMockRecorder) ListKeys 

func (mr *MockKeyValueMockRecorder) ListKeys(ctx any, opts ...any) *gomock.Call

ListKeys indicates an expected call of ListKeys.

func (*MockKeyValueMockRecorder) ListKeysFiltered 

func (mr *MockKeyValueMockRecorder) ListKeysFiltered(ctx any, filters ...any) *gomock.Call

ListKeysFiltered indicates an expected call of ListKeysFiltered.

func (*MockKeyValueMockRecorder) Purge 

func (mr *MockKeyValueMockRecorder) Purge(ctx, key any, opts ...any) *gomock.Call

Purge indicates an expected call of Purge.

func (*MockKeyValueMockRecorder) PurgeDeletes 

func (mr *MockKeyValueMockRecorder) PurgeDeletes(ctx any, opts ...any) *gomock.Call

PurgeDeletes indicates an expected call of PurgeDeletes.

func (*MockKeyValueMockRecorder) Put 

func (mr *MockKeyValueMockRecorder) Put(ctx, key, value any) *gomock.Call

Put indicates an expected call of Put.

func (*MockKeyValueMockRecorder) PutString 

func (mr *MockKeyValueMockRecorder) PutString(ctx, key, value any) *gomock.Call

PutString indicates an expected call of PutString.

func (*MockKeyValueMockRecorder) Status 

func (mr *MockKeyValueMockRecorder) Status(ctx any) *gomock.Call

Status indicates an expected call of Status.

func (*MockKeyValueMockRecorder) Update 

func (mr *MockKeyValueMockRecorder) Update(ctx, key, value, revision any) *gomock.Call

Update indicates an expected call of Update.

func (*MockKeyValueMockRecorder) Watch 

func (mr *MockKeyValueMockRecorder) Watch(ctx, keys any, opts ...any) *gomock.Call

Watch indicates an expected call of Watch.

func (*MockKeyValueMockRecorder) WatchAll 

func (mr *MockKeyValueMockRecorder) WatchAll(ctx any, opts ...any) *gomock.Call

WatchAll indicates an expected call of WatchAll.

func (*MockKeyValueMockRecorder) WatchFiltered 

func (mr *MockKeyValueMockRecorder) WatchFiltered(ctx, keys any, opts ...any) *gomock.Call

WatchFiltered indicates an expected call of WatchFiltered.

type MockKeyWatcher 

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

MockKeyWatcher is a mock of KeyWatcher interface.

func NewMockKeyWatcher 

func NewMockKeyWatcher(ctrl *gomock.Controller) *MockKeyWatcher

NewMockKeyWatcher creates a new mock instance.

func (*MockKeyWatcher) EXPECT 

func (m *MockKeyWatcher) EXPECT() *MockKeyWatcherMockRecorder

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

func (*MockKeyWatcher) Stop 

func (m *MockKeyWatcher) Stop() error

Stop mocks base method.

func (*MockKeyWatcher) Updates 

func (m *MockKeyWatcher) Updates() <-chan jetstream.KeyValueEntry

Updates mocks base method.

type MockKeyWatcherMockRecorder 

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

MockKeyWatcherMockRecorder is the mock recorder for MockKeyWatcher.

func (*MockKeyWatcherMockRecorder) Stop 

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

Stop indicates an expected call of Stop.

func (*MockKeyWatcherMockRecorder) Updates 

func (mr *MockKeyWatcherMockRecorder) Updates() *gomock.Call

Updates indicates an expected call of Updates.

type MockMessageBatch 

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

MockMessageBatch is a mock of MessageBatch interface.

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 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(delay 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(reason 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 any) *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(delay any) *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(reason any) *gomock.Call

TermWithReason indicates an expected call of TermWithReason.

type MockNATSConnector 

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

MockNATSConnector is a mock of NATSConnector interface.

func NewMockNATSConnector 

func NewMockNATSConnector(ctrl *gomock.Controller) *MockNATSConnector

NewMockNATSConnector creates a new mock instance.

func (*MockNATSConnector) Close 

func (m *MockNATSConnector) Close()

Close mocks base method.

func (*MockNATSConnector) Connect 

func (m *MockNATSConnector) Connect(url string, opts ...nats.Option) (*nats.Conn, error)

Connect mocks base method.

func (*MockNATSConnector) ConnectedUrl 

func (m *MockNATSConnector) ConnectedUrl() string

ConnectedUrl mocks base method.

func (*MockNATSConnector) EXPECT 

func (m *MockNATSConnector) EXPECT() *MockNATSConnectorMockRecorder

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

func (*MockNATSConnector) JetStream 

func (m *MockNATSConnector) JetStream(opts ...nats.JSOpt) (nats.JetStreamContext, error)

JetStream mocks base method.

func (*MockNATSConnector) Publish 

func (m *MockNATSConnector) Publish(subject string, data []byte) error

Publish mocks base method.

func (*MockNATSConnector) QueueSubscribe 

func (m *MockNATSConnector) QueueSubscribe(subject, queue string, handler nats.MsgHandler) (*nats.Subscription, error)

QueueSubscribe mocks base method.

func (*MockNATSConnector) Subscribe 

func (m *MockNATSConnector) Subscribe(subject string, handler nats.MsgHandler) (*nats.Subscription, error)

Subscribe mocks base method.

type MockNATSConnectorMockRecorder 

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

MockNATSConnectorMockRecorder is the mock recorder for MockNATSConnector.

func (*MockNATSConnectorMockRecorder) Close 

func (mr *MockNATSConnectorMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockNATSConnectorMockRecorder) Connect 

func (mr *MockNATSConnectorMockRecorder) Connect(url any, opts ...any) *gomock.Call

Connect indicates an expected call of Connect.

func (*MockNATSConnectorMockRecorder) ConnectedUrl 

func (mr *MockNATSConnectorMockRecorder) ConnectedUrl() *gomock.Call

ConnectedUrl indicates an expected call of ConnectedUrl.

func (*MockNATSConnectorMockRecorder) JetStream 

func (mr *MockNATSConnectorMockRecorder) JetStream(opts ...any) *gomock.Call

JetStream indicates an expected call of JetStream.

func (*MockNATSConnectorMockRecorder) Publish 

func (mr *MockNATSConnectorMockRecorder) Publish(subject, data any) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockNATSConnectorMockRecorder) QueueSubscribe 

func (mr *MockNATSConnectorMockRecorder) QueueSubscribe(subject, queue, handler any) *gomock.Call

QueueSubscribe indicates an expected call of QueueSubscribe.

func (*MockNATSConnectorMockRecorder) Subscribe 

func (mr *MockNATSConnectorMockRecorder) Subscribe(subject, handler any) *gomock.Call

Subscribe indicates an expected call of Subscribe.

type MockObjectStore 

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

MockObjectStore is a mock of ObjectStore interface.

func NewMockObjectStore 

func NewMockObjectStore(ctrl *gomock.Controller) *MockObjectStore

NewMockObjectStore creates a new mock instance. 

func (m *MockObjectStore) AddBucketLink(ctx context.Context, name string, bucket jetstream.ObjectStore) (*jetstream.ObjectInfo, error)

AddBucketLink mocks base method. 

func (m *MockObjectStore) AddLink(ctx context.Context, name string, obj *jetstream.ObjectInfo) (*jetstream.ObjectInfo, error)

AddLink mocks base method.

func (*MockObjectStore) Delete 

func (m *MockObjectStore) Delete(ctx context.Context, name string) error

Delete mocks base method.

func (*MockObjectStore) EXPECT 

func (m *MockObjectStore) EXPECT() *MockObjectStoreMockRecorder

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

func (*MockObjectStore) Get 

func (m *MockObjectStore) Get(ctx context.Context, name string, opts ...jetstream.GetObjectOpt) (jetstream.ObjectResult, error)

Get mocks base method.

func (*MockObjectStore) GetBytes 

func (m *MockObjectStore) GetBytes(ctx context.Context, name string, opts ...jetstream.GetObjectOpt) ([]byte, error)

GetBytes mocks base method.

func (*MockObjectStore) GetFile 

func (m *MockObjectStore) GetFile(ctx context.Context, name, file string, opts ...jetstream.GetObjectOpt) error

GetFile mocks base method.

func (*MockObjectStore) GetInfo 

func (m *MockObjectStore) GetInfo(ctx context.Context, name string, opts ...jetstream.GetObjectInfoOpt) (*jetstream.ObjectInfo, error)

GetInfo mocks base method.

func (*MockObjectStore) GetString 

func (m *MockObjectStore) GetString(ctx context.Context, name string, opts ...jetstream.GetObjectOpt) (string, error)

GetString mocks base method.

func (*MockObjectStore) List 

func (m *MockObjectStore) List(ctx context.Context, opts ...jetstream.ListObjectsOpt) ([]*jetstream.ObjectInfo, error)

List mocks base method.

func (*MockObjectStore) Put 

func (m *MockObjectStore) Put(ctx context.Context, obj jetstream.ObjectMeta, reader io.Reader) (*jetstream.ObjectInfo, error)

Put mocks base method.

func (*MockObjectStore) PutBytes 

func (m *MockObjectStore) PutBytes(ctx context.Context, name string, data []byte) (*jetstream.ObjectInfo, error)

PutBytes mocks base method.

func (*MockObjectStore) PutFile 

func (m *MockObjectStore) PutFile(ctx context.Context, file string) (*jetstream.ObjectInfo, error)

PutFile mocks base method.

func (*MockObjectStore) PutString 

func (m *MockObjectStore) PutString(ctx context.Context, name, data string) (*jetstream.ObjectInfo, error)

PutString mocks base method.

func (*MockObjectStore) Seal 

func (m *MockObjectStore) Seal(ctx context.Context) error

Seal mocks base method.

func (*MockObjectStore) Status 

func (m *MockObjectStore) Status(ctx context.Context) (jetstream.ObjectStoreStatus, error)

Status mocks base method.

func (*MockObjectStore) UpdateMeta 

func (m *MockObjectStore) UpdateMeta(ctx context.Context, name string, meta jetstream.ObjectMeta) error

UpdateMeta mocks base method.

func (*MockObjectStore) Watch 

func (m *MockObjectStore) Watch(ctx context.Context, opts ...jetstream.WatchOpt) (jetstream.ObjectWatcher, error)

Watch mocks base method.

type MockObjectStoreMockRecorder 

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

MockObjectStoreMockRecorder is the mock recorder for MockObjectStore. 

func (mr *MockObjectStoreMockRecorder) AddBucketLink(ctx, name, bucket any) *gomock.Call

AddBucketLink indicates an expected call of AddBucketLink. 

func (mr *MockObjectStoreMockRecorder) AddLink(ctx, name, obj any) *gomock.Call

AddLink indicates an expected call of AddLink.

func (*MockObjectStoreMockRecorder) Delete 

func (mr *MockObjectStoreMockRecorder) Delete(ctx, name any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockObjectStoreMockRecorder) Get 

func (mr *MockObjectStoreMockRecorder) Get(ctx, name any, opts ...any) *gomock.Call

Get indicates an expected call of Get.

func (*MockObjectStoreMockRecorder) GetBytes 

func (mr *MockObjectStoreMockRecorder) GetBytes(ctx, name any, opts ...any) *gomock.Call

GetBytes indicates an expected call of GetBytes.

func (*MockObjectStoreMockRecorder) GetFile 

func (mr *MockObjectStoreMockRecorder) GetFile(ctx, name, file any, opts ...any) *gomock.Call

GetFile indicates an expected call of GetFile.

func (*MockObjectStoreMockRecorder) GetInfo 

func (mr *MockObjectStoreMockRecorder) GetInfo(ctx, name any, opts ...any) *gomock.Call

GetInfo indicates an expected call of GetInfo.

func (*MockObjectStoreMockRecorder) GetString 

func (mr *MockObjectStoreMockRecorder) GetString(ctx, name any, opts ...any) *gomock.Call

GetString indicates an expected call of GetString.

func (*MockObjectStoreMockRecorder) List 

func (mr *MockObjectStoreMockRecorder) List(ctx any, opts ...any) *gomock.Call

List indicates an expected call of List.

func (*MockObjectStoreMockRecorder) Put 

func (mr *MockObjectStoreMockRecorder) Put(ctx, obj, reader any) *gomock.Call

Put indicates an expected call of Put.

func (*MockObjectStoreMockRecorder) PutBytes 

func (mr *MockObjectStoreMockRecorder) PutBytes(ctx, name, data any) *gomock.Call

PutBytes indicates an expected call of PutBytes.

func (*MockObjectStoreMockRecorder) PutFile 

func (mr *MockObjectStoreMockRecorder) PutFile(ctx, file any) *gomock.Call

PutFile indicates an expected call of PutFile.

func (*MockObjectStoreMockRecorder) PutString 

func (mr *MockObjectStoreMockRecorder) PutString(ctx, name, data any) *gomock.Call

PutString indicates an expected call of PutString.

func (*MockObjectStoreMockRecorder) Seal 

func (mr *MockObjectStoreMockRecorder) Seal(ctx any) *gomock.Call

Seal indicates an expected call of Seal.

func (*MockObjectStoreMockRecorder) Status 

func (mr *MockObjectStoreMockRecorder) Status(ctx any) *gomock.Call

Status indicates an expected call of Status.

func (*MockObjectStoreMockRecorder) UpdateMeta 

func (mr *MockObjectStoreMockRecorder) UpdateMeta(ctx, name, meta any) *gomock.Call

UpdateMeta indicates an expected call of UpdateMeta.

func (*MockObjectStoreMockRecorder) Watch 

func (mr *MockObjectStoreMockRecorder) Watch(ctx any, opts ...any) *gomock.Call

Watch indicates an expected call of Watch.

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(ctx context.Context, consumer 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(ctx context.Context, cfg jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateConsumer mocks base method.

func (*MockStream) CreateOrUpdateConsumer 

func (m *MockStream) CreateOrUpdateConsumer(ctx context.Context, cfg jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateOrUpdateConsumer mocks base method.

func (*MockStream) CreateOrUpdatePushConsumer 

func (m *MockStream) CreateOrUpdatePushConsumer(ctx context.Context, cfg jetstream.ConsumerConfig) (jetstream.PushConsumer, error)

CreateOrUpdatePushConsumer mocks base method.

func (*MockStream) CreatePushConsumer 

func (m *MockStream) CreatePushConsumer(ctx context.Context, cfg jetstream.ConsumerConfig) (jetstream.PushConsumer, error)

CreatePushConsumer mocks base method.

func (*MockStream) DeleteConsumer 

func (m *MockStream) DeleteConsumer(ctx context.Context, consumer string) error

DeleteConsumer mocks base method.

func (*MockStream) DeleteMsg 

func (m *MockStream) DeleteMsg(ctx context.Context, seq 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(ctx context.Context, subject string) (*jetstream.RawStreamMsg, error)

GetLastMsgForSubject mocks base method.

func (*MockStream) GetMsg 

func (m *MockStream) GetMsg(ctx context.Context, seq uint64, opts ...jetstream.GetMsgOpt) (*jetstream.RawStreamMsg, error)

GetMsg mocks base method.

func (*MockStream) Info 

func (m *MockStream) Info(ctx context.Context, opts ...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(ctx context.Context, cfg jetstream.OrderedConsumerConfig) (jetstream.Consumer, error)

OrderedConsumer mocks base method.

func (*MockStream) PauseConsumer 

func (m *MockStream) PauseConsumer(ctx context.Context, consumer string, pauseUntil time.Time) (*jetstream.ConsumerPauseResponse, error)

PauseConsumer mocks base method.

func (*MockStream) Purge 

func (m *MockStream) Purge(ctx context.Context, opts ...jetstream.StreamPurgeOpt) error

Purge mocks base method.

func (*MockStream) PushConsumer 

func (m *MockStream) PushConsumer(ctx context.Context, consumer string) (jetstream.PushConsumer, error)

PushConsumer mocks base method.

func (*MockStream) ResetConsumer 

func (m *MockStream) ResetConsumer(ctx context.Context, consumer string) (*jetstream.ConsumerResetResponse, error)

ResetConsumer mocks base method.

func (*MockStream) ResetConsumerToSequence 

func (m *MockStream) ResetConsumerToSequence(ctx context.Context, consumer string, seq uint64) (*jetstream.ConsumerResetResponse, error)

ResetConsumerToSequence mocks base method.

func (*MockStream) ResumeConsumer 

func (m *MockStream) ResumeConsumer(ctx context.Context, consumer string) (*jetstream.ConsumerPauseResponse, error)

ResumeConsumer mocks base method.

func (*MockStream) SecureDeleteMsg 

func (m *MockStream) SecureDeleteMsg(ctx context.Context, seq uint64) error

SecureDeleteMsg mocks base method.

func (*MockStream) UnpinConsumer 

func (m *MockStream) UnpinConsumer(ctx context.Context, consumer, group string) error

UnpinConsumer mocks base method.

func (*MockStream) UpdateConsumer 

func (m *MockStream) UpdateConsumer(ctx context.Context, cfg jetstream.ConsumerConfig) (jetstream.Consumer, error)

UpdateConsumer mocks base method.

func (*MockStream) UpdatePushConsumer 

func (m *MockStream) UpdatePushConsumer(ctx context.Context, cfg jetstream.ConsumerConfig) (jetstream.PushConsumer, error)

UpdatePushConsumer mocks base method.

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(ctx, consumer any) *gomock.Call

Consumer indicates an expected call of Consumer.

func (*MockStreamMockRecorder) ConsumerNames 

func (mr *MockStreamMockRecorder) ConsumerNames(arg0 any) *gomock.Call

ConsumerNames indicates an expected call of ConsumerNames.

func (*MockStreamMockRecorder) CreateConsumer 

func (mr *MockStreamMockRecorder) CreateConsumer(ctx, cfg any) *gomock.Call

CreateConsumer indicates an expected call of CreateConsumer.

func (*MockStreamMockRecorder) CreateOrUpdateConsumer 

func (mr *MockStreamMockRecorder) CreateOrUpdateConsumer(ctx, cfg any) *gomock.Call

CreateOrUpdateConsumer indicates an expected call of CreateOrUpdateConsumer.

func (*MockStreamMockRecorder) CreateOrUpdatePushConsumer 

func (mr *MockStreamMockRecorder) CreateOrUpdatePushConsumer(ctx, cfg any) *gomock.Call

CreateOrUpdatePushConsumer indicates an expected call of CreateOrUpdatePushConsumer.

func (*MockStreamMockRecorder) CreatePushConsumer 

func (mr *MockStreamMockRecorder) CreatePushConsumer(ctx, cfg any) *gomock.Call

CreatePushConsumer indicates an expected call of CreatePushConsumer.

func (*MockStreamMockRecorder) DeleteConsumer 

func (mr *MockStreamMockRecorder) DeleteConsumer(ctx, consumer any) *gomock.Call

DeleteConsumer indicates an expected call of DeleteConsumer.

func (*MockStreamMockRecorder) DeleteMsg 

func (mr *MockStreamMockRecorder) DeleteMsg(ctx, seq any) *gomock.Call

DeleteMsg indicates an expected call of DeleteMsg.

func (*MockStreamMockRecorder) GetLastMsgForSubject 

func (mr *MockStreamMockRecorder) GetLastMsgForSubject(ctx, subject any) *gomock.Call

GetLastMsgForSubject indicates an expected call of GetLastMsgForSubject.

func (*MockStreamMockRecorder) GetMsg 

func (mr *MockStreamMockRecorder) GetMsg(ctx, seq any, opts ...any) *gomock.Call

GetMsg indicates an expected call of GetMsg.

func (*MockStreamMockRecorder) Info 

func (mr *MockStreamMockRecorder) Info(ctx any, opts ...any) *gomock.Call

Info indicates an expected call of Info.

func (*MockStreamMockRecorder) ListConsumers 

func (mr *MockStreamMockRecorder) ListConsumers(arg0 any) *gomock.Call

ListConsumers indicates an expected call of ListConsumers.

func (*MockStreamMockRecorder) OrderedConsumer 

func (mr *MockStreamMockRecorder) OrderedConsumer(ctx, cfg any) *gomock.Call

OrderedConsumer indicates an expected call of OrderedConsumer.

func (*MockStreamMockRecorder) PauseConsumer 

func (mr *MockStreamMockRecorder) PauseConsumer(ctx, consumer, pauseUntil any) *gomock.Call

PauseConsumer indicates an expected call of PauseConsumer.

func (*MockStreamMockRecorder) Purge 

func (mr *MockStreamMockRecorder) Purge(ctx any, opts ...any) *gomock.Call

Purge indicates an expected call of Purge.

func (*MockStreamMockRecorder) PushConsumer 

func (mr *MockStreamMockRecorder) PushConsumer(ctx, consumer any) *gomock.Call

PushConsumer indicates an expected call of PushConsumer.

func (*MockStreamMockRecorder) ResetConsumer 

func (mr *MockStreamMockRecorder) ResetConsumer(ctx, consumer any) *gomock.Call

ResetConsumer indicates an expected call of ResetConsumer.

func (*MockStreamMockRecorder) ResetConsumerToSequence 

func (mr *MockStreamMockRecorder) ResetConsumerToSequence(ctx, consumer, seq any) *gomock.Call

ResetConsumerToSequence indicates an expected call of ResetConsumerToSequence.

func (*MockStreamMockRecorder) ResumeConsumer 

func (mr *MockStreamMockRecorder) ResumeConsumer(ctx, consumer any) *gomock.Call

ResumeConsumer indicates an expected call of ResumeConsumer.

func (*MockStreamMockRecorder) SecureDeleteMsg 

func (mr *MockStreamMockRecorder) SecureDeleteMsg(ctx, seq any) *gomock.Call

SecureDeleteMsg indicates an expected call of SecureDeleteMsg.

func (*MockStreamMockRecorder) UnpinConsumer 

func (mr *MockStreamMockRecorder) UnpinConsumer(ctx, consumer, group any) *gomock.Call

UnpinConsumer indicates an expected call of UnpinConsumer.

func (*MockStreamMockRecorder) UpdateConsumer 

func (mr *MockStreamMockRecorder) UpdateConsumer(ctx, cfg any) *gomock.Call

UpdateConsumer indicates an expected call of UpdateConsumer.

func (*MockStreamMockRecorder) UpdatePushConsumer 

func (mr *MockStreamMockRecorder) UpdatePushConsumer(ctx, cfg any) *gomock.Call

UpdatePushConsumer indicates an expected call of UpdatePushConsumer.

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.