mocks

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2026 License: MIT Imports: 15 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.

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) 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) 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 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 MockAuthProvider 

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

MockAuthProvider is a mock of AuthProvider interface.

func NewMockAuthProvider 

func NewMockAuthProvider(ctrl *gomock.Controller) *MockAuthProvider

NewMockAuthProvider creates a new mock instance.

func (*MockAuthProvider) EXPECT 

func (m *MockAuthProvider) EXPECT() *MockAuthProviderMockRecorder

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

func (*MockAuthProvider) HasPermission 

func (m *MockAuthProvider) HasPermission(ctx context.Context, permission, resource string) bool

HasPermission mocks base method.

func (*MockAuthProvider) HasRole 

func (m *MockAuthProvider) HasRole(ctx context.Context, role string) bool

HasRole mocks base method.

func (*MockAuthProvider) TenantContext 

func (m *MockAuthProvider) TenantContext(ctx context.Context) (*types.TenantContext, error)

TenantContext mocks base method.

func (*MockAuthProvider) ValidateToken 

func (m *MockAuthProvider) ValidateToken(ctx context.Context, token string) (*interfaces.AuthIdentity, error)

ValidateToken mocks base method.

type MockAuthProviderMockRecorder 

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

MockAuthProviderMockRecorder is the mock recorder for MockAuthProvider.

func (*MockAuthProviderMockRecorder) HasPermission 

func (mr *MockAuthProviderMockRecorder) HasPermission(ctx, permission, resource any) *gomock.Call

HasPermission indicates an expected call of HasPermission.

func (*MockAuthProviderMockRecorder) HasRole 

func (mr *MockAuthProviderMockRecorder) HasRole(ctx, role any) *gomock.Call

HasRole indicates an expected call of HasRole.

func (*MockAuthProviderMockRecorder) TenantContext 

func (mr *MockAuthProviderMockRecorder) TenantContext(ctx any) *gomock.Call

TenantContext indicates an expected call of TenantContext.

func (*MockAuthProviderMockRecorder) ValidateToken 

func (mr *MockAuthProviderMockRecorder) ValidateToken(ctx, token any) *gomock.Call

ValidateToken indicates an expected call of ValidateToken.

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 MockCacheInvalidator 

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

MockCacheInvalidator is a mock of CacheInvalidator interface.

func NewMockCacheInvalidator 

func NewMockCacheInvalidator(ctrl *gomock.Controller) *MockCacheInvalidator

NewMockCacheInvalidator creates a new mock instance.

func (*MockCacheInvalidator) EXPECT 

func (m *MockCacheInvalidator) EXPECT() *MockCacheInvalidatorMockRecorder

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

func (*MockCacheInvalidator) InvalidateAll 

func (m *MockCacheInvalidator) InvalidateAll(ctx context.Context) error

InvalidateAll mocks base method.

func (*MockCacheInvalidator) InvalidatePrefix 

func (m *MockCacheInvalidator) InvalidatePrefix(ctx context.Context, prefix string) error

InvalidatePrefix mocks base method.

type MockCacheInvalidatorMockRecorder 

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

MockCacheInvalidatorMockRecorder is the mock recorder for MockCacheInvalidator.

func (*MockCacheInvalidatorMockRecorder) InvalidateAll 

func (mr *MockCacheInvalidatorMockRecorder) InvalidateAll(ctx any) *gomock.Call

InvalidateAll indicates an expected call of InvalidateAll.

func (*MockCacheInvalidatorMockRecorder) InvalidatePrefix 

func (mr *MockCacheInvalidatorMockRecorder) InvalidatePrefix(ctx, prefix any) *gomock.Call

InvalidatePrefix indicates an expected call of InvalidatePrefix.

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 MockCountingPublisher 

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

MockCountingPublisher is a mock of CountingPublisher interface.

func NewMockCountingPublisher 

func NewMockCountingPublisher(ctrl *gomock.Controller) *MockCountingPublisher

NewMockCountingPublisher creates a new mock instance.

func (*MockCountingPublisher) EXPECT 

func (m *MockCountingPublisher) EXPECT() *MockCountingPublisherMockRecorder

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

func (*MockCountingPublisher) Publish 

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

