mocks

package
v0.0.39 Latest Latest
Warning

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

 Go to latest Published: Nov 1, 2026 License: MIT Imports: 24 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockAPI 

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

MockAPI is a mock of API interface.

func NewMockAPI 

func NewMockAPI(ctrl *gomock.Controller) *MockAPI

NewMockAPI creates a new mock instance.

func (*MockAPI) ChangeMessageVisibility 

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

ChangeMessageVisibility mocks base method.

func (*MockAPI) CreateQueue 

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

CreateQueue mocks base method.

func (*MockAPI) DeleteMessage 

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

DeleteMessage mocks base method.

func (*MockAPI) DeleteMessageBatch 

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

DeleteMessageBatch mocks base method.

func (*MockAPI) EXPECT 

func (m *MockAPI) EXPECT() *MockAPIMockRecorder

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

func (*MockAPI) GetQueueUrl 

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

GetQueueUrl mocks base method.

func (*MockAPI) ReceiveMessage 

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

ReceiveMessage mocks base method.

func (*MockAPI) SendMessage 

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

SendMessage mocks base method.

func (*MockAPI) SendMessageBatch 

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

SendMessageBatch mocks base method.

type MockAPIMockRecorder 

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

MockAPIMockRecorder is the mock recorder for MockAPI.

func (*MockAPIMockRecorder) ChangeMessageVisibility 

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

ChangeMessageVisibility indicates an expected call of ChangeMessageVisibility.

func (*MockAPIMockRecorder) CreateQueue 

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

CreateQueue indicates an expected call of CreateQueue.

func (*MockAPIMockRecorder) DeleteMessage 

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

DeleteMessage indicates an expected call of DeleteMessage.

func (*MockAPIMockRecorder) DeleteMessageBatch 

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

DeleteMessageBatch indicates an expected call of DeleteMessageBatch.

func (*MockAPIMockRecorder) GetQueueUrl 

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

GetQueueUrl indicates an expected call of GetQueueUrl.

func (*MockAPIMockRecorder) ReceiveMessage 

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

ReceiveMessage indicates an expected call of ReceiveMessage.

func (*MockAPIMockRecorder) SendMessage 

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

SendMessage indicates an expected call of SendMessage.

func (*MockAPIMockRecorder) SendMessageBatch 

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

SendMessageBatch indicates an expected call of SendMessageBatch.

type MockAWSBedrockAPI added in v0.0.17 

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

MockAWSBedrockAPI is a mock of API interface.

func NewMockAWSBedrockAPI added in v0.0.17 

func NewMockAWSBedrockAPI(ctrl *gomock.Controller) *MockAWSBedrockAPI

NewMockAWSBedrockAPI creates a new mock instance.

func (*MockAWSBedrockAPI) Converse added in v0.0.17 

func (m *MockAWSBedrockAPI) Converse(ctx context.Context, in *bedrockruntime.ConverseInput, optFns ...func(*bedrockruntime.Options)) (*bedrockruntime.ConverseOutput, error)

Converse mocks base method.

func (*MockAWSBedrockAPI) EXPECT added in v0.0.17 

func (m *MockAWSBedrockAPI) EXPECT() *MockAWSBedrockAPIMockRecorder

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

type MockAWSBedrockAPIMockRecorder added in v0.0.17 

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

MockAWSBedrockAPIMockRecorder is the mock recorder for MockAWSBedrockAPI.

func (*MockAWSBedrockAPIMockRecorder) Converse added in v0.0.17 

func (mr *MockAWSBedrockAPIMockRecorder) Converse(ctx, in any, optFns ...any) *gomock.Call

Converse indicates an expected call of Converse.

type MockAWSIAMAPI added in v0.0.17 

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

MockAWSIAMAPI is a mock of API interface.

func NewMockAWSIAMAPI added in v0.0.17 

func NewMockAWSIAMAPI(ctrl *gomock.Controller) *MockAWSIAMAPI

NewMockAWSIAMAPI creates a new mock instance.

func (*MockAWSIAMAPI) EXPECT added in v0.0.17 

func (m *MockAWSIAMAPI) EXPECT() *MockAWSIAMAPIMockRecorder

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

func (*MockAWSIAMAPI) SimulatePrincipalPolicy added in v0.0.17 

func (m *MockAWSIAMAPI) SimulatePrincipalPolicy(ctx context.Context, in *iam.SimulatePrincipalPolicyInput, optFns ...func(*iam.Options)) (*iam.SimulatePrincipalPolicyOutput, error)

SimulatePrincipalPolicy mocks base method.

type MockAWSIAMAPIMockRecorder added in v0.0.17 

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

MockAWSIAMAPIMockRecorder is the mock recorder for MockAWSIAMAPI.

func (*MockAWSIAMAPIMockRecorder) SimulatePrincipalPolicy added in v0.0.17 

func (mr *MockAWSIAMAPIMockRecorder) SimulatePrincipalPolicy(ctx, in any, optFns ...any) *gomock.Call

SimulatePrincipalPolicy indicates an expected call of SimulatePrincipalPolicy.

type MockAWSRoute53API added in v0.0.17 

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

MockAWSRoute53API is a mock of API interface.

func NewMockAWSRoute53API added in v0.0.17 

func NewMockAWSRoute53API(ctrl *gomock.Controller) *MockAWSRoute53API

NewMockAWSRoute53API creates a new mock instance.

func (*MockAWSRoute53API) EXPECT added in v0.0.17 

func (m *MockAWSRoute53API) EXPECT() *MockAWSRoute53APIMockRecorder

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

func (*MockAWSRoute53API) ListHostedZonesByName added in v0.0.17 

func (m *MockAWSRoute53API) ListHostedZonesByName(ctx context.Context, in *route53.ListHostedZonesByNameInput, optFns ...func(*route53.Options)) (*route53.ListHostedZonesByNameOutput, error)

ListHostedZonesByName mocks base method.

type MockAWSRoute53APIMockRecorder added in v0.0.17 

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

MockAWSRoute53APIMockRecorder is the mock recorder for MockAWSRoute53API.

func (*MockAWSRoute53APIMockRecorder) ListHostedZonesByName added in v0.0.17 

func (mr *MockAWSRoute53APIMockRecorder) ListHostedZonesByName(ctx, in any, optFns ...any) *gomock.Call

ListHostedZonesByName indicates an expected call of ListHostedZonesByName.

type MockAWSSESAPI added in v0.0.17 

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

MockAWSSESAPI is a mock of API interface.

func NewMockAWSSESAPI added in v0.0.17 

func NewMockAWSSESAPI(ctrl *gomock.Controller) *MockAWSSESAPI

NewMockAWSSESAPI creates a new mock instance.

func (*MockAWSSESAPI) EXPECT added in v0.0.17 

func (m *MockAWSSESAPI) EXPECT() *MockAWSSESAPIMockRecorder

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

func (*MockAWSSESAPI) GetAccount added in v0.0.17 

func (m *MockAWSSESAPI) GetAccount(ctx context.Context, in *sesv2.GetAccountInput, optFns ...func(*sesv2.Options)) (*sesv2.GetAccountOutput, error)

GetAccount mocks base method.

type MockAWSSESAPIMockRecorder added in v0.0.17 

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

MockAWSSESAPIMockRecorder is the mock recorder for MockAWSSESAPI.

func (*MockAWSSESAPIMockRecorder) GetAccount added in v0.0.17 

func (mr *MockAWSSESAPIMockRecorder) GetAccount(ctx, in any, optFns ...any) *gomock.Call

GetAccount indicates an expected call of GetAccount.

type MockAWSSTSAPI added in v0.0.17 

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

MockAWSSTSAPI is a mock of API interface.

func NewMockAWSSTSAPI added in v0.0.17 

func NewMockAWSSTSAPI(ctrl *gomock.Controller) *MockAWSSTSAPI

NewMockAWSSTSAPI creates a new mock instance.

func (*MockAWSSTSAPI) EXPECT added in v0.0.17 

func (m *MockAWSSTSAPI) EXPECT() *MockAWSSTSAPIMockRecorder

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

func (*MockAWSSTSAPI) GetCallerIdentity added in v0.0.17 

func (m *MockAWSSTSAPI) GetCallerIdentity(ctx context.Context, in *sts.GetCallerIdentityInput, optFns ...func(*sts.Options)) (*sts.GetCallerIdentityOutput, error)

GetCallerIdentity mocks base method.

type MockAWSSTSAPIMockRecorder added in v0.0.17 

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

MockAWSSTSAPIMockRecorder is the mock recorder for MockAWSSTSAPI.

func (*MockAWSSTSAPIMockRecorder) GetCallerIdentity added in v0.0.17 

func (mr *MockAWSSTSAPIMockRecorder) GetCallerIdentity(ctx, in any, optFns ...any) *gomock.Call

GetCallerIdentity indicates an expected call of GetCallerIdentity.

type MockAWSSecretsManagerAPI added in v0.0.17 

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

MockAWSSecretsManagerAPI is a mock of API interface.

func NewMockAWSSecretsManagerAPI added in v0.0.17 

func NewMockAWSSecretsManagerAPI(ctrl *gomock.Controller) *MockAWSSecretsManagerAPI

NewMockAWSSecretsManagerAPI creates a new mock instance.

func (*MockAWSSecretsManagerAPI) DescribeSecret added in v0.0.17 

func (m *MockAWSSecretsManagerAPI) DescribeSecret(ctx context.Context, in *secretsmanager.DescribeSecretInput, optFns ...func(*secretsmanager.Options)) (*secretsmanager.DescribeSecretOutput, error)

DescribeSecret mocks base method.

func (*MockAWSSecretsManagerAPI) EXPECT added in v0.0.17 

func (m *MockAWSSecretsManagerAPI) EXPECT() *MockAWSSecretsManagerAPIMockRecorder

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

func (*MockAWSSecretsManagerAPI) GetSecretValue added in v0.0.17 

func (m *MockAWSSecretsManagerAPI) GetSecretValue(ctx context.Context, in *secretsmanager.GetSecretValueInput, optFns ...func(*secretsmanager.Options)) (*secretsmanager.GetSecretValueOutput, error)

GetSecretValue mocks base method.

func (*MockAWSSecretsManagerAPI) ListSecrets added in v0.0.17 

func (m *MockAWSSecretsManagerAPI) ListSecrets(ctx context.Context, in *secretsmanager.ListSecretsInput, optFns ...func(*secretsmanager.Options)) (*secretsmanager.ListSecretsOutput, error)

ListSecrets mocks base method.

func (*MockAWSSecretsManagerAPI) PutSecretValue added in v0.0.17 

func (m *MockAWSSecretsManagerAPI) PutSecretValue(ctx context.Context, in *secretsmanager.PutSecretValueInput, optFns ...func(*secretsmanager.Options)) (*secretsmanager.PutSecretValueOutput, error)

PutSecretValue mocks base method.

type MockAWSSecretsManagerAPIMockRecorder added in v0.0.17 

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

MockAWSSecretsManagerAPIMockRecorder is the mock recorder for MockAWSSecretsManagerAPI.

func (*MockAWSSecretsManagerAPIMockRecorder) DescribeSecret added in v0.0.17 

func (mr *MockAWSSecretsManagerAPIMockRecorder) DescribeSecret(ctx, in any, optFns ...any) *gomock.Call

DescribeSecret indicates an expected call of DescribeSecret.

func (*MockAWSSecretsManagerAPIMockRecorder) GetSecretValue added in v0.0.17 

func (mr *MockAWSSecretsManagerAPIMockRecorder) GetSecretValue(ctx, in any, optFns ...any) *gomock.Call

GetSecretValue indicates an expected call of GetSecretValue.

func (*MockAWSSecretsManagerAPIMockRecorder) ListSecrets added in v0.0.17 

func (mr *MockAWSSecretsManagerAPIMockRecorder) ListSecrets(ctx, in any, optFns ...any) *gomock.Call

ListSecrets indicates an expected call of ListSecrets.

func (*MockAWSSecretsManagerAPIMockRecorder) PutSecretValue added in v0.0.17 

func (mr *MockAWSSecretsManagerAPIMockRecorder) PutSecretValue(ctx, in any, optFns ...any) *gomock.Call

PutSecretValue indicates an expected call of PutSecretValue.

type MockAWSServiceQuotasAPI added in v0.0.17 

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

MockAWSServiceQuotasAPI is a mock of API interface.

func NewMockAWSServiceQuotasAPI added in v0.0.17 

func NewMockAWSServiceQuotasAPI(ctrl *gomock.Controller) *MockAWSServiceQuotasAPI

NewMockAWSServiceQuotasAPI creates a new mock instance.

func (*MockAWSServiceQuotasAPI) EXPECT added in v0.0.17 

func (m *MockAWSServiceQuotasAPI) EXPECT() *MockAWSServiceQuotasAPIMockRecorder

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

func (*MockAWSServiceQuotasAPI) GetServiceQuota added in v0.0.17 

func (m *MockAWSServiceQuotasAPI) GetServiceQuota(ctx context.Context, in *servicequotas.GetServiceQuotaInput, optFns ...func(*servicequotas.Options)) (*servicequotas.GetServiceQuotaOutput, error)

GetServiceQuota mocks base method.

type MockAWSServiceQuotasAPIMockRecorder added in v0.0.17 

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

MockAWSServiceQuotasAPIMockRecorder is the mock recorder for MockAWSServiceQuotasAPI.

func (*MockAWSServiceQuotasAPIMockRecorder) GetServiceQuota added in v0.0.17 

func (mr *MockAWSServiceQuotasAPIMockRecorder) GetServiceQuota(ctx, in any, optFns ...any) *gomock.Call

GetServiceQuota indicates an expected call of GetServiceQuota.

type MockAnalyticsCompactor 

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

MockAnalyticsCompactor is a mock of AnalyticsCompactor interface.

func NewMockAnalyticsCompactor 

func NewMockAnalyticsCompactor(ctrl *gomock.Controller) *MockAnalyticsCompactor

NewMockAnalyticsCompactor creates a new mock instance.

func (*MockAnalyticsCompactor) Compact 

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

Compact mocks base method.

func (*MockAnalyticsCompactor) EXPECT 

func (m *MockAnalyticsCompactor) EXPECT() *MockAnalyticsCompactorMockRecorder

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

type MockAnalyticsCompactorMockRecorder 

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

MockAnalyticsCompactorMockRecorder is the mock recorder for MockAnalyticsCompactor.

func (*MockAnalyticsCompactorMockRecorder) Compact 

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

Compact indicates an expected call of Compact.

type MockAnalyticsStore 

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

MockAnalyticsStore is a mock of AnalyticsStore interface.

func NewMockAnalyticsStore 

func NewMockAnalyticsStore(ctrl *gomock.Controller) *MockAnalyticsStore

NewMockAnalyticsStore creates a new mock instance.

func (*MockAnalyticsStore) Aggregate 

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

Aggregate mocks base method.

func (*MockAnalyticsStore) EXPECT 

func (m *MockAnalyticsStore) EXPECT() *MockAnalyticsStoreMockRecorder

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

func (*MockAnalyticsStore) Liveness added in v0.0.6 

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

Liveness mocks base method.

func (*MockAnalyticsStore) Readiness added in v0.0.6 

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

Readiness mocks base method.

func (*MockAnalyticsStore) Start 

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

Start mocks base method.

func (*MockAnalyticsStore) Stop 

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

Stop mocks base method.

func (*MockAnalyticsStore) Write 

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

Write mocks base method.

type MockAnalyticsStoreMockRecorder 

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

MockAnalyticsStoreMockRecorder is the mock recorder for MockAnalyticsStore.

func (*MockAnalyticsStoreMockRecorder) Aggregate 

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

Aggregate indicates an expected call of Aggregate.

func (*MockAnalyticsStoreMockRecorder) Liveness added in v0.0.6 

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

Liveness indicates an expected call of Liveness.

func (*MockAnalyticsStoreMockRecorder) Readiness added in v0.0.6 

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

Readiness indicates an expected call of Readiness.

func (*MockAnalyticsStoreMockRecorder) Start 

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

Start indicates an expected call of Start.

func (*MockAnalyticsStoreMockRecorder) Stop 

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

