mocks

package
v0.3.14 Latest Latest
Warning

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

 Go to latest Published: Jul 24, 2018 License: MIT Imports: 12 Imported by: 0

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

func (_m *ClusterMetadata) GetAllClusterFailoverVersions() map[string]int64

GetAllClusterFailoverVersions 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) 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 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) 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) CreateWorkflowExecution 

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

CreateWorkflowExecution 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) 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) 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) ResetMutableState added in v0.3.12 

func (_m *ExecutionManager) ResetMutableState(request *persistence.ResetMutableStateRequest) error

ResetMutableState provides a mock function with given fields: request

func (*ExecutionManager) UpdateWorkflowExecution 

func (_m *ExecutionManager) UpdateWorkflowExecution(request *persistence.UpdateWorkflowExecutionRequest) 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) CreateExecutionManager 

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

CreateExecutionManager provides a mock function with given fields: shardID

type HistoryClient 

type HistoryClient struct {
	mock.Mock
}

HistoryClient is an autogenerated mock type for the Client type

func (*HistoryClient) DescribeHistoryHost added in v0.3.13 

func (_m *HistoryClient) DescribeHistoryHost(ctx context.Context, request *shared.DescribeHistoryHostRequest, opts ...yarpc.CallOption) (*shared.DescribeHistoryHostResponse, error)

DescribeHistoryHost provides a mock function with given fields: ctx, getRequest

func (*HistoryClient) DescribeMutableState added in v0.3.13 

func (_m *HistoryClient) DescribeMutableState(ctx context.Context, request *history.DescribeMutableStateRequest, opts ...yarpc.CallOption) (*history.DescribeMutableStateResponse, error)

DescribeMutableState provides a mock function with given fields: ctx, getRequest

func (*HistoryClient) DescribeWorkflowExecution added in v0.3.3 

func (_m *HistoryClient) DescribeWorkflowExecution(ctx context.Context, request *history.DescribeWorkflowExecutionRequest, opts ...yarpc.CallOption) (*shared.DescribeWorkflowExecutionResponse, error)

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

func (*HistoryClient) GetMutableState added in v0.3.5 

func (_m *HistoryClient) GetMutableState(ctx context.Context, getRequest *history.GetMutableStateRequest, opts ...yarpc.CallOption) (*history.GetMutableStateResponse, error)

GetMutableState provides a mock function with given fields: ctx, getRequest

func (*HistoryClient) RecordActivityTaskHeartbeat 

