mocks

package
v1.2.13 Latest Latest
Warning

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

 Go to latest Published: Sep 4, 2024 License: MIT Imports: 4 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 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 

func (_m *ExecutionManager) ConflictResolveWorkflowExecution(ctx context.Context, request *persistence.ConflictResolveWorkflowExecutionRequest) (*persistence.ConflictResolveWorkflowExecutionResponse, error)

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 ¶ 

func (_m *ExecutionManager) CreateWorkflowExecution(ctx context.Context, request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)

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 

func (_m *ExecutionManager) GetCrossClusterTasks(ctx context.Context, request *persistence.GetCrossClusterTasksRequest) (*persistence.GetCrossClusterTasksResponse, error)

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

func (*ExecutionManager) GetCurrentExecution ¶ 

func (_m *ExecutionManager) GetCurrentExecution(ctx context.Context, request *persistence.GetCurrentExecutionRequest) (*persistence.GetCurrentExecutionResponse, error)

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 

func (_m *ExecutionManager) GetReplicationDLQSize(ctx context.Context, request *persistence.GetReplicationDLQSizeRequest) (*persistence.GetReplicationDLQSizeResponse, error)

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

func (*ExecutionManager) GetReplicationTasks ¶ added in v0.3.11 

func (_m *ExecutionManager) GetReplicationTasks(ctx context.Context, request *persistence.GetReplicationTasksRequest) (*persistence.GetReplicationTasksResponse, error)

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

func (*ExecutionManager) GetReplicationTasksFromDLQ ¶ added in v0.11.0 

func (_m *ExecutionManager) GetReplicationTasksFromDLQ(ctx context.Context, request *persistence.GetReplicationTasksFromDLQRequest) (*persistence.GetReplicationTasksResponse, error)

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 ¶ 

func (_m *ExecutionManager) GetTimerIndexTasks(ctx context.Context, request *persistence.GetTimerIndexTasksRequest) (*persistence.GetTimerIndexTasksResponse, error)

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

func (*ExecutionManager) GetTransferTasks ¶ 

func (_m *ExecutionManager) GetTransferTasks(ctx context.Context, request *persistence.GetTransferTasksRequest) (*persistence.GetTransferTasksResponse, error)

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

func (*ExecutionManager) GetWorkflowExecution ¶ 

func (_m *ExecutionManager) GetWorkflowExecution(ctx context.Context, request *persistence.GetWorkflowExecutionRequest) (*persistence.GetWorkflowExecutionResponse, error)

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

func (*ExecutionManager) IsWorkflowExecutionExists ¶ added in v0.14.0 

func (_m *ExecutionManager) IsWorkflowExecutionExists(ctx context.Context, request *persistence.IsWorkflowExecutionExistsRequest) (*persistence.IsWorkflowExecutionExistsResponse, error)

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

func (*ExecutionManager) ListConcreteExecutions ¶ added in v0.13.0 

func (_m *ExecutionManager) ListConcreteExecutions(ctx context.Context, request *persistence.ListConcreteExecutionsRequest) (*persistence.ListConcreteExecutionsResponse, error)

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

func (*ExecutionManager) ListCurrentExecutions ¶ added in v0.14.0 

func (_m *ExecutionManager) ListCurrentExecutions(ctx context.Context, request *persistence.ListCurrentExecutionsRequest) (*persistence.ListCurrentExecutionsResponse, error)

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) (*persistence.RangeCompleteCrossClusterTaskResponse, 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) (*persistence.RangeCompleteReplicationTaskResponse, 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) (*persistence.RangeCompleteTimerTaskResponse, 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) (*persistence.RangeCompleteTransferTaskResponse, 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) (*persistence.RangeDeleteReplicationTaskFromDLQResponse, error)

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

func (*ExecutionManager) UpdateWorkflowExecution ¶ 

func (_m *ExecutionManager) UpdateWorkflowExecution(ctx context.Context, request *persistence.UpdateWorkflowExecutionRequest) (*persistence.UpdateWorkflowExecutionResponse, error)

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 

func (_m *HistoryV2Manager) AppendHistoryNodes(ctx context.Context, request *persistence.AppendHistoryNodesRequest) (*persistence.AppendHistoryNodesResponse, error)

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 