Stop indicates an expected call of Stop.

func (*MockAnalyticsStoreMockRecorder) Write 

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

Write indicates an expected call of Write.

type MockAnyJob 

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

MockAnyJob is a mock of AnyJob interface.

func NewMockAnyJob 

func NewMockAnyJob(ctrl *gomock.Controller) *MockAnyJob

NewMockAnyJob creates a new mock instance.

func (*MockAnyJob) EXPECT 

func (m *MockAnyJob) EXPECT() *MockAnyJobMockRecorder

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

func (*MockAnyJob) Execute 

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

Execute mocks base method.

func (*MockAnyJob) Meta 

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

Meta mocks base method.

type MockAnyJobMockRecorder 

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

MockAnyJobMockRecorder is the mock recorder for MockAnyJob.

func (*MockAnyJobMockRecorder) Execute 

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

Execute indicates an expected call of Execute.

func (*MockAnyJobMockRecorder) Meta 

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

Meta indicates an expected call of Meta.

type MockAssumeRoleAPIClient 

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

MockAssumeRoleAPIClient is a mock of AssumeRoleAPIClient interface.

func NewMockAssumeRoleAPIClient 

func NewMockAssumeRoleAPIClient(ctrl *gomock.Controller) *MockAssumeRoleAPIClient

NewMockAssumeRoleAPIClient creates a new mock instance.

func (*MockAssumeRoleAPIClient) AssumeRole 

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

AssumeRole mocks base method.

func (*MockAssumeRoleAPIClient) EXPECT 

func (m *MockAssumeRoleAPIClient) EXPECT() *MockAssumeRoleAPIClientMockRecorder

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

type MockAssumeRoleAPIClientMockRecorder 

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

MockAssumeRoleAPIClientMockRecorder is the mock recorder for MockAssumeRoleAPIClient.

func (*MockAssumeRoleAPIClientMockRecorder) AssumeRole 

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

AssumeRole indicates an expected call of AssumeRole.

type MockAuth0Management added in v0.0.22 

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

MockAuth0Management is a mock of Auth0Management interface.

func NewMockAuth0Management added in v0.0.22 

func NewMockAuth0Management(ctrl *gomock.Controller) *MockAuth0Management

NewMockAuth0Management creates a new mock instance.

func (*MockAuth0Management) EXPECT added in v0.0.22 

func (m *MockAuth0Management) EXPECT() *MockAuth0ManagementMockRecorder

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

func (*MockAuth0Management) OrganizationID added in v0.0.22 

func (m *MockAuth0Management) OrganizationID(ctx context.Context, name string) (string, error)

OrganizationID mocks base method.

func (*MockAuth0Management) OrganizationIDs added in v0.0.22 

func (m *MockAuth0Management) OrganizationIDs(ctx context.Context) ([]string, error)

OrganizationIDs mocks base method.

func (*MockAuth0Management) SigningKey added in v0.0.22 

func (m *MockAuth0Management) SigningKey(ctx context.Context) (types.SigningKey, error)

SigningKey mocks base method.

type MockAuth0ManagementMockRecorder added in v0.0.22 

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

MockAuth0ManagementMockRecorder is the mock recorder for MockAuth0Management.

func (*MockAuth0ManagementMockRecorder) OrganizationID added in v0.0.22 

func (mr *MockAuth0ManagementMockRecorder) OrganizationID(ctx, name any) *gomock.Call

OrganizationID indicates an expected call of OrganizationID.

func (*MockAuth0ManagementMockRecorder) OrganizationIDs added in v0.0.22 

func (mr *MockAuth0ManagementMockRecorder) OrganizationIDs(ctx any) *gomock.Call

OrganizationIDs indicates an expected call of OrganizationIDs.

func (*MockAuth0ManagementMockRecorder) SigningKey added in v0.0.22 

func (mr *MockAuth0ManagementMockRecorder) SigningKey(ctx any) *gomock.Call

SigningKey indicates an expected call of SigningKey.

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 MockCQLBatch added in v0.0.7 

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

MockCQLBatch is a mock of CQLBatch interface.

func NewMockCQLBatch added in v0.0.7 

func NewMockCQLBatch(ctrl *gomock.Controller) *MockCQLBatch

NewMockCQLBatch creates a new mock instance.

func (*MockCQLBatch) EXPECT added in v0.0.7 

func (m *MockCQLBatch) EXPECT() *MockCQLBatchMockRecorder

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

func (*MockCQLBatch) Query added in v0.0.7 

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

Query mocks base method.

func (*MockCQLBatch) Size added in v0.0.7 

func (m *MockCQLBatch) Size() int

Size mocks base method.

func (*MockCQLBatch) WithContext added in v0.0.7 

func (m *MockCQLBatch) WithContext(ctx context.Context) interfaces.CQLBatch

WithContext mocks base method.

type MockCQLBatchMockRecorder added in v0.0.7 

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

MockCQLBatchMockRecorder is the mock recorder for MockCQLBatch.

func (*MockCQLBatchMockRecorder) Query added in v0.0.7 

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

Query indicates an expected call of Query.

func (*MockCQLBatchMockRecorder) Size added in v0.0.7 

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

Size indicates an expected call of Size.

func (*MockCQLBatchMockRecorder) WithContext added in v0.0.7 

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

WithContext indicates an expected call of WithContext.

type MockCQLIter added in v0.0.7 

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

MockCQLIter is a mock of CQLIter interface.

func NewMockCQLIter added in v0.0.7 

func NewMockCQLIter(ctrl *gomock.Controller) *MockCQLIter

NewMockCQLIter creates a new mock instance.

func (*MockCQLIter) Close added in v0.0.7 

func (m *MockCQLIter) Close() error

Close mocks base method.

func (*MockCQLIter) EXPECT added in v0.0.7 

func (m *MockCQLIter) EXPECT() *MockCQLIterMockRecorder

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

func (*MockCQLIter) PageState added in v0.0.7 

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

PageState mocks base method.

func (*MockCQLIter) Scan added in v0.0.7 

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

Scan mocks base method.

type MockCQLIterMockRecorder added in v0.0.7 

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

MockCQLIterMockRecorder is the mock recorder for MockCQLIter.

func (*MockCQLIterMockRecorder) Close added in v0.0.7 

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

Close indicates an expected call of Close.

func (*MockCQLIterMockRecorder) PageState added in v0.0.7 

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

PageState indicates an expected call of PageState.

func (*MockCQLIterMockRecorder) Scan added in v0.0.7 

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

Scan indicates an expected call of Scan.

type MockCQLQuery added in v0.0.7 

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

MockCQLQuery is a mock of CQLQuery interface.

func NewMockCQLQuery added in v0.0.7 

func NewMockCQLQuery(ctrl *gomock.Controller) *MockCQLQuery

NewMockCQLQuery creates a new mock instance.

func (*MockCQLQuery) EXPECT added in v0.0.7 

func (m *MockCQLQuery) EXPECT() *MockCQLQueryMockRecorder

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

func (*MockCQLQuery) Exec added in v0.0.7 

func (m *MockCQLQuery) Exec() error

Exec mocks base method.

func (*MockCQLQuery) Idempotent added in v0.0.7 

func (m *MockCQLQuery) Idempotent(idempotent bool) interfaces.CQLQuery

Idempotent mocks base method.

func (*MockCQLQuery) Iter added in v0.0.7 

func (m *MockCQLQuery) Iter() interfaces.CQLIter

Iter mocks base method.

func (*MockCQLQuery) PageSize added in v0.0.7 

func (m *MockCQLQuery) PageSize(n int) interfaces.CQLQuery

PageSize mocks base method.

func (*MockCQLQuery) PageState added in v0.0.7 

func (m *MockCQLQuery) PageState(state []byte) interfaces.CQLQuery

PageState mocks base method.

func (*MockCQLQuery) WithContext added in v0.0.7 

func (m *MockCQLQuery) WithContext(ctx context.Context) interfaces.CQLQuery

WithContext mocks base method.

type MockCQLQueryMockRecorder added in v0.0.7 

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

MockCQLQueryMockRecorder is the mock recorder for MockCQLQuery.

func (*MockCQLQueryMockRecorder) Exec added in v0.0.7 

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

Exec indicates an expected call of Exec.

func (*MockCQLQueryMockRecorder) Idempotent added in v0.0.7 

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

Idempotent indicates an expected call of Idempotent.

func (*MockCQLQueryMockRecorder) Iter added in v0.0.7 

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

Iter indicates an expected call of Iter.

func (*MockCQLQueryMockRecorder) PageSize added in v0.0.7 

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

PageSize indicates an expected call of PageSize.

func (*MockCQLQueryMockRecorder) PageState added in v0.0.7 

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

PageState indicates an expected call of PageState.

func (*MockCQLQueryMockRecorder) WithContext added in v0.0.7 

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

WithContext indicates an expected call of WithContext.

type MockCQLSession added in v0.0.7 

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

MockCQLSession is a mock of CQLSession interface.

func NewMockCQLSession added in v0.0.7 

func NewMockCQLSession(ctrl *gomock.Controller) *MockCQLSession

NewMockCQLSession creates a new mock instance.

func (*MockCQLSession) Batch added in v0.0.7 

func (m *MockCQLSession) Batch(kind interfaces.CQLBatchKind) interfaces.CQLBatch

Batch mocks base method.

func (*MockCQLSession) Close added in v0.0.7 

func (m *MockCQLSession) Close()

Close mocks base method.

func (*MockCQLSession) EXPECT added in v0.0.7 

func (m *MockCQLSession) EXPECT() *MockCQLSessionMockRecorder

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

func (*MockCQLSession) ExecuteBatch added in v0.0.7 

func (m *MockCQLSession) ExecuteBatch(b interfaces.CQLBatch) error

ExecuteBatch mocks base method.

func (*MockCQLSession) Query added in v0.0.7 

func (m *MockCQLSession) Query(stmt string, values ...any) interfaces.CQLQuery

Query mocks base method.

type MockCQLSessionMockRecorder added in v0.0.7 

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

MockCQLSessionMockRecorder is the mock recorder for MockCQLSession.

func (*MockCQLSessionMockRecorder) Batch added in v0.0.7 

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

Batch indicates an expected call of Batch.

func (*MockCQLSessionMockRecorder) Close added in v0.0.7 

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

Close indicates an expected call of Close.

func (*MockCQLSessionMockRecorder) ExecuteBatch added in v0.0.7 

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

ExecuteBatch indicates an expected call of ExecuteBatch.

func (*MockCQLSessionMockRecorder) Query added in v0.0.7 

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

Query indicates an expected call of Query.

type MockCRUDNoListRepository added in v0.0.7 

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

MockCRUDNoListRepository is a mock of CRUDNoListRepository interface.

func NewMockCRUDNoListRepository added in v0.0.7 

func NewMockCRUDNoListRepository[T any, ID comparable](ctrl *gomock.Controller) *MockCRUDNoListRepository[T, ID]

NewMockCRUDNoListRepository creates a new mock instance.

func (*MockCRUDNoListRepository[T, ID]) Create added in v0.0.7 

func (m *MockCRUDNoListRepository[T, ID]) Create(ctx context.Context, in *T) (*T, error)

Create mocks base method.

func (*MockCRUDNoListRepository[T, ID]) Delete added in v0.0.7 

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

Delete mocks base method.

func (*MockCRUDNoListRepository[T, ID]) EXPECT added in v0.0.7 

func (m *MockCRUDNoListRepository[T, ID]) EXPECT() *MockCRUDNoListRepositoryMockRecorder[T, ID]

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

func (*MockCRUDNoListRepository[T, ID]) Get added in v0.0.7 

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

Get mocks base method.

func (*MockCRUDNoListRepository[T, ID]) Update added in v0.0.7 

func (m *MockCRUDNoListRepository[T, ID]) Update(ctx context.Context, id ID, in *T) (*T, error)

Update mocks base method.

type MockCRUDNoListRepositoryMockRecorder added in v0.0.7 

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

MockCRUDNoListRepositoryMockRecorder is the mock recorder for MockCRUDNoListRepository.

func (*MockCRUDNoListRepositoryMockRecorder[T, ID]) Create added in v0.0.7 

func (mr *MockCRUDNoListRepositoryMockRecorder[T, ID]) Create(ctx, in any) *gomock.Call

Create indicates an expected call of Create.

func (*MockCRUDNoListRepositoryMockRecorder[T, ID]) Delete added in v0.0.7 

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

Delete indicates an expected call of Delete.

func (*MockCRUDNoListRepositoryMockRecorder[T, ID]) Get added in v0.0.7 

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

Get indicates an expected call of Get.

func (*MockCRUDNoListRepositoryMockRecorder[T, ID]) Update added in v0.0.7 

func (mr *MockCRUDNoListRepositoryMockRecorder[T, ID]) Update(ctx, id, in any) *gomock.Call

Update indicates an expected call of Update.

type MockCRUDNoListStore added in v0.0.7 

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

MockCRUDNoListStore is a mock of CRUDNoListStore interface.

func NewMockCRUDNoListStore added in v0.0.7 

func NewMockCRUDNoListStore[T any, ID comparable](ctrl *gomock.Controller) *MockCRUDNoListStore[T, ID]

NewMockCRUDNoListStore creates a new mock instance.

func (*MockCRUDNoListStore[T, ID]) Create added in v0.0.7 

func (m *MockCRUDNoListStore[T, ID]) Create(ctx context.Context, in *T) (*T, error)

Create mocks base method.

func (*MockCRUDNoListStore[T, ID]) Delete added in v0.0.7 

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

Delete mocks base method.

func (*MockCRUDNoListStore[T, ID]) EXPECT added in v0.0.7 

func (m *MockCRUDNoListStore[T, ID]) EXPECT() *MockCRUDNoListStoreMockRecorder[T, ID]

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

func (*MockCRUDNoListStore[T, ID]) Exists added in v0.0.7 

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

Exists mocks base method.

func (*MockCRUDNoListStore[T, ID]) Get added in v0.0.7 

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

Get mocks base method.

func (*MockCRUDNoListStore[T, ID]) Update added in v0.0.7 

func (m *MockCRUDNoListStore[T, ID]) Update(ctx context.Context, id ID, in *T) (*T, error)

Update mocks base method.

type MockCRUDNoListStoreMockRecorder added in v0.0.7 

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

MockCRUDNoListStoreMockRecorder is the mock recorder for MockCRUDNoListStore.

func (*MockCRUDNoListStoreMockRecorder[T, ID]) Create added in v0.0.7 

func (mr *MockCRUDNoListStoreMockRecorder[T, ID]) Create(ctx, in any) *gomock.Call

Create indicates an expected call of Create.

func (*MockCRUDNoListStoreMockRecorder[T, ID]) Delete added in v0.0.7 

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

Delete indicates an expected call of Delete.

func (*MockCRUDNoListStoreMockRecorder[T, ID]) Exists added in v0.0.7 

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

Exists indicates an expected call of Exists.

func (*MockCRUDNoListStoreMockRecorder[T, ID]) Get added in v0.0.7 

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

Get indicates an expected call of Get.

func (*MockCRUDNoListStoreMockRecorder[T, ID]) Update added in v0.0.7 

func (mr *MockCRUDNoListStoreMockRecorder[T, ID]) Update(ctx, id, in any) *gomock.Call

Update indicates an expected call of Update.

type MockCacheInvalidator added in v0.0.4 

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

MockCacheInvalidator is a mock of CacheInvalidator interface.

func NewMockCacheInvalidator added in v0.0.4 

func NewMockCacheInvalidator(ctrl *gomock.Controller) *MockCacheInvalidator

NewMockCacheInvalidator creates a new mock instance.

func (*MockCacheInvalidator) EXPECT added in v0.0.4 

func (m *MockCacheInvalidator) EXPECT() *MockCacheInvalidatorMockRecorder

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

func (*MockCacheInvalidator) InvalidateAll added in v0.0.4 

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

InvalidateAll mocks base method.

func (*MockCacheInvalidator) InvalidatePrefix added in v0.0.4 

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

InvalidatePrefix mocks base method.

type MockCacheInvalidatorMockRecorder added in v0.0.4 

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