Publish mocks base method.

func (*MockCountingPublisher) PublishBatch 

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

PublishBatch mocks base method.

func (*MockCountingPublisher) PublishCount 

func (m *MockCountingPublisher) PublishCount(ctx context.Context, topic string, payload []byte) (int, error)

PublishCount mocks base method.

type MockCountingPublisherMockRecorder 

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

MockCountingPublisherMockRecorder is the mock recorder for MockCountingPublisher.

func (*MockCountingPublisherMockRecorder) Publish 

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

Publish indicates an expected call of Publish.

func (*MockCountingPublisherMockRecorder) PublishBatch 

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

PublishBatch indicates an expected call of PublishBatch.

func (*MockCountingPublisherMockRecorder) PublishCount 

func (mr *MockCountingPublisherMockRecorder) PublishCount(ctx, topic, payload any) *gomock.Call

PublishCount indicates an expected call of PublishCount.

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 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 MockEventPublisher 

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

MockEventPublisher is a mock of EventPublisher interface.

func NewMockEventPublisher 

func NewMockEventPublisher(ctrl *gomock.Controller) *MockEventPublisher

NewMockEventPublisher creates a new mock instance.

func (*MockEventPublisher) EXPECT 

func (m *MockEventPublisher) EXPECT() *MockEventPublisherMockRecorder

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

func (*MockEventPublisher) Publish 

func (m *MockEventPublisher) Publish(ctx context.Context, event events.Event) error

Publish mocks base method.

func (*MockEventPublisher) PublishBatch 

func (m *MockEventPublisher) PublishBatch(ctx context.Context, arg1 []events.Event) error

PublishBatch mocks base method.

type MockEventPublisherMockRecorder 

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

MockEventPublisherMockRecorder is the mock recorder for MockEventPublisher.

func (*MockEventPublisherMockRecorder) Publish 

func (mr *MockEventPublisherMockRecorder) Publish(ctx, event any) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockEventPublisherMockRecorder) PublishBatch 

func (mr *MockEventPublisherMockRecorder) PublishBatch(ctx, arg1 any) *gomock.Call

PublishBatch indicates an expected call of PublishBatch.

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 MockIdentityResolver 

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

MockIdentityResolver is a mock of IdentityResolver interface.

func NewMockIdentityResolver 

func NewMockIdentityResolver(ctrl *gomock.Controller) *MockIdentityResolver

NewMockIdentityResolver creates a new mock instance.

func (*MockIdentityResolver) EXPECT 

func (m *MockIdentityResolver) EXPECT() *MockIdentityResolverMockRecorder

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

func (*MockIdentityResolver) Resolve 

func (m *MockIdentityResolver) Resolve(ctx context.Context, externalSub, orgExternalID string) (*interceptors.UserPermissions, error)

Resolve mocks base method.

type MockIdentityResolverMockRecorder 

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

MockIdentityResolverMockRecorder is the mock recorder for MockIdentityResolver.

func (*MockIdentityResolverMockRecorder) Resolve 

func (mr *MockIdentityResolverMockRecorder) Resolve(ctx, externalSub, orgExternalID any) *gomock.Call

Resolve indicates an expected call of Resolve.

type MockInviter 

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

MockInviter is a mock of Inviter interface.

func NewMockInviter 

func NewMockInviter(ctrl *gomock.Controller) *MockInviter

NewMockInviter creates a new mock instance.

func (*MockInviter) CreateInvitation 

func (m *MockInviter) CreateInvitation(ctx context.Context, orgExtID string, inv types.InviteInput) error

CreateInvitation mocks base method.

func (*MockInviter) DeleteInvitation 

func (m *MockInviter) DeleteInvitation(ctx context.Context, orgExtID, invitationID string) error

DeleteInvitation mocks base method.

func (*MockInviter) EXPECT 

func (m *MockInviter) EXPECT() *MockInviterMockRecorder

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

func (*MockInviter) ListInvitations 

func (m *MockInviter) ListInvitations(ctx context.Context, orgExtID string) ([]types.Invitation, error)

ListInvitations mocks base method.

func (*MockInviter) RemoveMember 

