Help us shape the future of Go! Take the 2026 Go Developer Survey

mocks

package
v0.3.6 Latest Latest
Warning

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

 Go to latest Published: Oct 11, 2026 License: MIT Imports: 17 Imported by: 0

Documentation

Overview

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.

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.

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.

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.

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.

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.

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.

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.

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 MockAPI 

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

MockAPI is a mock of API interface.

func NewMockAPI 

func NewMockAPI(ctrl *gomock.Controller) *MockAPI

NewMockAPI creates a new mock instance.

func (*MockAPI) ChangeMessageVisibility added in v0.3.5 

func (m *MockAPI) ChangeMessageVisibility(ctx context.Context, in *sqs.ChangeMessageVisibilityInput, optFns ...func(*sqs.Options)) (*sqs.ChangeMessageVisibilityOutput, error)

ChangeMessageVisibility mocks base method.

func (*MockAPI) CreateQueue 

func (m *MockAPI) CreateQueue(ctx context.Context, in *sqs.CreateQueueInput, optFns ...func(*sqs.Options)) (*sqs.CreateQueueOutput, error)

CreateQueue mocks base method.

func (*MockAPI) DeleteMessage 

func (m *MockAPI) DeleteMessage(ctx context.Context, in *sqs.DeleteMessageInput, optFns ...func(*sqs.Options)) (*sqs.DeleteMessageOutput, error)

DeleteMessage mocks base method.

func (*MockAPI) DeleteMessageBatch 

func (m *MockAPI) DeleteMessageBatch(ctx context.Context, in *sqs.DeleteMessageBatchInput, optFns ...func(*sqs.Options)) (*sqs.DeleteMessageBatchOutput, error)

DeleteMessageBatch mocks base method.

func (*MockAPI) EXPECT 

func (m *MockAPI) EXPECT() *MockAPIMockRecorder

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

func (*MockAPI) GetQueueUrl 

func (m *MockAPI) GetQueueUrl(ctx context.Context, in *sqs.GetQueueUrlInput, optFns ...func(*sqs.Options)) (*sqs.GetQueueUrlOutput, error)

GetQueueUrl mocks base method.

func (*MockAPI) ReceiveMessage 

func (m *MockAPI) ReceiveMessage(ctx context.Context, in *sqs.ReceiveMessageInput, optFns ...func(*sqs.Options)) (*sqs.ReceiveMessageOutput, error)

ReceiveMessage mocks base method.

func (*MockAPI) SendMessage 

func (m *MockAPI) SendMessage(ctx context.Context, in *sqs.SendMessageInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageOutput, error)

SendMessage mocks base method.

func (*MockAPI) SendMessageBatch 

func (m *MockAPI) SendMessageBatch(ctx context.Context, in *sqs.SendMessageBatchInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageBatchOutput, error)

SendMessageBatch mocks base method.

type MockAPIMockRecorder 

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

MockAPIMockRecorder is the mock recorder for MockAPI.

func (*MockAPIMockRecorder) ChangeMessageVisibility added in v0.3.5 

func (mr *MockAPIMockRecorder) ChangeMessageVisibility(ctx, in any, optFns ...any) *gomock.Call

ChangeMessageVisibility indicates an expected call of ChangeMessageVisibility.

func (*MockAPIMockRecorder) CreateQueue 

func (mr *MockAPIMockRecorder) CreateQueue(ctx, in any, optFns ...any) *gomock.Call

CreateQueue indicates an expected call of CreateQueue.

func (*MockAPIMockRecorder) DeleteMessage 

func (mr *MockAPIMockRecorder) DeleteMessage(ctx, in any, optFns ...any) *gomock.Call

DeleteMessage indicates an expected call of DeleteMessage.

func (*MockAPIMockRecorder) DeleteMessageBatch 

func (mr *MockAPIMockRecorder) DeleteMessageBatch(ctx, in any, optFns ...any) *gomock.Call

DeleteMessageBatch indicates an expected call of DeleteMessageBatch.

func (*MockAPIMockRecorder) GetQueueUrl 

func (mr *MockAPIMockRecorder) GetQueueUrl(ctx, in any, optFns ...any) *gomock.Call

GetQueueUrl indicates an expected call of GetQueueUrl.

func (*MockAPIMockRecorder) ReceiveMessage 

func (mr *MockAPIMockRecorder) ReceiveMessage(ctx, in any, optFns ...any) *gomock.Call

ReceiveMessage indicates an expected call of ReceiveMessage.

func (*MockAPIMockRecorder) SendMessage 

func (mr *MockAPIMockRecorder) SendMessage(ctx, in any, optFns ...any) *gomock.Call

SendMessage indicates an expected call of SendMessage.

func (*MockAPIMockRecorder) SendMessageBatch 

func (mr *MockAPIMockRecorder) SendMessageBatch(ctx, in any, optFns ...any) *gomock.Call

SendMessageBatch indicates an expected call of SendMessageBatch.

type MockAnalyticsCompactor added in v0.3.2 

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

MockAnalyticsCompactor is a mock of AnalyticsCompactor interface.

func NewMockAnalyticsCompactor added in v0.3.2 

func NewMockAnalyticsCompactor(ctrl *gomock.Controller) *MockAnalyticsCompactor

NewMockAnalyticsCompactor creates a new mock instance.

func (*MockAnalyticsCompactor) Compact added in v0.3.2 

func (m *MockAnalyticsCompactor) Compact(ctx context.Context, cube string, grain types.Grain, org string, bucket time.Time) error

Compact mocks base method.

func (*MockAnalyticsCompactor) EXPECT added in v0.3.2 

func (m *MockAnalyticsCompactor) EXPECT() *MockAnalyticsCompactorMockRecorder

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

type MockAnalyticsCompactorMockRecorder added in v0.3.2 

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

MockAnalyticsCompactorMockRecorder is the mock recorder for MockAnalyticsCompactor.

func (*MockAnalyticsCompactorMockRecorder) Compact added in v0.3.2 

func (mr *MockAnalyticsCompactorMockRecorder) Compact(ctx, cube, grain, org, bucket any) *gomock.Call

Compact indicates an expected call of Compact.

type MockAnalyticsStore added in v0.3.2 

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

MockAnalyticsStore is a mock of AnalyticsStore interface.

func NewMockAnalyticsStore added in v0.3.2 

func NewMockAnalyticsStore(ctrl *gomock.Controller) *MockAnalyticsStore

NewMockAnalyticsStore creates a new mock instance.

func (*MockAnalyticsStore) Aggregate added in v0.3.2 

func (m *MockAnalyticsStore) Aggregate(ctx context.Context, q types.AggregateQuery) (interfaces.RowStream, error)

Aggregate mocks base method.

func (*MockAnalyticsStore) EXPECT added in v0.3.2 

func (m *MockAnalyticsStore) EXPECT() *MockAnalyticsStoreMockRecorder

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

func (*MockAnalyticsStore) Start added in v0.3.2 

func (m *MockAnalyticsStore) Start(ctx context.Context) error

Start mocks base method.

func (*MockAnalyticsStore) Stop added in v0.3.2 

func (m *MockAnalyticsStore) Stop(ctx context.Context) error

Stop mocks base method.

func (*MockAnalyticsStore) Write added in v0.3.2 

func (m *MockAnalyticsStore) Write(ctx context.Context, facts []types.Fact) error

Write mocks base method.

type MockAnalyticsStoreMockRecorder added in v0.3.2 

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

MockAnalyticsStoreMockRecorder is the mock recorder for MockAnalyticsStore.

func (*MockAnalyticsStoreMockRecorder) Aggregate added in v0.3.2 

func (mr *MockAnalyticsStoreMockRecorder) Aggregate(ctx, q any) *gomock.Call

Aggregate indicates an expected call of Aggregate.

func (*MockAnalyticsStoreMockRecorder) Start added in v0.3.2 

func (mr *MockAnalyticsStoreMockRecorder) Start(ctx any) *gomock.Call

Start indicates an expected call of Start.

func (*MockAnalyticsStoreMockRecorder) Stop added in v0.3.2 

func (mr *MockAnalyticsStoreMockRecorder) Stop(ctx any) *gomock.Call

Stop indicates an expected call of Stop.

func (*MockAnalyticsStoreMockRecorder) Write added in v0.3.2 

func (mr *MockAnalyticsStoreMockRecorder) Write(ctx, facts any) *gomock.Call

Write indicates an expected call of Write.

type MockAnyJob 

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

MockAnyJob is a mock of AnyJob interface.

func NewMockAnyJob 

func NewMockAnyJob(ctrl *gomock.Controller) *MockAnyJob

NewMockAnyJob creates a new mock instance.

func (*MockAnyJob) EXPECT 

func (m *MockAnyJob) EXPECT() *MockAnyJobMockRecorder

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

func (*MockAnyJob) Execute 

func (m *MockAnyJob) Execute(ctx context.Context, runner interfaces.CommandRunner, root string) (types.StepResults, error)

Execute mocks base method.

func (*MockAnyJob) Meta 

func (m *MockAnyJob) Meta() types.JobMeta

Meta mocks base method.

type MockAnyJobMockRecorder 

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

MockAnyJobMockRecorder is the mock recorder for MockAnyJob.

func (*MockAnyJobMockRecorder) Execute 

func (mr *MockAnyJobMockRecorder) Execute(ctx, runner, root any) *gomock.Call

Execute indicates an expected call of Execute.

func (*MockAnyJobMockRecorder) Meta 

func (mr *MockAnyJobMockRecorder) Meta() *gomock.Call

Meta indicates an expected call of Meta.

type MockAssumeRoleAPIClient added in v0.2.0 

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

MockAssumeRoleAPIClient is a mock of AssumeRoleAPIClient interface.

func NewMockAssumeRoleAPIClient added in v0.2.0 

func NewMockAssumeRoleAPIClient(ctrl *gomock.Controller) *MockAssumeRoleAPIClient

NewMockAssumeRoleAPIClient creates a new mock instance.

func (*MockAssumeRoleAPIClient) AssumeRole added in v0.2.0 

func (m *MockAssumeRoleAPIClient) AssumeRole(ctx context.Context, params *sts.AssumeRoleInput, optFns ...func(*sts.Options)) (*sts.AssumeRoleOutput, error)

AssumeRole mocks base method.

func (*MockAssumeRoleAPIClient) EXPECT added in v0.2.0 

func (m *MockAssumeRoleAPIClient) EXPECT() *MockAssumeRoleAPIClientMockRecorder

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

type MockAssumeRoleAPIClientMockRecorder added in v0.2.0 

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

MockAssumeRoleAPIClientMockRecorder is the mock recorder for MockAssumeRoleAPIClient.

func (*MockAssumeRoleAPIClientMockRecorder) AssumeRole added in v0.2.0 

func (mr *MockAssumeRoleAPIClientMockRecorder) AssumeRole(ctx, params any, optFns ...any) *gomock.Call

AssumeRole indicates an expected call of AssumeRole.

type MockBatch added in v0.3.2 

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

MockBatch is a mock of Batch interface.

func NewMockBatch added in v0.3.2 

func NewMockBatch(ctrl *gomock.Controller) *MockBatch

NewMockBatch creates a new mock instance.

func (*MockBatch) EXPECT added in v0.3.2 

func (m *MockBatch) EXPECT() *MockBatchMockRecorder

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

func (*MockBatch) Query added in v0.3.2 

func (m *MockBatch) Query(stmt string, values ...any)

Query mocks base method.

func (*MockBatch) Size added in v0.3.2 

func (m *MockBatch) Size() int

Size mocks base method.

func (*MockBatch) WithContext added in v0.3.2 

func (m *MockBatch) WithContext(ctx context.Context) cassandra.Batch

WithContext mocks base method.

type MockBatchMockRecorder added in v0.3.2 

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

MockBatchMockRecorder is the mock recorder for MockBatch.

func (*MockBatchMockRecorder) Query added in v0.3.2 

func (mr *MockBatchMockRecorder) Query(stmt any, values ...any) *gomock.Call

Query indicates an expected call of Query.

func (*MockBatchMockRecorder) Size added in v0.3.2 

func (mr *MockBatchMockRecorder) Size() *gomock.Call

Size indicates an expected call of Size.

func (*MockBatchMockRecorder) WithContext added in v0.3.2 

func (mr *MockBatchMockRecorder) WithContext(ctx any) *gomock.Call

WithContext indicates an expected call of WithContext.

type MockBulkhead 

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

MockBulkhead is a mock of Bulkhead interface.

func NewMockBulkhead 

func NewMockBulkhead(ctrl *gomock.Controller) *MockBulkhead

NewMockBulkhead creates a new mock instance.

func (*MockBulkhead) EXPECT 

func (m *MockBulkhead) EXPECT() *MockBulkheadMockRecorder

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

func (*MockBulkhead) Execute 

func (m *MockBulkhead) Execute(ctx context.Context, fn func() error) error

Execute mocks base method.

func (*MockBulkhead) TryExecute 

func (m *MockBulkhead) TryExecute(fn func() error) error

TryExecute mocks base method.

type MockBulkheadMockRecorder 

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

MockBulkheadMockRecorder is the mock recorder for MockBulkhead.