MockCacheInvalidatorMockRecorder is the mock recorder for MockCacheInvalidator.

func (*MockCacheInvalidatorMockRecorder) InvalidateAll added in v0.0.4 

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

InvalidateAll indicates an expected call of InvalidateAll.

func (*MockCacheInvalidatorMockRecorder) InvalidatePrefix added in v0.0.4 

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 MockCodebase added in v0.0.17 

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

MockCodebase is a mock of Codebase interface.

func NewMockCodebase added in v0.0.17 

func NewMockCodebase(ctrl *gomock.Controller) *MockCodebase

NewMockCodebase creates a new mock instance.

func (*MockCodebase) Changed added in v0.0.17 

func (m *MockCodebase) Changed(ctx context.Context, base string) (map[string]bool, error)

Changed mocks base method.

func (*MockCodebase) Docs added in v0.0.20 

func (m *MockCodebase) Docs(ctx context.Context, sel types.FileSelector) ([]types.Document, error)

Docs mocks base method.

func (*MockCodebase) EXPECT added in v0.0.17 

func (m *MockCodebase) EXPECT() *MockCodebaseMockRecorder

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

func (*MockCodebase) Files added in v0.0.17 

func (m *MockCodebase) Files(ctx context.Context, sel types.FileSelector) ([]types.File, error)

Files mocks base method.

func (*MockCodebase) Go added in v0.0.17 

func (m *MockCodebase) Go() interfaces.GoView

Go mocks base method.

func (*MockCodebase) Match added in v0.0.17 

func (m *MockCodebase) Match(ctx context.Context, sel types.FileSelector, patterns []*regexp.Regexp) ([]types.Hit, error)

Match mocks base method.

func (*MockCodebase) Rendered added in v0.0.17 

func (m *MockCodebase) Rendered(ctx context.Context, spec types.RenderSpec) ([]types.Object, error)

Rendered mocks base method.

func (*MockCodebase) Text added in v0.0.17 

func (m *MockCodebase) Text(ctx context.Context, path string) (types.Text, error)

Text mocks base method.

func (*MockCodebase) YAML added in v0.0.17 

func (m *MockCodebase) YAML() interfaces.YAMLView

YAML mocks base method.

type MockCodebaseMockRecorder added in v0.0.17 

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

MockCodebaseMockRecorder is the mock recorder for MockCodebase.

func (*MockCodebaseMockRecorder) Changed added in v0.0.17 

func (mr *MockCodebaseMockRecorder) Changed(ctx, base any) *gomock.Call

Changed indicates an expected call of Changed.

func (*MockCodebaseMockRecorder) Docs added in v0.0.20 

func (mr *MockCodebaseMockRecorder) Docs(ctx, sel any) *gomock.Call

Docs indicates an expected call of Docs.

func (*MockCodebaseMockRecorder) Files added in v0.0.17 

func (mr *MockCodebaseMockRecorder) Files(ctx, sel any) *gomock.Call

Files indicates an expected call of Files.

func (*MockCodebaseMockRecorder) Go added in v0.0.17 

func (mr *MockCodebaseMockRecorder) Go() *gomock.Call

Go indicates an expected call of Go.

func (*MockCodebaseMockRecorder) Match added in v0.0.17 

func (mr *MockCodebaseMockRecorder) Match(ctx, sel, patterns any) *gomock.Call

Match indicates an expected call of Match.

func (*MockCodebaseMockRecorder) Rendered added in v0.0.17 

func (mr *MockCodebaseMockRecorder) Rendered(ctx, spec any) *gomock.Call

Rendered indicates an expected call of Rendered.

func (*MockCodebaseMockRecorder) Text added in v0.0.17 

func (mr *MockCodebaseMockRecorder) Text(ctx, path any) *gomock.Call

Text indicates an expected call of Text.

func (*MockCodebaseMockRecorder) YAML added in v0.0.17 

func (mr *MockCodebaseMockRecorder) YAML() *gomock.Call

YAML indicates an expected call of YAML.

type MockCodebaseSource added in v0.0.17 

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

MockCodebaseSource is a mock of CodebaseSource interface.

func NewMockCodebaseSource added in v0.0.17 

func NewMockCodebaseSource(ctrl *gomock.Controller) *MockCodebaseSource

NewMockCodebaseSource creates a new mock instance.

func (*MockCodebaseSource) Changed added in v0.0.17 

func (m *MockCodebaseSource) Changed(ctx context.Context, base string) (map[string]bool, error)

Changed mocks base method.

func (*MockCodebaseSource) EXPECT added in v0.0.17 

func (m *MockCodebaseSource) EXPECT() *MockCodebaseSourceMockRecorder

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

func (*MockCodebaseSource) List added in v0.0.17 

func (m *MockCodebaseSource) List(ctx context.Context) ([]types.File, error)

List mocks base method.

func (*MockCodebaseSource) Read added in v0.0.17 

func (m *MockCodebaseSource) Read(ctx context.Context, path string) ([]byte, error)

Read mocks base method.

type MockCodebaseSourceMockRecorder added in v0.0.17 

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

MockCodebaseSourceMockRecorder is the mock recorder for MockCodebaseSource.

func (*MockCodebaseSourceMockRecorder) Changed added in v0.0.17 

func (mr *MockCodebaseSourceMockRecorder) Changed(ctx, base any) *gomock.Call

Changed indicates an expected call of Changed.

func (*MockCodebaseSourceMockRecorder) List added in v0.0.17 

func (mr *MockCodebaseSourceMockRecorder) List(ctx any) *gomock.Call

List indicates an expected call of List.

func (*MockCodebaseSourceMockRecorder) Read added in v0.0.17 

func (mr *MockCodebaseSourceMockRecorder) Read(ctx, path any) *gomock.Call

Read indicates an expected call of Read.

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) RunBufferedWithInput added in v0.0.22 

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

RunBufferedWithInput 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) RunBufferedWithInput added in v0.0.22 

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

RunBufferedWithInput indicates an expected call of RunBufferedWithInput.

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 added in v0.0.4 

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

MockCountingPublisher is a mock of CountingPublisher interface.

func NewMockCountingPublisher added in v0.0.4 

func NewMockCountingPublisher(ctrl *gomock.Controller) *MockCountingPublisher

NewMockCountingPublisher creates a new mock instance.

func (*MockCountingPublisher) EXPECT added in v0.0.4 

func (m *MockCountingPublisher) EXPECT() *MockCountingPublisherMockRecorder

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

func (*MockCountingPublisher) Publish added in v0.0.4 

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

Publish mocks base method.

func (*MockCountingPublisher) PublishBatch added in v0.0.4 

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

PublishBatch mocks base method.

func (*MockCountingPublisher) PublishCount added in v0.0.4 

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

PublishCount mocks base method.

type MockCountingPublisherMockRecorder added in v0.0.4 

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

MockCountingPublisherMockRecorder is the mock recorder for MockCountingPublisher.

func (*MockCountingPublisherMockRecorder) Publish added in v0.0.4 

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

Publish indicates an expected call of Publish.

func (*MockCountingPublisherMockRecorder) PublishBatch added in v0.0.4 

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

PublishBatch indicates an expected call of PublishBatch.

func (*MockCountingPublisherMockRecorder) PublishCount added in v0.0.4 

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

PublishCount indicates an expected call of PublishCount.

type MockCreator added in v0.0.11 

type MockCreator[T any, C any] struct {
	// contains filtered or unexported fields
}

MockCreator is a mock of Creator interface.

func NewMockCreator added in v0.0.11 

func NewMockCreator[T any, C any](ctrl *gomock.Controller) *MockCreator[T, C]

NewMockCreator creates a new mock instance.

func (*MockCreator[T, C]) Create added in v0.0.11 

func (m *MockCreator[T, C]) Create(ctx context.Context, in C) (*T, error)

Create mocks base method.

func (*MockCreator[T, C]) EXPECT added in v0.0.11 

func (m *MockCreator[T, C]) EXPECT() *MockCreatorMockRecorder[T, C]

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

type MockCreatorMockRecorder added in v0.0.11 

type MockCreatorMockRecorder[T any, C any] struct {
	// contains filtered or unexported fields
}

MockCreatorMockRecorder is the mock recorder for MockCreator.

func (*MockCreatorMockRecorder[T, C]) Create added in v0.0.11 

func (mr *MockCreatorMockRecorder[T, C]) Create(ctx, in any) *gomock.Call

Create indicates an expected call of Create.

type MockDeadLetterBackend 

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

MockDeadLetterBackend is a mock of DeadLetterBackend interface.

func NewMockDeadLetterBackend 

func NewMockDeadLetterBackend(ctrl *gomock.Controller) *MockDeadLetterBackend

NewMockDeadLetterBackend creates a new mock instance.

func (*MockDeadLetterBackend) EXPECT 

func (m *MockDeadLetterBackend) EXPECT() *MockDeadLetterBackendMockRecorder

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

func (*MockDeadLetterBackend) Send 

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

Send mocks base method.

type MockDeadLetterBackendMockRecorder 

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

MockDeadLetterBackendMockRecorder is the mock recorder for MockDeadLetterBackend.

func (*MockDeadLetterBackendMockRecorder) Send 

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

Send indicates an expected call of Send.

type MockDeduplicator 

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

MockDeduplicator is a mock of Deduplicator interface.

func NewMockDeduplicator 

func NewMockDeduplicator(ctrl *gomock.Controller) *MockDeduplicator

NewMockDeduplicator creates a new mock instance.

func (*MockDeduplicator) EXPECT 

func (m *MockDeduplicator) EXPECT() *MockDeduplicatorMockRecorder

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

func (*MockDeduplicator) Seen 

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

Seen mocks base method.

type MockDeduplicatorMockRecorder 

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

MockDeduplicatorMockRecorder is the mock recorder for MockDeduplicator.

func (*MockDeduplicatorMockRecorder) Seen 

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

Seen indicates an expected call of Seen.

type MockDeleter added in v0.0.7 

type MockDeleter[ID comparable] struct {
	// contains filtered or unexported fields
}

MockDeleter is a mock of Deleter interface.

func NewMockDeleter added in v0.0.7 

func NewMockDeleter[ID comparable](ctrl *gomock.Controller) *MockDeleter[ID]

NewMockDeleter creates a new mock instance.

func (*MockDeleter[ID]) Delete added in v0.0.7 

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

Delete mocks base method.

func (*MockDeleter[ID]) EXPECT added in v0.0.7 

func (m *MockDeleter[ID]) EXPECT() *MockDeleterMockRecorder[ID]

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

type MockDeleterMockRecorder added in v0.0.7 

type MockDeleterMockRecorder[ID comparable] struct {
	// contains filtered or unexported fields
}

MockDeleterMockRecorder is the mock recorder for MockDeleter.

func (*MockDeleterMockRecorder[ID]) Delete added in v0.0.7 

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

Delete indicates an expected call of Delete.

type MockDialer added in v0.0.22 

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

MockDialer is a mock of Dialer interface.

func NewMockDialer added in v0.0.22 

func NewMockDialer(ctrl *gomock.Controller) *MockDialer

NewMockDialer creates a new mock instance.

func (*MockDialer) DialContext added in v0.0.22 

func (m *MockDialer) DialContext(ctx context.Context, network, address string) (net.Conn, error)

DialContext mocks base method.

func (*MockDialer) EXPECT added in v0.0.22 

func (m *MockDialer) EXPECT() *MockDialerMockRecorder

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

type MockDialerMockRecorder added in v0.0.22 

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

MockDialerMockRecorder is the mock recorder for MockDialer.

func (*MockDialerMockRecorder) DialContext added in v0.0.22 

func (mr *MockDialerMockRecorder) DialContext(ctx, network, address any) *gomock.Call

DialContext indicates an expected call of DialContext.

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 MockDockerClient added in v0.0.17 

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

MockDockerClient is a mock of DockerClient interface.

func NewMockDockerClient added in v0.0.17 

func NewMockDockerClient(ctrl *gomock.Controller) *MockDockerClient

NewMockDockerClient creates a new mock instance.

func (*MockDockerClient) Build added in v0.0.17 

func (m *MockDockerClient) Build(ctx context.Context, spec types.BuildSpec) error

Build mocks base method.

func (*MockDockerClient) ComposeDown added in v0.0.17 

func (m *MockDockerClient) ComposeDown(ctx context.Context, spec types.ComposeSpec) error

ComposeDown mocks base method.

func (*MockDockerClient) ComposeUp added in v0.0.17 

func (m *MockDockerClient) ComposeUp(ctx context.Context, spec types.ComposeSpec) error

ComposeUp mocks base method.

func (*MockDockerClient) EXPECT added in v0.0.17 

func (m *MockDockerClient) EXPECT() *MockDockerClientMockRecorder

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

func (*MockDockerClient) Inspect added in v0.0.17 

func (m *MockDockerClient) Inspect(ctx context.Context, ref string) ([]byte, error)

Inspect mocks base method.

func (*MockDockerClient) Push added in v0.0.17 

func (m *MockDockerClient) Push(ctx context.Context, ref string) error

Push mocks base method.

type MockDockerClientMockRecorder added in v0.0.17 

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

MockDockerClientMockRecorder is the mock recorder for MockDockerClient.

func (*MockDockerClientMockRecorder) Build added in v0.0.17 

func (mr *MockDockerClientMockRecorder) Build(ctx, spec any) *gomock.Call

Build indicates an expected call of Build.

func (*MockDockerClientMockRecorder) ComposeDown added in v0.0.17 

func (mr *MockDockerClientMockRecorder) ComposeDown(ctx, spec any) *gomock.Call

ComposeDown indicates an expected call of ComposeDown.

func (*MockDockerClientMockRecorder) ComposeUp added in v0.0.17 

func (mr *MockDockerClientMockRecorder) ComposeUp(ctx, spec any) *gomock.Call

ComposeUp indicates an expected call of ComposeUp.

func (*MockDockerClientMockRecorder) Inspect added in v0.0.17 

func (mr *MockDockerClientMockRecorder) Inspect(ctx, ref any) *gomock.Call

Inspect indicates an expected call of Inspect.

func (*MockDockerClientMockRecorder) Push added in v0.0.17 

func (mr *MockDockerClientMockRecorder) Push(ctx, ref any) *gomock.Call

Push indicates an expected call of Push.

type MockDownloader added in v0.0.17 

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

MockDownloader is a mock of Downloader interface.

func NewMockDownloader added in v0.0.17 

func NewMockDownloader(ctrl *gomock.Controller) *MockDownloader

NewMockDownloader creates a new mock instance.

func (*MockDownloader) EXPECT added in v0.0.17 

func (m *MockDownloader) EXPECT() *MockDownloaderMockRecorder

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

func (*MockDownloader) Fetch added in v0.0.17 

func (m *MockDownloader) Fetch(ctx context.Context, url string) (io.ReadCloser, error)

Fetch mocks base method.

type MockDownloaderMockRecorder added in v0.0.17 

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

MockDownloaderMockRecorder is the mock recorder for MockDownloader.

func (*MockDownloaderMockRecorder) Fetch added in v0.0.17 

func (mr *MockDownloaderMockRecorder) Fetch(ctx, url any) *gomock.Call

Fetch indicates an expected call of Fetch.

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 MockEncryptor added in v0.0.4 

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

MockEncryptor is a mock of Encryptor interface.

func NewMockEncryptor added in v0.0.4 

func NewMockEncryptor(ctrl *gomock.Controller) *MockEncryptor

NewMockEncryptor creates a new mock instance.

func (*MockEncryptor) Decrypt added in v0.0.4 

func (m *MockEncryptor) Decrypt(ciphertext []byte) ([]byte, error)

Decrypt mocks base method.

func (*MockEncryptor) EXPECT added in v0.0.4 

func (m *MockEncryptor) EXPECT() *MockEncryptorMockRecorder

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

func (*MockEncryptor) Encrypt added in v0.0.4 

func (m *MockEncryptor) Encrypt(plaintext []byte) ([]byte, error)

Encrypt mocks base method.

type MockEncryptorMockRecorder added in v0.0.4 

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

MockEncryptorMockRecorder is the mock recorder for MockEncryptor.

func (*MockEncryptorMockRecorder) Decrypt added in v0.0.4 