func (m *MockInviter) RemoveMember(ctx context.Context, orgExtID, userExtID string) error

RemoveMember mocks base method.

type MockInviterMockRecorder 

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

MockInviterMockRecorder is the mock recorder for MockInviter.

func (*MockInviterMockRecorder) CreateInvitation 

func (mr *MockInviterMockRecorder) CreateInvitation(ctx, orgExtID, inv any) *gomock.Call

CreateInvitation indicates an expected call of CreateInvitation.

func (*MockInviterMockRecorder) DeleteInvitation 

func (mr *MockInviterMockRecorder) DeleteInvitation(ctx, orgExtID, invitationID any) *gomock.Call

DeleteInvitation indicates an expected call of DeleteInvitation.

func (*MockInviterMockRecorder) ListInvitations 

func (mr *MockInviterMockRecorder) ListInvitations(ctx, orgExtID any) *gomock.Call

ListInvitations indicates an expected call of ListInvitations.

func (*MockInviterMockRecorder) RemoveMember 

func (mr *MockInviterMockRecorder) RemoveMember(ctx, orgExtID, userExtID any) *gomock.Call

RemoveMember indicates an expected call of RemoveMember.

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 MockJobEnqueuer 

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

MockJobEnqueuer is a mock of JobEnqueuer interface.

func NewMockJobEnqueuer 

func NewMockJobEnqueuer(ctrl *gomock.Controller) *MockJobEnqueuer

NewMockJobEnqueuer creates a new mock instance.

func (*MockJobEnqueuer) Close 

func (m *MockJobEnqueuer) Close() error

Close mocks base method.

func (*MockJobEnqueuer) EXPECT 

func (m *MockJobEnqueuer) EXPECT() *MockJobEnqueuerMockRecorder

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

func (*MockJobEnqueuer) Enqueue 

func (m *MockJobEnqueuer) Enqueue(ctx context.Context, job interfaces.Job) error

Enqueue mocks base method.

type MockJobEnqueuerMockRecorder 

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

MockJobEnqueuerMockRecorder is the mock recorder for MockJobEnqueuer.

func (*MockJobEnqueuerMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockJobEnqueuerMockRecorder) Enqueue 

func (mr *MockJobEnqueuerMockRecorder) Enqueue(ctx, job any) *gomock.Call

Enqueue indicates an expected call of Enqueue.

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 MockJobScheduler 

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

MockJobScheduler is a mock of JobScheduler interface.

func NewMockJobScheduler 

func NewMockJobScheduler(ctrl *gomock.Controller) *MockJobScheduler

NewMockJobScheduler creates a new mock instance.

func (*MockJobScheduler) EXPECT 

func (m *MockJobScheduler) EXPECT() *MockJobSchedulerMockRecorder

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

func (*MockJobScheduler) Schedule 

func (m *MockJobScheduler) Schedule(job interfaces.PeriodicJob, interval time.Duration) error

Schedule mocks base method.

type MockJobSchedulerMockRecorder 

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

MockJobSchedulerMockRecorder is the mock recorder for MockJobScheduler.

func (*MockJobSchedulerMockRecorder) Schedule 

func (mr *MockJobSchedulerMockRecorder) Schedule(job, interval any) *gomock.Call

Schedule indicates an expected call of Schedule.

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 MockLocker 

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

MockLocker is a mock of Locker interface.

func NewMockLocker 

func NewMockLocker(ctrl *gomock.Controller) *MockLocker

NewMockLocker creates a new mock instance.

func (*MockLocker) Acquire 

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

Acquire mocks base method.

func (*MockLocker) EXPECT 

func (m *MockLocker) EXPECT() *MockLockerMockRecorder

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

func (*MockLocker) Hold 

func (m *MockLocker) Hold(ctx context.Context, key string) (context.Context, func(), bool, error)

Hold mocks base method.

func (*MockLocker) Release 

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

Release mocks base method.

func (*MockLocker) Renew 

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

Renew mocks base method.

type MockLockerMockRecorder 

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

MockLockerMockRecorder is the mock recorder for MockLocker.

func (*MockLockerMockRecorder) Acquire 

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

Acquire indicates an expected call of Acquire.

func (*MockLockerMockRecorder) Hold 

