mocks

package
v0.15.1 Latest Latest
Warning

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

 Go to latest Published: Oct 22, 2020 License: MIT Imports: 5 Imported by: 4

Documentation

Overview

Code generated by mockery v1.0.0. DO NOT EDIT.

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) GetMasterClusterName added in v0.3.11 

func (_m *ClusterMetadata) GetMasterClusterName() string

GetMasterClusterName 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) IsGlobalDomainEnabled added in v0.3.11 

func (_m *ClusterMetadata) IsGlobalDomainEnabled() bool

IsGlobalDomainEnabled provides a mock function with given fields:

func (*ClusterMetadata) IsMasterCluster added in v0.3.11 

func (_m *ClusterMetadata) IsMasterCluster() bool

IsMasterCluster 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 mock implementation

func (*ExecutionManager) Close 

func (_m *ExecutionManager) Close()

Close provides a mock function with given fields:

func (*ExecutionManager) CompleteReplicationTask added in v0.3.11 

func (_m *ExecutionManager) CompleteReplicationTask(request *persistence.CompleteReplicationTaskRequest) error

CompleteReplicationTask provides a mock function with given fields: request

func (*ExecutionManager) CompleteTimerTask 

func (_m *ExecutionManager) CompleteTimerTask(request *persistence.CompleteTimerTaskRequest) error

CompleteTimerTask provides a mock function with given fields: request

func (*ExecutionManager) CompleteTransferTask 

func (_m *ExecutionManager) CompleteTransferTask(request *persistence.CompleteTransferTaskRequest) error

CompleteTransferTask provides a mock function with given fields: request

func (*ExecutionManager) ConflictResolveWorkflowExecution added in v0.7.0 

func (_m *ExecutionManager) ConflictResolveWorkflowExecution(request *persistence.ConflictResolveWorkflowExecutionRequest) error

ConflictResolveWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) CreateFailoverMarkerTasks added in v0.14.0 

func (_m *ExecutionManager) CreateFailoverMarkerTasks(request *persistence.CreateFailoverMarkersRequest) error

CreateFailoverMarkerTasks provides a mock function with given fields: request

func (*ExecutionManager) CreateWorkflowExecution 

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

CreateWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) DeleteCurrentWorkflowExecution added in v0.5.8 

func (_m *ExecutionManager) DeleteCurrentWorkflowExecution(request *persistence.DeleteCurrentWorkflowExecutionRequest) error

DeleteCurrentWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) DeleteReplicationTaskFromDLQ added in v0.12.0 

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

DeleteReplicationTaskFromDLQ provides a mock function with given fields: request

func (*ExecutionManager) DeleteWorkflowExecution 

func (_m *ExecutionManager) DeleteWorkflowExecution(request *persistence.DeleteWorkflowExecutionRequest) error

DeleteWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) GetCurrentExecution 

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

GetCurrentExecution provides a mock function with given fields: 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(request *persistence.GetReplicationDLQSizeRequest) (*persistence.GetReplicationDLQSizeResponse, error)

GetReplicationDLQSize provides a mock function with given fields: request

func (*ExecutionManager) GetReplicationTasks added in v0.3.11 

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

GetReplicationTasks provides a mock function with given fields: request

func (*ExecutionManager) GetReplicationTasksFromDLQ added in v0.11.0 

func (_m *ExecutionManager) GetReplicationTasksFromDLQ(request *persistence.GetReplicationTasksFromDLQRequest) (*persistence.GetReplicationTasksFromDLQResponse, error)

GetReplicationTasksFromDLQ provides a mock function with given fields: 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(request *persistence.GetTimerIndexTasksRequest) (*persistence.GetTimerIndexTasksResponse, error)

GetTimerIndexTasks provides a mock function with given fields: request

func (*ExecutionManager) GetTransferTasks 

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

GetTransferTasks provides a mock function with given fields: request

func (*ExecutionManager) GetWorkflowExecution 

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

GetWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) IsWorkflowExecutionExists added in v0.14.0 

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

IsWorkflowExecutionExists provides a mock function with given fields: request

func (*ExecutionManager) ListConcreteExecutions added in v0.13.0 

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

ListConcreteExecutions provides a mock function with given fields: request

func (*ExecutionManager) ListCurrentExecutions added in v0.14.0 

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

ListCurrentExecutions provides a mock function with given fields: request

func (*ExecutionManager) PutReplicationTaskToDLQ added in v0.11.0 