func (mr *MockEncryptorMockRecorder) Decrypt(ciphertext any) *gomock.Call

Decrypt indicates an expected call of Decrypt.

func (*MockEncryptorMockRecorder) Encrypt added in v0.0.4 

func (mr *MockEncryptorMockRecorder) Encrypt(plaintext any) *gomock.Call

Encrypt indicates an expected call of Encrypt.

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 added in v0.0.4 

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

MockEventPublisher is a mock of EventPublisher interface.

func NewMockEventPublisher added in v0.0.4 

func NewMockEventPublisher(ctrl *gomock.Controller) *MockEventPublisher

NewMockEventPublisher creates a new mock instance.

func (*MockEventPublisher) EXPECT added in v0.0.4 

func (m *MockEventPublisher) EXPECT() *MockEventPublisherMockRecorder

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

func (*MockEventPublisher) Publish added in v0.0.4 

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

Publish mocks base method.

func (*MockEventPublisher) PublishBatch added in v0.0.4 

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

PublishBatch mocks base method.

type MockEventPublisherMockRecorder added in v0.0.4 

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

MockEventPublisherMockRecorder is the mock recorder for MockEventPublisher.

func (*MockEventPublisherMockRecorder) Publish added in v0.0.4 

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

Publish indicates an expected call of Publish.

func (*MockEventPublisherMockRecorder) PublishBatch added in v0.0.4 

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 MockExister added in v0.0.7 

type MockExister[ID comparable] struct {
	// contains filtered or unexported fields
}

MockExister is a mock of Exister interface.

func NewMockExister added in v0.0.7 

func NewMockExister[ID comparable](ctrl *gomock.Controller) *MockExister[ID]

NewMockExister creates a new mock instance.

func (*MockExister[ID]) EXPECT added in v0.0.7 

func (m *MockExister[ID]) EXPECT() *MockExisterMockRecorder[ID]

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

func (*MockExister[ID]) Exists added in v0.0.7 

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

Exists mocks base method.

type MockExisterMockRecorder added in v0.0.7 

type MockExisterMockRecorder[ID comparable] struct {
	// contains filtered or unexported fields
}

MockExisterMockRecorder is the mock recorder for MockExister.

func (*MockExisterMockRecorder[ID]) Exists added in v0.0.7 

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

Exists indicates an expected call of Exists.

type MockFS added in v0.0.22 

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

MockFS is a mock of FS interface.

func NewMockFS added in v0.0.22 

func NewMockFS(ctrl *gomock.Controller) *MockFS

NewMockFS creates a new mock instance.

func (*MockFS) EXPECT added in v0.0.22 

func (m *MockFS) EXPECT() *MockFSMockRecorder

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

func (*MockFS) MkdirAll added in v0.0.22 

func (m *MockFS) MkdirAll(path string, perm fs.FileMode) error

MkdirAll mocks base method.

func (*MockFS) ReadDir added in v0.0.22 

func (m *MockFS) ReadDir(name string) ([]fs.DirEntry, error)

ReadDir mocks base method.

func (*MockFS) ReadFile added in v0.0.22 

func (m *MockFS) ReadFile(name string) ([]byte, error)

ReadFile mocks base method.

func (*MockFS) RemoveAll added in v0.0.22 

func (m *MockFS) RemoveAll(path string) error

RemoveAll mocks base method.

func (*MockFS) Rename added in v0.0.22 

func (m *MockFS) Rename(oldpath, newpath string) error

Rename mocks base method.

func (*MockFS) Stat added in v0.0.22 

func (m *MockFS) Stat(name string) (fs.FileInfo, error)

Stat mocks base method.

func (*MockFS) WriteFile added in v0.0.22 

func (m *MockFS) WriteFile(name string, data []byte, perm fs.FileMode) error

WriteFile mocks base method.

type MockFSMockRecorder added in v0.0.22 

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

MockFSMockRecorder is the mock recorder for MockFS.

func (*MockFSMockRecorder) MkdirAll added in v0.0.22 

func (mr *MockFSMockRecorder) MkdirAll(path, perm any) *gomock.Call

MkdirAll indicates an expected call of MkdirAll.

func (*MockFSMockRecorder) ReadDir added in v0.0.22 

func (mr *MockFSMockRecorder) ReadDir(name any) *gomock.Call

ReadDir indicates an expected call of ReadDir.

func (*MockFSMockRecorder) ReadFile added in v0.0.22 

func (mr *MockFSMockRecorder) ReadFile(name any) *gomock.Call

ReadFile indicates an expected call of ReadFile.

func (*MockFSMockRecorder) RemoveAll added in v0.0.22 

func (mr *MockFSMockRecorder) RemoveAll(path any) *gomock.Call

RemoveAll indicates an expected call of RemoveAll.

func (*MockFSMockRecorder) Rename added in v0.0.22 

func (mr *MockFSMockRecorder) Rename(oldpath, newpath any) *gomock.Call

Rename indicates an expected call of Rename.

func (*MockFSMockRecorder) Stat added in v0.0.22 

func (mr *MockFSMockRecorder) Stat(name any) *gomock.Call

Stat indicates an expected call of Stat.

func (*MockFSMockRecorder) WriteFile added in v0.0.22 

func (mr *MockFSMockRecorder) WriteFile(name, data, perm any) *gomock.Call

WriteFile indicates an expected call of WriteFile.

type MockFaultInjector added in v0.0.19 

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

MockFaultInjector is a mock of FaultInjector interface.

func NewMockFaultInjector added in v0.0.19 

func NewMockFaultInjector(ctrl *gomock.Controller) *MockFaultInjector

NewMockFaultInjector creates a new mock instance.

func (*MockFaultInjector) Active added in v0.0.19 

func (m *MockFaultInjector) Active(ctx context.Context, namespace string) ([]string, error)

Active mocks base method.

func (*MockFaultInjector) EXPECT added in v0.0.19 

func (m *MockFaultInjector) EXPECT() *MockFaultInjectorMockRecorder

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

func (*MockFaultInjector) Inject added in v0.0.19 

func (m *MockFaultInjector) Inject(ctx context.Context, f types.Fault) error

Inject mocks base method.

func (*MockFaultInjector) Revert added in v0.0.19 

func (m *MockFaultInjector) Revert(ctx context.Context, f types.Fault) error

Revert mocks base method.

type MockFaultInjectorMockRecorder added in v0.0.19 

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

MockFaultInjectorMockRecorder is the mock recorder for MockFaultInjector.

func (*MockFaultInjectorMockRecorder) Active added in v0.0.19 

func (mr *MockFaultInjectorMockRecorder) Active(ctx, namespace any) *gomock.Call

Active indicates an expected call of Active.

func (*MockFaultInjectorMockRecorder) Inject added in v0.0.19 

func (mr *MockFaultInjectorMockRecorder) Inject(ctx, f any) *gomock.Call

Inject indicates an expected call of Inject.

func (*MockFaultInjectorMockRecorder) Revert added in v0.0.19 

func (mr *MockFaultInjectorMockRecorder) Revert(ctx, f any) *gomock.Call

Revert indicates an expected call of Revert.

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 MockGenerator added in v0.0.17 

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

MockGenerator is a mock of Generator interface.

func NewMockGenerator added in v0.0.17 

func NewMockGenerator(ctrl *gomock.Controller) *MockGenerator

NewMockGenerator creates a new mock instance.

func (*MockGenerator) EXPECT added in v0.0.17 

func (m *MockGenerator) EXPECT() *MockGeneratorMockRecorder

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

func (*MockGenerator) Inputs added in v0.0.17 

func (m *MockGenerator) Inputs() types.FileSelector

Inputs mocks base method.

func (*MockGenerator) Name added in v0.0.17 

func (m *MockGenerator) Name() string

Name mocks base method.

func (*MockGenerator) Render added in v0.0.17 

func (m *MockGenerator) Render(ctx context.Context, cb interfaces.Codebase) (types.Artifacts, error)

Render mocks base method.

type MockGeneratorMockRecorder added in v0.0.17 

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

MockGeneratorMockRecorder is the mock recorder for MockGenerator.

func (*MockGeneratorMockRecorder) Inputs added in v0.0.17 

func (mr *MockGeneratorMockRecorder) Inputs() *gomock.Call

Inputs indicates an expected call of Inputs.

func (*MockGeneratorMockRecorder) Name added in v0.0.17 

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

Name indicates an expected call of Name.

func (*MockGeneratorMockRecorder) Render added in v0.0.17 

func (mr *MockGeneratorMockRecorder) Render(ctx, cb any) *gomock.Call

Render indicates an expected call of Render.

type MockGitClient added in v0.0.17 

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

MockGitClient is a mock of GitClient interface.

func NewMockGitClient added in v0.0.17 

func NewMockGitClient(ctrl *gomock.Controller) *MockGitClient

NewMockGitClient creates a new mock instance.

func (*MockGitClient) ChangedSince added in v0.0.17 

func (m *MockGitClient) ChangedSince(ctx context.Context, root, base string) ([]string, error)

ChangedSince mocks base method.

func (*MockGitClient) Diff added in v0.0.17 

func (m *MockGitClient) Diff(ctx context.Context, root string, args ...string) ([]byte, error)

Diff mocks base method.

func (*MockGitClient) EXPECT added in v0.0.17 

func (m *MockGitClient) EXPECT() *MockGitClientMockRecorder

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

func (*MockGitClient) Grep added in v0.0.39 

func (m *MockGitClient) Grep(ctx context.Context, root, needle string) ([]string, error)

Grep mocks base method.

func (*MockGitClient) HasPathsChanged added in v0.0.17 

func (m *MockGitClient) HasPathsChanged(ctx context.Context, root, from, to string, paths []string) (bool, error)

HasPathsChanged mocks base method.

func (*MockGitClient) IsRepo added in v0.0.17 

func (m *MockGitClient) IsRepo(ctx context.Context, root string) bool

IsRepo mocks base method.

func (*MockGitClient) Log added in v0.0.39 

func (m *MockGitClient) Log(ctx context.Context, root string, args ...string) ([]byte, error)

Log mocks base method.

func (*MockGitClient) LsFiles added in v0.0.17 

func (m *MockGitClient) LsFiles(ctx context.Context, root string, pathspecs []string) ([]string, error)

LsFiles mocks base method.

func (*MockGitClient) LsUntracked added in v0.0.39 

func (m *MockGitClient) LsUntracked(ctx context.Context, root string, pathspecs []string) ([]string, error)

LsUntracked mocks base method.

func (*MockGitClient) Move added in v0.0.39 

func (m *MockGitClient) Move(ctx context.Context, root, from, to string) error

Move mocks base method.

func (*MockGitClient) RemoteHasRef added in v0.0.22 

func (m *MockGitClient) RemoteHasRef(ctx context.Context, root, remote, ref string) (bool, error)

RemoteHasRef mocks base method.

func (*MockGitClient) Remove added in v0.0.39 

func (m *MockGitClient) Remove(ctx context.Context, root string, paths []string) error

Remove mocks base method.

func (*MockGitClient) RevParse added in v0.0.17 

func (m *MockGitClient) RevParse(ctx context.Context, root, ref string) (string, error)

RevParse mocks base method.

func (*MockGitClient) StageFiles added in v0.0.17 

func (m *MockGitClient) StageFiles(ctx context.Context, root string, paths []string) error

StageFiles mocks base method.

func (*MockGitClient) StagedFiles added in v0.0.17 

func (m *MockGitClient) StagedFiles(ctx context.Context, root string, patterns []string) ([]string, error)

StagedFiles mocks base method.

func (*MockGitClient) Status added in v0.0.39 

func (m *MockGitClient) Status(ctx context.Context, root string, pathspecs []string) ([]byte, error)

Status mocks base method.

func (*MockGitClient) Tag added in v0.0.17 

func (m *MockGitClient) Tag(ctx context.Context, root string) (string, error)

Tag mocks base method.

type MockGitClientMockRecorder added in v0.0.17 

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

MockGitClientMockRecorder is the mock recorder for MockGitClient.

func (*MockGitClientMockRecorder) ChangedSince added in v0.0.17 

func (mr *MockGitClientMockRecorder) ChangedSince(ctx, root, base any) *gomock.Call

ChangedSince indicates an expected call of ChangedSince.

func (*MockGitClientMockRecorder) Diff added in v0.0.17 

func (mr *MockGitClientMockRecorder) Diff(ctx, root any, args ...any) *gomock.Call

Diff indicates an expected call of Diff.

func (*MockGitClientMockRecorder) Grep added in v0.0.39 

func (mr *MockGitClientMockRecorder) Grep(ctx, root, needle any) *gomock.Call

Grep indicates an expected call of Grep.

func (*MockGitClientMockRecorder) HasPathsChanged added in v0.0.17 

func (mr *MockGitClientMockRecorder) HasPathsChanged(ctx, root, from, to, paths any) *gomock.Call

HasPathsChanged indicates an expected call of HasPathsChanged.

func (*MockGitClientMockRecorder) IsRepo added in v0.0.17 

func (mr *MockGitClientMockRecorder) IsRepo(ctx, root any) *gomock.Call

IsRepo indicates an expected call of IsRepo.

func (*MockGitClientMockRecorder) Log added in v0.0.39 

func (mr *MockGitClientMockRecorder) Log(ctx, root any, args ...any) *gomock.Call

Log indicates an expected call of Log.

func (*MockGitClientMockRecorder) LsFiles added in v0.0.17 

func (mr *MockGitClientMockRecorder) LsFiles(ctx, root, pathspecs any) *gomock.Call

LsFiles indicates an expected call of LsFiles.

func (*MockGitClientMockRecorder) LsUntracked added in v0.0.39 

func (mr *MockGitClientMockRecorder) LsUntracked(ctx, root, pathspecs any) *gomock.Call

LsUntracked indicates an expected call of LsUntracked.

func (*MockGitClientMockRecorder) Move added in v0.0.39 

func (mr *MockGitClientMockRecorder) Move(ctx, root, from, to any) *gomock.Call

Move indicates an expected call of Move.

func (*MockGitClientMockRecorder) RemoteHasRef added in v0.0.22 

func (mr *MockGitClientMockRecorder) RemoteHasRef(ctx, root, remote, ref any) *gomock.Call

RemoteHasRef indicates an expected call of RemoteHasRef.

func (*MockGitClientMockRecorder) Remove added in v0.0.39 

func (mr *MockGitClientMockRecorder) Remove(ctx, root, paths any) *gomock.Call

Remove indicates an expected call of Remove.

func (*MockGitClientMockRecorder) RevParse added in v0.0.17 

func (mr *MockGitClientMockRecorder) RevParse(ctx, root, ref any) *gomock.Call

RevParse indicates an expected call of RevParse.

func (*MockGitClientMockRecorder) StageFiles added in v0.0.17 

func (mr *MockGitClientMockRecorder) StageFiles(ctx, root, paths any) *gomock.Call

StageFiles indicates an expected call of StageFiles.

func (*MockGitClientMockRecorder) StagedFiles added in v0.0.17 

func (mr *MockGitClientMockRecorder) StagedFiles(ctx, root, patterns any) *gomock.Call

StagedFiles indicates an expected call of StagedFiles.

func (*MockGitClientMockRecorder) Status added in v0.0.39 

func (mr *MockGitClientMockRecorder) Status(ctx, root, pathspecs any) *gomock.Call

Status indicates an expected call of Status.

func (*MockGitClientMockRecorder) Tag added in v0.0.17 

func (mr *MockGitClientMockRecorder) Tag(ctx, root any) *gomock.Call

Tag indicates an expected call of Tag.

type MockGitOps added in v0.0.17 

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

MockGitOps is a mock of GitOps interface.

func NewMockGitOps added in v0.0.17 

func NewMockGitOps(ctrl *gomock.Controller) *MockGitOps

NewMockGitOps creates a new mock instance.

func (*MockGitOps) EXPECT added in v0.0.17 

func (m *MockGitOps) EXPECT() *MockGitOpsMockRecorder

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

func (*MockGitOps) HasPathsChanged added in v0.0.17 

func (m *MockGitOps) HasPathsChanged(ctx context.Context, root, from, to string, paths []string) (bool, error)