func (mr *MockLockerMockRecorder) Hold(ctx, key any) *gomock.Call

Hold indicates an expected call of Hold.

func (*MockLockerMockRecorder) Release 

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

Release indicates an expected call of Release.

func (*MockLockerMockRecorder) Renew 

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

Renew indicates an expected call of Renew.

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 MockMemberPager 

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

MockMemberPager is a mock of MemberPager interface.

func NewMockMemberPager 

func NewMockMemberPager(ctrl *gomock.Controller) *MockMemberPager

NewMockMemberPager creates a new mock instance.

func (*MockMemberPager) EXPECT 

func (m *MockMemberPager) EXPECT() *MockMemberPagerMockRecorder

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

func (*MockMemberPager) ListMemberPage 

func (m *MockMemberPager) ListMemberPage(ctx context.Context, orgExtID string, cursor *string) ([]auth0.RawMember, *string, error)

ListMemberPage mocks base method.

type MockMemberPagerMockRecorder 

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

MockMemberPagerMockRecorder is the mock recorder for MockMemberPager.

func (*MockMemberPagerMockRecorder) ListMemberPage 

func (mr *MockMemberPagerMockRecorder) ListMemberPage(ctx, orgExtID, cursor any) *gomock.Call

ListMemberPage indicates an expected call of ListMemberPage.

type MockMemberRoleLister 

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

MockMemberRoleLister is a mock of MemberRoleLister interface.

func NewMockMemberRoleLister 

func NewMockMemberRoleLister(ctrl *gomock.Controller) *MockMemberRoleLister

NewMockMemberRoleLister creates a new mock instance.

func (*MockMemberRoleLister) EXPECT 

func (m *MockMemberRoleLister) EXPECT() *MockMemberRoleListerMockRecorder

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

func (*MockMemberRoleLister) ListMemberRoles 

func (m *MockMemberRoleLister) ListMemberRoles(ctx context.Context, orgExtID, userSub string) ([]string, error)

ListMemberRoles mocks base method.

type MockMemberRoleListerMockRecorder 

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

MockMemberRoleListerMockRecorder is the mock recorder for MockMemberRoleLister.

func (*MockMemberRoleListerMockRecorder) ListMemberRoles 

func (mr *MockMemberRoleListerMockRecorder) ListMemberRoles(ctx, orgExtID, userSub any) *gomock.Call

ListMemberRoles indicates an expected call of ListMemberRoles.

type MockMessageConsumer 

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

MockMessageConsumer is a mock of MessageConsumer interface.

func NewMockMessageConsumer 

func NewMockMessageConsumer(ctrl *gomock.Controller) *MockMessageConsumer

NewMockMessageConsumer creates a new mock instance.

func (*MockMessageConsumer) Close 

func (m *MockMessageConsumer) Close() error

Close mocks base method.

func (*MockMessageConsumer) EXPECT 

func (m *MockMessageConsumer) EXPECT() *MockMessageConsumerMockRecorder

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

func (*MockMessageConsumer) Subscribe 

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

Subscribe mocks base method.

type MockMessageConsumerMockRecorder 

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

MockMessageConsumerMockRecorder is the mock recorder for MockMessageConsumer.

func (*MockMessageConsumerMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockMessageConsumerMockRecorder) Subscribe 

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

Subscribe indicates an expected call of Subscribe.

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 MockOrgPager 

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

MockOrgPager is a mock of OrgPager interface.

func NewMockOrgPager 

func NewMockOrgPager(ctrl *gomock.Controller) *MockOrgPager

NewMockOrgPager creates a new mock instance.

func (*MockOrgPager) EXPECT 

func (m *MockOrgPager) EXPECT() *MockOrgPagerMockRecorder

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

func (*MockOrgPager) ListOrgPage 

func (m *MockOrgPager) ListOrgPage(ctx context.Context, cursor *string) ([]auth0.RawOrg, *string, error)

ListOrgPage mocks base method.

type MockOrgPagerMockRecorder 

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

MockOrgPagerMockRecorder is the mock recorder for MockOrgPager.

func (*MockOrgPagerMockRecorder) ListOrgPage 

