mocks

package
v0.22.3 Latest Latest
Warning

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

Go to latest
Published: Oct 14, 2021 License: MIT Imports: 6 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMockMessagingClient added in v0.3.11

func NewMockMessagingClient(publisher messaging.Producer, consumer messaging.Consumer) messaging.Client

NewMockMessagingClient generate a dummy implementation of messaging client

Types

type ClusterMetadata added in v0.3.11

type ClusterMetadata struct {
	mock.Mock
}

ClusterMetadata is an autogenerated mock type for the Metadata type

func (*ClusterMetadata) ClusterNameForFailoverVersion added in v0.3.11

func (_m *ClusterMetadata) ClusterNameForFailoverVersion(failoverVersion int64) string

ClusterNameForFailoverVersion provides a mock function with given fields:

func (*ClusterMetadata) GetAllClusterInfo added in v0.5.8

func (_m *ClusterMetadata) GetAllClusterInfo() map[string]config.ClusterInformation

GetAllClusterInfo provides a mock function with given fields:

func (*ClusterMetadata) GetCurrentClusterName added in v0.3.11

func (_m *ClusterMetadata) GetCurrentClusterName() string

GetCurrentClusterName provides a mock function with given fields:

func (*ClusterMetadata) GetDeploymentGroup added in v0.5.0

func (_m *ClusterMetadata) GetDeploymentGroup() string

GetDeploymentGroup provides a mock function with given fields:

func (*ClusterMetadata) GetNextFailoverVersion added in v0.3.11

func (_m *ClusterMetadata) GetNextFailoverVersion(_a0 string, _a1 int64) int64

GetNextFailoverVersion provides a mock function with given fields: _a0, _a1

func (*ClusterMetadata) GetPrimaryClusterName added in v0.22.0

func (_m *ClusterMetadata) GetPrimaryClusterName() string

GetPrimaryClusterName provides a mock function with given fields:

func (*ClusterMetadata) IsGlobalDomainEnabled added in v0.3.11

func (_m *ClusterMetadata) IsGlobalDomainEnabled() bool

IsGlobalDomainEnabled provides a mock function with given fields:

func (*ClusterMetadata) IsPrimaryCluster added in v0.22.0

func (_m *ClusterMetadata) IsPrimaryCluster() bool

IsPrimaryCluster provides a mock function with given fields:

func (*ClusterMetadata) IsVersionFromSameCluster added in v0.3.14

func (_m *ClusterMetadata) IsVersionFromSameCluster(_a0 int64, _a1 int64) bool

IsVersionFromSameCluster provides a mock function with given fields: _a0, _a1

type ExecutionManager

type ExecutionManager struct {
	mock.Mock
}

ExecutionManager is an autogenerated mock type for the ExecutionManager type

func (*ExecutionManager) Close

func (_m *ExecutionManager) Close()

Close provides a mock function with given fields:

func (*ExecutionManager) CompleteCrossClusterTask added in v0.22.0

func (_m *ExecutionManager) CompleteCrossClusterTask(ctx context.Context, request *persistence.CompleteCrossClusterTaskRequest) error

CompleteCrossClusterTask provides a mock function with given fields: ctx, request

func (*ExecutionManager) CompleteReplicationTask added in v0.3.11

func (_m *ExecutionManager) CompleteReplicationTask(ctx context.Context, request *persistence.CompleteReplicationTaskRequest) error

CompleteReplicationTask provides a mock function with given fields: ctx, request

func (*ExecutionManager) CompleteTimerTask

func (_m *ExecutionManager) CompleteTimerTask(ctx context.Context, request *persistence.CompleteTimerTaskRequest) error

CompleteTimerTask provides a mock function with given fields: ctx, request

func (*ExecutionManager) CompleteTransferTask

func (_m *ExecutionManager) CompleteTransferTask(ctx context.Context, request *persistence.CompleteTransferTaskRequest) error

CompleteTransferTask provides a mock function with given fields: ctx, request

func (*ExecutionManager) ConflictResolveWorkflowExecution added in v0.7.0

ConflictResolveWorkflowExecution provides a mock function with given fields: ctx, request

func (*ExecutionManager) CreateFailoverMarkerTasks added in v0.14.0