HasPathsChanged mocks base method.

func (*MockGitOps) StageFiles added in v0.0.17 

func (m *MockGitOps) StageFiles(ctx context.Context, root string, paths []string) error

StageFiles mocks base method.

func (*MockGitOps) StagedFiles added in v0.0.17 

func (m *MockGitOps) StagedFiles(ctx context.Context, root string, patterns []string) ([]string, error)

StagedFiles mocks base method.

type MockGitOpsMockRecorder added in v0.0.17 

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

MockGitOpsMockRecorder is the mock recorder for MockGitOps.

func (*MockGitOpsMockRecorder) HasPathsChanged added in v0.0.17 

func (mr *MockGitOpsMockRecorder) HasPathsChanged(ctx, root, from, to, paths any) *gomock.Call

HasPathsChanged indicates an expected call of HasPathsChanged.

func (*MockGitOpsMockRecorder) StageFiles added in v0.0.17 

func (mr *MockGitOpsMockRecorder) StageFiles(ctx, root, paths any) *gomock.Call

StageFiles indicates an expected call of StageFiles.

func (*MockGitOpsMockRecorder) StagedFiles added in v0.0.17 

func (mr *MockGitOpsMockRecorder) StagedFiles(ctx, root, patterns any) *gomock.Call

StagedFiles indicates an expected call of StagedFiles.

type MockGoView added in v0.0.17 

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

MockGoView is a mock of GoView interface.

func NewMockGoView added in v0.0.17 

func NewMockGoView(ctrl *gomock.Controller) *MockGoView

NewMockGoView creates a new mock instance.

func (*MockGoView) EXPECT added in v0.0.17 

func (m *MockGoView) EXPECT() *MockGoViewMockRecorder

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

func (*MockGoView) Modules added in v0.0.17 

func (m *MockGoView) Modules(ctx context.Context) ([]string, error)

Modules mocks base method.

func (*MockGoView) Parse added in v0.0.17 

func (m *MockGoView) Parse(ctx context.Context, sel types.FileSelector, mode types.ParseMode) ([]types.GoFile, error)

Parse mocks base method.

type MockGoViewMockRecorder added in v0.0.17 

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

MockGoViewMockRecorder is the mock recorder for MockGoView.

func (*MockGoViewMockRecorder) Modules added in v0.0.17 

func (mr *MockGoViewMockRecorder) Modules(ctx any) *gomock.Call

Modules indicates an expected call of Modules.

func (*MockGoViewMockRecorder) Parse added in v0.0.17 

func (mr *MockGoViewMockRecorder) Parse(ctx, sel, mode any) *gomock.Call

Parse indicates an expected call of Parse.

type MockGuard added in v0.0.19 

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

MockGuard is a mock of Guard interface.

func NewMockGuard added in v0.0.19 

func NewMockGuard(ctrl *gomock.Controller) *MockGuard

NewMockGuard creates a new mock instance.

func (*MockGuard) EXPECT added in v0.0.19 

func (m *MockGuard) EXPECT() *MockGuardMockRecorder

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

func (*MockGuard) Meta added in v0.0.19 

func (m *MockGuard) Meta() types.EntryMeta

Meta mocks base method.

func (*MockGuard) Name added in v0.0.19 

func (m *MockGuard) Name() string

Name mocks base method.

func (*MockGuard) Run added in v0.0.19 

func (m *MockGuard) Run(ctx context.Context, target interfaces.Codebase) types.Verdict

Run mocks base method.

type MockGuardMockRecorder added in v0.0.19 

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

MockGuardMockRecorder is the mock recorder for MockGuard.

func (*MockGuardMockRecorder) Meta added in v0.0.19 

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

Meta indicates an expected call of Meta.

func (*MockGuardMockRecorder) Name added in v0.0.19 

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

Name indicates an expected call of Name.

func (*MockGuardMockRecorder) Run added in v0.0.19 

func (mr *MockGuardMockRecorder) Run(ctx, target any) *gomock.Call

Run indicates an expected call of Run.

type MockHTTPDoer added in v0.0.19 

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

MockHTTPDoer is a mock of HTTPDoer interface.

func NewMockHTTPDoer added in v0.0.19 

func NewMockHTTPDoer(ctrl *gomock.Controller) *MockHTTPDoer

NewMockHTTPDoer creates a new mock instance.

func (*MockHTTPDoer) Do added in v0.0.19 

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

Do mocks base method.

func (*MockHTTPDoer) EXPECT added in v0.0.19 

func (m *MockHTTPDoer) EXPECT() *MockHTTPDoerMockRecorder

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

type MockHTTPDoerMockRecorder added in v0.0.19 

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

MockHTTPDoerMockRecorder is the mock recorder for MockHTTPDoer.

func (*MockHTTPDoerMockRecorder) Do added in v0.0.19 

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

Do indicates an expected call of Do.

type MockHelmClient added in v0.0.17 

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

MockHelmClient is a mock of HelmClient interface.

func NewMockHelmClient added in v0.0.17 

func NewMockHelmClient(ctrl *gomock.Controller) *MockHelmClient

NewMockHelmClient creates a new mock instance.

func (*MockHelmClient) DependencyBuild added in v0.0.17 

func (m *MockHelmClient) DependencyBuild(ctx context.Context, chartDir string) error

DependencyBuild mocks base method.

func (*MockHelmClient) EXPECT added in v0.0.17 

func (m *MockHelmClient) EXPECT() *MockHelmClientMockRecorder

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

func (*MockHelmClient) Lint added in v0.0.17 

func (m *MockHelmClient) Lint(ctx context.Context, spec types.RenderSpec) error

Lint mocks base method.

func (*MockHelmClient) Template added in v0.0.17 

func (m *MockHelmClient) Template(ctx context.Context, spec types.RenderSpec) ([]byte, error)

Template mocks base method.

type MockHelmClientMockRecorder added in v0.0.17 

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

MockHelmClientMockRecorder is the mock recorder for MockHelmClient.

func (*MockHelmClientMockRecorder) DependencyBuild added in v0.0.17 

func (mr *MockHelmClientMockRecorder) DependencyBuild(ctx, chartDir any) *gomock.Call

DependencyBuild indicates an expected call of DependencyBuild.

func (*MockHelmClientMockRecorder) Lint added in v0.0.17 

func (mr *MockHelmClientMockRecorder) Lint(ctx, spec any) *gomock.Call

Lint indicates an expected call of Lint.

func (*MockHelmClientMockRecorder) Template added in v0.0.17 

func (mr *MockHelmClientMockRecorder) Template(ctx, spec any) *gomock.Call

Template indicates an expected call of Template.

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 MockInsertOnlyStore added in v0.0.7 

type MockInsertOnlyStore[T any] struct {
	// contains filtered or unexported fields
}

MockInsertOnlyStore is a mock of InsertOnlyStore interface.

func NewMockInsertOnlyStore added in v0.0.7 

func NewMockInsertOnlyStore[T any](ctrl *gomock.Controller) *MockInsertOnlyStore[T]

NewMockInsertOnlyStore creates a new mock instance.

func (*MockInsertOnlyStore[T]) EXPECT added in v0.0.7 

func (m *MockInsertOnlyStore[T]) EXPECT() *MockInsertOnlyStoreMockRecorder[T]

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

func (*MockInsertOnlyStore[T]) Insert added in v0.0.7 

func (m *MockInsertOnlyStore[T]) Insert(ctx context.Context, entity *T) error

Insert mocks base method.

type MockInsertOnlyStoreMockRecorder added in v0.0.7 

type MockInsertOnlyStoreMockRecorder[T any] struct {
	// contains filtered or unexported fields
}

MockInsertOnlyStoreMockRecorder is the mock recorder for MockInsertOnlyStore.

func (*MockInsertOnlyStoreMockRecorder[T]) Insert added in v0.0.7 

func (mr *MockInsertOnlyStoreMockRecorder[T]) Insert(ctx, entity any) *gomock.Call

Insert indicates an expected call of Insert.

type MockInserter added in v0.0.7 

type MockInserter[T any] struct {
	// contains filtered or unexported fields
}

MockInserter is a mock of Inserter interface.

func NewMockInserter added in v0.0.7 

func NewMockInserter[T any](ctrl *gomock.Controller) *MockInserter[T]

NewMockInserter creates a new mock instance.

func (*MockInserter[T]) EXPECT added in v0.0.7 

func (m *MockInserter[T]) EXPECT() *MockInserterMockRecorder[T]

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

func (*MockInserter[T]) Insert added in v0.0.7 

func (m *MockInserter[T]) Insert(ctx context.Context, entity *T) error

Insert mocks base method.

type MockInserterMockRecorder added in v0.0.7 

type MockInserterMockRecorder[T any] struct {
	// contains filtered or unexported fields
}

MockInserterMockRecorder is the mock recorder for MockInserter.

func (*MockInserterMockRecorder[T]) Insert added in v0.0.7 

func (mr *MockInserterMockRecorder[T]) Insert(ctx, entity any) *gomock.Call

Insert indicates an expected call of Insert.

type MockKeyedLimiter added in v0.0.6 

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

MockKeyedLimiter is a mock of KeyedLimiter interface.

func NewMockKeyedLimiter added in v0.0.6 

func NewMockKeyedLimiter(ctrl *gomock.Controller) *MockKeyedLimiter

NewMockKeyedLimiter creates a new mock instance.

func (*MockKeyedLimiter) EXPECT added in v0.0.6 

func (m *MockKeyedLimiter) EXPECT() *MockKeyedLimiterMockRecorder

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

func (*MockKeyedLimiter) TryAcquire added in v0.0.6 

func (m *MockKeyedLimiter) TryAcquire(key string) (func(), bool)

TryAcquire mocks base method.

type MockKeyedLimiterMockRecorder added in v0.0.6 

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

MockKeyedLimiterMockRecorder is the mock recorder for MockKeyedLimiter.

func (*MockKeyedLimiterMockRecorder) TryAcquire added in v0.0.6 

func (mr *MockKeyedLimiterMockRecorder) TryAcquire(key any) *gomock.Call

TryAcquire indicates an expected call of TryAcquire.

type MockKubectlClient added in v0.0.17 

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

MockKubectlClient is a mock of KubectlClient interface.

func NewMockKubectlClient added in v0.0.17 

func NewMockKubectlClient(ctrl *gomock.Controller) *MockKubectlClient

NewMockKubectlClient creates a new mock instance.

func (*MockKubectlClient) Apply added in v0.0.17 

func (m *MockKubectlClient) Apply(ctx context.Context, ns string, files ...string) error

Apply mocks base method.

func (*MockKubectlClient) AuthCanI added in v0.0.22 

func (m *MockKubectlClient) AuthCanI(ctx context.Context, verb, resource string) (bool, error)

AuthCanI mocks base method.

func (*MockKubectlClient) CurrentContext added in v0.0.17 

func (m *MockKubectlClient) CurrentContext(ctx context.Context) (string, error)

CurrentContext mocks base method.

func (*MockKubectlClient) EXPECT added in v0.0.17 

func (m *MockKubectlClient) EXPECT() *MockKubectlClientMockRecorder

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

func (*MockKubectlClient) Get added in v0.0.17 

func (m *MockKubectlClient) Get(ctx context.Context, ns, kind, name string) ([]byte, error)

Get mocks base method.

func (*MockKubectlClient) Rollout added in v0.0.17 

func (m *MockKubectlClient) Rollout(ctx context.Context, ns, kind, name string, timeout time.Duration) error

Rollout mocks base method.

type MockKubectlClientMockRecorder added in v0.0.17 

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

MockKubectlClientMockRecorder is the mock recorder for MockKubectlClient.

func (*MockKubectlClientMockRecorder) Apply added in v0.0.17 

func (mr *MockKubectlClientMockRecorder) Apply(ctx, ns any, files ...any) *gomock.Call

Apply indicates an expected call of Apply.

func (*MockKubectlClientMockRecorder) AuthCanI added in v0.0.22 

func (mr *MockKubectlClientMockRecorder) AuthCanI(ctx, verb, resource any) *gomock.Call

AuthCanI indicates an expected call of AuthCanI.

func (*MockKubectlClientMockRecorder) CurrentContext added in v0.0.17 

func (mr *MockKubectlClientMockRecorder) CurrentContext(ctx any) *gomock.Call

CurrentContext indicates an expected call of CurrentContext.

func (*MockKubectlClientMockRecorder) Get added in v0.0.17 

func (mr *MockKubectlClientMockRecorder) Get(ctx, ns, kind, name any) *gomock.Call

Get indicates an expected call of Get.

func (*MockKubectlClientMockRecorder) Rollout added in v0.0.17 

func (mr *MockKubectlClientMockRecorder) Rollout(ctx, ns, kind, name, timeout any) *gomock.Call

Rollout indicates an expected call of Rollout.

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 MockLister added in v0.0.7 

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

MockLister is a mock of Lister interface.

func NewMockLister added in v0.0.7 

func NewMockLister[T any, P any](ctrl *gomock.Controller) *MockLister[T, P]

NewMockLister creates a new mock instance.

func (*MockLister[T, P]) EXPECT added in v0.0.7 

func (m *MockLister[T, P]) EXPECT() *MockListerMockRecorder[T, P]

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

func (*MockLister[T, P]) List added in v0.0.7 

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

List mocks base method.

type MockListerMockRecorder added in v0.0.7 

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

MockListerMockRecorder is the mock recorder for MockLister.

func (*MockListerMockRecorder[T, P]) List added in v0.0.7 

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

List indicates an expected call of List.

type MockLocker added in v0.0.4 

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

MockLocker is a mock of Locker interface.

func NewMockLocker added in v0.0.4 

func NewMockLocker(ctrl *gomock.Controller) *MockLocker

NewMockLocker creates a new mock instance.

func (*MockLocker) Acquire added in v0.0.4 

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

Acquire mocks base method.

func (*MockLocker) EXPECT added in v0.0.4 

func (m *MockLocker) EXPECT() *MockLockerMockRecorder

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

func (*MockLocker) Hold added in v0.0.4 

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

Hold mocks base method.

func (*MockLocker) Release added in v0.0.4 

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

Release mocks base method.

func (*MockLocker) Renew added in v0.0.4 

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

Renew mocks base method.

type MockLockerMockRecorder added in v0.0.4 

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

MockLockerMockRecorder is the mock recorder for MockLocker.

func (*MockLockerMockRecorder) Acquire added in v0.0.4 

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

Acquire indicates an expected call of Acquire.

func (*MockLockerMockRecorder) Hold added in v0.0.4 

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

Hold indicates an expected call of Hold.

func (*MockLockerMockRecorder) Release added in v0.0.4 

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

Release indicates an expected call of Release.

func (*MockLockerMockRecorder) Renew added in v0.0.4 

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 MockMessageConsumer added in v0.0.4 

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

MockMessageConsumer is a mock of MessageConsumer interface.

func NewMockMessageConsumer added in v0.0.4 

func NewMockMessageConsumer(ctrl *gomock.Controller) *MockMessageConsumer

NewMockMessageConsumer creates a new mock instance.

func (*MockMessageConsumer) Close added in v0.0.4 

func (m *MockMessageConsumer) Close() error

Close mocks base method.

func (*MockMessageConsumer) EXPECT added in v0.0.4 

func (m *MockMessageConsumer) EXPECT() *MockMessageConsumerMockRecorder

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

func (*MockMessageConsumer) Subscribe added in v0.0.4 

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

Subscribe mocks base method.

type MockMessageConsumerMockRecorder added in v0.0.4 

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

MockMessageConsumerMockRecorder is the mock recorder for MockMessageConsumer.

func (*MockMessageConsumerMockRecorder) Close added in v0.0.4 

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

Close indicates an expected call of Close.

func (*MockMessageConsumerMockRecorder) Subscribe added in v0.0.4 

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 MockMetricsQuerier added in v0.0.8 

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

MockMetricsQuerier is a mock of MetricsQuerier interface.

func NewMockMetricsQuerier added in v0.0.8 

func NewMockMetricsQuerier(ctrl *gomock.Controller) *MockMetricsQuerier

NewMockMetricsQuerier creates a new mock instance.