func (*MockBulkheadMockRecorder) Execute 

func (mr *MockBulkheadMockRecorder) Execute(ctx, fn any) *gomock.Call

Execute indicates an expected call of Execute.

func (*MockBulkheadMockRecorder) TryExecute 

func (mr *MockBulkheadMockRecorder) TryExecute(fn any) *gomock.Call

TryExecute indicates an expected call of TryExecute.

type MockByteCache 

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

MockByteCache is a mock of ByteCache interface.

func NewMockByteCache 

func NewMockByteCache(ctrl *gomock.Controller) *MockByteCache

NewMockByteCache creates a new mock instance.

func (*MockByteCache) Delete 

func (m *MockByteCache) Delete(ctx context.Context, key string)

Delete mocks base method.

func (*MockByteCache) EXPECT 

func (m *MockByteCache) EXPECT() *MockByteCacheMockRecorder

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

func (*MockByteCache) Get 

func (m *MockByteCache) Get(ctx context.Context, key string) ([]byte, bool)

Get mocks base method.

func (*MockByteCache) Set 

func (m *MockByteCache) Set(ctx context.Context, key string, value []byte, ttl time.Duration)

Set mocks base method.

type MockByteCacheMockRecorder 

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

MockByteCacheMockRecorder is the mock recorder for MockByteCache.

func (*MockByteCacheMockRecorder) Delete 

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

Delete indicates an expected call of Delete.

func (*MockByteCacheMockRecorder) Get 

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

Get indicates an expected call of Get.

func (*MockByteCacheMockRecorder) Set 

func (mr *MockByteCacheMockRecorder) Set(ctx, key, value, ttl any) *gomock.Call

Set indicates an expected call of Set.

type MockCircuitBreaker 

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

MockCircuitBreaker is a mock of CircuitBreaker interface.

func NewMockCircuitBreaker 

func NewMockCircuitBreaker(ctrl *gomock.Controller) *MockCircuitBreaker

NewMockCircuitBreaker creates a new mock instance.

func (*MockCircuitBreaker) EXPECT 

func (m *MockCircuitBreaker) EXPECT() *MockCircuitBreakerMockRecorder

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

func (*MockCircuitBreaker) Execute 

func (m *MockCircuitBreaker) Execute(fn func() error) error

Execute mocks base method.

type MockCircuitBreakerMockRecorder 

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

MockCircuitBreakerMockRecorder is the mock recorder for MockCircuitBreaker.

func (*MockCircuitBreakerMockRecorder) Execute 

func (mr *MockCircuitBreakerMockRecorder) Execute(fn any) *gomock.Call

Execute indicates an expected call of Execute.

type MockClientStream 

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

MockClientStream is a mock of ClientStream interface.

func NewMockClientStream 

func NewMockClientStream(ctrl *gomock.Controller) *MockClientStream

NewMockClientStream creates a new mock instance.

func (*MockClientStream) CloseSend 

func (m *MockClientStream) CloseSend() error

CloseSend mocks base method.

func (*MockClientStream) Context 

func (m *MockClientStream) Context() context.Context

Context mocks base method.

func (*MockClientStream) EXPECT 

func (m *MockClientStream) EXPECT() *MockClientStreamMockRecorder

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

func (*MockClientStream) Header 

func (m *MockClientStream) Header() (metadata.MD, error)

Header mocks base method.

func (*MockClientStream) RecvMsg 

func (m_2 *MockClientStream) RecvMsg(m any) error

RecvMsg mocks base method.

func (*MockClientStream) SendMsg 

func (m_2 *MockClientStream) SendMsg(m any) error

SendMsg mocks base method.

func (*MockClientStream) Trailer 

func (m *MockClientStream) Trailer() metadata.MD

Trailer mocks base method.

type MockClientStreamMockRecorder 

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

MockClientStreamMockRecorder is the mock recorder for MockClientStream.

func (*MockClientStreamMockRecorder) CloseSend 

func (mr *MockClientStreamMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockClientStreamMockRecorder) Context 

func (mr *MockClientStreamMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockClientStreamMockRecorder) Header 

func (mr *MockClientStreamMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockClientStreamMockRecorder) RecvMsg 

func (mr *MockClientStreamMockRecorder) RecvMsg(m any) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockClientStreamMockRecorder) SendMsg 

func (mr *MockClientStreamMockRecorder) SendMsg(m any) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockClientStreamMockRecorder) Trailer 