func (_m *HistoryClient) RecordActivityTaskHeartbeat(ctx context.Context, heartbeatRequest *history.RecordActivityTaskHeartbeatRequest, opts ...yarpc.CallOption) (*shared.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeat provides a mock function with given fields: ctx, heartbeatRequest

func (*HistoryClient) RecordActivityTaskStarted 

func (_m *HistoryClient) RecordActivityTaskStarted(ctx context.Context, addRequest *history.RecordActivityTaskStartedRequest, opts ...yarpc.CallOption) (*history.RecordActivityTaskStartedResponse, error)

RecordActivityTaskStarted provides a mock function with given fields: ctx, addRequest

func (*HistoryClient) RecordChildExecutionCompleted 

func (_m *HistoryClient) RecordChildExecutionCompleted(ctx context.Context, request *history.RecordChildExecutionCompletedRequest, opts ...yarpc.CallOption) error

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

func (*HistoryClient) RecordDecisionTaskStarted 

func (_m *HistoryClient) RecordDecisionTaskStarted(ctx context.Context, addRequest *history.RecordDecisionTaskStartedRequest, opts ...yarpc.CallOption) (*history.RecordDecisionTaskStartedResponse, error)

RecordDecisionTaskStarted provides a mock function with given fields: ctx, addRequest

func (*HistoryClient) RemoveSignalMutableState added in v0.3.6 

func (_m *HistoryClient) RemoveSignalMutableState(ctx context.Context, removeRequest *history.RemoveSignalMutableStateRequest, opts ...yarpc.CallOption) error

RemoveSignalMutableState provides a mock function with given fields: ctx, removeRequest

func (*HistoryClient) ReplicateEvents added in v0.3.11 

func (_m *HistoryClient) ReplicateEvents(ctx context.Context, request *history.ReplicateEventsRequest, opts ...yarpc.CallOption) error

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

func (*HistoryClient) RequestCancelWorkflowExecution 

func (_m *HistoryClient) RequestCancelWorkflowExecution(ctx context.Context, request *history.RequestCancelWorkflowExecutionRequest, opts ...yarpc.CallOption) error

RequestCancelWorkflowExecution is mock implementation for RequestCancelWorkflowExecution of HistoryEngine

func (*HistoryClient) ResetStickyTaskList added in v0.3.7 

func (_m *HistoryClient) ResetStickyTaskList(ctx context.Context, request *history.ResetStickyTaskListRequest, opts ...yarpc.CallOption) (*history.ResetStickyTaskListResponse, error)

ResetStickyTaskList provides a mock function with given fields: ctx, getRequest

func (*HistoryClient) RespondActivityTaskCanceled 

func (_m *HistoryClient) RespondActivityTaskCanceled(ctx context.Context, canceledRequest *history.RespondActivityTaskCanceledRequest, opts ...yarpc.CallOption) error

RespondActivityTaskCanceled provides a mock function with given fields: ctx, canceledRequest

func (*HistoryClient) RespondActivityTaskCompleted 

func (_m *HistoryClient) RespondActivityTaskCompleted(ctx context.Context, completeRequest *history.RespondActivityTaskCompletedRequest, opts ...yarpc.CallOption) error

RespondActivityTaskCompleted provides a mock function with given fields: ctx, completeRequest

func (*HistoryClient) RespondActivityTaskFailed 

func (_m *HistoryClient) RespondActivityTaskFailed(ctx context.Context, failRequest *history.RespondActivityTaskFailedRequest, opts ...yarpc.CallOption) error

RespondActivityTaskFailed provides a mock function with given fields: ctx, failRequest

func (*HistoryClient) RespondDecisionTaskCompleted 

func (_m *HistoryClient) RespondDecisionTaskCompleted(ctx context.Context, completeRequest *history.RespondDecisionTaskCompletedRequest, opts ...yarpc.CallOption) (*history.RespondDecisionTaskCompletedResponse, error)

RespondDecisionTaskCompleted provides a mock function with given fields: ctx, completeRequest

func (*HistoryClient) RespondDecisionTaskFailed added in v0.3.3 

func (_m *HistoryClient) RespondDecisionTaskFailed(ctx context.Context, failedRequest *history.RespondDecisionTaskFailedRequest, opts ...yarpc.CallOption) error

RespondDecisionTaskFailed provides a mock function with given fields: ctx, failedRequest

func (*HistoryClient) ScheduleDecisionTask 

func (_m *HistoryClient) ScheduleDecisionTask(ctx context.Context, request *history.ScheduleDecisionTaskRequest, opts ...yarpc.CallOption) error

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

func (*HistoryClient) SignalWithStartWorkflowExecution added in v0.3.11 

func (_m *HistoryClient) SignalWithStartWorkflowExecution(ctx context.Context,
	signalWithStartRequest *history.SignalWithStartWorkflowExecutionRequest,
	opts ...yarpc.CallOption) (*shared.StartWorkflowExecutionResponse, error)

SignalWithStartWorkflowExecution provides a mock function with given fields: ctx, signalWithStartRequest

func (*HistoryClient) SignalWorkflowExecution 

func (_m *HistoryClient) SignalWorkflowExecution(ctx context.Context, signalRequest *history.SignalWorkflowExecutionRequest, opts ...yarpc.CallOption) error

SignalWorkflowExecution provides a mock function with given fields: ctx, signalRequest

func (*HistoryClient) StartWorkflowExecution 

func (_m *HistoryClient) StartWorkflowExecution(ctx context.Context, startRequest *history.StartWorkflowExecutionRequest, opts ...yarpc.CallOption) (*shared.StartWorkflowExecutionResponse, error)

StartWorkflowExecution provides a mock function with given fields: ctx, startRequest

func (*HistoryClient) SyncShardStatus added in v0.3.14 

func (_m *HistoryClient) SyncShardStatus(ctx context.Context, request *history.SyncShardStatusRequest, opts ...yarpc.CallOption) error

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

func (*HistoryClient) TerminateWorkflowExecution 

func (_m *HistoryClient) TerminateWorkflowExecution(ctx context.Context, terminateRequest *history.TerminateWorkflowExecutionRequest, opts ...yarpc.CallOption) error

TerminateWorkflowExecution provides a mock function with given fields: ctx, terminateRequest

type HistoryManager 

type HistoryManager struct {
	mock.Mock
}

HistoryManager is an autogenerated mock type for the ExecutionManager type

func (*HistoryManager) AppendHistoryEvents 

func (_m *HistoryManager) AppendHistoryEvents(request *persistence.AppendHistoryEventsRequest) error

AppendHistoryEvents provides a mock function with given fields: request

func (*HistoryManager) Close 

func (_m *HistoryManager) Close()

Close provides a mock function with given fields:

func (*HistoryManager) DeleteWorkflowExecutionHistory 

func (_m *HistoryManager) DeleteWorkflowExecutionHistory(request *persistence.DeleteWorkflowExecutionHistoryRequest) error

DeleteWorkflowExecutionHistory provides a mock function with given fields: request

func (*HistoryManager) GetWorkflowExecutionHistory 

func (_m *HistoryManager) GetWorkflowExecutionHistory(
	request *persistence.GetWorkflowExecutionHistoryRequest) (*persistence.GetWorkflowExecutionHistoryResponse, error)

GetWorkflowExecutionHistory 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 *replicator.ReplicationTask) error