func (*MockMetricsQuerier) EXPECT added in v0.0.8 

func (m *MockMetricsQuerier) EXPECT() *MockMetricsQuerierMockRecorder

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

func (*MockMetricsQuerier) Query added in v0.0.8 

func (m *MockMetricsQuerier) Query(ctx context.Context, query string) (float64, error)

Query mocks base method.

func (*MockMetricsQuerier) QueryRange added in v0.0.8 

func (m *MockMetricsQuerier) QueryRange(ctx context.Context, query string, start, end time.Time, step time.Duration) ([]types.MetricSample, error)

QueryRange mocks base method.

type MockMetricsQuerierMockRecorder added in v0.0.8 

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

MockMetricsQuerierMockRecorder is the mock recorder for MockMetricsQuerier.

func (*MockMetricsQuerierMockRecorder) Query added in v0.0.8 

func (mr *MockMetricsQuerierMockRecorder) Query(ctx, query any) *gomock.Call

Query indicates an expected call of Query.

func (*MockMetricsQuerierMockRecorder) QueryRange added in v0.0.8 

func (mr *MockMetricsQuerierMockRecorder) QueryRange(ctx, query, start, end, step any) *gomock.Call

QueryRange indicates an expected call of QueryRange.

type MockNSResolver added in v0.0.19 

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

MockNSResolver is a mock of NSResolver interface.

func NewMockNSResolver added in v0.0.19 

func NewMockNSResolver(ctrl *gomock.Controller) *MockNSResolver

NewMockNSResolver creates a new mock instance.

func (*MockNSResolver) EXPECT added in v0.0.19 

func (m *MockNSResolver) EXPECT() *MockNSResolverMockRecorder

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

func (*MockNSResolver) LookupNS added in v0.0.19 

func (m *MockNSResolver) LookupNS(ctx context.Context, host string) ([]*net.NS, error)

LookupNS mocks base method.

type MockNSResolverMockRecorder added in v0.0.19 

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

MockNSResolverMockRecorder is the mock recorder for MockNSResolver.

func (*MockNSResolverMockRecorder) LookupNS added in v0.0.19 

func (mr *MockNSResolverMockRecorder) LookupNS(ctx, host any) *gomock.Call

LookupNS indicates an expected call of LookupNS.

type MockOperation added in v0.0.17 

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

MockOperation is a mock of Operation interface.

func NewMockOperation added in v0.0.17 

func NewMockOperation(ctrl *gomock.Controller) *MockOperation

NewMockOperation creates a new mock instance.

func (*MockOperation) Descriptor added in v0.0.17 

func (m *MockOperation) Descriptor() types.OperationDescriptor

Descriptor mocks base method.

func (*MockOperation) EXPECT added in v0.0.17 

func (m *MockOperation) EXPECT() *MockOperationMockRecorder

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

func (*MockOperation) InputSchema added in v0.0.17 

func (m *MockOperation) InputSchema() []byte

InputSchema mocks base method.

func (*MockOperation) NewInput added in v0.0.17 

func (m *MockOperation) NewInput() any

NewInput mocks base method.

func (*MockOperation) Run added in v0.0.17 

func (m *MockOperation) Run(ctx context.Context, input any, obs interfaces.ExecutionObserver) error

Run mocks base method.

type MockOperationMockRecorder added in v0.0.17 

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

MockOperationMockRecorder is the mock recorder for MockOperation.

func (*MockOperationMockRecorder) Descriptor added in v0.0.17 

func (mr *MockOperationMockRecorder) Descriptor() *gomock.Call

Descriptor indicates an expected call of Descriptor.

func (*MockOperationMockRecorder) InputSchema added in v0.0.17 

func (mr *MockOperationMockRecorder) InputSchema() *gomock.Call

InputSchema indicates an expected call of InputSchema.

func (*MockOperationMockRecorder) NewInput added in v0.0.17 

func (mr *MockOperationMockRecorder) NewInput() *gomock.Call

NewInput indicates an expected call of NewInput.

func (*MockOperationMockRecorder) Run added in v0.0.17 

func (mr *MockOperationMockRecorder) Run(ctx, input, obs any) *gomock.Call

Run indicates an expected call of Run.

type MockOutboxS3API 

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

MockOutboxS3API is a mock of API interface.

func NewMockOutboxS3API 

func NewMockOutboxS3API(ctrl *gomock.Controller) *MockOutboxS3API

NewMockOutboxS3API creates a new mock instance.

func (*MockOutboxS3API) EXPECT 

func (m *MockOutboxS3API) EXPECT() *MockOutboxS3APIMockRecorder

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

func (*MockOutboxS3API) PutObject 

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

PutObject mocks base method.

type MockOutboxS3APIMockRecorder 

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

MockOutboxS3APIMockRecorder is the mock recorder for MockOutboxS3API.

func (*MockOutboxS3APIMockRecorder) PutObject 

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

PutObject indicates an expected call of PutObject.

type MockOutboxSQSAPI 

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

MockOutboxSQSAPI is a mock of API interface.

func NewMockOutboxSQSAPI 

func NewMockOutboxSQSAPI(ctrl *gomock.Controller) *MockOutboxSQSAPI

NewMockOutboxSQSAPI creates a new mock instance.

func (*MockOutboxSQSAPI) EXPECT 

func (m *MockOutboxSQSAPI) EXPECT() *MockOutboxSQSAPIMockRecorder

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

func (*MockOutboxSQSAPI) GetQueueUrl 

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

GetQueueUrl mocks base method.

func (*MockOutboxSQSAPI) SendMessageBatch 

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

SendMessageBatch mocks base method.

type MockOutboxSQSAPIMockRecorder 

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

MockOutboxSQSAPIMockRecorder is the mock recorder for MockOutboxSQSAPI.

func (*MockOutboxSQSAPIMockRecorder) GetQueueUrl 

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

GetQueueUrl indicates an expected call of GetQueueUrl.

func (*MockOutboxSQSAPIMockRecorder) SendMessageBatch 

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

SendMessageBatch indicates an expected call of SendMessageBatch.

type MockOutboxSink 

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

MockOutboxSink is a mock of OutboxSink interface.

func NewMockOutboxSink 

func NewMockOutboxSink(ctrl *gomock.Controller) *MockOutboxSink

NewMockOutboxSink creates a new mock instance.

func (*MockOutboxSink) EXPECT 

func (m *MockOutboxSink) EXPECT() *MockOutboxSinkMockRecorder

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

func (*MockOutboxSink) Send 

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

Send mocks base method.

type MockOutboxSinkMockRecorder 

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

MockOutboxSinkMockRecorder is the mock recorder for MockOutboxSink.

func (*MockOutboxSinkMockRecorder) Send 

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

Send indicates an expected call of Send.

type MockOutboxStore 

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

MockOutboxStore is a mock of OutboxStore interface.

func NewMockOutboxStore 

func NewMockOutboxStore(ctrl *gomock.Controller) *MockOutboxStore

NewMockOutboxStore creates a new mock instance.

func (*MockOutboxStore) Claim 

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

Claim mocks base method.

func (*MockOutboxStore) DeleteSentBefore added in v0.0.7 

func (m *MockOutboxStore) DeleteSentBefore(ctx context.Context, cutoff time.Time) (int, error)

DeleteSentBefore mocks base method.

func (*MockOutboxStore) EXPECT 

func (m *MockOutboxStore) EXPECT() *MockOutboxStoreMockRecorder

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

func (*MockOutboxStore) Enqueue added in v0.0.16 

func (m *MockOutboxStore) Enqueue(ctx context.Context, rec types.OutboxRecord) error

Enqueue mocks base method.

func (*MockOutboxStore) MarkSent 

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

MarkSent mocks base method.

func (*MockOutboxStore) Park 

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

Park mocks base method.

func (*MockOutboxStore) Retry 

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

Retry mocks base method.

func (*MockOutboxStore) Stats 

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

Stats mocks base method.

type MockOutboxStoreMockRecorder 

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

MockOutboxStoreMockRecorder is the mock recorder for MockOutboxStore.

func (*MockOutboxStoreMockRecorder) Claim 

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

Claim indicates an expected call of Claim.

func (*MockOutboxStoreMockRecorder) DeleteSentBefore added in v0.0.7 

func (mr *MockOutboxStoreMockRecorder) DeleteSentBefore(ctx, cutoff any) *gomock.Call

DeleteSentBefore indicates an expected call of DeleteSentBefore.

func (*MockOutboxStoreMockRecorder) Enqueue added in v0.0.16 

func (mr *MockOutboxStoreMockRecorder) Enqueue(ctx, rec any) *gomock.Call

Enqueue indicates an expected call of Enqueue.

func (*MockOutboxStoreMockRecorder) MarkSent 

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

MarkSent indicates an expected call of MarkSent.

func (*MockOutboxStoreMockRecorder) Park 

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

Park indicates an expected call of Park.

func (*MockOutboxStoreMockRecorder) Retry 

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

Retry indicates an expected call of Retry.

func (*MockOutboxStoreMockRecorder) Stats 

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

Stats indicates an expected call of Stats.

type MockParser added in v0.0.17 

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

MockParser is a mock of Parser interface.

func NewMockParser added in v0.0.17 

func NewMockParser(ctrl *gomock.Controller) *MockParser

NewMockParser creates a new mock instance.

func (*MockParser) EXPECT added in v0.0.17 

func (m *MockParser) EXPECT() *MockParserMockRecorder

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

func (*MockParser) Parse added in v0.0.17 

func (m *MockParser) Parse(res interfaces.CmdResult) types.Verdict

Parse mocks base method.

type MockParserMockRecorder added in v0.0.17 

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

MockParserMockRecorder is the mock recorder for MockParser.

func (*MockParserMockRecorder) Parse added in v0.0.17 

func (mr *MockParserMockRecorder) Parse(res any) *gomock.Call

Parse indicates an expected call of Parse.

type MockPathResolver added in v0.0.17 

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

MockPathResolver is a mock of PathResolver interface.

func NewMockPathResolver added in v0.0.17 

func NewMockPathResolver(ctrl *gomock.Controller) *MockPathResolver

NewMockPathResolver creates a new mock instance.

func (*MockPathResolver) EXPECT added in v0.0.17 

func (m *MockPathResolver) EXPECT() *MockPathResolverMockRecorder

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

func (*MockPathResolver) LookPath added in v0.0.17 

func (m *MockPathResolver) LookPath(file string) (string, error)

LookPath mocks base method.

type MockPathResolverMockRecorder added in v0.0.17 

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

MockPathResolverMockRecorder is the mock recorder for MockPathResolver.

func (*MockPathResolverMockRecorder) LookPath added in v0.0.17 

func (mr *MockPathResolverMockRecorder) LookPath(file any) *gomock.Call

LookPath indicates an expected call of LookPath.

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 MockProbe added in v0.0.17 

type MockProbe[T any] struct {
	// contains filtered or unexported fields
}

MockProbe is a mock of Probe interface.

func NewMockProbe added in v0.0.17 

func NewMockProbe[T any](ctrl *gomock.Controller) *MockProbe[T]

NewMockProbe creates a new mock instance.

func (*MockProbe[T]) EXPECT added in v0.0.17 

func (m *MockProbe[T]) EXPECT() *MockProbeMockRecorder[T]

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

func (*MockProbe[T]) Name added in v0.0.17 

func (m *MockProbe[T]) Name() string

Name mocks base method.

func (*MockProbe[T]) Run added in v0.0.17 

func (m *MockProbe[T]) Run(ctx context.Context, target T) types.Verdict

Run mocks base method.

type MockProbeMockRecorder added in v0.0.17 

type MockProbeMockRecorder[T any] struct {
	// contains filtered or unexported fields
}

MockProbeMockRecorder is the mock recorder for MockProbe.

func (*MockProbeMockRecorder[T]) Name added in v0.0.17 

func (mr *MockProbeMockRecorder[T]) Name() *gomock.Call

Name indicates an expected call of Name.

func (*MockProbeMockRecorder[T]) Run added in v0.0.17 

func (mr *MockProbeMockRecorder[T]) Run(ctx, target any) *gomock.Call

Run indicates an expected call of Run.

type MockProbeSet added in v0.0.17 

type MockProbeSet[T any] struct {
	// contains filtered or unexported fields
}

MockProbeSet is a mock of ProbeSet interface.

func NewMockProbeSet added in v0.0.17 

func NewMockProbeSet[T any](ctrl *gomock.Controller) *MockProbeSet[T]

NewMockProbeSet creates a new mock instance.

func (*MockProbeSet[T]) EXPECT added in v0.0.17 

func (m *MockProbeSet[T]) EXPECT() *MockProbeSetMockRecorder[T]

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

func (*MockProbeSet[T]) Run added in v0.0.17 

func (m *MockProbeSet[T]) Run(ctx context.Context, target T) (types.StepResults, error)

Run mocks base method.

type MockProbeSetMockRecorder added in v0.0.17 

type MockProbeSetMockRecorder[T any] struct {
	// contains filtered or unexported fields
}

MockProbeSetMockRecorder is the mock recorder for MockProbeSet.

func (*MockProbeSetMockRecorder[T]) Run added in v0.0.17 

func (mr *MockProbeSetMockRecorder[T]) Run(ctx, target any) *gomock.Call

Run indicates an expected call of Run.

type MockProcedureRunner added in v0.0.19 

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

MockProcedureRunner is a mock of ProcedureRunner interface.

func NewMockProcedureRunner added in v0.0.19 

func NewMockProcedureRunner(ctrl *gomock.Controller) *MockProcedureRunner

NewMockProcedureRunner creates a new mock instance.

func (*MockProcedureRunner) EXPECT added in v0.0.19 

func (m *MockProcedureRunner) EXPECT() *MockProcedureRunnerMockRecorder

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

func (*MockProcedureRunner) Run added in v0.0.19 

func (m *MockProcedureRunner) Run(ctx context.Context, name string, input map[string]any, opts types.RunOptions) (types.StepResults, error)

Run mocks base method.

type MockProcedureRunnerMockRecorder added in v0.0.19 

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

MockProcedureRunnerMockRecorder is the mock recorder for MockProcedureRunner.

func (*MockProcedureRunnerMockRecorder) Run added in v0.0.19 

func (mr *MockProcedureRunnerMockRecorder) Run(ctx, name, input, opts any) *gomock.Call

Run indicates an expected call of Run.

type MockProcessHandle added in v0.0.17 

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

MockProcessHandle is a mock of ProcessHandle interface.

func NewMockProcessHandle added in v0.0.17 

func NewMockProcessHandle(ctrl *gomock.Controller) *MockProcessHandle

NewMockProcessHandle creates a new mock instance.

func (*MockProcessHandle) EXPECT added in v0.0.17 

func (m *MockProcessHandle) EXPECT() *MockProcessHandleMockRecorder

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

func (*MockProcessHandle) Stop added in v0.0.17 

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

Stop mocks base method.

func (*MockProcessHandle) Wait added in v0.0.17 

func (m *MockProcessHandle) Wait() error

Wait mocks base method.

type MockProcessHandleMockRecorder added in v0.0.17 

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

MockProcessHandleMockRecorder is the mock recorder for MockProcessHandle.

func (*MockProcessHandleMockRecorder) Stop added in v0.0.17 

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

Stop indicates an expected call of Stop.

func (*MockProcessHandleMockRecorder) Wait added in v0.0.17 

func (mr *MockProcessHandleMockRecorder) Wait() *gomock.Call

Wait indicates an expected call of Wait.

type MockPrometheusHTTPDoer 

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

MockPrometheusHTTPDoer is a mock of HTTPDoer interface.

func NewMockPrometheusHTTPDoer 

func NewMockPrometheusHTTPDoer(ctrl *gomock.Controller) *MockPrometheusHTTPDoer

NewMockPrometheusHTTPDoer creates a new mock instance.

func (*MockPrometheusHTTPDoer) Do 

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

Do mocks base method.

func (*MockPrometheusHTTPDoer) EXPECT 

func (m *MockPrometheusHTTPDoer) EXPECT() *MockPrometheusHTTPDoerMockRecorder

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

type MockPrometheusHTTPDoerMockRecorder 

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