func (mr *MockClientStreamMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockCmdHook 

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

MockCmdHook is a mock of CmdHook interface.

func NewMockCmdHook 

func NewMockCmdHook(ctrl *gomock.Controller) *MockCmdHook

NewMockCmdHook creates a new mock instance.

func (*MockCmdHook) EXPECT 

func (m *MockCmdHook) EXPECT() *MockCmdHookMockRecorder

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

func (*MockCmdHook) OnFailure 

func (m *MockCmdHook) OnFailure(cmdStr string)

OnFailure mocks base method.

func (*MockCmdHook) OnStart 

func (m *MockCmdHook) OnStart(cmdStr string)

OnStart mocks base method.

func (*MockCmdHook) OnSuccess 

func (m *MockCmdHook) OnSuccess(cmdStr string)

OnSuccess mocks base method.

type MockCmdHookMockRecorder 

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

MockCmdHookMockRecorder is the mock recorder for MockCmdHook.

func (*MockCmdHookMockRecorder) OnFailure 

func (mr *MockCmdHookMockRecorder) OnFailure(cmdStr any) *gomock.Call

OnFailure indicates an expected call of OnFailure.

func (*MockCmdHookMockRecorder) OnStart 

func (mr *MockCmdHookMockRecorder) OnStart(cmdStr any) *gomock.Call

OnStart indicates an expected call of OnStart.

func (*MockCmdHookMockRecorder) OnSuccess 

func (mr *MockCmdHookMockRecorder) OnSuccess(cmdStr any) *gomock.Call

OnSuccess indicates an expected call of OnSuccess.

type MockCommandRunner 

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

MockCommandRunner is a mock of CommandRunner interface.

func NewMockCommandRunner 

func NewMockCommandRunner(ctrl *gomock.Controller) *MockCommandRunner

NewMockCommandRunner creates a new mock instance.

func (*MockCommandRunner) EXPECT 

func (m *MockCommandRunner) EXPECT() *MockCommandRunnerMockRecorder

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

func (*MockCommandRunner) Exists 

func (m *MockCommandRunner) Exists(name string) bool

Exists mocks base method.

func (*MockCommandRunner) RequireTool 

func (m *MockCommandRunner) RequireTool(name, installHint string) error

RequireTool mocks base method.

func (*MockCommandRunner) Run 

func (m *MockCommandRunner) Run(ctx context.Context, dir, name string, args ...string) error

Run mocks base method.

func (*MockCommandRunner) RunBuffered 

func (m *MockCommandRunner) RunBuffered(ctx context.Context, dir, name string, args ...string) interfaces.CmdResult

RunBuffered mocks base method.

func (*MockCommandRunner) RunBufferedWithEnv 

func (m *MockCommandRunner) RunBufferedWithEnv(ctx context.Context, dir string, extraEnv []string, name string, args ...string) interfaces.CmdResult

RunBufferedWithEnv mocks base method.

func (*MockCommandRunner) RunWithEnv 

func (m *MockCommandRunner) RunWithEnv(ctx context.Context, dir string, extraEnv []string, name string, args ...string) error

RunWithEnv mocks base method.

type MockCommandRunnerMockRecorder 

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

MockCommandRunnerMockRecorder is the mock recorder for MockCommandRunner.

func (*MockCommandRunnerMockRecorder) Exists 

func (mr *MockCommandRunnerMockRecorder) Exists(name any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockCommandRunnerMockRecorder) RequireTool 

func (mr *MockCommandRunnerMockRecorder) RequireTool(name, installHint any) *gomock.Call

RequireTool indicates an expected call of RequireTool.

func (*MockCommandRunnerMockRecorder) Run 

func (mr *MockCommandRunnerMockRecorder) Run(ctx, dir, name any, args ...any) *gomock.Call

Run indicates an expected call of Run.

func (*MockCommandRunnerMockRecorder) RunBuffered 

func (mr *MockCommandRunnerMockRecorder) RunBuffered(ctx, dir, name any, args ...any) *gomock.Call

RunBuffered indicates an expected call of RunBuffered.

func (*MockCommandRunnerMockRecorder) RunBufferedWithEnv 

func (mr *MockCommandRunnerMockRecorder) RunBufferedWithEnv(ctx, dir, extraEnv, name any, args ...any) *gomock.Call

RunBufferedWithEnv indicates an expected call of RunBufferedWithEnv.

func (*MockCommandRunnerMockRecorder) RunWithEnv 

func (mr *MockCommandRunnerMockRecorder) RunWithEnv(ctx, dir, extraEnv, name any, args ...any) *gomock.Call

RunWithEnv indicates an expected call of RunWithEnv.

type MockConfigLoader 

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

MockConfigLoader is a mock of ConfigLoader interface.

func NewMockConfigLoader 

func NewMockConfigLoader(ctrl *gomock.Controller) *MockConfigLoader

NewMockConfigLoader creates a new mock instance.

func (*MockConfigLoader) EXPECT 

func (m *MockConfigLoader) EXPECT() *MockConfigLoaderMockRecorder

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

func (*MockConfigLoader) Get 

func (m *MockConfigLoader) Get(key string) any

Get mocks base method.

func (*MockConfigLoader) GetBool 

func (m *MockConfigLoader) GetBool(key string) bool

GetBool mocks base method.

func (*MockConfigLoader) GetInt 

func (m *MockConfigLoader) GetInt(key string) int

GetInt mocks base method.

func (*MockConfigLoader) GetString 

func (m *MockConfigLoader) GetString(key string) string

GetString mocks base method.

func (*MockConfigLoader) Unmarshal 

func (m *MockConfigLoader) Unmarshal(target any) error

Unmarshal mocks base method.

func (*MockConfigLoader) UnmarshalKey 

func (m *MockConfigLoader) UnmarshalKey(key string, target any) error

UnmarshalKey mocks base method.

type MockConfigLoaderMockRecorder 

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

MockConfigLoaderMockRecorder is the mock recorder for MockConfigLoader.

func (*MockConfigLoaderMockRecorder) Get 

func (mr *MockConfigLoaderMockRecorder) Get(key any) *gomock.Call

Get indicates an expected call of Get.

func (*MockConfigLoaderMockRecorder) GetBool 

func (mr *MockConfigLoaderMockRecorder) GetBool(key any) *gomock.Call

GetBool indicates an expected call of GetBool.

func (*MockConfigLoaderMockRecorder) GetInt 

func (mr *MockConfigLoaderMockRecorder) GetInt(key any) *gomock.Call

GetInt indicates an expected call of GetInt.

func (*MockConfigLoaderMockRecorder) GetString 

func (mr *MockConfigLoaderMockRecorder) GetString(key any) *gomock.Call

GetString indicates an expected call of GetString.

func (*MockConfigLoaderMockRecorder) Unmarshal 

func (mr *MockConfigLoaderMockRecorder) Unmarshal(target any) *gomock.Call

Unmarshal indicates an expected call of Unmarshal.

func (*MockConfigLoaderMockRecorder) UnmarshalKey 

func (mr *MockConfigLoaderMockRecorder) UnmarshalKey(key, target any) *gomock.Call

UnmarshalKey indicates an expected call of UnmarshalKey.

type MockConnectorSource 

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

MockConnectorSource is a mock of ConnectorSource interface.

func NewMockConnectorSource 

func NewMockConnectorSource(ctrl *gomock.Controller) *MockConnectorSource

NewMockConnectorSource creates a new mock instance.

func (*MockConnectorSource) EXPECT 

func (m *MockConnectorSource) EXPECT() *MockConnectorSourceMockRecorder

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

func (*MockConnectorSource) ListPage 

func (m *MockConnectorSource) ListPage(ctx context.Context, continuationToken string, limit int) ([]interfaces.StorageObject, string, error)

ListPage mocks base method.

func (*MockConnectorSource) TestConnection 

func (m *MockConnectorSource) TestConnection(ctx context.Context) (int, error)

TestConnection mocks base method.

type MockConnectorSourceMockRecorder 

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

MockConnectorSourceMockRecorder is the mock recorder for MockConnectorSource.

func (*MockConnectorSourceMockRecorder) ListPage 

func (mr *MockConnectorSourceMockRecorder) ListPage(ctx, continuationToken, limit any) *gomock.Call

ListPage indicates an expected call of ListPage.

func (*MockConnectorSourceMockRecorder) TestConnection 

func (mr *MockConnectorSourceMockRecorder) TestConnection(ctx any) *gomock.Call

TestConnection indicates an expected call of TestConnection.

type MockCounter 

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

MockCounter is a mock of Counter interface.

func NewMockCounter 

func NewMockCounter(ctrl *gomock.Controller) *MockCounter

NewMockCounter creates a new mock instance.

func (*MockCounter) Add 

func (m *MockCounter) Add(value float64, labelValues ...string)

Add mocks base method.

func (*MockCounter) EXPECT 

func (m *MockCounter) EXPECT() *MockCounterMockRecorder

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

func (*MockCounter) Inc 

func (m *MockCounter) Inc(labelValues ...string)

Inc mocks base method.

type MockCounterMockRecorder 

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

MockCounterMockRecorder is the mock recorder for MockCounter.

func (*MockCounterMockRecorder) Add 

func (mr *MockCounterMockRecorder) Add(value any, labelValues ...any) *gomock.Call

Add indicates an expected call of Add.

func (*MockCounterMockRecorder) Inc 

func (mr *MockCounterMockRecorder) Inc(labelValues ...any) *gomock.Call

Inc indicates an expected call of Inc.

type MockDeadLetterBackend 

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

MockDeadLetterBackend is a mock of DeadLetterBackend interface.

func NewMockDeadLetterBackend 

func NewMockDeadLetterBackend(ctrl *gomock.Controller) *MockDeadLetterBackend

NewMockDeadLetterBackend creates a new mock instance.

func (*MockDeadLetterBackend) EXPECT 

func (m *MockDeadLetterBackend) EXPECT() *MockDeadLetterBackendMockRecorder

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

func (*MockDeadLetterBackend) Send 

func (m *MockDeadLetterBackend) Send(ctx context.Context, letter interfaces.DeadLetter) error

Send mocks base method.

type MockDeadLetterBackendMockRecorder 

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

MockDeadLetterBackendMockRecorder is the mock recorder for MockDeadLetterBackend.

func (*MockDeadLetterBackendMockRecorder) Send 

func (mr *MockDeadLetterBackendMockRecorder) Send(ctx, letter any) *gomock.Call

Send indicates an expected call of Send.

type MockDeduplicator added in v0.2.0 

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

MockDeduplicator is a mock of Deduplicator interface.

func NewMockDeduplicator added in v0.2.0 

func NewMockDeduplicator(ctrl *gomock.Controller) *MockDeduplicator

NewMockDeduplicator creates a new mock instance.

func (*MockDeduplicator) EXPECT added in v0.2.0 

func (m *MockDeduplicator) EXPECT() *MockDeduplicatorMockRecorder

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

func (*MockDeduplicator) Seen added in v0.2.0 

func (m *MockDeduplicator) Seen(ctx context.Context, key string) (bool, error)

Seen mocks base method.

type MockDeduplicatorMockRecorder added in v0.2.0 

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

MockDeduplicatorMockRecorder is the mock recorder for MockDeduplicator.

func (*MockDeduplicatorMockRecorder) Seen added in v0.2.0 

func (mr *MockDeduplicatorMockRecorder) Seen(ctx, key any) *gomock.Call

Seen indicates an expected call of Seen.

type MockDistributedLock 

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

MockDistributedLock is a mock of DistributedLock interface.

func NewMockDistributedLock 

func NewMockDistributedLock(ctrl *gomock.Controller) *MockDistributedLock

NewMockDistributedLock creates a new mock instance.

func (*MockDistributedLock) Acquire 

func (m *MockDistributedLock) Acquire(ctx context.Context, key string) (string, bool, error)

Acquire mocks base method.

func (*MockDistributedLock) EXPECT 

func (m *MockDistributedLock) EXPECT() *MockDistributedLockMockRecorder

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

func (*MockDistributedLock) Release 

func (m *MockDistributedLock) Release(ctx context.Context, key, token string) error

Release mocks base method.

func (*MockDistributedLock) Renew 

func (m *MockDistributedLock) Renew(ctx context.Context, key, token string) (bool, error)

Renew mocks base method.

type MockDistributedLockMockRecorder 

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

MockDistributedLockMockRecorder is the mock recorder for MockDistributedLock.

func (*MockDistributedLockMockRecorder) Acquire 

func (mr *MockDistributedLockMockRecorder) Acquire(ctx, key any) *gomock.Call

Acquire indicates an expected call of Acquire.

func (*MockDistributedLockMockRecorder) Release 

func (mr *MockDistributedLockMockRecorder) Release(ctx, key, token any) *gomock.Call

Release indicates an expected call of Release.

func (*MockDistributedLockMockRecorder) Renew 

func (mr *MockDistributedLockMockRecorder) Renew(ctx, key, token any) *gomock.Call

Renew indicates an expected call of Renew.

type MockDynamicConsumer 

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

MockDynamicConsumer is a mock of DynamicConsumer interface.

func NewMockDynamicConsumer 

func NewMockDynamicConsumer(ctrl *gomock.Controller) *MockDynamicConsumer

NewMockDynamicConsumer creates a new mock instance.

func (*MockDynamicConsumer) Close 

func (m *MockDynamicConsumer) Close() error

Close mocks base method.

func (*MockDynamicConsumer) EXPECT 

func (m *MockDynamicConsumer) EXPECT() *MockDynamicConsumerMockRecorder

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

func (*MockDynamicConsumer) Subscribe 

func (m *MockDynamicConsumer) Subscribe(ctx context.Context, topic string, handler interfaces.MessageHandler) error

Subscribe mocks base method.

func (*MockDynamicConsumer) Unsubscribe 

func (m *MockDynamicConsumer) Unsubscribe(ctx context.Context, topic string) error

Unsubscribe mocks base method.

type MockDynamicConsumerMockRecorder 

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

MockDynamicConsumerMockRecorder is the mock recorder for MockDynamicConsumer.

func (*MockDynamicConsumerMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockDynamicConsumerMockRecorder) Subscribe 

func (mr *MockDynamicConsumerMockRecorder) Subscribe(ctx, topic, handler any) *gomock.Call

Subscribe indicates an expected call of Subscribe.

func (*MockDynamicConsumerMockRecorder) Unsubscribe 

func (mr *MockDynamicConsumerMockRecorder) Unsubscribe(ctx, topic any) *gomock.Call

Unsubscribe indicates an expected call of Unsubscribe.

type MockEvent 

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

MockEvent is a mock of Event interface.

func NewMockEvent 

func NewMockEvent(ctrl *gomock.Controller) *MockEvent

NewMockEvent creates a new mock instance.

func (*MockEvent) EXPECT 

func (m *MockEvent) EXPECT() *MockEventMockRecorder

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

func (*MockEvent) Metadata 

func (m *MockEvent) Metadata() events.EventMetadata

Metadata mocks base method.

func (*MockEvent) Type 

func (m *MockEvent) Type() events.EventType

Type mocks base method.

type MockEventMockRecorder 

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

MockEventMockRecorder is the mock recorder for MockEvent.

func (*MockEventMockRecorder) Metadata 

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

Metadata indicates an expected call of Metadata.

func (*MockEventMockRecorder) Type 

func (mr *MockEventMockRecorder) Type() *gomock.Call

Type indicates an expected call of Type.

type MockExecutionObserver 

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

MockExecutionObserver is a mock of ExecutionObserver interface.

func NewMockExecutionObserver 

func NewMockExecutionObserver(ctrl *gomock.Controller) *MockExecutionObserver

NewMockExecutionObserver creates a new mock instance.

func (*MockExecutionObserver) EXPECT 

func (m *MockExecutionObserver) EXPECT() *MockExecutionObserverMockRecorder

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

func (*MockExecutionObserver) OnGateComplete 

func (m *MockExecutionObserver) OnGateComplete(gateName string, results types.StepResults, elapsed time.Duration)

OnGateComplete mocks base method.

func (*MockExecutionObserver) OnGateStart 

func (m *MockExecutionObserver) OnGateStart(name string, phases []string)

OnGateStart mocks base method.

func (*MockExecutionObserver) OnPhaseComplete 

func (m *MockExecutionObserver) OnPhaseComplete(name string, results types.StepResults, elapsed time.Duration)

OnPhaseComplete mocks base method.

func (*MockExecutionObserver) OnPhaseStart 

func (m *MockExecutionObserver) OnPhaseStart(name string, jobs []string)

OnPhaseStart mocks base method.

func (*MockExecutionObserver) OnStepComplete 

func (m *MockExecutionObserver) OnStepComplete(result types.StepResult)

OnStepComplete mocks base method.

func (*MockExecutionObserver) OnStepStart 

func (m *MockExecutionObserver) OnStepStart(name, group string)

OnStepStart mocks base method.

type MockExecutionObserverMockRecorder 

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

MockExecutionObserverMockRecorder is the mock recorder for MockExecutionObserver.

func (*MockExecutionObserverMockRecorder) OnGateComplete 

func (mr *MockExecutionObserverMockRecorder) OnGateComplete(gateName, results, elapsed any) *gomock.Call

OnGateComplete indicates an expected call of OnGateComplete.

func (*MockExecutionObserverMockRecorder) OnGateStart 

func (mr *MockExecutionObserverMockRecorder) OnGateStart(name, phases any) *gomock.Call

OnGateStart indicates an expected call of OnGateStart.

func (*MockExecutionObserverMockRecorder) OnPhaseComplete 

func (mr *MockExecutionObserverMockRecorder) OnPhaseComplete(name, results, elapsed any) *gomock.Call

OnPhaseComplete indicates an expected call of OnPhaseComplete.

func (*MockExecutionObserverMockRecorder) OnPhaseStart 

func (mr *MockExecutionObserverMockRecorder) OnPhaseStart(name, jobs any) *gomock.Call

OnPhaseStart indicates an expected call of OnPhaseStart.

func (*MockExecutionObserverMockRecorder) OnStepComplete 

func (mr *MockExecutionObserverMockRecorder) OnStepComplete(result any) *gomock.Call

OnStepComplete indicates an expected call of OnStepComplete.

func (*MockExecutionObserverMockRecorder) OnStepStart 

func (mr *MockExecutionObserverMockRecorder) OnStepStart(name, group any) *gomock.Call

OnStepStart indicates an expected call of OnStepStart.

type MockGauge 

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

MockGauge is a mock of Gauge interface.

func NewMockGauge 

func NewMockGauge(ctrl *gomock.Controller) *MockGauge

NewMockGauge creates a new mock instance.

func (*MockGauge) Dec 

func (m *MockGauge) Dec(labelValues ...string)

Dec mocks base method.

func (*MockGauge) EXPECT 

func (m *MockGauge) EXPECT() *MockGaugeMockRecorder

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

func (*MockGauge) Inc 

func (m *MockGauge) Inc(labelValues ...string)

Inc mocks base method.

func (*MockGauge) Set 

func (m *MockGauge) Set(value float64, labelValues ...string)

Set mocks base method.

type MockGaugeMockRecorder 

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

MockGaugeMockRecorder is the mock recorder for MockGauge.

func (*MockGaugeMockRecorder) Dec 

func (mr *MockGaugeMockRecorder) Dec(labelValues ...any) *gomock.Call

Dec indicates an expected call of Dec.

func (*MockGaugeMockRecorder) Inc 

func (mr *MockGaugeMockRecorder) Inc(labelValues ...any) *gomock.Call

Inc indicates an expected call of Inc.

func (*MockGaugeMockRecorder) Set 

func (mr *MockGaugeMockRecorder) Set(value any, labelValues ...any) *gomock.Call

Set indicates an expected call of Set.

type MockHistogram 

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

MockHistogram is a mock of Histogram interface.

func NewMockHistogram 

func NewMockHistogram(ctrl *gomock.Controller) *MockHistogram

NewMockHistogram creates a new mock instance.

func (*MockHistogram) EXPECT 

func (m *MockHistogram) EXPECT() *MockHistogramMockRecorder

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

func (*MockHistogram) Observe 

func (m *MockHistogram) Observe(value float64, labelValues ...string)

Observe mocks base method.

type MockHistogramMockRecorder 

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

MockHistogramMockRecorder is the mock recorder for MockHistogram.

func (*MockHistogramMockRecorder) Observe 

func (mr *MockHistogramMockRecorder) Observe(value any, labelValues ...any) *gomock.Call

Observe indicates an expected call of Observe.

type MockIter added in v0.3.2 

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

MockIter is a mock of Iter interface.

func NewMockIter added in v0.3.2 

func NewMockIter(ctrl *gomock.Controller) *MockIter

NewMockIter creates a new mock instance.

func (*MockIter) Close added in v0.3.2 

func (m *MockIter) Close() error

Close mocks base method.

func (*MockIter) EXPECT added in v0.3.2 

func (m *MockIter) EXPECT() *MockIterMockRecorder

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

func (*MockIter) PageState added in v0.3.2 

func (m *MockIter) PageState() []byte

PageState mocks base method.

func (*MockIter) Scan added in v0.3.2 

func (m *MockIter) Scan(dest ...any) bool

Scan mocks base method.

type MockIterMockRecorder added in v0.3.2 

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

MockIterMockRecorder is the mock recorder for MockIter.

func (*MockIterMockRecorder) Close added in v0.3.2 

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

Close indicates an expected call of Close.

func (*MockIterMockRecorder) PageState added in v0.3.2 

func (mr *MockIterMockRecorder) PageState() *gomock.Call

PageState indicates an expected call of PageState.

func (*MockIterMockRecorder) Scan added in v0.3.2 

func (mr *MockIterMockRecorder) Scan(dest ...any) *gomock.Call

Scan indicates an expected call of Scan.

type MockJob 

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

MockJob is a mock of Job interface.

func NewMockJob 

func NewMockJob(ctrl *gomock.Controller) *MockJob

NewMockJob creates a new mock instance.

func (*MockJob) Args 

func (m *MockJob) Args() map[string]any

Args mocks base method.

func (*MockJob) EXPECT 

func (m *MockJob) EXPECT() *MockJobMockRecorder

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

func (*MockJob) Kind 

func (m *MockJob) Kind() string

Kind mocks base method.

type MockJobMockRecorder 

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

MockJobMockRecorder is the mock recorder for MockJob.

func (*MockJobMockRecorder) Args 

func (mr *MockJobMockRecorder) Args() *gomock.Call

Args indicates an expected call of Args.

func (*MockJobMockRecorder) Kind 

func (mr *MockJobMockRecorder) Kind() *gomock.Call

Kind indicates an expected call of Kind.

type MockLeaderElector 

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

MockLeaderElector is a mock of LeaderElector interface.

func NewMockLeaderElector 

func NewMockLeaderElector(ctrl *gomock.Controller) *MockLeaderElector

NewMockLeaderElector creates a new mock instance.

func (*MockLeaderElector) EXPECT 

func (m *MockLeaderElector) EXPECT() *MockLeaderElectorMockRecorder

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

func (*MockLeaderElector) IsLeader 

func (m *MockLeaderElector) IsLeader(ctx context.Context) (bool, error)

IsLeader mocks base method.

type MockLeaderElectorMockRecorder 

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

MockLeaderElectorMockRecorder is the mock recorder for MockLeaderElector.

func (*MockLeaderElectorMockRecorder) IsLeader 

func (mr *MockLeaderElectorMockRecorder) IsLeader(ctx any) *gomock.Call

IsLeader indicates an expected call of IsLeader.

type MockLifecycle 

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

MockLifecycle is a mock of Lifecycle interface.

func NewMockLifecycle 

func NewMockLifecycle(ctrl *gomock.Controller) *MockLifecycle

NewMockLifecycle creates a new mock instance.

func (*MockLifecycle) EXPECT 

func (m *MockLifecycle) EXPECT() *MockLifecycleMockRecorder

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

func (*MockLifecycle) Start 

func (m *MockLifecycle) Start(ctx context.Context) error

Start mocks base method.

func (*MockLifecycle) Stop 

func (m *MockLifecycle) Stop(ctx context.Context) error

Stop mocks base method.

type MockLifecycleMockRecorder 

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

MockLifecycleMockRecorder is the mock recorder for MockLifecycle.

func (*MockLifecycleMockRecorder) Start 

func (mr *MockLifecycleMockRecorder) Start(ctx any) *gomock.Call

Start indicates an expected call of Start.

func (*MockLifecycleMockRecorder) Stop 

func (mr *MockLifecycleMockRecorder) Stop(ctx any) *gomock.Call

Stop indicates an expected call of Stop.

type MockLogger 

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

MockLogger is a mock of Logger interface.

func NewMockLogger 

func NewMockLogger(ctrl *gomock.Controller) *MockLogger

NewMockLogger creates a new mock instance.

func (*MockLogger) Debug 

func (m *MockLogger) Debug(msg string, keysAndValues ...any)

Debug mocks base method.

func (*MockLogger) EXPECT 

func (m *MockLogger) EXPECT() *MockLoggerMockRecorder

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

func (*MockLogger) Error 

func (m *MockLogger) Error(msg string, keysAndValues ...any)

Error mocks base method.

func (*MockLogger) Info 

func (m *MockLogger) Info(msg string, keysAndValues ...any)

Info mocks base method.

func (*MockLogger) Warn 

func (m *MockLogger) Warn(msg string, keysAndValues ...any)

Warn mocks base method.

func (*MockLogger) With 

func (m *MockLogger) With(keysAndValues ...any) interfaces.Logger

With mocks base method.

func (*MockLogger) WithContext 

func (m *MockLogger) WithContext(ctx context.Context) interfaces.Logger

WithContext mocks base method.

type MockLoggerMockRecorder 

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

MockLoggerMockRecorder is the mock recorder for MockLogger.

func (*MockLoggerMockRecorder) Debug 

func (mr *MockLoggerMockRecorder) Debug(msg any, keysAndValues ...any) *gomock.Call

Debug indicates an expected call of Debug.

func (*MockLoggerMockRecorder) Error 

func (mr *MockLoggerMockRecorder) Error(msg any, keysAndValues ...any) *gomock.Call

Error indicates an expected call of Error.

func (*MockLoggerMockRecorder) Info 

func (mr *MockLoggerMockRecorder) Info(msg any, keysAndValues ...any) *gomock.Call

Info indicates an expected call of Info.

func (*MockLoggerMockRecorder) Warn 

func (mr *MockLoggerMockRecorder) Warn(msg any, keysAndValues ...any) *gomock.Call

Warn indicates an expected call of Warn.

func (*MockLoggerMockRecorder) With 

func (mr *MockLoggerMockRecorder) With(keysAndValues ...any) *gomock.Call

With indicates an expected call of With.

func (*MockLoggerMockRecorder) WithContext 

func (mr *MockLoggerMockRecorder) WithContext(ctx any) *gomock.Call

WithContext indicates an expected call of WithContext.

type MockMessagePublisher 

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

MockMessagePublisher is a mock of MessagePublisher interface.

func NewMockMessagePublisher 

func NewMockMessagePublisher(ctrl *gomock.Controller) *MockMessagePublisher

NewMockMessagePublisher creates a new mock instance.

func (*MockMessagePublisher) EXPECT 

func (m *MockMessagePublisher) EXPECT() *MockMessagePublisherMockRecorder

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

func (*MockMessagePublisher) Publish 

func (m *MockMessagePublisher) Publish(ctx context.Context, topic string, payload []byte) error

Publish mocks base method.

func (*MockMessagePublisher) PublishBatch 

func (m *MockMessagePublisher) PublishBatch(ctx context.Context, topic string, payloads [][]byte) error

PublishBatch mocks base method.

type MockMessagePublisherMockRecorder 

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

MockMessagePublisherMockRecorder is the mock recorder for MockMessagePublisher.

func (*MockMessagePublisherMockRecorder) Publish 

func (mr *MockMessagePublisherMockRecorder) Publish(ctx, topic, payload any) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockMessagePublisherMockRecorder) PublishBatch 