func (_m *ExecutionManager) PutReplicationTaskToDLQ(request *persistence.PutReplicationTaskToDLQRequest) error

PutReplicationTaskToDLQ provides a mock function with given fields: request

func (*ExecutionManager) RangeCompleteReplicationTask added in v0.11.0 

func (_m *ExecutionManager) RangeCompleteReplicationTask(request *persistence.RangeCompleteReplicationTaskRequest) error

RangeCompleteReplicationTask provides a mock function with given fields: request

func (*ExecutionManager) RangeCompleteTimerTask added in v0.4.0 

func (_m *ExecutionManager) RangeCompleteTimerTask(request *persistence.RangeCompleteTimerTaskRequest) error

RangeCompleteTimerTask provides a mock function with given fields: request

func (*ExecutionManager) RangeCompleteTransferTask added in v0.4.0 

func (_m *ExecutionManager) RangeCompleteTransferTask(request *persistence.RangeCompleteTransferTaskRequest) error

RangeCompleteTransferTask provides a mock function with given fields: request

func (*ExecutionManager) RangeDeleteReplicationTaskFromDLQ added in v0.12.0 

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

RangeDeleteReplicationTaskFromDLQ provides a mock function with given fields: request

func (*ExecutionManager) ResetWorkflowExecution added in v0.5.2 

func (_m *ExecutionManager) ResetWorkflowExecution(request *persistence.ResetWorkflowExecutionRequest) error

ResetWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) UpdateWorkflowExecution 

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

UpdateWorkflowExecution provides a mock function with given fields: 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
}

HistoryManager mock implementation

func (*HistoryV2Manager) AppendHistoryNodes added in v0.5.0 

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

AppendHistoryNodes provides a mock function with given fields: request

func (*HistoryV2Manager) Close added in v0.5.0 

func (_m *HistoryV2Manager) Close()

Close provides a mock function with given fields:

func (*HistoryV2Manager) CompleteForkBranch added in v0.5.2 

func (_m *HistoryV2Manager) CompleteForkBranch(request *persistence.CompleteForkBranchRequest) error

CompleteForkBranch provides a mock function with given fields: request

func (*HistoryV2Manager) DeleteHistoryBranch added in v0.5.0 

func (_m *HistoryV2Manager) DeleteHistoryBranch(request *persistence.DeleteHistoryBranchRequest) error

DeleteHistoryBranch provides a mock function with given fields: request

func (*HistoryV2Manager) ForkHistoryBranch added in v0.5.0 

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

ForkHistoryBranch provides a mock function with given fields: request

func (*HistoryV2Manager) GetAllHistoryTreeBranches added in v0.9.0 

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

func (*HistoryV2Manager) GetHistoryTree added in v0.5.0 

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

GetHistoryTree provides a mock function with given fields: 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(request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchResponse, error)

ReadHistoryBranch provides a mock function with given fields: request

func (*HistoryV2Manager) ReadHistoryBranchByBatch added in v0.5.0 

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

ReadHistoryBranchByBatch provides a mock function with given fields: request

func (*HistoryV2Manager) ReadRawHistoryBranch added in v0.9.0 

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

ReadRawHistoryBranch provides a mock function with given fields: 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(msg interface{}) error

Publish provides a mock function with given fields: msg

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, concurrency int) (messaging.Consumer, error)

NewConsumer generates a dummy implementation of kafka consumer

func (*MessagingClient) NewConsumerWithClusterName added in v0.5.2 

func (c *MessagingClient) NewConsumerWithClusterName(currentCluster, sourceCluster, consumerName string, concurrency int) (messaging.Consumer, error)

NewConsumerWithClusterName 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

func (*MessagingClient) NewProducerWithClusterName added in v0.5.0 

func (c *MessagingClient) NewProducerWithClusterName(sourceCluster string) (messaging.Producer, error)

NewProducerWithClusterName 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(request *persistence.CreateDomainRequest) (*persistence.CreateDomainResponse, error)

CreateDomain provides a mock function with given fields: request

func (*MetadataManager) DeleteDomain 

func (_m *MetadataManager) DeleteDomain(request *persistence.DeleteDomainRequest) error

DeleteDomain provides a mock function with given fields: request

func (*MetadataManager) DeleteDomainByName 

func (_m *MetadataManager) DeleteDomainByName(request *persistence.DeleteDomainByNameRequest) error

DeleteDomainByName provides a mock function with given fields: request