MockPrometheusHTTPDoerMockRecorder is the mock recorder for MockPrometheusHTTPDoer.

func (*MockPrometheusHTTPDoerMockRecorder) Do 

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

Do indicates an expected call of Do.

type MockPrompter added in v0.0.17 

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

MockPrompter is a mock of Prompter interface.

func NewMockPrompter added in v0.0.17 

func NewMockPrompter(ctrl *gomock.Controller) *MockPrompter

NewMockPrompter creates a new mock instance.

func (*MockPrompter) Confirm added in v0.0.17 

func (m *MockPrompter) Confirm(ctx context.Context, question string) (bool, error)

Confirm mocks base method.

func (*MockPrompter) EXPECT added in v0.0.17 

func (m *MockPrompter) EXPECT() *MockPrompterMockRecorder

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

type MockPrompterMockRecorder added in v0.0.17 

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

MockPrompterMockRecorder is the mock recorder for MockPrompter.

func (*MockPrompterMockRecorder) Confirm added in v0.0.17 

func (mr *MockPrompterMockRecorder) Confirm(ctx, question any) *gomock.Call

Confirm indicates an expected call of Confirm.

type MockPurger added in v0.0.16 

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

MockPurger is a mock of Purger interface.

func NewMockPurger added in v0.0.16 

func NewMockPurger(ctrl *gomock.Controller) *MockPurger

NewMockPurger creates a new mock instance.

func (*MockPurger) EXPECT added in v0.0.16 

func (m *MockPurger) EXPECT() *MockPurgerMockRecorder

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

func (*MockPurger) PurgeBefore added in v0.0.16 

func (m *MockPurger) PurgeBefore(ctx context.Context, cutoff time.Time) (int, error)

PurgeBefore mocks base method.

type MockPurgerMockRecorder added in v0.0.16 

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

MockPurgerMockRecorder is the mock recorder for MockPurger.

func (*MockPurgerMockRecorder) PurgeBefore added in v0.0.16 

func (mr *MockPurgerMockRecorder) PurgeBefore(ctx, cutoff any) *gomock.Call

PurgeBefore indicates an expected call of PurgeBefore.

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 MockReadListExistStore added in v0.0.7 

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

MockReadListExistStore is a mock of ReadListExistStore interface.

func NewMockReadListExistStore added in v0.0.7 

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

NewMockReadListExistStore creates a new mock instance.

func (*MockReadListExistStore[T, P, ID]) EXPECT added in v0.0.7 

func (m *MockReadListExistStore[T, P, ID]) EXPECT() *MockReadListExistStoreMockRecorder[T, P, ID]

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

func (*MockReadListExistStore[T, P, ID]) Exists added in v0.0.7 

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

Exists mocks base method.

func (*MockReadListExistStore[T, P, ID]) Get added in v0.0.7 

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

Get mocks base method.

func (*MockReadListExistStore[T, P, ID]) List added in v0.0.7 

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

List mocks base method.

type MockReadListExistStoreMockRecorder added in v0.0.7 

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

MockReadListExistStoreMockRecorder is the mock recorder for MockReadListExistStore.

func (*MockReadListExistStoreMockRecorder[T, P, ID]) Exists added in v0.0.7 

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

Exists indicates an expected call of Exists.

func (*MockReadListExistStoreMockRecorder[T, P, ID]) Get added in v0.0.7 

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

Get indicates an expected call of Get.

func (*MockReadListExistStoreMockRecorder[T, P, ID]) List added in v0.0.7 

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

List indicates an expected call of List.

type MockReader added in v0.0.7 

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

MockReader is a mock of Reader interface.

func NewMockReader added in v0.0.7 

func NewMockReader[T any, ID comparable](ctrl *gomock.Controller) *MockReader[T, ID]

NewMockReader creates a new mock instance.

func (*MockReader[T, ID]) EXPECT added in v0.0.7 

func (m *MockReader[T, ID]) EXPECT() *MockReaderMockRecorder[T, ID]

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

func (*MockReader[T, ID]) Get added in v0.0.7 

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

Get mocks base method.

type MockReaderMockRecorder added in v0.0.7 

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

MockReaderMockRecorder is the mock recorder for MockReader.

func (*MockReaderMockRecorder[T, ID]) Get added in v0.0.7 

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

Get indicates an expected call of Get.

type MockRenderer added in v0.0.17 

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

MockRenderer is a mock of Renderer interface.

func NewMockRenderer added in v0.0.17 

func NewMockRenderer(ctrl *gomock.Controller) *MockRenderer

NewMockRenderer creates a new mock instance.

func (*MockRenderer) EXPECT added in v0.0.17 

func (m *MockRenderer) EXPECT() *MockRendererMockRecorder

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

func (*MockRenderer) Render added in v0.0.17 

func (m *MockRenderer) Render(ctx context.Context, spec types.RenderSpec) ([]types.Object, error)

Render mocks base method.

type MockRendererMockRecorder added in v0.0.17 

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

MockRendererMockRecorder is the mock recorder for MockRenderer.

func (*MockRendererMockRecorder) Render added in v0.0.17 

func (mr *MockRendererMockRecorder) Render(ctx, spec any) *gomock.Call

Render indicates an expected call of Render.

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 added in v0.0.4 

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

MockRepository is a mock of Repository interface.

func NewMockRepository added in v0.0.4 

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 added in v0.0.4 

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

Create mocks base method.

func (*MockRepository[T, P, ID]) Delete added in v0.0.4 

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

Delete mocks base method.

func (*MockRepository[T, P, ID]) EXPECT added in v0.0.4 

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 added in v0.0.4 

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

Exists mocks base method.

func (*MockRepository[T, P, ID]) Get added in v0.0.4 

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

Get mocks base method.

func (*MockRepository[T, P, ID]) List added in v0.0.4 

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 added in v0.0.4 

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

Update mocks base method.

type MockRepositoryMockRecorder added in v0.0.4 

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 added in v0.0.4 

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

Create indicates an expected call of Create.

func (*MockRepositoryMockRecorder[T, P, ID]) Delete added in v0.0.4 

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 added in v0.0.4 

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 added in v0.0.4 

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 added in v0.0.4 

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 added in v0.0.4 

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

Update indicates an expected call of Update.

type MockReservation added in v0.0.17 

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

MockReservation is a mock of Reservation interface.

func NewMockReservation added in v0.0.17 

func NewMockReservation(ctrl *gomock.Controller) *MockReservation

NewMockReservation creates a new mock instance.

func (*MockReservation) EXPECT added in v0.0.17 

func (m *MockReservation) EXPECT() *MockReservationMockRecorder

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

func (*MockReservation) Release added in v0.0.17 

func (m *MockReservation) Release()

Release mocks base method.

func (*MockReservation) Run added in v0.0.17 

func (m *MockReservation) Run(ctx context.Context, input any, obs interfaces.ExecutionObserver) error

Run mocks base method.

type MockReservationMockRecorder added in v0.0.17 

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

MockReservationMockRecorder is the mock recorder for MockReservation.

func (*MockReservationMockRecorder) Release added in v0.0.17 

func (mr *MockReservationMockRecorder) Release() *gomock.Call

Release indicates an expected call of Release.

func (*MockReservationMockRecorder) Run added in v0.0.17 

func (mr *MockReservationMockRecorder) Run(ctx, input, obs any) *gomock.Call

Run indicates an expected call of Run.

type MockResource added in v0.0.11 

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

MockResource is a mock of Resource interface.

func NewMockResource added in v0.0.11 

func NewMockResource[T any, P any, ID comparable, C any, U any](ctrl *gomock.Controller) *MockResource[T, P, ID, C, U]

NewMockResource creates a new mock instance.

func (*MockResource[T, P, ID, C, U]) Create added in v0.0.11 

func (m *MockResource[T, P, ID, C, U]) Create(ctx context.Context, in C) (*T, error)

Create mocks base method.

func (*MockResource[T, P, ID, C, U]) Delete added in v0.0.11 

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

Delete mocks base method.

func (*MockResource[T, P, ID, C, U]) EXPECT added in v0.0.11 

func (m *MockResource[T, P, ID, C, U]) EXPECT() *MockResourceMockRecorder[T, P, ID, C, U]

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

func (*MockResource[T, P, ID, C, U]) Exists added in v0.0.11 

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

Exists mocks base method.

func (*MockResource[T, P, ID, C, U]) Get added in v0.0.11 

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

Get mocks base method.

func (*MockResource[T, P, ID, C, U]) List added in v0.0.11 

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

List mocks base method.

func (*MockResource[T, P, ID, C, U]) Update added in v0.0.11 

func (m *MockResource[T, P, ID, C, U]) Update(ctx context.Context, id ID, in U) (*T, error)

Update mocks base method.

type MockResourceMockRecorder added in v0.0.11 

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

MockResourceMockRecorder is the mock recorder for MockResource.

func (*MockResourceMockRecorder[T, P, ID, C, U]) Create added in v0.0.11 

func (mr *MockResourceMockRecorder[T, P, ID, C, U]) Create(ctx, in any) *gomock.Call

Create indicates an expected call of Create.

func (*MockResourceMockRecorder[T, P, ID, C, U]) Delete added in v0.0.11 

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

Delete indicates an expected call of Delete.

func (*MockResourceMockRecorder[T, P, ID, C, U]) Exists added in v0.0.11 

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

Exists indicates an expected call of Exists.

func (*MockResourceMockRecorder[T, P, ID, C, U]) Get added in v0.0.11 

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

Get indicates an expected call of Get.

func (*MockResourceMockRecorder[T, P, ID, C, U]) List added in v0.0.11 

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

List indicates an expected call of List.

func (*MockResourceMockRecorder[T, P, ID, C, U]) Update added in v0.0.11 

func (mr *MockResourceMockRecorder[T, P, ID, C, U]) Update(ctx, id, in 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 MockRowStream 

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

MockRowStream is a mock of RowStream interface.

func NewMockRowStream 

func NewMockRowStream(ctrl *gomock.Controller) *MockRowStream

NewMockRowStream creates a new mock instance.

func (*MockRowStream) Close 

func (m *MockRowStream) Close() error

Close mocks base method.

func (*MockRowStream) EXPECT 

func (m *MockRowStream) EXPECT() *MockRowStreamMockRecorder

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

func (*MockRowStream) Next 

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

Next mocks base method.

func (*MockRowStream) ResumeToken 

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

ResumeToken mocks base method.

type MockRowStreamMockRecorder 

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

MockRowStreamMockRecorder is the mock recorder for MockRowStream.

func (*MockRowStreamMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockRowStreamMockRecorder) Next 

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

Next indicates an expected call of Next.

func (*MockRowStreamMockRecorder) ResumeToken 

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

ResumeToken indicates an expected call of ResumeToken.

type MockS3API 

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

MockS3API is a mock of S3API interface.

func NewMockS3API 

func NewMockS3API(ctrl *gomock.Controller) *MockS3API

NewMockS3API creates a new mock instance.

func (*MockS3API) AbortMultipartUpload 

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

AbortMultipartUpload mocks base method.

func (*MockS3API) CompleteMultipartUpload 

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

CompleteMultipartUpload mocks base method.

func (*MockS3API) CreateBucket 

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

CreateBucket mocks base method.

func (*MockS3API) CreateMultipartUpload 

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

CreateMultipartUpload mocks base method.

func (*MockS3API) DeleteObject 

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

DeleteObject mocks base method.

func (*MockS3API) DeleteObjects 

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

DeleteObjects mocks base method.

func (*MockS3API) EXPECT 

func (m *MockS3API) EXPECT() *MockS3APIMockRecorder

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

func (*MockS3API) GetObject 

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

GetObject mocks base method.

func (*MockS3API) HeadBucket 

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

HeadBucket mocks base method.

func (*MockS3API) HeadObject 

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

HeadObject mocks base method.

func (*MockS3API) ListMultipartUploads 

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

ListMultipartUploads mocks base method.

func (*MockS3API) ListObjectsV2 

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

ListObjectsV2 mocks base method.

func (*MockS3API) PutObject 

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

PutObject mocks base method.

func (*MockS3API) UploadPart 

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

UploadPart mocks base method.

type MockS3APIMockRecorder 

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

MockS3APIMockRecorder is the mock recorder for MockS3API.

func (*MockS3APIMockRecorder) AbortMultipartUpload 

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

AbortMultipartUpload indicates an expected call of AbortMultipartUpload.

func (*MockS3APIMockRecorder) CompleteMultipartUpload 

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

CompleteMultipartUpload indicates an expected call of CompleteMultipartUpload.

func (*MockS3APIMockRecorder) CreateBucket 

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

CreateBucket indicates an expected call of CreateBucket.

func (*MockS3APIMockRecorder) CreateMultipartUpload 

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

CreateMultipartUpload indicates an expected call of CreateMultipartUpload.

func (*MockS3APIMockRecorder) DeleteObject 

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

DeleteObject indicates an expected call of DeleteObject.

func (*MockS3APIMockRecorder) DeleteObjects 

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

DeleteObjects indicates an expected call of DeleteObjects.

func (*MockS3APIMockRecorder) GetObject 

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

GetObject indicates an expected call of GetObject.

func (*MockS3APIMockRecorder) HeadBucket 

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

HeadBucket indicates an expected call of HeadBucket.

func (*MockS3APIMockRecorder) HeadObject 

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

HeadObject indicates an expected call of HeadObject.

func (*MockS3APIMockRecorder) ListMultipartUploads 

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

ListMultipartUploads indicates an expected call of ListMultipartUploads.

func (*MockS3APIMockRecorder) ListObjectsV2 

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

ListObjectsV2 indicates an expected call of ListObjectsV2.

func (*MockS3APIMockRecorder) PutObject 

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

PutObject indicates an expected call of PutObject.

func (*MockS3APIMockRecorder) UploadPart 

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

UploadPart indicates an expected call of UploadPart.

type MockSecretsManagerAPI 

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

MockSecretsManagerAPI is a mock of SecretsManagerAPI interface.

func NewMockSecretsManagerAPI 

func NewMockSecretsManagerAPI(ctrl *gomock.Controller) *MockSecretsManagerAPI

NewMockSecretsManagerAPI creates a new mock instance.

func (*MockSecretsManagerAPI) EXPECT 

func (m *MockSecretsManagerAPI) EXPECT() *MockSecretsManagerAPIMockRecorder

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

func (*MockSecretsManagerAPI) GetSecretValue 

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

GetSecretValue mocks base method.

type MockSecretsManagerAPIMockRecorder 

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

MockSecretsManagerAPIMockRecorder is the mock recorder for MockSecretsManagerAPI.

func (*MockSecretsManagerAPIMockRecorder) GetSecretValue 

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

GetSecretValue indicates an expected call of GetSecretValue.

type MockService 

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

MockService is a mock of Service interface.

func NewMockService 

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

NewMockService creates a new mock instance.

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

func (m *MockService[T, P, ID]) Create(ctx context.Context, in *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, in *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, in 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, in any) *gomock.Call

Update indicates an expected call of Update.

type MockSource added in v0.0.4 

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

MockSource is a mock of Source interface.

func NewMockSource added in v0.0.4 

func NewMockSource(ctrl *gomock.Controller) *MockSource

NewMockSource creates a new mock instance.

func (*MockSource) EXPECT added in v0.0.4 

func (m *MockSource) EXPECT() *MockSourceMockRecorder

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

func (*MockSource) Get added in v0.0.4 

func (m *MockSource) Get(ctx context.Context, ref types.Ref) (types.Secret, error)

Get mocks base method.

func (*MockSource) Put added in v0.0.4 

func (m *MockSource) Put(ctx context.Context, ref types.Ref, value types.Secret) error

Put mocks base method.

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 MockSourceMockRecorder added in v0.0.4 

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

MockSourceMockRecorder is the mock recorder for MockSource.

func (*MockSourceMockRecorder) Get added in v0.0.4 

func (mr *MockSourceMockRecorder) Get(ctx, ref any) *gomock.Call

Get indicates an expected call of Get.

func (*MockSourceMockRecorder) Put added in v0.0.4 

func (mr *MockSourceMockRecorder) Put(ctx, ref, value any) *gomock.Call

Put indicates an expected call of Put.

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 MockStepCache added in v0.0.17 

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

MockStepCache is a mock of StepCache interface.

func NewMockStepCache added in v0.0.17 

func NewMockStepCache(ctrl *gomock.Controller) *MockStepCache

NewMockStepCache creates a new mock instance.

func (*MockStepCache) EXPECT added in v0.0.17 

func (m *MockStepCache) EXPECT() *MockStepCacheMockRecorder

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

func (*MockStepCache) Hit added in v0.0.17 

func (m *MockStepCache) Hit(ctx context.Context, key string) (bool, error)

Hit mocks base method.

func (*MockStepCache) Record added in v0.0.17 

func (m *MockStepCache) Record(ctx context.Context, key string) error

Record mocks base method.

type MockStepCacheMockRecorder added in v0.0.17 

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

MockStepCacheMockRecorder is the mock recorder for MockStepCache.

func (*MockStepCacheMockRecorder) Hit added in v0.0.17 

func (mr *MockStepCacheMockRecorder) Hit(ctx, key any) *gomock.Call

Hit indicates an expected call of Hit.

func (*MockStepCacheMockRecorder) Record added in v0.0.17 

func (mr *MockStepCacheMockRecorder) Record(ctx, key any) *gomock.Call

Record indicates an expected call of Record.

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, in *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, in *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, in 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, in any) *gomock.Call