func (mr *MockMessagePublisherMockRecorder) PublishBatch(ctx, topic, payloads any) *gomock.Call

PublishBatch indicates an expected call of PublishBatch.

type MockMetrics 

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

MockMetrics is a mock of Metrics interface.

func NewMockMetrics 

func NewMockMetrics(ctrl *gomock.Controller) *MockMetrics

NewMockMetrics creates a new mock instance.

func (*MockMetrics) Counter 

func (m *MockMetrics) Counter(name, help string, labels ...string) interfaces.Counter

Counter mocks base method.

func (*MockMetrics) EXPECT 

func (m *MockMetrics) EXPECT() *MockMetricsMockRecorder

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

func (*MockMetrics) Gauge 

func (m *MockMetrics) Gauge(name, help string, labels ...string) interfaces.Gauge

Gauge mocks base method.

func (*MockMetrics) Handler 

func (m *MockMetrics) Handler() http.Handler

Handler mocks base method.

func (*MockMetrics) Histogram 

func (m *MockMetrics) Histogram(name, help string, buckets []float64, labels ...string) interfaces.Histogram

Histogram mocks base method.

type MockMetricsMockRecorder 

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

MockMetricsMockRecorder is the mock recorder for MockMetrics.

func (*MockMetricsMockRecorder) Counter 

func (mr *MockMetricsMockRecorder) Counter(name, help any, labels ...any) *gomock.Call

Counter indicates an expected call of Counter.

func (*MockMetricsMockRecorder) Gauge 

func (mr *MockMetricsMockRecorder) Gauge(name, help any, labels ...any) *gomock.Call

Gauge indicates an expected call of Gauge.

func (*MockMetricsMockRecorder) Handler 

func (mr *MockMetricsMockRecorder) Handler() *gomock.Call

Handler indicates an expected call of Handler.

func (*MockMetricsMockRecorder) Histogram 

func (mr *MockMetricsMockRecorder) Histogram(name, help, buckets any, labels ...any) *gomock.Call

Histogram indicates an expected call of Histogram.

type MockOutboxS3API added in v0.3.2 

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

MockOutboxS3API is a mock of API interface.

func NewMockOutboxS3API added in v0.3.2 

func NewMockOutboxS3API(ctrl *gomock.Controller) *MockOutboxS3API

NewMockOutboxS3API creates a new mock instance.

func (*MockOutboxS3API) EXPECT added in v0.3.2 

func (m *MockOutboxS3API) EXPECT() *MockOutboxS3APIMockRecorder

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

func (*MockOutboxS3API) PutObject added in v0.3.2 

func (m *MockOutboxS3API) PutObject(ctx context.Context, in *s3.PutObjectInput, optFns ...func(*s3.Options)) (*s3.PutObjectOutput, error)

PutObject mocks base method.

type MockOutboxS3APIMockRecorder added in v0.3.2 

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

MockOutboxS3APIMockRecorder is the mock recorder for MockOutboxS3API.

func (*MockOutboxS3APIMockRecorder) PutObject added in v0.3.2 

func (mr *MockOutboxS3APIMockRecorder) PutObject(ctx, in any, optFns ...any) *gomock.Call

PutObject indicates an expected call of PutObject.

type MockOutboxSQSAPI added in v0.3.2 

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

MockOutboxSQSAPI is a mock of API interface.

func NewMockOutboxSQSAPI added in v0.3.2 

func NewMockOutboxSQSAPI(ctrl *gomock.Controller) *MockOutboxSQSAPI

NewMockOutboxSQSAPI creates a new mock instance.

func (*MockOutboxSQSAPI) EXPECT added in v0.3.2 

func (m *MockOutboxSQSAPI) EXPECT() *MockOutboxSQSAPIMockRecorder

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

func (*MockOutboxSQSAPI) GetQueueUrl added in v0.3.2 

func (m *MockOutboxSQSAPI) GetQueueUrl(ctx context.Context, in *sqs.GetQueueUrlInput, optFns ...func(*sqs.Options)) (*sqs.GetQueueUrlOutput, error)

GetQueueUrl mocks base method.

func (*MockOutboxSQSAPI) SendMessageBatch added in v0.3.2 

func (m *MockOutboxSQSAPI) SendMessageBatch(ctx context.Context, in *sqs.SendMessageBatchInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageBatchOutput, error)

SendMessageBatch mocks base method.

type MockOutboxSQSAPIMockRecorder added in v0.3.2 

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

MockOutboxSQSAPIMockRecorder is the mock recorder for MockOutboxSQSAPI.

func (*MockOutboxSQSAPIMockRecorder) GetQueueUrl added in v0.3.2 

func (mr *MockOutboxSQSAPIMockRecorder) GetQueueUrl(ctx, in any, optFns ...any) *gomock.Call

GetQueueUrl indicates an expected call of GetQueueUrl.

func (*MockOutboxSQSAPIMockRecorder) SendMessageBatch added in v0.3.2 

func (mr *MockOutboxSQSAPIMockRecorder) SendMessageBatch(ctx, in any, optFns ...any) *gomock.Call

SendMessageBatch indicates an expected call of SendMessageBatch.

type MockOutboxSink added in v0.3.2 

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

MockOutboxSink is a mock of OutboxSink interface.

func NewMockOutboxSink added in v0.3.2 

func NewMockOutboxSink(ctrl *gomock.Controller) *MockOutboxSink

NewMockOutboxSink creates a new mock instance.

func (*MockOutboxSink) EXPECT added in v0.3.2 

func (m *MockOutboxSink) EXPECT() *MockOutboxSinkMockRecorder

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

func (*MockOutboxSink) Send added in v0.3.2 

func (m *MockOutboxSink) Send(ctx context.Context, recs []types.OutboxRecord) []error

Send mocks base method.

type MockOutboxSinkMockRecorder added in v0.3.2 

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

MockOutboxSinkMockRecorder is the mock recorder for MockOutboxSink.

func (*MockOutboxSinkMockRecorder) Send added in v0.3.2 

func (mr *MockOutboxSinkMockRecorder) Send(ctx, recs any) *gomock.Call

Send indicates an expected call of Send.

type MockOutboxStore added in v0.3.2 

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

MockOutboxStore is a mock of OutboxStore interface.

func NewMockOutboxStore added in v0.3.2 

func NewMockOutboxStore(ctrl *gomock.Controller) *MockOutboxStore

NewMockOutboxStore creates a new mock instance.

func (*MockOutboxStore) Claim added in v0.3.2 

func (m *MockOutboxStore) Claim(ctx context.Context, lane string, limit int) ([]types.OutboxRecord, error)

Claim mocks base method.

func (*MockOutboxStore) EXPECT added in v0.3.2 

func (m *MockOutboxStore) EXPECT() *MockOutboxStoreMockRecorder

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

func (*MockOutboxStore) MarkSent added in v0.3.2 

func (m *MockOutboxStore) MarkSent(ctx context.Context, id uuid.UUID) error

MarkSent mocks base method.