func (mr *MockOrgPagerMockRecorder) ListOrgPage(ctx, cursor any) *gomock.Call

ListOrgPage indicates an expected call of ListOrgPage.

type MockOrgProvider 

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

MockOrgProvider is a mock of OrgProvider interface.

func NewMockOrgProvider 

func NewMockOrgProvider(ctrl *gomock.Controller) *MockOrgProvider

NewMockOrgProvider creates a new mock instance.

func (*MockOrgProvider) CreateOrganization 

func (m *MockOrgProvider) CreateOrganization(ctx context.Context, org types.OrgWrite) (string, error)

CreateOrganization mocks base method.

func (*MockOrgProvider) DeleteInvitation 

func (m *MockOrgProvider) DeleteInvitation(ctx context.Context, orgExtID, invitationID string) error

DeleteInvitation mocks base method.

func (*MockOrgProvider) DeleteOrganization 

func (m *MockOrgProvider) DeleteOrganization(ctx context.Context, orgExtID string) error

DeleteOrganization mocks base method.

func (*MockOrgProvider) EXPECT 

func (m *MockOrgProvider) EXPECT() *MockOrgProviderMockRecorder

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

func (*MockOrgProvider) InviteMembers 

func (m *MockOrgProvider) InviteMembers(ctx context.Context, orgExtID string, invites []types.InviteInput) map[string]error

InviteMembers mocks base method.

func (*MockOrgProvider) ListInvitations 

func (m *MockOrgProvider) ListInvitations(ctx context.Context, orgExtID string) ([]types.Invitation, error)

ListInvitations mocks base method.

func (*MockOrgProvider) ListOrganizationMembers 

func (m *MockOrgProvider) ListOrganizationMembers(ctx context.Context, orgExtID string) ([]types.Member, error)

ListOrganizationMembers mocks base method.

func (*MockOrgProvider) ListOrganizations 

func (m *MockOrgProvider) ListOrganizations(ctx context.Context) ([]types.Organization, error)

ListOrganizations mocks base method.

func (*MockOrgProvider) RemoveOrganizationMember 

func (m *MockOrgProvider) RemoveOrganizationMember(ctx context.Context, orgExtID, userExtID string) error

RemoveOrganizationMember mocks base method.

func (*MockOrgProvider) UpdateOrganization 

func (m *MockOrgProvider) UpdateOrganization(ctx context.Context, org types.OrgWrite) error

UpdateOrganization mocks base method.

type MockOrgProviderMockRecorder 

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

MockOrgProviderMockRecorder is the mock recorder for MockOrgProvider.

func (*MockOrgProviderMockRecorder) CreateOrganization 

func (mr *MockOrgProviderMockRecorder) CreateOrganization(ctx, org any) *gomock.Call

CreateOrganization indicates an expected call of CreateOrganization.

func (*MockOrgProviderMockRecorder) DeleteInvitation 

func (mr *MockOrgProviderMockRecorder) DeleteInvitation(ctx, orgExtID, invitationID any) *gomock.Call

DeleteInvitation indicates an expected call of DeleteInvitation.

func (*MockOrgProviderMockRecorder) DeleteOrganization 

func (mr *MockOrgProviderMockRecorder) DeleteOrganization(ctx, orgExtID any) *gomock.Call

DeleteOrganization indicates an expected call of DeleteOrganization.

func (*MockOrgProviderMockRecorder) InviteMembers 

func (mr *MockOrgProviderMockRecorder) InviteMembers(ctx, orgExtID, invites any) *gomock.Call

InviteMembers indicates an expected call of InviteMembers.

func (*MockOrgProviderMockRecorder) ListInvitations 

func (mr *MockOrgProviderMockRecorder) ListInvitations(ctx, orgExtID any) *gomock.Call

ListInvitations indicates an expected call of ListInvitations.

func (*MockOrgProviderMockRecorder) ListOrganizationMembers 

func (mr *MockOrgProviderMockRecorder) ListOrganizationMembers(ctx, orgExtID any) *gomock.Call

ListOrganizationMembers indicates an expected call of ListOrganizationMembers.

func (*MockOrgProviderMockRecorder) ListOrganizations 

func (mr *MockOrgProviderMockRecorder) ListOrganizations(ctx any) *gomock.Call