Update indicates an expected call of Update.

type MockStream added in v0.0.3 

type MockStream[T any] struct {
	// contains filtered or unexported fields
}

MockStream is a mock of Stream interface.

func NewMockStream added in v0.0.3 

func NewMockStream[T any](ctrl *gomock.Controller) *MockStream[T]

NewMockStream creates a new mock instance.

func (*MockStream[T]) Close added in v0.0.3 

func (m *MockStream[T]) Close() error

Close mocks base method.

func (*MockStream[T]) EXPECT added in v0.0.3 

func (m *MockStream[T]) EXPECT() *MockStreamMockRecorder[T]

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

func (*MockStream[T]) Next added in v0.0.3 

func (m *MockStream[T]) Next(ctx context.Context) (T, bool, error)

Next mocks base method.

type MockStreamMockRecorder added in v0.0.3 

type MockStreamMockRecorder[T any] struct {
	// contains filtered or unexported fields
}

MockStreamMockRecorder is the mock recorder for MockStream.

func (*MockStreamMockRecorder[T]) Close added in v0.0.3 

func (mr *MockStreamMockRecorder[T]) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockStreamMockRecorder[T]) Next added in v0.0.3 

func (mr *MockStreamMockRecorder[T]) Next(ctx any) *gomock.Call

Next indicates an expected call of Next.

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 MockSuggester added in v0.0.11 

type MockSuggester[P any] struct {
	// contains filtered or unexported fields
}

MockSuggester is a mock of Suggester interface.

func NewMockSuggester added in v0.0.11 

func NewMockSuggester[P any](ctrl *gomock.Controller) *MockSuggester[P]

NewMockSuggester creates a new mock instance.

func (*MockSuggester[P]) EXPECT added in v0.0.11 

func (m *MockSuggester[P]) EXPECT() *MockSuggesterMockRecorder[P]

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

func (*MockSuggester[P]) SuggestValues added in v0.0.11 

func (m *MockSuggester[P]) SuggestValues(ctx context.Context, params P) (*types.Page[string], error)

SuggestValues mocks base method.

type MockSuggesterMockRecorder added in v0.0.11 

type MockSuggesterMockRecorder[P any] struct {
	// contains filtered or unexported fields
}

MockSuggesterMockRecorder is the mock recorder for MockSuggester.

func (*MockSuggesterMockRecorder[P]) SuggestValues added in v0.0.11 

func (mr *MockSuggesterMockRecorder[P]) SuggestValues(ctx, params any) *gomock.Call

SuggestValues indicates an expected call of SuggestValues.

type MockSupervisor added in v0.0.17 

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

MockSupervisor is a mock of Supervisor interface.

func NewMockSupervisor added in v0.0.17 

func NewMockSupervisor(ctrl *gomock.Controller) *MockSupervisor

NewMockSupervisor creates a new mock instance.

func (*MockSupervisor) Detach added in v0.0.17 

func (m *MockSupervisor) Detach(spec types.ProcessSpec) error

Detach mocks base method.

func (*MockSupervisor) EXPECT added in v0.0.17 

func (m *MockSupervisor) EXPECT() *MockSupervisorMockRecorder

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

func (*MockSupervisor) Start added in v0.0.17 

func (m *MockSupervisor) Start(ctx context.Context, spec types.ProcessSpec, ready interfaces.Probe[interfaces.ProcessHandle]) (interfaces.ProcessHandle, error)

Start mocks base method.

func (*MockSupervisor) StopAll added in v0.0.17 

func (m *MockSupervisor) StopAll(ctx context.Context) error

StopAll mocks base method.

type MockSupervisorMockRecorder added in v0.0.17 

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

MockSupervisorMockRecorder is the mock recorder for MockSupervisor.

func (*MockSupervisorMockRecorder) Detach added in v0.0.17 

func (mr *MockSupervisorMockRecorder) Detach(spec any) *gomock.Call

Detach indicates an expected call of Detach.

func (*MockSupervisorMockRecorder) Start added in v0.0.17 

func (mr *MockSupervisorMockRecorder) Start(ctx, spec, ready any) *gomock.Call

Start indicates an expected call of Start.

func (*MockSupervisorMockRecorder) StopAll added in v0.0.17 

func (mr *MockSupervisorMockRecorder) StopAll(ctx any) *gomock.Call

StopAll indicates an expected call of StopAll.

type MockTargetSelector added in v0.0.17 

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

MockTargetSelector is a mock of TargetSelector interface.

func NewMockTargetSelector added in v0.0.17 

func NewMockTargetSelector(ctrl *gomock.Controller) *MockTargetSelector

NewMockTargetSelector creates a new mock instance.

func (*MockTargetSelector) EXPECT added in v0.0.17 

func (m *MockTargetSelector) EXPECT() *MockTargetSelectorMockRecorder

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

func (*MockTargetSelector) Select added in v0.0.17 

func (m *MockTargetSelector) Select(ctx context.Context, cb interfaces.Codebase, spec types.TargetSpec) ([]string, error)

Select mocks base method.

type MockTargetSelectorMockRecorder added in v0.0.17 

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

MockTargetSelectorMockRecorder is the mock recorder for MockTargetSelector.

func (*MockTargetSelectorMockRecorder) Select added in v0.0.17 

func (mr *MockTargetSelectorMockRecorder) Select(ctx, cb, spec any) *gomock.Call

Select indicates an expected call of Select.

type MockTerraformClient added in v0.0.17 

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

MockTerraformClient is a mock of TerraformClient interface.

func NewMockTerraformClient added in v0.0.17 

func NewMockTerraformClient(ctrl *gomock.Controller) *MockTerraformClient

NewMockTerraformClient creates a new mock instance.

func (*MockTerraformClient) Apply added in v0.0.17 

func (m *MockTerraformClient) Apply(ctx context.Context, dir, planFile string) error

Apply mocks base method.

func (*MockTerraformClient) EXPECT added in v0.0.17 

func (m *MockTerraformClient) EXPECT() *MockTerraformClientMockRecorder

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

func (*MockTerraformClient) Init added in v0.0.17 

func (m *MockTerraformClient) Init(ctx context.Context, dir string) error

Init mocks base method.

func (*MockTerraformClient) Plan added in v0.0.17 

func (m *MockTerraformClient) Plan(ctx context.Context, dir, out string) (types.Plan, error)

Plan mocks base method.

func (*MockTerraformClient) Show added in v0.0.17 

func (m *MockTerraformClient) Show(ctx context.Context, dir, planFile string) (types.Plan, error)

Show mocks base method.

type MockTerraformClientMockRecorder added in v0.0.17 

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

MockTerraformClientMockRecorder is the mock recorder for MockTerraformClient.

func (*MockTerraformClientMockRecorder) Apply added in v0.0.17 

func (mr *MockTerraformClientMockRecorder) Apply(ctx, dir, planFile any) *gomock.Call

Apply indicates an expected call of Apply.

func (*MockTerraformClientMockRecorder) Init added in v0.0.17 

func (mr *MockTerraformClientMockRecorder) Init(ctx, dir any) *gomock.Call

Init indicates an expected call of Init.

func (*MockTerraformClientMockRecorder) Plan added in v0.0.17 

func (mr *MockTerraformClientMockRecorder) Plan(ctx, dir, out any) *gomock.Call

Plan indicates an expected call of Plan.

func (*MockTerraformClientMockRecorder) Show added in v0.0.17 

func (mr *MockTerraformClientMockRecorder) Show(ctx, dir, planFile any) *gomock.Call

Show indicates an expected call of Show.

type MockToolRunner added in v0.0.17 

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

MockToolRunner is a mock of ToolRunner interface.

func NewMockToolRunner added in v0.0.17 

func NewMockToolRunner(ctrl *gomock.Controller) *MockToolRunner

NewMockToolRunner creates a new mock instance.

func (*MockToolRunner) EXPECT added in v0.0.17 

func (m *MockToolRunner) EXPECT() *MockToolRunnerMockRecorder

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

func (*MockToolRunner) Run added in v0.0.17 

func (m *MockToolRunner) Run(ctx context.Context, cb interfaces.Codebase, run types.ToolRun, opts types.RunOptions) (types.StepResults, error)

Run mocks base method.

type MockToolRunnerMockRecorder added in v0.0.17 

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

MockToolRunnerMockRecorder is the mock recorder for MockToolRunner.

func (*MockToolRunnerMockRecorder) Run added in v0.0.17 

func (mr *MockToolRunnerMockRecorder) Run(ctx, cb, run, opts any) *gomock.Call

Run indicates an expected call of Run.

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 added in v0.0.4 

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

MockTransaction is a mock of Transaction interface.

func NewMockTransaction added in v0.0.4 

func NewMockTransaction(ctrl *gomock.Controller) *MockTransaction

NewMockTransaction creates a new mock instance.

func (*MockTransaction) Commit added in v0.0.4 

func (m *MockTransaction) Commit() error

Commit mocks base method.

func (*MockTransaction) EXPECT added in v0.0.4 

func (m *MockTransaction) EXPECT() *MockTransactionMockRecorder

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

func (*MockTransaction) Rollback added in v0.0.4 

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 added in v0.0.4 

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

MockTransactionMockRecorder is the mock recorder for MockTransaction.

func (*MockTransactionMockRecorder) Commit added in v0.0.4 

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

Commit indicates an expected call of Commit.

func (*MockTransactionMockRecorder) Rollback added in v0.0.4 

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

Rollback indicates an expected call of Rollback.

type MockUpdater added in v0.0.7 

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

MockUpdater is a mock of Updater interface.

func NewMockUpdater added in v0.0.7 

func NewMockUpdater[T any, ID comparable, U any](ctrl *gomock.Controller) *MockUpdater[T, ID, U]

NewMockUpdater creates a new mock instance.

func (*MockUpdater[T, ID, U]) EXPECT added in v0.0.7 

func (m *MockUpdater[T, ID, U]) EXPECT() *MockUpdaterMockRecorder[T, ID, U]

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

func (*MockUpdater[T, ID, U]) Update added in v0.0.7 

func (m *MockUpdater[T, ID, U]) Update(ctx context.Context, id ID, in U) (*T, error)

Update mocks base method.

type MockUpdaterMockRecorder added in v0.0.7 

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

MockUpdaterMockRecorder is the mock recorder for MockUpdater.

func (*MockUpdaterMockRecorder[T, ID, U]) Update added in v0.0.7 

func (mr *MockUpdaterMockRecorder[T, ID, U]) Update(ctx, id, in any) *gomock.Call

Update indicates an expected call of Update.

type MockUpserter added in v0.0.16 

type MockUpserter[T any] struct {
	// contains filtered or unexported fields
}

MockUpserter is a mock of Upserter interface.

func NewMockUpserter added in v0.0.16 

func NewMockUpserter[T any](ctrl *gomock.Controller) *MockUpserter[T]

NewMockUpserter creates a new mock instance.

func (*MockUpserter[T]) EXPECT added in v0.0.16 

func (m *MockUpserter[T]) EXPECT() *MockUpserterMockRecorder[T]

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

func (*MockUpserter[T]) Upsert added in v0.0.16 

func (m *MockUpserter[T]) Upsert(ctx context.Context, entity *T) error

Upsert mocks base method.

type MockUpserterMockRecorder added in v0.0.16 

type MockUpserterMockRecorder[T any] struct {
	// contains filtered or unexported fields
}

MockUpserterMockRecorder is the mock recorder for MockUpserter.

func (*MockUpserterMockRecorder[T]) Upsert added in v0.0.16 

func (mr *MockUpserterMockRecorder[T]) Upsert(ctx, entity any) *gomock.Call

Upsert indicates an expected call of Upsert.

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.

type MockWriter added in v0.0.7 

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

MockWriter is a mock of Writer interface.

func NewMockWriter added in v0.0.7 

func NewMockWriter[T any, ID comparable](ctrl *gomock.Controller) *MockWriter[T, ID]

NewMockWriter creates a new mock instance.

func (*MockWriter[T, ID]) Create added in v0.0.7 

func (m *MockWriter[T, ID]) Create(ctx context.Context, in *T) (*T, error)

Create mocks base method.

func (*MockWriter[T, ID]) EXPECT added in v0.0.7 

func (m *MockWriter[T, ID]) EXPECT() *MockWriterMockRecorder[T, ID]

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

func (*MockWriter[T, ID]) Update added in v0.0.7 

func (m *MockWriter[T, ID]) Update(ctx context.Context, id ID, in *T) (*T, error)

Update mocks base method.

type MockWriterMockRecorder added in v0.0.7 

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

MockWriterMockRecorder is the mock recorder for MockWriter.

func (*MockWriterMockRecorder[T, ID]) Create added in v0.0.7 

func (mr *MockWriterMockRecorder[T, ID]) Create(ctx, in any) *gomock.Call

Create indicates an expected call of Create.

func (*MockWriterMockRecorder[T, ID]) Update added in v0.0.7 

func (mr *MockWriterMockRecorder[T, ID]) Update(ctx, id, in any) *gomock.Call

Update indicates an expected call of Update.

type MockYAMLView added in v0.0.17 

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

MockYAMLView is a mock of YAMLView interface.

func NewMockYAMLView added in v0.0.17 

func NewMockYAMLView(ctrl *gomock.Controller) *MockYAMLView

NewMockYAMLView creates a new mock instance.

func (*MockYAMLView) Decode added in v0.0.17 

func (m *MockYAMLView) Decode(ctx context.Context, doc types.YAMLDoc, out any) error

Decode mocks base method.

func (*MockYAMLView) Docs added in v0.0.17 

func (m *MockYAMLView) Docs(ctx context.Context, sel types.FileSelector) ([]types.YAMLDoc, error)

Docs mocks base method.

func (*MockYAMLView) EXPECT added in v0.0.17 

func (m *MockYAMLView) EXPECT() *MockYAMLViewMockRecorder

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

func (*MockYAMLView) Query added in v0.0.17 

func (m *MockYAMLView) Query(ctx context.Context, doc types.YAMLDoc, path string) ([]types.YAMLMatch, error)

Query mocks base method.

type MockYAMLViewMockRecorder added in v0.0.17 

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

MockYAMLViewMockRecorder is the mock recorder for MockYAMLView.

func (*MockYAMLViewMockRecorder) Decode added in v0.0.17 

func (mr *MockYAMLViewMockRecorder) Decode(ctx, doc, out any) *gomock.Call

Decode indicates an expected call of Decode.

func (*MockYAMLViewMockRecorder) Docs added in v0.0.17 

func (mr *MockYAMLViewMockRecorder) Docs(ctx, sel any) *gomock.Call

Docs indicates an expected call of Docs.

func (*MockYAMLViewMockRecorder) Query added in v0.0.17 

func (mr *MockYAMLViewMockRecorder) Query(ctx, doc, path any) *gomock.Call

Query indicates an expected call of Query.

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.