func (_m *HistoryV2Manager) ForkHistoryBranch(ctx context.Context, request *persistence.ForkHistoryBranchRequest) (*persistence.ForkHistoryBranchResponse, error)

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

func (*HistoryV2Manager) GetAllHistoryTreeBranches ¶ added in v0.9.0 

func (_m *HistoryV2Manager) GetAllHistoryTreeBranches(ctx context.Context, request *persistence.GetAllHistoryTreeBranchesRequest) (*persistence.GetAllHistoryTreeBranchesResponse, error)

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

func (*HistoryV2Manager) GetHistoryTree ¶ added in v0.5.0 

func (_m *HistoryV2Manager) GetHistoryTree(ctx context.Context, request *persistence.GetHistoryTreeRequest) (*persistence.GetHistoryTreeResponse, error)

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 

func (_m *HistoryV2Manager) ReadHistoryBranch(ctx context.Context, request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchResponse, error)

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

func (*HistoryV2Manager) ReadHistoryBranchByBatch ¶ added in v0.5.0 

func (_m *HistoryV2Manager) ReadHistoryBranchByBatch(ctx context.Context, request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchByBatchResponse, error)

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

func (*HistoryV2Manager) ReadRawHistoryBranch ¶ added in v0.9.0 

func (_m *HistoryV2Manager) ReadRawHistoryBranch(ctx context.Context, request *persistence.ReadHistoryBranchRequest) (*persistence.ReadRawHistoryBranchResponse, error)

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 ¶ 

func (_m *MetadataManager) CreateDomain(ctx context.Context, request *persistence.CreateDomainRequest) (*persistence.CreateDomainResponse, error)

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 ¶ 

func (_m *MetadataManager) GetDomain(ctx context.Context, request *persistence.GetDomainRequest) (*persistence.GetDomainResponse, error)

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

func (*MetadataManager) GetMetadata ¶ added in v0.3.13 

func (_m *MetadataManager) GetMetadata(ctx context.Context) (*persistence.GetMetadataResponse, error)

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 

func (_m *MetadataManager) ListDomains(ctx context.Context, request *persistence.ListDomainsRequest) (*persistence.ListDomainsResponse, error)

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

func (_m *ShardManager) GetShard(ctx context.Context, request *persistence.GetShardRequest) (*persistence.GetShardResponse, error)

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 NewTaskManager ¶ added in v1.2.6 

func NewTaskManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *TaskManager

NewTaskManager creates a new instance of TaskManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

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) (*persistence.CompleteTasksLessThanResponse, error)

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

func (*TaskManager) CreateTasks ¶ 

func (_m *TaskManager) CreateTasks(ctx context.Context, request *persistence.CreateTasksRequest) (*persistence.CreateTasksResponse, error)

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 

func (_m *TaskManager) GetOrphanTasks(ctx context.Context, request *persistence.GetOrphanTasksRequest) (*persistence.GetOrphanTasksResponse, error)

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

func (*TaskManager) GetTaskListSize ¶ added in v1.2.6 

func (_m *TaskManager) GetTaskListSize(ctx context.Context, request *persistence.GetTaskListSizeRequest) (*persistence.GetTaskListSizeResponse, error)

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

func (*TaskManager) GetTasks ¶ 

func (_m *TaskManager) GetTasks(ctx context.Context, request *persistence.GetTasksRequest) (*persistence.GetTasksResponse, error)

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

func (*TaskManager) LeaseTaskList ¶ 

func (_m *TaskManager) LeaseTaskList(ctx context.Context, request *persistence.LeaseTaskListRequest) (*persistence.LeaseTaskListResponse, error)

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

func (*TaskManager) ListTaskList ¶ added in v0.5.7 

func (_m *TaskManager) ListTaskList(ctx context.Context, request *persistence.ListTaskListRequest) (*persistence.ListTaskListResponse, error)

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

func (*TaskManager) UpdateTaskList ¶ 

func (_m *TaskManager) UpdateTaskList(ctx context.Context, request *persistence.UpdateTaskListRequest) (*persistence.UpdateTaskListResponse, error)

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 NewVisibilityManager ¶ added in v1.2.11 

func NewVisibilityManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *VisibilityManager

NewVisibilityManager creates a new instance of VisibilityManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*VisibilityManager) Close ¶ 

