mocks

package
v0.2.0 Latest Latest
Warning

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

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

Documentation

Overview

Package mocks is a generated GoMock package.

Package mocks provides 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.

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 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 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) 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(ctx context.Context, subject string, data []byte) error

Publish mocks base method.

type MockPublisherMockRecorder 

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

MockPublisherMockRecorder is the mock recorder for MockPublisher.

func (*MockPublisherMockRecorder) Publish 

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

Publish indicates an expected call of Publish.

type MockStore 

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

MockStore is a mock of Store interface.

func NewMockStore 

func NewMockStore(ctrl *gomock.Controller) *MockStore

NewMockStore creates a new mock instance.

func (*MockStore) EXPECT 

func (m *MockStore) EXPECT() *MockStoreMockRecorder

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

func (*MockStore) Get 

func (m *MockStore) Get(ctx context.Context, id string) (*audit.Entry, error)

Get mocks base method.

func (*MockStore) List 

func (m *MockStore) List(ctx context.Context, limit, offset int) ([]audit.Entry, int, error)

List mocks base method.

func (*MockStore) ListAll 

func (m *MockStore) ListAll(ctx context.Context) ([]audit.Entry, error)

ListAll mocks base method.

func (*MockStore) Write 

func (m *MockStore) Write(ctx context.Context, entry audit.Entry) error

Write mocks base method.

type MockStoreMockRecorder 

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

MockStoreMockRecorder is the mock recorder for MockStore.

func (*MockStoreMockRecorder) Get 

func (mr *MockStoreMockRecorder) Get(ctx, id any) *gomock.Call

Get indicates an expected call of Get.

func (*MockStoreMockRecorder) List 

func (mr *MockStoreMockRecorder) List(ctx, limit, offset any) *gomock.Call

List indicates an expected call of List.

func (*MockStoreMockRecorder) ListAll 

func (mr *MockStoreMockRecorder) ListAll(ctx any) *gomock.Call

ListAll indicates an expected call of ListAll.

func (*MockStoreMockRecorder) Write 

func (mr *MockStoreMockRecorder) Write(ctx, entry any) *gomock.Call

Write indicates an expected call of Write.

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.