func (*MockOutboxStore) Park added in v0.3.2 

func (m *MockOutboxStore) Park(ctx context.Context, id uuid.UUID, lastErr string) error

Park mocks base method.

func (*MockOutboxStore) Retry added in v0.3.2 

func (m *MockOutboxStore) Retry(ctx context.Context, id uuid.UUID, next time.Time, lastErr string) error

Retry mocks base method.

func (*MockOutboxStore) Stats added in v0.3.2 

func (m *MockOutboxStore) Stats(ctx context.Context, lane string) (types.OutboxStats, error)

Stats mocks base method.

type MockOutboxStoreMockRecorder added in v0.3.2 

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

MockOutboxStoreMockRecorder is the mock recorder for MockOutboxStore.

func (*MockOutboxStoreMockRecorder) Claim added in v0.3.2 

func (mr *MockOutboxStoreMockRecorder) Claim(ctx, lane, limit any) *gomock.Call

Claim indicates an expected call of Claim.

func (*MockOutboxStoreMockRecorder) MarkSent added in v0.3.2 

func (mr *MockOutboxStoreMockRecorder) MarkSent(ctx, id any) *gomock.Call

MarkSent indicates an expected call of MarkSent.

func (*MockOutboxStoreMockRecorder) Park added in v0.3.2 

func (mr *MockOutboxStoreMockRecorder) Park(ctx, id, lastErr any) *gomock.Call

Park indicates an expected call of Park.

func (*MockOutboxStoreMockRecorder) Retry added in v0.3.2 

func (mr *MockOutboxStoreMockRecorder) Retry(ctx, id, next, lastErr any) *gomock.Call

Retry indicates an expected call of Retry.

func (*MockOutboxStoreMockRecorder) Stats added in v0.3.2 

func (mr *MockOutboxStoreMockRecorder) Stats(ctx, lane any) *gomock.Call

Stats indicates an expected call of Stats.

type MockPatternConsumer 

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

MockPatternConsumer is a mock of PatternConsumer interface.

func NewMockPatternConsumer 

func NewMockPatternConsumer(ctrl *gomock.Controller) *MockPatternConsumer

NewMockPatternConsumer creates a new mock instance.

func (*MockPatternConsumer) Close 

func (m *MockPatternConsumer) Close() error

Close mocks base method.

func (*MockPatternConsumer) EXPECT 

func (m *MockPatternConsumer) EXPECT() *MockPatternConsumerMockRecorder

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

func (*MockPatternConsumer) PSubscribe 

func (m *MockPatternConsumer) PSubscribe(ctx context.Context, pattern string, handler interfaces.MessageHandler) error

PSubscribe mocks base method.

func (*MockPatternConsumer) PUnsubscribe 

func (m *MockPatternConsumer) PUnsubscribe(ctx context.Context, pattern string) error

PUnsubscribe mocks base method.

func (*MockPatternConsumer) Subscribe 

func (m *MockPatternConsumer) Subscribe(ctx context.Context, topic string, handler interfaces.MessageHandler) error

Subscribe mocks base method.

func (*MockPatternConsumer) Unsubscribe 

func (m *MockPatternConsumer) Unsubscribe(ctx context.Context, topic string) error

Unsubscribe mocks base method.

type MockPatternConsumerMockRecorder 

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

MockPatternConsumerMockRecorder is the mock recorder for MockPatternConsumer.

func (*MockPatternConsumerMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockPatternConsumerMockRecorder) PSubscribe 

func (mr *MockPatternConsumerMockRecorder) PSubscribe(ctx, pattern, handler any) *gomock.Call

PSubscribe indicates an expected call of PSubscribe.

func (*MockPatternConsumerMockRecorder) PUnsubscribe 

func (mr *MockPatternConsumerMockRecorder) PUnsubscribe(ctx, pattern any) *gomock.Call

PUnsubscribe indicates an expected call of PUnsubscribe.

func (*MockPatternConsumerMockRecorder) Subscribe 

func (mr *MockPatternConsumerMockRecorder) Subscribe(ctx, topic, handler any) *gomock.Call

Subscribe indicates an expected call of Subscribe.

func (*MockPatternConsumerMockRecorder) Unsubscribe 

func (mr *MockPatternConsumerMockRecorder) Unsubscribe(ctx, topic any) *gomock.Call

Unsubscribe indicates an expected call of Unsubscribe.

type MockPipeline 

type MockPipeline[In any, Out any] struct {
	// contains filtered or unexported fields
}

MockPipeline is a mock of Pipeline interface.

func NewMockPipeline 

func NewMockPipeline[In any, Out any](ctrl *gomock.Controller) *MockPipeline[In, Out]

NewMockPipeline creates a new mock instance.

func (*MockPipeline[In, Out]) EXPECT 

func (m *MockPipeline[In, Out]) EXPECT() *MockPipelineMockRecorder[In, Out]

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

func (*MockPipeline[In, Out]) Execute 

func (m *MockPipeline[In, Out]) Execute(ctx context.Context, input In) (Out, error)

Execute mocks base method.

type MockPipelineMockRecorder 

type MockPipelineMockRecorder[In any, Out any] struct {
	// contains filtered or unexported fields
}

MockPipelineMockRecorder is the mock recorder for MockPipeline.

func (*MockPipelineMockRecorder[In, Out]) Execute 

func (mr *MockPipelineMockRecorder[In, Out]) Execute(ctx, input any) *gomock.Call

Execute indicates an expected call of Execute.

type MockPrometheusHTTPDoer added in v0.3.2 

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

MockPrometheusHTTPDoer is a mock of HTTPDoer interface.

func NewMockPrometheusHTTPDoer added in v0.3.2 

func NewMockPrometheusHTTPDoer(ctrl *gomock.Controller) *MockPrometheusHTTPDoer

NewMockPrometheusHTTPDoer creates a new mock instance.

func (*MockPrometheusHTTPDoer) Do added in v0.3.2 

func (m *MockPrometheusHTTPDoer) Do(req *http.Request) (*http.Response, error)

Do mocks base method.

func (*MockPrometheusHTTPDoer) EXPECT added in v0.3.2 

func (m *MockPrometheusHTTPDoer) EXPECT() *MockPrometheusHTTPDoerMockRecorder

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

type MockPrometheusHTTPDoerMockRecorder added in v0.3.2 

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

MockPrometheusHTTPDoerMockRecorder is the mock recorder for MockPrometheusHTTPDoer.

func (*MockPrometheusHTTPDoerMockRecorder) Do added in v0.3.2 

func (mr *MockPrometheusHTTPDoerMockRecorder) Do(req any) *gomock.Call

Do indicates an expected call of Do.

type MockQuery added in v0.3.2 

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

MockQuery is a mock of Query interface.

func NewMockQuery added in v0.3.2 

func NewMockQuery(ctrl *gomock.Controller) *MockQuery

NewMockQuery creates a new mock instance.

func (*MockQuery) EXPECT added in v0.3.2 

func (m *MockQuery) EXPECT() *MockQueryMockRecorder

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

func (*MockQuery) Exec added in v0.3.2 

func (m *MockQuery) Exec() error

Exec mocks base method.

func (*MockQuery) Idempotent added in v0.3.2 

func (m *MockQuery) Idempotent(idempotent bool) cassandra.Query

Idempotent mocks base method.

func (*MockQuery) Iter added in v0.3.2 

func (m *MockQuery) Iter() cassandra.Iter

Iter mocks base method.

func (*MockQuery) PageSize added in v0.3.2 

func (m *MockQuery) PageSize(n int) cassandra.Query

PageSize mocks base method.

func (*MockQuery) PageState added in v0.3.2 

func (m *MockQuery) PageState(state []byte) cassandra.Query

PageState mocks base method.

func (*MockQuery) WithContext added in v0.3.2 

func (m *MockQuery) WithContext(ctx context.Context) cassandra.Query

WithContext mocks base method.

type MockQueryMockRecorder added in v0.3.2 

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

MockQueryMockRecorder is the mock recorder for MockQuery.

func (*MockQueryMockRecorder) Exec added in v0.3.2 

func (mr *MockQueryMockRecorder) Exec() *gomock.Call

Exec indicates an expected call of Exec.

func (*MockQueryMockRecorder) Idempotent added in v0.3.2 

func (mr *MockQueryMockRecorder) Idempotent(idempotent any) *gomock.Call

Idempotent indicates an expected call of Idempotent.

func (*MockQueryMockRecorder) Iter added in v0.3.2 

func (mr *MockQueryMockRecorder) Iter() *gomock.Call

Iter indicates an expected call of Iter.

func (*MockQueryMockRecorder) PageSize added in v0.3.2 

func (mr *MockQueryMockRecorder) PageSize(n any) *gomock.Call

PageSize indicates an expected call of PageSize.

func (*MockQueryMockRecorder) PageState added in v0.3.2 

func (mr *MockQueryMockRecorder) PageState(state any) *gomock.Call

PageState indicates an expected call of PageState.

func (*MockQueryMockRecorder) WithContext added in v0.3.2 

func (mr *MockQueryMockRecorder) WithContext(ctx any) *gomock.Call

WithContext indicates an expected call of WithContext.

type MockRateLimiter 

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

MockRateLimiter is a mock of RateLimiter interface.

func NewMockRateLimiter 

func NewMockRateLimiter(ctrl *gomock.Controller) *MockRateLimiter

NewMockRateLimiter creates a new mock instance.

func (*MockRateLimiter) Allow 

func (m *MockRateLimiter) Allow() bool

Allow mocks base method.

func (*MockRateLimiter) EXPECT 

func (m *MockRateLimiter) EXPECT() *MockRateLimiterMockRecorder

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

func (*MockRateLimiter) Wait 

func (m *MockRateLimiter) Wait(ctx context.Context) error

Wait mocks base method.

type MockRateLimiterMockRecorder 

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

MockRateLimiterMockRecorder is the mock recorder for MockRateLimiter.

func (*MockRateLimiterMockRecorder) Allow 

func (mr *MockRateLimiterMockRecorder) Allow() *gomock.Call

Allow indicates an expected call of Allow.

func (*MockRateLimiterMockRecorder) Wait 

func (mr *MockRateLimiterMockRecorder) Wait(ctx any) *gomock.Call

Wait indicates an expected call of Wait.

type MockReadCloser 

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

MockReadCloser is a mock of ReadCloser interface.

func NewMockReadCloser 

func NewMockReadCloser(ctrl *gomock.Controller) *MockReadCloser

NewMockReadCloser creates a new mock instance.

func (*MockReadCloser) Close 

func (m *MockReadCloser) Close() error

Close mocks base method.

func (*MockReadCloser) EXPECT 

func (m *MockReadCloser) EXPECT() *MockReadCloserMockRecorder

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

func (*MockReadCloser) Read 

func (m *MockReadCloser) Read(p []byte) (int, error)

Read mocks base method.

type MockReadCloserMockRecorder 

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

MockReadCloserMockRecorder is the mock recorder for MockReadCloser.

func (*MockReadCloserMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockReadCloserMockRecorder) Read 

func (mr *MockReadCloserMockRecorder) Read(p any) *gomock.Call

Read indicates an expected call of Read.

type MockReplayBuffer 

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

MockReplayBuffer is a mock of ReplayBuffer interface.

func NewMockReplayBuffer 

func NewMockReplayBuffer(ctrl *gomock.Controller) *MockReplayBuffer

NewMockReplayBuffer creates a new mock instance.

func (*MockReplayBuffer) Append 

func (m *MockReplayBuffer) Append(ctx context.Context, key, msgID string, payload []byte) error

Append mocks base method.

func (*MockReplayBuffer) Delete 

func (m *MockReplayBuffer) Delete(ctx context.Context, key string) error

Delete mocks base method.

func (*MockReplayBuffer) EXPECT 

func (m *MockReplayBuffer) EXPECT() *MockReplayBufferMockRecorder

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

func (*MockReplayBuffer) Prune 

func (m *MockReplayBuffer) Prune(ctx context.Context, key, upToMsgID string) error

Prune mocks base method.

func (*MockReplayBuffer) ReplayAfter 

func (m *MockReplayBuffer) ReplayAfter(ctx context.Context, key, afterMsgID string) ([]interfaces.BufferedMessage, bool, error)

ReplayAfter mocks base method.

type MockReplayBufferMockRecorder 

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

MockReplayBufferMockRecorder is the mock recorder for MockReplayBuffer.

func (*MockReplayBufferMockRecorder) Append 

func (mr *MockReplayBufferMockRecorder) Append(ctx, key, msgID, payload any) *gomock.Call

Append indicates an expected call of Append.

func (*MockReplayBufferMockRecorder) Delete 

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

Delete indicates an expected call of Delete.

func (*MockReplayBufferMockRecorder) Prune 

func (mr *MockReplayBufferMockRecorder) Prune(ctx, key, upToMsgID any) *gomock.Call

Prune indicates an expected call of Prune.

func (*MockReplayBufferMockRecorder) ReplayAfter 

func (mr *MockReplayBufferMockRecorder) ReplayAfter(ctx, key, afterMsgID any) *gomock.Call

ReplayAfter indicates an expected call of ReplayAfter.