func (_m *ExecutionManager) CreateFailoverMarkerTasks(ctx context.Context, request *persistence.CreateFailoverMarkersRequest) error

CreateFailoverMarkerTasks provides a mock function with given fields: ctx, request

func (*ExecutionManager) CreateWorkflowExecution

CreateWorkflowExecution provides a mock function with given fields: ctx, request

func (*ExecutionManager) DeleteCurrentWorkflowExecution added in v0.5.8

func (_m *ExecutionManager) DeleteCurrentWorkflowExecution(ctx context.Context, request *persistence.DeleteCurrentWorkflowExecutionRequest) error

DeleteCurrentWorkflowExecution provides a mock function with given fields: ctx, request

func (*ExecutionManager) DeleteReplicationTaskFromDLQ added in v0.12.0

func (_m *ExecutionManager) DeleteReplicationTaskFromDLQ(ctx context.Context, request *persistence.DeleteReplicationTaskFromDLQRequest) error

DeleteReplicationTaskFromDLQ provides a mock function with given fields: ctx, request

func (*ExecutionManager) DeleteWorkflowExecution

func (_m *ExecutionManager) DeleteWorkflowExecution(ctx context.Context, request *persistence.DeleteWorkflowExecutionRequest) error

DeleteWorkflowExecution provides a mock function with given fields: ctx, request

func (*ExecutionManager) GetCrossClusterTasks added in v0.22.0

GetCrossClusterTasks provides a mock function with given fields: ctx, request

func (*ExecutionManager) GetCurrentExecution

GetCurrentExecution provides a mock function with given fields: ctx, request

func (*ExecutionManager) GetName added in v0.4.0

func (_m *ExecutionManager) GetName() string

GetName provides a mock function with given fields:

func (*ExecutionManager) GetReplicationDLQSize added in v0.14.0

GetReplicationDLQSize provides a mock function with given fields: ctx, request

func (*ExecutionManager) GetReplicationTasks added in v0.3.11

GetReplicationTasks provides a mock function with given fields: ctx, request

func (*ExecutionManager) GetReplicationTasksFromDLQ added in v0.11.0

GetReplicationTasksFromDLQ provides a mock function with given fields: ctx, request

func (*ExecutionManager) GetShardID added in v0.5.0

func (_m *ExecutionManager) GetShardID() int

GetShardID provides a mock function with given fields:

func (*ExecutionManager) GetTimerIndexTasks

GetTimerIndexTasks provides a mock function with given fields: ctx, request

func (*ExecutionManager) GetTransferTasks

GetTransferTasks provides a mock function with given fields: ctx, request

func (*ExecutionManager) GetWorkflowExecution

GetWorkflowExecution provides a mock function with given fields: ctx, request

func (*ExecutionManager) IsWorkflowExecutionExists added in v0.14.0

IsWorkflowExecutionExists provides a mock function with given fields: ctx, request

func (*ExecutionManager) ListConcreteExecutions added in v0.13.0

ListConcreteExecutions provides a mock function with given fields: ctx, request

func (*ExecutionManager) ListCurrentExecutions added in v0.14.0

ListCurrentExecutions provides a mock function with given fields: ctx, request

func (*ExecutionManager) PutReplicationTaskToDLQ added in v0.11.0

func (_m *ExecutionManager) PutReplicationTaskToDLQ(ctx context.Context, request *persistence.PutReplicationTaskToDLQRequest) error

PutReplicationTaskToDLQ provides a mock function with given fields: ctx, request

func (*ExecutionManager) RangeCompleteCrossClusterTask added in v0.22.0

func (_m *ExecutionManager) RangeCompleteCrossClusterTask(ctx context.Context, request *persistence.RangeCompleteCrossClusterTaskRequest) error

RangeCompleteCrossClusterTask provides a mock function with given fields: ctx, request

func (*ExecutionManager) RangeCompleteReplicationTask added in v0.11.0

func (_m *ExecutionManager) RangeCompleteReplicationTask(ctx context.Context, request *persistence.RangeCompleteReplicationTaskRequest) error

RangeCompleteReplicationTask provides a mock function with given fields: ctx, request

func (*ExecutionManager) RangeCompleteTimerTask added in v0.4.0

func (_m *ExecutionManager) RangeCompleteTimerTask(ctx context.Context, request *persistence.RangeCompleteTimerTaskRequest) error