ListOrganizations indicates an expected call of ListOrganizations.

func (*MockOrgProviderMockRecorder) RemoveOrganizationMember 

func (mr *MockOrgProviderMockRecorder) RemoveOrganizationMember(ctx, orgExtID, userExtID any) *gomock.Call

RemoveOrganizationMember indicates an expected call of RemoveOrganizationMember.

func (*MockOrgProviderMockRecorder) UpdateOrganization 

func (mr *MockOrgProviderMockRecorder) UpdateOrganization(ctx, org any) *gomock.Call

UpdateOrganization indicates an expected call of UpdateOrganization.

type MockOrgWriter 

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

MockOrgWriter is a mock of OrgWriter interface.

func NewMockOrgWriter 

func NewMockOrgWriter(ctrl *gomock.Controller) *MockOrgWriter

NewMockOrgWriter creates a new mock instance.

func (*MockOrgWriter) CreateOrg 

func (m *MockOrgWriter) CreateOrg(ctx context.Context, org types.OrgWrite) (string, error)

CreateOrg mocks base method.

func (*MockOrgWriter) DeleteOrg 

func (m *MockOrgWriter) DeleteOrg(ctx context.Context, orgExtID string) error

DeleteOrg mocks base method.

func (*MockOrgWriter) EXPECT 

func (m *MockOrgWriter) EXPECT() *MockOrgWriterMockRecorder

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

func (*MockOrgWriter) UpdateOrg 

func (m *MockOrgWriter) UpdateOrg(ctx context.Context, org types.OrgWrite) error

UpdateOrg mocks base method.

type MockOrgWriterMockRecorder 

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

MockOrgWriterMockRecorder is the mock recorder for MockOrgWriter.

func (*MockOrgWriterMockRecorder) CreateOrg 

func (mr *MockOrgWriterMockRecorder) CreateOrg(ctx, org any) *gomock.Call

CreateOrg indicates an expected call of CreateOrg.

func (*MockOrgWriterMockRecorder) DeleteOrg 

func (mr *MockOrgWriterMockRecorder) DeleteOrg(ctx, orgExtID any) *gomock.Call

DeleteOrg indicates an expected call of DeleteOrg.

func (*MockOrgWriterMockRecorder) UpdateOrg 

func (mr *MockOrgWriterMockRecorder) UpdateOrg(ctx, org any) *gomock.Call

UpdateOrg indicates an expected call of UpdateOrg.

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 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 MockRepository 

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

MockRepository is a mock of Repository interface.

func NewMockRepository 

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

NewMockRepository creates a new mock instance.

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

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

Create mocks base method.

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

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

Delete mocks base method.

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

func (m *MockRepository[T, P, ID]) EXPECT() *MockRepositoryMockRecorder[T, P, ID]

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

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

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

Exists mocks base method.

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

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

Get mocks base method.

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

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

List mocks base method.

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

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

Update mocks base method.

type MockRepositoryMockRecorder 

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

MockRepositoryMockRecorder is the mock recorder for MockRepository.

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

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

Create indicates an expected call of Create.

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

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

Delete indicates an expected call of Delete.

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

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

Exists indicates an expected call of Exists.

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

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

Get indicates an expected call of Get.

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

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

List indicates an expected call of List.

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

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

Update indicates an expected call of Update.

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 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 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 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 MockTransaction 

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

MockTransaction is a mock of Transaction interface.

func NewMockTransaction 

func NewMockTransaction(ctrl *gomock.Controller) *MockTransaction

NewMockTransaction creates a new mock instance.

func (*MockTransaction) Commit 

func (m *MockTransaction) Commit() error

Commit mocks base method.

func (*MockTransaction) EXPECT 

func (m *MockTransaction) EXPECT() *MockTransactionMockRecorder

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

func (*MockTransaction) Rollback 

func (m *MockTransaction) Rollback() error

Rollback mocks base method.

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 MockTransactionMockRecorder 

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

MockTransactionMockRecorder is the mock recorder for MockTransaction.

func (*MockTransactionMockRecorder) Commit 

func (mr *MockTransactionMockRecorder) Commit() *gomock.Call