type MockRetrier 

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

MockRetrier is a mock of Retrier interface.

func NewMockRetrier 

func NewMockRetrier(ctrl *gomock.Controller) *MockRetrier

NewMockRetrier creates a new mock instance.

func (*MockRetrier) EXPECT 

func (m *MockRetrier) EXPECT() *MockRetrierMockRecorder

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

func (*MockRetrier) Retry 

func (m *MockRetrier) Retry(ctx context.Context, op func() error) error

Retry mocks base method.

type MockRetrierMockRecorder 

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

MockRetrierMockRecorder is the mock recorder for MockRetrier.

func (*MockRetrierMockRecorder) Retry 

func (mr *MockRetrierMockRecorder) Retry(ctx, op any) *gomock.Call

Retry indicates an expected call of Retry.

type MockRoundTripper 

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

MockRoundTripper is a mock of RoundTripper interface.

func NewMockRoundTripper 

func NewMockRoundTripper(ctrl *gomock.Controller) *MockRoundTripper

NewMockRoundTripper creates a new mock instance.

func (*MockRoundTripper) EXPECT 

func (m *MockRoundTripper) EXPECT() *MockRoundTripperMockRecorder

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

func (*MockRoundTripper) RoundTrip 

func (m *MockRoundTripper) RoundTrip(arg0 *http.Request) (*http.Response, error)

RoundTrip mocks base method.

type MockRoundTripperMockRecorder 

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

MockRoundTripperMockRecorder is the mock recorder for MockRoundTripper.

func (*MockRoundTripperMockRecorder) RoundTrip 

func (mr *MockRoundTripperMockRecorder) RoundTrip(arg0 any) *gomock.Call

RoundTrip indicates an expected call of RoundTrip.

type MockRowStream added in v0.3.2 

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

MockRowStream is a mock of RowStream interface.

func NewMockRowStream added in v0.3.2 

func NewMockRowStream(ctrl *gomock.Controller) *MockRowStream

NewMockRowStream creates a new mock instance.

func (*MockRowStream) Close added in v0.3.2 

func (m *MockRowStream) Close() error

Close mocks base method.

func (*MockRowStream) EXPECT added in v0.3.2 

func (m *MockRowStream) EXPECT() *MockRowStreamMockRecorder

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

func (*MockRowStream) Next added in v0.3.2 

func (m *MockRowStream) Next(ctx context.Context) ([]types.Row, bool, error)

Next mocks base method.

func (*MockRowStream) ResumeToken added in v0.3.2 

func (m *MockRowStream) ResumeToken() []byte

ResumeToken mocks base method.

type MockRowStreamMockRecorder added in v0.3.2 

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

MockRowStreamMockRecorder is the mock recorder for MockRowStream.

func (*MockRowStreamMockRecorder) Close added in v0.3.2 

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

Close indicates an expected call of Close.

func (*MockRowStreamMockRecorder) Next added in v0.3.2 

func (mr *MockRowStreamMockRecorder) Next(ctx any) *gomock.Call

Next indicates an expected call of Next.

func (*MockRowStreamMockRecorder) ResumeToken added in v0.3.2 

func (mr *MockRowStreamMockRecorder) ResumeToken() *gomock.Call

ResumeToken indicates an expected call of ResumeToken.

type MockRunnable 

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

MockRunnable is a mock of Runnable interface.

func NewMockRunnable 

func NewMockRunnable(ctrl *gomock.Controller) *MockRunnable

NewMockRunnable creates a new mock instance.

func (*MockRunnable) EXPECT 

func (m *MockRunnable) EXPECT() *MockRunnableMockRecorder

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

func (*MockRunnable) Meta 

func (m *MockRunnable) Meta() types.JobMeta

Meta mocks base method.

func (*MockRunnable) Run 

func (m *MockRunnable) Run(ctx context.Context) (types.StepResults, error)

Run mocks base method.

type MockRunnableMockRecorder 

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

MockRunnableMockRecorder is the mock recorder for MockRunnable.

func (*MockRunnableMockRecorder) Meta 

func (mr *MockRunnableMockRecorder) Meta() *gomock.Call

Meta indicates an expected call of Meta.

func (*MockRunnableMockRecorder) Run 

func (mr *MockRunnableMockRecorder) Run(ctx any) *gomock.Call

Run indicates an expected call of Run.

type MockS3API 

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

MockS3API is a mock of S3API interface.

func NewMockS3API 

func NewMockS3API(ctrl *gomock.Controller) *MockS3API

NewMockS3API creates a new mock instance.

func (*MockS3API) AbortMultipartUpload 

func (m *MockS3API) AbortMultipartUpload(arg0 context.Context, arg1 *s3.AbortMultipartUploadInput, arg2 ...func(*s3.Options)) (*s3.AbortMultipartUploadOutput, error)

AbortMultipartUpload mocks base method.

func (*MockS3API) CompleteMultipartUpload 

func (m *MockS3API) CompleteMultipartUpload(arg0 context.Context, arg1 *s3.CompleteMultipartUploadInput, arg2 ...func(*s3.Options)) (*s3.CompleteMultipartUploadOutput, error)

CompleteMultipartUpload mocks base method.

func (*MockS3API) CreateBucket 

func (m *MockS3API) CreateBucket(arg0 context.Context, arg1 *s3.CreateBucketInput, arg2 ...func(*s3.Options)) (*s3.CreateBucketOutput, error)

CreateBucket mocks base method.

func (*MockS3API) CreateMultipartUpload 

func (m *MockS3API) CreateMultipartUpload(arg0 context.Context, arg1 *s3.CreateMultipartUploadInput, arg2 ...func(*s3.Options)) (*s3.CreateMultipartUploadOutput, error)

CreateMultipartUpload mocks base method.

func (*MockS3API) DeleteObject 

func (m *MockS3API) DeleteObject(arg0 context.Context, arg1 *s3.DeleteObjectInput, arg2 ...func(*s3.Options)) (*s3.DeleteObjectOutput, error)

DeleteObject mocks base method.

func (*MockS3API) DeleteObjects 

func (m *MockS3API) DeleteObjects(arg0 context.Context, arg1 *s3.DeleteObjectsInput, arg2 ...func(*s3.Options)) (*s3.DeleteObjectsOutput, error)

DeleteObjects mocks base method.

func (*MockS3API) EXPECT 

func (m *MockS3API) EXPECT() *MockS3APIMockRecorder

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

func (*MockS3API) GetObject 

func (m *MockS3API) GetObject(arg0 context.Context, arg1 *s3.GetObjectInput, arg2 ...func(*s3.Options)) (*s3.GetObjectOutput, error)

GetObject mocks base method.

func (*MockS3API) HeadBucket 

func (m *MockS3API) HeadBucket(arg0 context.Context, arg1 *s3.HeadBucketInput, arg2 ...func(*s3.Options)) (*s3.HeadBucketOutput, error)

HeadBucket mocks base method.

func (*MockS3API) HeadObject 

func (m *MockS3API) HeadObject(arg0 context.Context, arg1 *s3.HeadObjectInput, arg2 ...func(*s3.Options)) (*s3.HeadObjectOutput, error)

HeadObject mocks base method.

func (*MockS3API) ListMultipartUploads 

func (m *MockS3API) ListMultipartUploads(arg0 context.Context, arg1 *s3.ListMultipartUploadsInput, arg2 ...func(*s3.Options)) (*s3.ListMultipartUploadsOutput, error)

ListMultipartUploads mocks base method.

func (*MockS3API) ListObjectsV2 

func (m *MockS3API) ListObjectsV2(arg0 context.Context, arg1 *s3.ListObjectsV2Input, arg2 ...func(*s3.Options)) (*s3.ListObjectsV2Output, error)

ListObjectsV2 mocks base method.

func (*MockS3API) PutObject 

func (m *MockS3API) PutObject(arg0 context.Context, arg1 *s3.PutObjectInput, arg2 ...func(*s3.Options)) (*s3.PutObjectOutput, error)

PutObject mocks base method.

func (*MockS3API) UploadPart 

func (m *MockS3API) UploadPart(arg0 context.Context, arg1 *s3.UploadPartInput, arg2 ...func(*s3.Options)) (*s3.UploadPartOutput, error)

UploadPart mocks base method.

type MockS3APIMockRecorder 

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

MockS3APIMockRecorder is the mock recorder for MockS3API.

func (*MockS3APIMockRecorder) AbortMultipartUpload 

func (mr *MockS3APIMockRecorder) AbortMultipartUpload(arg0, arg1 any, arg2 ...any) *gomock.Call

AbortMultipartUpload indicates an expected call of AbortMultipartUpload.

func (*MockS3APIMockRecorder) CompleteMultipartUpload 

func (mr *MockS3APIMockRecorder) CompleteMultipartUpload(arg0, arg1 any, arg2 ...any) *gomock.Call

CompleteMultipartUpload indicates an expected call of CompleteMultipartUpload.

func (*MockS3APIMockRecorder) CreateBucket 

func (mr *MockS3APIMockRecorder) CreateBucket(arg0, arg1 any, arg2 ...any) *gomock.Call

CreateBucket indicates an expected call of CreateBucket.

func (*MockS3APIMockRecorder) CreateMultipartUpload 

func (mr *MockS3APIMockRecorder) CreateMultipartUpload(arg0, arg1 any, arg2 ...any) *gomock.Call

CreateMultipartUpload indicates an expected call of CreateMultipartUpload.

func (*MockS3APIMockRecorder) DeleteObject 

func (mr *MockS3APIMockRecorder) DeleteObject(arg0, arg1 any, arg2 ...any) *gomock.Call

DeleteObject indicates an expected call of DeleteObject.

func (*MockS3APIMockRecorder) DeleteObjects 

func (mr *MockS3APIMockRecorder) DeleteObjects(arg0, arg1 any, arg2 ...any) *gomock.Call

DeleteObjects indicates an expected call of DeleteObjects.

func (*MockS3APIMockRecorder) GetObject 

func (mr *MockS3APIMockRecorder) GetObject(arg0, arg1 any, arg2 ...any) *gomock.Call

GetObject indicates an expected call of GetObject.

func (*MockS3APIMockRecorder) HeadBucket 

func (mr *MockS3APIMockRecorder) HeadBucket(arg0, arg1 any, arg2 ...any) *gomock.Call

HeadBucket indicates an expected call of HeadBucket.

func (*MockS3APIMockRecorder) HeadObject 

func (mr *MockS3APIMockRecorder) HeadObject(arg0, arg1 any, arg2 ...any) *gomock.Call

HeadObject indicates an expected call of HeadObject.

func (*MockS3APIMockRecorder) ListMultipartUploads 

func (mr *MockS3APIMockRecorder) ListMultipartUploads(arg0, arg1 any, arg2 ...any) *gomock.Call

ListMultipartUploads indicates an expected call of ListMultipartUploads.

func (*MockS3APIMockRecorder) ListObjectsV2 

func (mr *MockS3APIMockRecorder) ListObjectsV2(arg0, arg1 any, arg2 ...any) *gomock.Call

ListObjectsV2 indicates an expected call of ListObjectsV2.

func (*MockS3APIMockRecorder) PutObject 

func (mr *MockS3APIMockRecorder) PutObject(arg0, arg1 any, arg2 ...any) *gomock.Call

PutObject indicates an expected call of PutObject.

func (*MockS3APIMockRecorder) UploadPart 

func (mr *MockS3APIMockRecorder) UploadPart(arg0, arg1 any, arg2 ...any) *gomock.Call

UploadPart indicates an expected call of UploadPart.

type MockSecretsManagerAPI added in v0.1.2 

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

MockSecretsManagerAPI is a mock of SecretsManagerAPI interface.

func NewMockSecretsManagerAPI added in v0.1.2 

func NewMockSecretsManagerAPI(ctrl *gomock.Controller) *MockSecretsManagerAPI

NewMockSecretsManagerAPI creates a new mock instance.

func (*MockSecretsManagerAPI) EXPECT added in v0.1.2 

func (m *MockSecretsManagerAPI) EXPECT() *MockSecretsManagerAPIMockRecorder

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

func (*MockSecretsManagerAPI) GetSecretValue added in v0.1.2 

func (m *MockSecretsManagerAPI) GetSecretValue(arg0 context.Context, arg1 *secretsmanager.GetSecretValueInput, arg2 ...func(*secretsmanager.Options)) (*secretsmanager.GetSecretValueOutput, error)

GetSecretValue mocks base method.

type MockSecretsManagerAPIMockRecorder added in v0.1.2 

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

MockSecretsManagerAPIMockRecorder is the mock recorder for MockSecretsManagerAPI.

func (*MockSecretsManagerAPIMockRecorder) GetSecretValue added in v0.1.2 

func (mr *MockSecretsManagerAPIMockRecorder) GetSecretValue(arg0, arg1 any, arg2 ...any) *gomock.Call

GetSecretValue indicates an expected call of GetSecretValue.

type MockService 