RangeCompleteTimerTask provides a mock function with given fields: ctx, request

func (*ExecutionManager) RangeCompleteTransferTask added in v0.4.0

func (_m *ExecutionManager) RangeCompleteTransferTask(ctx context.Context, request *persistence.RangeCompleteTransferTaskRequest) error

RangeCompleteTransferTask provides a mock function with given fields: ctx, request

func (*ExecutionManager) RangeDeleteReplicationTaskFromDLQ added in v0.12.0

func (_m *ExecutionManager) RangeDeleteReplicationTaskFromDLQ(ctx context.Context, request *persistence.RangeDeleteReplicationTaskFromDLQRequest) error

RangeDeleteReplicationTaskFromDLQ provides a mock function with given fields: ctx, request

func (*ExecutionManager) UpdateWorkflowExecution

UpdateWorkflowExecution provides a mock function with given fields: ctx, request

type ExecutionManagerFactory

type ExecutionManagerFactory struct {
	mock.Mock
}

ExecutionManagerFactory is an autogenerated mock type for the ExecutionManagerFactory type

func (*ExecutionManagerFactory) Close added in v0.3.2

func (_m *ExecutionManagerFactory) Close()

Close is mock implementation for Close of ExecutionManagerFactory

func (*ExecutionManagerFactory) NewExecutionManager added in v0.4.0

func (_m *ExecutionManagerFactory) NewExecutionManager(shardID int) (persistence.ExecutionManager, error)

NewExecutionManager provides a mock function with given fields: shardID

type HistoryV2Manager added in v0.5.0

type HistoryV2Manager struct {
	mock.Mock
}

HistoryV2Manager is an autogenerated mock type for the HistoryV2Manager type TODO: rename to HistoryManager

func (*HistoryV2Manager) AppendHistoryNodes added in v0.5.0

AppendHistoryNodes provides a mock function with given fields: ctx, request

func (*HistoryV2Manager) Close added in v0.5.0

func (_m *HistoryV2Manager) Close()

Close provides a mock function with given fields:

func (*HistoryV2Manager) DeleteHistoryBranch added in v0.5.0

func (_m *HistoryV2Manager) DeleteHistoryBranch(ctx context.Context, request *persistence.DeleteHistoryBranchRequest) error

DeleteHistoryBranch provides a mock function with given fields: ctx, request

func (*HistoryV2Manager) ForkHistoryBranch added in v0.5.0

ForkHistoryBranch provides a mock function with given fields: ctx, request

func (*HistoryV2Manager) GetAllHistoryTreeBranches added in v0.9.0

GetAllHistoryTreeBranches provides a mock function with given fields: ctx, request

func (*HistoryV2Manager) GetHistoryTree added in v0.5.0

GetHistoryTree provides a mock function with given fields: ctx, request

func (*HistoryV2Manager) GetName added in v0.5.0

func (_m *HistoryV2Manager) GetName() string

GetName provides a mock function with given fields:

func (*HistoryV2Manager) ReadHistoryBranch added in v0.5.0

ReadHistoryBranch provides a mock function with given fields: ctx, request

func (*HistoryV2Manager) ReadHistoryBranchByBatch added in v0.5.0

ReadHistoryBranchByBatch provides a mock function with given fields: ctx, request

func (*HistoryV2Manager) ReadRawHistoryBranch added in v0.9.0

ReadRawHistoryBranch provides a mock function with given fields: ctx, request

type KafkaProducer added in v0.3.7

type KafkaProducer struct {
	mock.Mock
}

KafkaProducer is an autogenerated mock type for the KafkaProducer type

func (*KafkaProducer) Close added in v0.3.7

func (_m *KafkaProducer) Close() error

Close provides a mock function with given fields:

func (*KafkaProducer) Publish added in v0.3.7

func (_m *KafkaProducer) Publish(ctx context.Context, message interface{}) error

Publish provides a mock function with given fields: ctx, message

type MessagingClient added in v0.3.11

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

MessagingClient is the mock implementation for Service interface

func (*MessagingClient) NewConsumer added in v0.3.11

func (c *MessagingClient) NewConsumer(appName, consumerName string) (messaging.Consumer, error)