Commit indicates an expected call of Commit.

func (*MockTransactionMockRecorder) Rollback 

func (mr *MockTransactionMockRecorder) Rollback() *gomock.Call

Rollback indicates an expected call of Rollback.

type MockUserProvider 

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

MockUserProvider is a mock of UserProvider interface.

func NewMockUserProvider 

func NewMockUserProvider(ctrl *gomock.Controller) *MockUserProvider

NewMockUserProvider creates a new mock instance.

func (*MockUserProvider) CreateOrganization 

func (m *MockUserProvider) CreateOrganization(ctx context.Context, org types.OrgWrite) (string, error)

CreateOrganization mocks base method.

func (*MockUserProvider) CreateUser 

func (m *MockUserProvider) CreateUser(ctx context.Context, spec types.UserCreate) (string, error)

CreateUser mocks base method.

func (*MockUserProvider) DeleteInvitation 

func (m *MockUserProvider) DeleteInvitation(ctx context.Context, orgExtID, invitationID string) error

DeleteInvitation mocks base method.

func (*MockUserProvider) DeleteOrganization 

func (m *MockUserProvider) DeleteOrganization(ctx context.Context, orgExtID string) error

DeleteOrganization mocks base method.

func (*MockUserProvider) EXPECT 

func (m *MockUserProvider) EXPECT() *MockUserProviderMockRecorder

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

func (*MockUserProvider) InviteMembers 

func (m *MockUserProvider) InviteMembers(ctx context.Context, orgExtID string, invites []types.InviteInput) map[string]error

InviteMembers mocks base method.

func (*MockUserProvider) ListInvitations 

func (m *MockUserProvider) ListInvitations(ctx context.Context, orgExtID string) ([]types.Invitation, error)

ListInvitations mocks base method.

func (*MockUserProvider) ListOrganizationMembers 

func (m *MockUserProvider) ListOrganizationMembers(ctx context.Context, orgExtID string) ([]types.Member, error)

ListOrganizationMembers mocks base method.

func (*MockUserProvider) ListOrganizations 

func (m *MockUserProvider) ListOrganizations(ctx context.Context) ([]types.Organization, error)

ListOrganizations mocks base method.

func (*MockUserProvider) RemoveOrganizationMember 

func (m *MockUserProvider) RemoveOrganizationMember(ctx context.Context, orgExtID, userExtID string) error

RemoveOrganizationMember mocks base method.

func (*MockUserProvider) UpdateOrganization 

func (m *MockUserProvider) UpdateOrganization(ctx context.Context, org types.OrgWrite) error

UpdateOrganization mocks base method.

type MockUserProviderMockRecorder 

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

MockUserProviderMockRecorder is the mock recorder for MockUserProvider.

func (*MockUserProviderMockRecorder) CreateOrganization 

func (mr *MockUserProviderMockRecorder) CreateOrganization(ctx, org any) *gomock.Call

CreateOrganization indicates an expected call of CreateOrganization.

func (*MockUserProviderMockRecorder) CreateUser 

func (mr *MockUserProviderMockRecorder) CreateUser(ctx, spec any) *gomock.Call

CreateUser indicates an expected call of CreateUser.

func (*MockUserProviderMockRecorder) DeleteInvitation 

func (mr *MockUserProviderMockRecorder) DeleteInvitation(ctx, orgExtID, invitationID any) *gomock.Call

DeleteInvitation indicates an expected call of DeleteInvitation.

func (*MockUserProviderMockRecorder) DeleteOrganization 

func (mr *MockUserProviderMockRecorder) DeleteOrganization(ctx, orgExtID any) *gomock.Call

DeleteOrganization indicates an expected call of DeleteOrganization.

func (*MockUserProviderMockRecorder) InviteMembers 

func (mr *MockUserProviderMockRecorder) InviteMembers(ctx, orgExtID, invites any) *gomock.Call

InviteMembers indicates an expected call of InviteMembers.

func (*MockUserProviderMockRecorder) ListInvitations 

func (mr *MockUserProviderMockRecorder) ListInvitations(ctx, orgExtID any) *gomock.Call

ListInvitations indicates an expected call of ListInvitations.

func (*MockUserProviderMockRecorder) ListOrganizationMembers 

func (mr *MockUserProviderMockRecorder) ListOrganizationMembers(ctx, orgExtID any) *gomock.Call

ListOrganizationMembers indicates an expected call of ListOrganizationMembers.

func (*MockUserProviderMockRecorder) ListOrganizations 

func (mr *MockUserProviderMockRecorder) ListOrganizations(ctx any) *gomock.Call

ListOrganizations indicates an expected call of ListOrganizations.

func (*MockUserProviderMockRecorder) RemoveOrganizationMember 

func (mr *MockUserProviderMockRecorder) RemoveOrganizationMember(ctx, orgExtID, userExtID any) *gomock.Call

RemoveOrganizationMember indicates an expected call of RemoveOrganizationMember.

func (*MockUserProviderMockRecorder) UpdateOrganization 

func (mr *MockUserProviderMockRecorder) UpdateOrganization(ctx, org any) *gomock.Call

UpdateOrganization indicates an expected call of UpdateOrganization.

type MockUserProvisioner 

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

MockUserProvisioner is a mock of UserProvisioner interface.

func NewMockUserProvisioner 

func NewMockUserProvisioner(ctrl *gomock.Controller) *MockUserProvisioner

NewMockUserProvisioner creates a new mock instance.

func (*MockUserProvisioner) AssignRoles 

func (m *MockUserProvisioner) AssignRoles(ctx context.Context, userID string, roleIDs []string) error

AssignRoles mocks base method.

func (*MockUserProvisioner) CreateUser 

func (m *MockUserProvisioner) CreateUser(ctx context.Context, spec types.UserCreate) (string, error)

CreateUser mocks base method.

func (*MockUserProvisioner) EXPECT 

func (m *MockUserProvisioner) EXPECT() *MockUserProvisionerMockRecorder

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

func (*MockUserProvisioner) UserIDByEmail 

func (m *MockUserProvisioner) UserIDByEmail(ctx context.Context, email string) (string, error)

UserIDByEmail mocks base method.

type MockUserProvisionerMockRecorder 

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

MockUserProvisionerMockRecorder is the mock recorder for MockUserProvisioner.

func (*MockUserProvisionerMockRecorder) AssignRoles 

func (mr *MockUserProvisionerMockRecorder) AssignRoles(ctx, userID, roleIDs any) *gomock.Call

AssignRoles indicates an expected call of AssignRoles.

func (*MockUserProvisionerMockRecorder) CreateUser 

func (mr *MockUserProvisionerMockRecorder) CreateUser(ctx, spec any) *gomock.Call

CreateUser indicates an expected call of CreateUser.

func (*MockUserProvisionerMockRecorder) UserIDByEmail 

func (mr *MockUserProvisionerMockRecorder) UserIDByEmail(ctx, email any) *gomock.Call

UserIDByEmail indicates an expected call of UserIDByEmail.

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 MockWorkerRegistry 

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

MockWorkerRegistry is a mock of WorkerRegistry interface.

func NewMockWorkerRegistry 

func NewMockWorkerRegistry(ctrl *gomock.Controller) *MockWorkerRegistry

NewMockWorkerRegistry creates a new mock instance.

func (*MockWorkerRegistry) EXPECT 

func (m *MockWorkerRegistry) EXPECT() *MockWorkerRegistryMockRecorder

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

func (*MockWorkerRegistry) Get 

func (m *MockWorkerRegistry) Get(kind string) (interfaces.Worker, bool)

Get mocks base method.

func (*MockWorkerRegistry) Register 

func (m *MockWorkerRegistry) Register(kind string, worker interfaces.Worker)

Register mocks base method.

type MockWorkerRegistryMockRecorder 

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

MockWorkerRegistryMockRecorder is the mock recorder for MockWorkerRegistry.

func (*MockWorkerRegistryMockRecorder) Get 

func (mr *MockWorkerRegistryMockRecorder) Get(kind any) *gomock.Call

Get indicates an expected call of Get.

func (*MockWorkerRegistryMockRecorder) Register 

func (mr *MockWorkerRegistryMockRecorder) Register(kind, worker any) *gomock.Call

Register indicates an expected call of Register.

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.