func (_m *VisibilityManager) Close()

Close provides a mock function with given fields:

func (*VisibilityManager) CountWorkflowExecutions ¶ added in v0.5.8 

func (_m *VisibilityManager) CountWorkflowExecutions(ctx context.Context, request *persistence.CountWorkflowExecutionsRequest) (*persistence.CountWorkflowExecutionsResponse, error)

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

func (*VisibilityManager) DeleteUninitializedWorkflowExecution ¶ added in v1.0.0 

func (_m *VisibilityManager) DeleteUninitializedWorkflowExecution(ctx context.Context, request *persistence.VisibilityDeleteWorkflowExecutionRequest) error

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

func (*VisibilityManager) DeleteWorkflowExecution ¶ added in v0.5.7 

func (_m *VisibilityManager) DeleteWorkflowExecution(ctx context.Context, request *persistence.VisibilityDeleteWorkflowExecutionRequest) error

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

func (*VisibilityManager) GetClosedWorkflowExecution ¶ 

func (_m *VisibilityManager) GetClosedWorkflowExecution(ctx context.Context, request *persistence.GetClosedWorkflowExecutionRequest) (*persistence.GetClosedWorkflowExecutionResponse, error)

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 ¶ 

func (_m *VisibilityManager) ListClosedWorkflowExecutions(ctx context.Context, request *persistence.ListWorkflowExecutionsRequest) (*persistence.ListWorkflowExecutionsResponse, error)

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

func (*VisibilityManager) ListClosedWorkflowExecutionsByStatus ¶ 

func (_m *VisibilityManager) ListClosedWorkflowExecutionsByStatus(ctx context.Context, request *persistence.ListClosedWorkflowExecutionsByStatusRequest) (*persistence.ListWorkflowExecutionsResponse, error)

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

func (*VisibilityManager) ListClosedWorkflowExecutionsByType ¶ 

func (_m *VisibilityManager) ListClosedWorkflowExecutionsByType(ctx context.Context, request *persistence.ListWorkflowExecutionsByTypeRequest) (*persistence.ListWorkflowExecutionsResponse, error)

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

func (*VisibilityManager) ListClosedWorkflowExecutionsByWorkflowID ¶ 

func (_m *VisibilityManager) ListClosedWorkflowExecutionsByWorkflowID(ctx context.Context, request *persistence.ListWorkflowExecutionsByWorkflowIDRequest) (*persistence.ListWorkflowExecutionsResponse, error)

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

func (*VisibilityManager) ListOpenWorkflowExecutions ¶ 

func (_m *VisibilityManager) ListOpenWorkflowExecutions(ctx context.Context, request *persistence.ListWorkflowExecutionsRequest) (*persistence.ListWorkflowExecutionsResponse, error)

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

func (*VisibilityManager) ListOpenWorkflowExecutionsByType ¶ 

func (_m *VisibilityManager) ListOpenWorkflowExecutionsByType(ctx context.Context, request *persistence.ListWorkflowExecutionsByTypeRequest) (*persistence.ListWorkflowExecutionsResponse, error)

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

func (*VisibilityManager) ListOpenWorkflowExecutionsByWorkflowID ¶ 

func (_m *VisibilityManager) ListOpenWorkflowExecutionsByWorkflowID(ctx context.Context, request *persistence.ListWorkflowExecutionsByWorkflowIDRequest) (*persistence.ListWorkflowExecutionsResponse, error)

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

func (*VisibilityManager) ListWorkflowExecutions ¶ added in v0.5.7 

func (_m *VisibilityManager) ListWorkflowExecutions(ctx context.Context, request *persistence.ListWorkflowExecutionsByQueryRequest) (*persistence.ListWorkflowExecutionsResponse, error)

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) RecordWorkflowExecutionUninitialized ¶ added in v0.25.0 

func (_m *VisibilityManager) RecordWorkflowExecutionUninitialized(ctx context.Context, request *persistence.RecordWorkflowExecutionUninitializedRequest) error

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

func (*VisibilityManager) ScanWorkflowExecutions ¶ added in v0.5.8 

func (_m *VisibilityManager) ScanWorkflowExecutions(ctx context.Context, request *persistence.ListWorkflowExecutionsByQueryRequest) (*persistence.ListWorkflowExecutionsResponse, error)

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

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.