NewConsumer generates a dummy implementation of kafka consumer

func (*MessagingClient) NewProducer added in v0.3.11

func (c *MessagingClient) NewProducer(appName string) (messaging.Producer, error)

NewProducer generates a dummy implementation of kafka producer

type MetadataManager

type MetadataManager struct {
	mock.Mock
}

MetadataManager is an autogenerated mock type for the MetadataManager type

func (*MetadataManager) Close

func (_m *MetadataManager) Close()

Close provides a mock function with given fields:

func (*MetadataManager) CreateDomain

CreateDomain provides a mock function with given fields: ctx, request

func (*MetadataManager) DeleteDomain

func (_m *MetadataManager) DeleteDomain(ctx context.Context, request *persistence.DeleteDomainRequest) error

DeleteDomain provides a mock function with given fields: ctx, request

func (*MetadataManager) DeleteDomainByName

func (_m *MetadataManager) DeleteDomainByName(ctx context.Context, request *persistence.DeleteDomainByNameRequest) error

DeleteDomainByName provides a mock function with given fields: ctx, request

func (*MetadataManager) GetDomain

GetDomain provides a mock function with given fields: ctx, request

func (*MetadataManager) GetMetadata added in v0.3.13

GetMetadata provides a mock function with given fields: ctx

func (*MetadataManager) GetName added in v0.4.0

func (_m *MetadataManager) GetName() string

GetName provides a mock function with given fields:

func (*MetadataManager) ListDomains added in v0.3.14

ListDomains provides a mock function with given fields: ctx, request

func (*MetadataManager) UpdateDomain

func (_m *MetadataManager) UpdateDomain(ctx context.Context, request *persistence.UpdateDomainRequest) error

UpdateDomain provides a mock function with given fields: ctx, request

type ServiceResolver

type ServiceResolver struct {
	mock.Mock
}

ServiceResolver is an mock implementation

func (*ServiceResolver) AddListener

func (_m *ServiceResolver) AddListener(name string, notifyChannel chan<- *membership.ChangedEvent) error

AddListener is am mock implementation

func (*ServiceResolver) Lookup

func (_m *ServiceResolver) Lookup(key string) (*membership.HostInfo, error)

Lookup is am mock implementation

func (*ServiceResolver) MemberCount added in v0.11.0

func (_m *ServiceResolver) MemberCount() int

MemberCount is am mock implementation

func (*ServiceResolver) Members added in v0.11.0

func (_m *ServiceResolver) Members() []*membership.HostInfo

Members is am mock implementation

func (*ServiceResolver) RemoveListener

func (_m *ServiceResolver) RemoveListener(name string) error

RemoveListener is am mock implementation

type ShardManager

type ShardManager struct {
	mock.Mock
}

ShardManager is an autogenerated mock type for the ShardManager type

func (*ShardManager) Close

func (_m *ShardManager) Close()

Close provides a mock function with given fields:

func (*ShardManager) CreateShard

func (_m *ShardManager) CreateShard(ctx context.Context, request *persistence.CreateShardRequest) error

CreateShard provides a mock function with given fields: ctx, request

func (*ShardManager) GetName added in v0.4.0

func (_m *ShardManager) GetName() string

GetName provides a mock function with given fields:

func (*ShardManager) GetShard

GetShard provides a mock function with given fields: ctx, request

func (*ShardManager) UpdateShard

func (_m *ShardManager) UpdateShard(ctx context.Context, request *persistence.UpdateShardRequest) error

UpdateShard provides a mock function with given fields: ctx, request

type TaskManager

type TaskManager struct {
	mock.Mock
}

TaskManager is an autogenerated mock type for the TaskManager type

func (*TaskManager) Close

func (_m *TaskManager) Close()

Close provides a mock function with given fields:

func (*TaskManager) CompleteTask

func (_m *TaskManager) CompleteTask(ctx context.Context, request *persistence.CompleteTaskRequest) error

CompleteTask provides a mock function with given fields: ctx, request

func (*TaskManager) CompleteTasksLessThan added in v0.5.7

func (_m *TaskManager) CompleteTasksLessThan(ctx context.Context, request *persistence.CompleteTasksLessThanRequest) (int, error)

CompleteTasksLessThan provides a mock function with given fields: ctx, request