func (*MetadataManager) GetDomain 

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

GetDomain provides a mock function with given fields: request

func (*MetadataManager) GetMetadata added in v0.3.13 

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

GetMetadata provides a mock function with given fields: request

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(request *persistence.ListDomainsRequest) (*persistence.ListDomainsResponse, error)

ListDomains provides a mock function with given fields: request

func (*MetadataManager) UpdateDomain 

func (_m *MetadataManager) UpdateDomain(request *persistence.UpdateDomainRequest) error

UpdateDomain provides a mock function with given fields: 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(request *persistence.CreateShardRequest) error

CreateShard provides a mock function with given fields: 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(request *persistence.GetShardRequest) (*persistence.GetShardResponse, error)

GetShard provides a mock function with given fields: request

func (*ShardManager) UpdateShard 

func (_m *ShardManager) UpdateShard(request *persistence.UpdateShardRequest) error

UpdateShard provides a mock function with given fields: 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(request *persistence.CompleteTaskRequest) error

CompleteTask provides a mock function with given fields: request

func (*TaskManager) CompleteTasksLessThan added in v0.5.7 

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

CompleteTasksLessThan

func (*TaskManager) CreateTasks 

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

CreateTasks provides a mock function with given fields: request

func (*TaskManager) DeleteTaskList added in v0.5.7 

func (_m *TaskManager) DeleteTaskList(request *persistence.DeleteTaskListRequest) error

func (*TaskManager) GetName added in v0.4.0 

func (_m *TaskManager) GetName() string

GetName provides a mock function with given fields:

func (*TaskManager) GetTasks 

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

GetTasks provides a mock function with given fields: request

func (*TaskManager) LeaseTaskList 

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

LeaseTaskList provides a mock function with given fields: request

func (*TaskManager) ListTaskList added in v0.5.7 

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

func (*TaskManager) UpdateTaskList 

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

UpdateTaskList provides a mock function with given fields: 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(request *persistence.CountWorkflowExecutionsRequest) (*persistence.CountWorkflowExecutionsResponse, error)

CountWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) DeleteWorkflowExecution added in v0.5.7 

func (_m *VisibilityManager) DeleteWorkflowExecution(request *persistence.VisibilityDeleteWorkflowExecutionRequest) error

DeleteWorkflowExecution provides a mock function with given fields: request

func (*VisibilityManager) GetClosedWorkflowExecution 

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

GetClosedWorkflowExecution provides a mock function with given fields: 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(request *persistence.ListWorkflowExecutionsRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutionsByStatus 

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

ListClosedWorkflowExecutionsByStatus provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutionsByType 

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

ListClosedWorkflowExecutionsByType provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutionsByWorkflowID 

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

ListClosedWorkflowExecutionsByWorkflowID provides a mock function with given fields: request

func (*VisibilityManager) ListOpenWorkflowExecutions 

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

ListOpenWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) ListOpenWorkflowExecutionsByType 

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

ListOpenWorkflowExecutionsByType provides a mock function with given fields: request

func (*VisibilityManager) ListOpenWorkflowExecutionsByWorkflowID 

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

ListOpenWorkflowExecutionsByWorkflowID provides a mock function with given fields: request

func (*VisibilityManager) ListWorkflowExecutions added in v0.5.7 

func (_m *VisibilityManager) ListWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequestV2) (*persistence.ListWorkflowExecutionsResponse, error)

ListWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) RecordWorkflowExecutionClosed 

func (_m *VisibilityManager) RecordWorkflowExecutionClosed(request *persistence.RecordWorkflowExecutionClosedRequest) error

RecordWorkflowExecutionClosed provides a mock function with given fields: request

func (*VisibilityManager) RecordWorkflowExecutionStarted 

func (_m *VisibilityManager) RecordWorkflowExecutionStarted(request *persistence.RecordWorkflowExecutionStartedRequest) error

RecordWorkflowExecutionStarted provides a mock function with given fields: request

func (*VisibilityManager) ScanWorkflowExecutions added in v0.5.8 

func (_m *VisibilityManager) ScanWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequestV2) (*persistence.ListWorkflowExecutionsResponse, error)

ScanWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) UpsertWorkflowExecution added in v0.6.0 

func (_m *VisibilityManager) UpsertWorkflowExecution(request *persistence.UpsertWorkflowExecutionRequest) error

UpsertWorkflowExecution provides a mock function with given fields: 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.