type MockService[T any, P any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockService is a mock of Service interface.

func NewMockService 

func NewMockService[T any, P any, ID comparable](ctrl *gomock.Controller) *MockService[T, P, ID]

NewMockService creates a new mock instance.

func (*MockService[T, P, ID]) Create 

func (m *MockService[T, P, ID]) Create(ctx context.Context, entity *T) (*T, error)

Create mocks base method.

func (*MockService[T, P, ID]) Delete 

func (m *MockService[T, P, ID]) Delete(ctx context.Context, id ID) error

Delete mocks base method.

func (*MockService[T, P, ID]) EXPECT 

func (m *MockService[T, P, ID]) EXPECT() *MockServiceMockRecorder[T, P, ID]

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

func (*MockService[T, P, ID]) Get 

func (m *MockService[T, P, ID]) Get(ctx context.Context, id ID) (*T, error)

Get mocks base method.

func (*MockService[T, P, ID]) List 

func (m *MockService[T, P, ID]) List(ctx context.Context, params P, page types.PageRequest) (*types.Page[T], error)

List mocks base method.

func (*MockService[T, P, ID]) Update 

func (m *MockService[T, P, ID]) Update(ctx context.Context, id ID, entity *T) (*T, error)

Update mocks base method.

type MockServiceMockRecorder 

type MockServiceMockRecorder[T any, P any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockServiceMockRecorder is the mock recorder for MockService.

func (*MockServiceMockRecorder[T, P, ID]) Create 

func (mr *MockServiceMockRecorder[T, P, ID]) Create(ctx, entity any) *gomock.Call

Create indicates an expected call of Create.

func (*MockServiceMockRecorder[T, P, ID]) Delete 

func (mr *MockServiceMockRecorder[T, P, ID]) Delete(ctx, id any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockServiceMockRecorder[T, P, ID]) Get 

func (mr *MockServiceMockRecorder[T, P, ID]) Get(ctx, id any) *gomock.Call

Get indicates an expected call of Get.

func (*MockServiceMockRecorder[T, P, ID]) List 

func (mr *MockServiceMockRecorder[T, P, ID]) List(ctx, params, page any) *gomock.Call

List indicates an expected call of List.

func (*MockServiceMockRecorder[T, P, ID]) Update 

func (mr *MockServiceMockRecorder[T, P, ID]) Update(ctx, id, entity any) *gomock.Call

Update indicates an expected call of Update.

type MockSession added in v0.3.2 

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

MockSession is a mock of Session interface.

func NewMockSession added in v0.3.2 

func NewMockSession(ctrl *gomock.Controller) *MockSession

NewMockSession creates a new mock instance.

func (*MockSession) Batch added in v0.3.2 

func (m *MockSession) Batch(kind cassandra.BatchKind) cassandra.Batch

Batch mocks base method.

func (*MockSession) Close added in v0.3.2 

func (m *MockSession) Close()

Close mocks base method.

func (*MockSession) EXPECT added in v0.3.2 

func (m *MockSession) EXPECT() *MockSessionMockRecorder

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

func (*MockSession) ExecuteBatch added in v0.3.2 

func (m *MockSession) ExecuteBatch(b cassandra.Batch) error

ExecuteBatch mocks base method.

func (*MockSession) Query added in v0.3.2 

func (m *MockSession) Query(stmt string, values ...any) cassandra.Query

Query mocks base method.

type MockSessionMockRecorder added in v0.3.2 

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

MockSessionMockRecorder is the mock recorder for MockSession.

func (*MockSessionMockRecorder) Batch added in v0.3.2 

func (mr *MockSessionMockRecorder) Batch(kind any) *gomock.Call

Batch indicates an expected call of Batch.

func (*MockSessionMockRecorder) Close added in v0.3.2 

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

Close indicates an expected call of Close.

func (*MockSessionMockRecorder) ExecuteBatch added in v0.3.2 

func (mr *MockSessionMockRecorder) ExecuteBatch(b any) *gomock.Call

ExecuteBatch indicates an expected call of ExecuteBatch.

func (*MockSessionMockRecorder) Query added in v0.3.2 

func (mr *MockSessionMockRecorder) Query(stmt any, values ...any) *gomock.Call

Query indicates an expected call of Query.

type MockSourceBuilder 

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

MockSourceBuilder is a mock of SourceBuilder interface.

func NewMockSourceBuilder 

func NewMockSourceBuilder(ctrl *gomock.Controller) *MockSourceBuilder

NewMockSourceBuilder creates a new mock instance.

func (*MockSourceBuilder) Build 

func (m *MockSourceBuilder) Build(ctx context.Context, cfg interfaces.SourceConfig) (interfaces.ConnectorSource, error)

Build mocks base method.

func (*MockSourceBuilder) EXPECT 

func (m *MockSourceBuilder) EXPECT() *MockSourceBuilderMockRecorder

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

type MockSourceBuilderMockRecorder 

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

MockSourceBuilderMockRecorder is the mock recorder for MockSourceBuilder.

func (*MockSourceBuilderMockRecorder) Build 

func (mr *MockSourceBuilderMockRecorder) Build(ctx, cfg any) *gomock.Call

Build indicates an expected call of Build.

type MockSpan 

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

MockSpan is a mock of Span interface.

func NewMockSpan 

func NewMockSpan(ctrl *gomock.Controller) *MockSpan

NewMockSpan creates a new mock instance.

func (*MockSpan) EXPECT 

func (m *MockSpan) EXPECT() *MockSpanMockRecorder

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

func (*MockSpan) End 

func (m *MockSpan) End()

End mocks base method.

func (*MockSpan) RecordError 

func (m *MockSpan) RecordError(err error)

RecordError mocks base method.

func (*MockSpan) SetAttribute 

func (m *MockSpan) SetAttribute(key string, value any)

SetAttribute mocks base method.

func (*MockSpan) SetStatus 

func (m *MockSpan) SetStatus(code interfaces.SpanStatusCode, description string)

SetStatus mocks base method.

type MockSpanMockRecorder 

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

MockSpanMockRecorder is the mock recorder for MockSpan.

func (*MockSpanMockRecorder) End 

func (mr *MockSpanMockRecorder) End() *gomock.Call

End indicates an expected call of End.

func (*MockSpanMockRecorder) RecordError 

func (mr *MockSpanMockRecorder) RecordError(err any) *gomock.Call

RecordError indicates an expected call of RecordError.

func (*MockSpanMockRecorder) SetAttribute 

func (mr *MockSpanMockRecorder) SetAttribute(key, value any) *gomock.Call

SetAttribute indicates an expected call of SetAttribute.

func (*MockSpanMockRecorder) SetStatus 

func (mr *MockSpanMockRecorder) SetStatus(code, description any) *gomock.Call

SetStatus indicates an expected call of SetStatus.

type MockStorageClient 

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

MockStorageClient is a mock of StorageClient interface.

func NewMockStorageClient 

func NewMockStorageClient(ctrl *gomock.Controller) *MockStorageClient

NewMockStorageClient creates a new mock instance.

func (*MockStorageClient) AbortMultipartUpload 

func (m *MockStorageClient) AbortMultipartUpload(ctx context.Context, bucket, key, uploadID string) error

AbortMultipartUpload mocks base method.

func (*MockStorageClient) CompleteMultipartUpload 

func (m *MockStorageClient) CompleteMultipartUpload(ctx context.Context, bucket, key, uploadID string, parts []interfaces.CompletedPart) error

CompleteMultipartUpload mocks base method.

func (*MockStorageClient) CreateMultipartUpload 

func (m *MockStorageClient) CreateMultipartUpload(ctx context.Context, bucket, key, contentType string) (string, error)

CreateMultipartUpload mocks base method.

func (*MockStorageClient) Delete 

func (m *MockStorageClient) Delete(ctx context.Context, bucket, key string) error

Delete mocks base method.

func (*MockStorageClient) DeleteBatch 

func (m *MockStorageClient) DeleteBatch(ctx context.Context, bucket string, keys []string) error

DeleteBatch mocks base method.

func (*MockStorageClient) Download 

func (m *MockStorageClient) Download(ctx context.Context, bucket, key string) (io.ReadCloser, error)

Download mocks base method.

func (*MockStorageClient) EXPECT 

func (m *MockStorageClient) EXPECT() *MockStorageClientMockRecorder

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

func (*MockStorageClient) EnsureBucket 

func (m *MockStorageClient) EnsureBucket(ctx context.Context, bucket string) error

EnsureBucket mocks base method.

func (*MockStorageClient) Exists 

func (m *MockStorageClient) Exists(ctx context.Context, bucket, key string) (bool, error)

Exists mocks base method.

func (*MockStorageClient) ListMultipartUploads 

func (m *MockStorageClient) ListMultipartUploads(ctx context.Context, bucket string) ([]interfaces.MultipartUpload, error)

ListMultipartUploads mocks base method.

func (*MockStorageClient) ListObjects 

func (m *MockStorageClient) ListObjects(ctx context.Context, bucket, prefix string) ([]interfaces.StorageObject, error)

ListObjects mocks base method.

func (*MockStorageClient) ListObjectsPage 

func (m *MockStorageClient) ListObjectsPage(ctx context.Context, bucket, prefix string, limit int) ([]interfaces.StorageObject, error)

ListObjectsPage mocks base method.

func (*MockStorageClient) ListObjectsPageToken 

func (m *MockStorageClient) ListObjectsPageToken(ctx context.Context, bucket, prefix, continuationToken string, limit int) ([]interfaces.StorageObject, string, error)

ListObjectsPageToken mocks base method.

func (*MockStorageClient) PresignPutURL 

func (m *MockStorageClient) PresignPutURL(ctx context.Context, bucket, key string, expirySeconds int, contentType string) (string, error)

PresignPutURL mocks base method.

func (*MockStorageClient) PresignURL 

func (m *MockStorageClient) PresignURL(ctx context.Context, bucket, key string, expirySeconds int, displayFilename string) (string, error)

PresignURL mocks base method.

func (*MockStorageClient) PresignUploadPart 

func (m *MockStorageClient) PresignUploadPart(ctx context.Context, bucket, key, uploadID string, partNumber int32, expirySeconds int) (string, error)

PresignUploadPart mocks base method.

func (*MockStorageClient) Stat 

func (m *MockStorageClient) Stat(ctx context.Context, bucket, key string) (interfaces.StorageObject, error)

Stat mocks base method.

func (*MockStorageClient) Upload 

func (m *MockStorageClient) Upload(ctx context.Context, bucket, key string, body io.Reader, contentType string) error

Upload mocks base method.

type MockStorageClientMockRecorder 

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

MockStorageClientMockRecorder is the mock recorder for MockStorageClient.

func (*MockStorageClientMockRecorder) AbortMultipartUpload 

func (mr *MockStorageClientMockRecorder) AbortMultipartUpload(ctx, bucket, key, uploadID any) *gomock.Call

AbortMultipartUpload indicates an expected call of AbortMultipartUpload.

func (*MockStorageClientMockRecorder) CompleteMultipartUpload 

func (mr *MockStorageClientMockRecorder) CompleteMultipartUpload(ctx, bucket, key, uploadID, parts any) *gomock.Call

CompleteMultipartUpload indicates an expected call of CompleteMultipartUpload.

func (*MockStorageClientMockRecorder) CreateMultipartUpload 

func (mr *MockStorageClientMockRecorder) CreateMultipartUpload(ctx, bucket, key, contentType any) *gomock.Call

CreateMultipartUpload indicates an expected call of CreateMultipartUpload.

func (*MockStorageClientMockRecorder) Delete 

func (mr *MockStorageClientMockRecorder) Delete(ctx, bucket, key any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockStorageClientMockRecorder) DeleteBatch 

func (mr *MockStorageClientMockRecorder) DeleteBatch(ctx, bucket, keys any) *gomock.Call

DeleteBatch indicates an expected call of DeleteBatch.

func (*MockStorageClientMockRecorder) Download 

func (mr *MockStorageClientMockRecorder) Download(ctx, bucket, key any) *gomock.Call

Download indicates an expected call of Download.

func (*MockStorageClientMockRecorder) EnsureBucket 

func (mr *MockStorageClientMockRecorder) EnsureBucket(ctx, bucket any) *gomock.Call

EnsureBucket indicates an expected call of EnsureBucket.

func (*MockStorageClientMockRecorder) Exists 

func (mr *MockStorageClientMockRecorder) Exists(ctx, bucket, key any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockStorageClientMockRecorder) ListMultipartUploads 

func (mr *MockStorageClientMockRecorder) ListMultipartUploads(ctx, bucket any) *gomock.Call

ListMultipartUploads indicates an expected call of ListMultipartUploads.

func (*MockStorageClientMockRecorder) ListObjects 

func (mr *MockStorageClientMockRecorder) ListObjects(ctx, bucket, prefix any) *gomock.Call

ListObjects indicates an expected call of ListObjects.

func (*MockStorageClientMockRecorder) ListObjectsPage 

func (mr *MockStorageClientMockRecorder) ListObjectsPage(ctx, bucket, prefix, limit any) *gomock.Call

ListObjectsPage indicates an expected call of ListObjectsPage.

func (*MockStorageClientMockRecorder) ListObjectsPageToken 

func (mr *MockStorageClientMockRecorder) ListObjectsPageToken(ctx, bucket, prefix, continuationToken, limit any) *gomock.Call

ListObjectsPageToken indicates an expected call of ListObjectsPageToken.

func (*MockStorageClientMockRecorder) PresignPutURL 

func (mr *MockStorageClientMockRecorder) PresignPutURL(ctx, bucket, key, expirySeconds, contentType any) *gomock.Call

PresignPutURL indicates an expected call of PresignPutURL.

func (*MockStorageClientMockRecorder) PresignURL 

func (mr *MockStorageClientMockRecorder) PresignURL(ctx, bucket, key, expirySeconds, displayFilename any) *gomock.Call

PresignURL indicates an expected call of PresignURL.

func (*MockStorageClientMockRecorder) PresignUploadPart 

func (mr *MockStorageClientMockRecorder) PresignUploadPart(ctx, bucket, key, uploadID, partNumber, expirySeconds any) *gomock.Call

PresignUploadPart indicates an expected call of PresignUploadPart.

func (*MockStorageClientMockRecorder) Stat 

func (mr *MockStorageClientMockRecorder) Stat(ctx, bucket, key any) *gomock.Call

Stat indicates an expected call of Stat.

func (*MockStorageClientMockRecorder) Upload 

func (mr *MockStorageClientMockRecorder) Upload(ctx, bucket, key, body, contentType any) *gomock.Call

Upload indicates an expected call of Upload.

type MockStore 

type MockStore[T any, P any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockStore is a mock of Store interface.

func NewMockStore 

func NewMockStore[T any, P any, ID comparable](ctrl *gomock.Controller) *MockStore[T, P, ID]

NewMockStore creates a new mock instance.

func (*MockStore[T, P, ID]) Create 

func (m *MockStore[T, P, ID]) Create(ctx context.Context, entity *T) (*T, error)

Create mocks base method.

func (*MockStore[T, P, ID]) Delete 

func (m *MockStore[T, P, ID]) Delete(ctx context.Context, id ID) error

Delete mocks base method.

func (*MockStore[T, P, ID]) EXPECT 

func (m *MockStore[T, P, ID]) EXPECT() *MockStoreMockRecorder[T, P, ID]

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

func (*MockStore[T, P, ID]) Exists 

func (m *MockStore[T, P, ID]) Exists(ctx context.Context, id ID) (bool, error)

Exists mocks base method.

func (*MockStore[T, P, ID]) Get 

func (m *MockStore[T, P, ID]) Get(ctx context.Context, id ID) (*T, error)

Get mocks base method.

func (*MockStore[T, P, ID]) List 

func (m *MockStore[T, P, ID]) List(ctx context.Context, params P, page types.PageRequest) (*types.Page[T], error)

List mocks base method.

func (*MockStore[T, P, ID]) Update 

func (m *MockStore[T, P, ID]) Update(ctx context.Context, id ID, entity *T) (*T, error)

Update mocks base method.

type MockStoreMockRecorder 

type MockStoreMockRecorder[T any, P any, ID comparable] struct {
	// contains filtered or unexported fields
}

MockStoreMockRecorder is the mock recorder for MockStore.

func (*MockStoreMockRecorder[T, P, ID]) Create 

func (mr *MockStoreMockRecorder[T, P, ID]) Create(ctx, entity any) *gomock.Call

Create indicates an expected call of Create.

func (*MockStoreMockRecorder[T, P, ID]) Delete 

func (mr *MockStoreMockRecorder[T, P, ID]) Delete(ctx, id any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockStoreMockRecorder[T, P, ID]) Exists 

func (mr *MockStoreMockRecorder[T, P, ID]) Exists(ctx, id any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockStoreMockRecorder[T, P, ID]) Get 

func (mr *MockStoreMockRecorder[T, P, ID]) Get(ctx, id any) *gomock.Call

Get indicates an expected call of Get.

func (*MockStoreMockRecorder[T, P, ID]) List 

func (mr *MockStoreMockRecorder[T, P, ID]) List(ctx, params, page any) *gomock.Call

List indicates an expected call of List.

func (*MockStoreMockRecorder[T, P, ID]) Update 

func (mr *MockStoreMockRecorder[T, P, ID]) Update(ctx, id, entity any) *gomock.Call

Update indicates an expected call of Update.

type MockStreamingHandlerConn 

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

MockStreamingHandlerConn is a mock of StreamingHandlerConn interface.

func NewMockStreamingHandlerConn 

func NewMockStreamingHandlerConn(ctrl *gomock.Controller) *MockStreamingHandlerConn

NewMockStreamingHandlerConn creates a new mock instance.

func (*MockStreamingHandlerConn) EXPECT 

func (m *MockStreamingHandlerConn) EXPECT() *MockStreamingHandlerConnMockRecorder

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

func (*MockStreamingHandlerConn) Peer 

func (m *MockStreamingHandlerConn) Peer() connect.Peer

Peer mocks base method.

func (*MockStreamingHandlerConn) Receive 

func (m *MockStreamingHandlerConn) Receive(arg0 any) error

Receive mocks base method.

func (*MockStreamingHandlerConn) RequestHeader 

func (m *MockStreamingHandlerConn) RequestHeader() http.Header

RequestHeader mocks base method.

func (*MockStreamingHandlerConn) ResponseHeader 

func (m *MockStreamingHandlerConn) ResponseHeader() http.Header

ResponseHeader mocks base method.

func (*MockStreamingHandlerConn) ResponseTrailer 

func (m *MockStreamingHandlerConn) ResponseTrailer() http.Header

ResponseTrailer mocks base method.

func (*MockStreamingHandlerConn) Send 

func (m *MockStreamingHandlerConn) Send(arg0 any) error

Send mocks base method.

func (*MockStreamingHandlerConn) Spec 

func (m *MockStreamingHandlerConn) Spec() connect.Spec

Spec mocks base method.

type MockStreamingHandlerConnMockRecorder 

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

MockStreamingHandlerConnMockRecorder is the mock recorder for MockStreamingHandlerConn.

func (*MockStreamingHandlerConnMockRecorder) Peer 

func (mr *MockStreamingHandlerConnMockRecorder) Peer() *gomock.Call

Peer indicates an expected call of Peer.

func (*MockStreamingHandlerConnMockRecorder) Receive 

func (mr *MockStreamingHandlerConnMockRecorder) Receive(arg0 any) *gomock.Call

Receive indicates an expected call of Receive.

func (*MockStreamingHandlerConnMockRecorder) RequestHeader 

func (mr *MockStreamingHandlerConnMockRecorder) RequestHeader() *gomock.Call

RequestHeader indicates an expected call of RequestHeader.

func (*MockStreamingHandlerConnMockRecorder) ResponseHeader 

func (mr *MockStreamingHandlerConnMockRecorder) ResponseHeader() *gomock.Call

ResponseHeader indicates an expected call of ResponseHeader.

func (*MockStreamingHandlerConnMockRecorder) ResponseTrailer 

func (mr *MockStreamingHandlerConnMockRecorder) ResponseTrailer() *gomock.Call

ResponseTrailer indicates an expected call of ResponseTrailer.

func (*MockStreamingHandlerConnMockRecorder) Send 

func (mr *MockStreamingHandlerConnMockRecorder) Send(arg0 any) *gomock.Call

Send indicates an expected call of Send.

func (*MockStreamingHandlerConnMockRecorder) Spec 

func (mr *MockStreamingHandlerConnMockRecorder) Spec() *gomock.Call

Spec indicates an expected call of Spec.

type MockToolSpec 

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

MockToolSpec is a mock of ToolSpec interface.

func NewMockToolSpec 

func NewMockToolSpec(ctrl *gomock.Controller) *MockToolSpec

NewMockToolSpec creates a new mock instance.

func (*MockToolSpec) Binary 

func (m *MockToolSpec) Binary() string

Binary mocks base method.

func (*MockToolSpec) Cmd 

func (m *MockToolSpec) Cmd(args ...string) (string, []string)

Cmd mocks base method.

func (*MockToolSpec) EXPECT 

func (m *MockToolSpec) EXPECT() *MockToolSpecMockRecorder

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

func (*MockToolSpec) InstallHint 

func (m *MockToolSpec) InstallHint() string

InstallHint mocks base method.

func (*MockToolSpec) Name 

func (m *MockToolSpec) Name() string

Name mocks base method.

type MockToolSpecMockRecorder 

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

MockToolSpecMockRecorder is the mock recorder for MockToolSpec.

func (*MockToolSpecMockRecorder) Binary 

func (mr *MockToolSpecMockRecorder) Binary() *gomock.Call

Binary indicates an expected call of Binary.

func (*MockToolSpecMockRecorder) Cmd 

func (mr *MockToolSpecMockRecorder) Cmd(args ...any) *gomock.Call

Cmd indicates an expected call of Cmd.

func (*MockToolSpecMockRecorder) InstallHint 

func (mr *MockToolSpecMockRecorder) InstallHint() *gomock.Call

InstallHint indicates an expected call of InstallHint.

func (*MockToolSpecMockRecorder) Name 

func (mr *MockToolSpecMockRecorder) Name() *gomock.Call

Name indicates an expected call of Name.

type MockTracer 

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

MockTracer is a mock of Tracer interface.

func NewMockTracer 

func NewMockTracer(ctrl *gomock.Controller) *MockTracer

NewMockTracer creates a new mock instance.

func (*MockTracer) EXPECT 

func (m *MockTracer) EXPECT() *MockTracerMockRecorder

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

func (*MockTracer) Shutdown 

func (m *MockTracer) Shutdown(ctx context.Context) error

Shutdown mocks base method.

func (*MockTracer) Start 

func (m *MockTracer) Start(ctx context.Context, name string, opts ...interfaces.SpanOption) (context.Context, interfaces.Span)

Start mocks base method.

type MockTracerMockRecorder 

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

MockTracerMockRecorder is the mock recorder for MockTracer.

func (*MockTracerMockRecorder) Shutdown 

func (mr *MockTracerMockRecorder) Shutdown(ctx any) *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockTracerMockRecorder) Start 

func (mr *MockTracerMockRecorder) Start(ctx, name any, opts ...any) *gomock.Call

Start indicates an expected call of Start.

type MockTransactionManager 

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

MockTransactionManager is a mock of TransactionManager interface.

func NewMockTransactionManager 

func NewMockTransactionManager(ctrl *gomock.Controller) *MockTransactionManager

NewMockTransactionManager creates a new mock instance.

func (*MockTransactionManager) Begin 

func (m *MockTransactionManager) Begin(ctx context.Context) (context.Context, interfaces.Transaction, error)

Begin mocks base method.

func (*MockTransactionManager) EXPECT 

func (m *MockTransactionManager) EXPECT() *MockTransactionManagerMockRecorder

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

func (*MockTransactionManager) WithTransaction 

func (m *MockTransactionManager) WithTransaction(ctx context.Context, fn func(context.Context) error) error

WithTransaction mocks base method.

type MockTransactionManagerMockRecorder 

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

MockTransactionManagerMockRecorder is the mock recorder for MockTransactionManager.

func (*MockTransactionManagerMockRecorder) Begin 

func (mr *MockTransactionManagerMockRecorder) Begin(ctx any) *gomock.Call

Begin indicates an expected call of Begin.

func (*MockTransactionManagerMockRecorder) WithTransaction 

func (mr *MockTransactionManagerMockRecorder) WithTransaction(ctx, fn any) *gomock.Call

WithTransaction indicates an expected call of WithTransaction.

type MockWorker 

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

MockWorker is a mock of Worker interface.

func NewMockWorker 

func NewMockWorker(ctrl *gomock.Controller) *MockWorker

NewMockWorker creates a new mock instance.

func (*MockWorker) EXPECT 

func (m *MockWorker) EXPECT() *MockWorkerMockRecorder

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

func (*MockWorker) Work 

func (m *MockWorker) Work(args map[string]any) error

Work mocks base method.

type MockWorkerMockRecorder 

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

MockWorkerMockRecorder is the mock recorder for MockWorker.

func (*MockWorkerMockRecorder) Work 

func (mr *MockWorkerMockRecorder) Work(args any) *gomock.Call

Work indicates an expected call of Work.

type MockWorkflow 

type MockWorkflow[In any, Out any] struct {
	// contains filtered or unexported fields
}

MockWorkflow is a mock of Workflow interface.

func NewMockWorkflow 

func NewMockWorkflow[In any, Out any](ctrl *gomock.Controller) *MockWorkflow[In, Out]

NewMockWorkflow creates a new mock instance.

func (*MockWorkflow[In, Out]) EXPECT 

func (m *MockWorkflow[In, Out]) EXPECT() *MockWorkflowMockRecorder[In, Out]

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

func (*MockWorkflow[In, Out]) Execute 

func (m *MockWorkflow[In, Out]) Execute(ctx context.Context, input In) (Out, error)

Execute mocks base method.

type MockWorkflowMockRecorder 

type MockWorkflowMockRecorder[In any, Out any] struct {
	// contains filtered or unexported fields
}

MockWorkflowMockRecorder is the mock recorder for MockWorkflow.

func (*MockWorkflowMockRecorder[In, Out]) Execute 

func (mr *MockWorkflowMockRecorder[In, Out]) Execute(ctx, input any) *gomock.Call

Execute indicates an expected call of Execute.

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.