func (*TaskManager) CreateTasks

CreateTasks provides a mock function with given fields: ctx, request

func (*TaskManager) DeleteTaskList added in v0.5.7

func (_m *TaskManager) DeleteTaskList(ctx context.Context, request *persistence.DeleteTaskListRequest) error

DeleteTaskList provides a mock function with given fields: ctx, request

func (*TaskManager) GetName added in v0.4.0

func (_m *TaskManager) GetName() string

GetName provides a mock function with given fields:

func (*TaskManager) GetOrphanTasks added in v0.21.0

GetOrphanTasks provides a mock function with given fields: ctx, request

func (*TaskManager) GetTasks

GetTasks provides a mock function with given fields: ctx, request

func (*TaskManager) LeaseTaskList

LeaseTaskList provides a mock function with given fields: ctx, request

func (*TaskManager) ListTaskList added in v0.5.7

ListTaskList provides a mock function with given fields: ctx, request

func (*TaskManager) UpdateTaskList

UpdateTaskList provides a mock function with given fields: ctx, request

type VisibilityManager

type VisibilityManager struct {
	mock.Mock
}

VisibilityManager is an autogenerated mock type for the VisibilityManager type

func (*VisibilityManager) Close

func (_m *VisibilityManager) Close()

Close provides a mock function with given fields:

func (*VisibilityManager) CountWorkflowExecutions added in v0.5.8

CountWorkflowExecutions provides a mock function with given fields: ctx, request

func (*VisibilityManager) DeleteWorkflowExecution added in v0.5.7

DeleteWorkflowExecution provides a mock function with given fields: ctx, request

func (*VisibilityManager) GetClosedWorkflowExecution

GetClosedWorkflowExecution provides a mock function with given fields: ctx, request

func (*VisibilityManager) GetName added in v0.4.0

func (_m *VisibilityManager) GetName() string

GetName provides a mock function with given fields:

func (*VisibilityManager) ListClosedWorkflowExecutions

ListClosedWorkflowExecutions provides a mock function with given fields: ctx, request

func (*VisibilityManager) ListClosedWorkflowExecutionsByStatus

ListClosedWorkflowExecutionsByStatus provides a mock function with given fields: ctx, request

func (*VisibilityManager) ListClosedWorkflowExecutionsByType

ListClosedWorkflowExecutionsByType provides a mock function with given fields: ctx, request

func (*VisibilityManager) ListClosedWorkflowExecutionsByWorkflowID

ListClosedWorkflowExecutionsByWorkflowID provides a mock function with given fields: ctx, request

func (*VisibilityManager) ListOpenWorkflowExecutions

ListOpenWorkflowExecutions provides a mock function with given fields: ctx, request

func (*VisibilityManager) ListOpenWorkflowExecutionsByType

ListOpenWorkflowExecutionsByType provides a mock function with given fields: ctx, request

func (*VisibilityManager) ListOpenWorkflowExecutionsByWorkflowID

ListOpenWorkflowExecutionsByWorkflowID provides a mock function with given fields: ctx, request

func (*VisibilityManager) ListWorkflowExecutions added in v0.5.7

ListWorkflowExecutions provides a mock function with given fields: ctx, request

func (*VisibilityManager) RecordWorkflowExecutionClosed

func (_m *VisibilityManager) RecordWorkflowExecutionClosed(ctx context.Context, request *persistence.RecordWorkflowExecutionClosedRequest) error

RecordWorkflowExecutionClosed provides a mock function with given fields: ctx, request

func (*VisibilityManager) RecordWorkflowExecutionStarted

func (_m *VisibilityManager) RecordWorkflowExecutionStarted(ctx context.Context, request *persistence.RecordWorkflowExecutionStartedRequest) error

RecordWorkflowExecutionStarted provides a mock function with given fields: ctx, request

func (*VisibilityManager) ScanWorkflowExecutions added in v0.5.8

ScanWorkflowExecutions provides a mock function with given fields: ctx, request

func (*VisibilityManager) UpsertWorkflowExecution added in v0.6.0

func (_m *VisibilityManager) UpsertWorkflowExecution(ctx context.Context, request *persistence.UpsertWorkflowExecutionRequest) error

UpsertWorkflowExecution provides a mock function with given fields: ctx, request

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL