mocks

package
v1.2.9-prerelease3 Latest Latest
Warning

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

 Go to latest Published: Apr 9, 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 (*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.