Publish provides a mock function with given fields: msg

func (*KafkaProducer) PublishBatch added in v0.3.7 

func (_m *KafkaProducer) PublishBatch(msgs []*replicator.ReplicationTask) error

PublishBatch provides a mock function with given fields: msgs

type MatchingClient 

type MatchingClient struct {
	mock.Mock
}

MatchingClient is an autogenerated mock type for the Client type

func (*MatchingClient) AddActivityTask 

func (_m *MatchingClient) AddActivityTask(ctx context.Context, addRequest *matching.AddActivityTaskRequest, opts ...yarpc.CallOption) error

AddActivityTask provides a mock function with given fields: ctx, addRequest

func (*MatchingClient) AddDecisionTask 

func (_m *MatchingClient) AddDecisionTask(ctx context.Context, addRequest *matching.AddDecisionTaskRequest, opts ...yarpc.CallOption) error

AddDecisionTask provides a mock function with given fields: ctx, addRequest

func (*MatchingClient) CancelOutstandingPoll added in v0.3.2 

func (_m *MatchingClient) CancelOutstandingPoll(ctx context.Context,
	request *matching.CancelOutstandingPollRequest, opts ...yarpc.CallOption) error

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

func (*MatchingClient) DescribeTaskList added in v0.3.5 

func (_m *MatchingClient) DescribeTaskList(ctx context.Context,
	request *matching.DescribeTaskListRequest, opts ...yarpc.CallOption) (*shared.DescribeTaskListResponse, error)

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

func (*MatchingClient) PollForActivityTask 

func (_m *MatchingClient) PollForActivityTask(ctx context.Context,
	pollRequest *matching.PollForActivityTaskRequest, opts ...yarpc.CallOption) (*shared.PollForActivityTaskResponse, error)

PollForActivityTask provides a mock function with given fields: ctx, pollRequest

func (*MatchingClient) PollForDecisionTask 

func (_m *MatchingClient) PollForDecisionTask(ctx context.Context,
	pollRequest *matching.PollForDecisionTaskRequest, opts ...yarpc.CallOption) (*matching.PollForDecisionTaskResponse, error)

PollForDecisionTask provides a mock function with given fields: ctx, pollRequest

func (*MatchingClient) QueryWorkflow added in v0.3.2 

func (_m *MatchingClient) QueryWorkflow(ctx context.Context,
	queryRequest *matching.QueryWorkflowRequest, opts ...yarpc.CallOption) (*shared.QueryWorkflowResponse, error)

QueryWorkflow provides a mock function with given fields: ctx, queryRequest

func (*MatchingClient) RespondQueryTaskCompleted added in v0.3.2 

func (_m *MatchingClient) RespondQueryTaskCompleted(ctx context.Context,
	request *matching.RespondQueryTaskCompletedRequest, opts ...yarpc.CallOption) error

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

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(currentCluster, sourceCluster, consumerName string, concurrency int) (kafka.Consumer, error)

NewConsumer generates a dummy implementation of kafka consumer

func (*MessagingClient) NewProducer added in v0.3.11 

func (c *MessagingClient) NewProducer(sourceCluster 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(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) 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) 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) 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) CreateTasks 

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

CreateTasks provides a mock function with given fields: request

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) 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) GetClosedWorkflowExecution 

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

GetClosedWorkflowExecution provides a mock function with given fields: request

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

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.
JackTT - Gopher 🇻🇳