Documentation
¶
Index ¶
- func NewMockMessagingClient(publisher messaging.Producer, consumer messaging.Consumer) messaging.Client
- type ClusterMetadata
- func (_m *ClusterMetadata) ClusterNameForFailoverVersion(failoverVersion int64) string
- func (_m *ClusterMetadata) GetAllClusterFailoverVersions() map[string]int64
- func (_m *ClusterMetadata) GetCurrentClusterName() string
- func (_m *ClusterMetadata) GetMasterClusterName() string
- func (_m *ClusterMetadata) GetNextFailoverVersion(_a0 string, _a1 int64) int64
- func (_m *ClusterMetadata) IsGlobalDomainEnabled() bool
- func (_m *ClusterMetadata) IsMasterCluster() bool
- func (_m *ClusterMetadata) IsVersionFromSameCluster(_a0 int64, _a1 int64) bool
- type ExecutionManager
- func (_m *ExecutionManager) Close()
- func (_m *ExecutionManager) CompleteReplicationTask(request *persistence.CompleteReplicationTaskRequest) error
- func (_m *ExecutionManager) CompleteTimerTask(request *persistence.CompleteTimerTaskRequest) error
- func (_m *ExecutionManager) CompleteTransferTask(request *persistence.CompleteTransferTaskRequest) error
- func (_m *ExecutionManager) CreateWorkflowExecution(request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)
- func (_m *ExecutionManager) DeleteWorkflowExecution(request *persistence.DeleteWorkflowExecutionRequest) error
- func (_m *ExecutionManager) GetCurrentExecution(request *persistence.GetCurrentExecutionRequest) (*persistence.GetCurrentExecutionResponse, error)
- func (_m *ExecutionManager) GetName() string
- func (_m *ExecutionManager) GetReplicationTasks(request *persistence.GetReplicationTasksRequest) (*persistence.GetReplicationTasksResponse, error)
- func (_m *ExecutionManager) GetTimerIndexTasks(request *persistence.GetTimerIndexTasksRequest) (*persistence.GetTimerIndexTasksResponse, error)
- func (_m *ExecutionManager) GetTransferTasks(request *persistence.GetTransferTasksRequest) (*persistence.GetTransferTasksResponse, error)
- func (_m *ExecutionManager) GetWorkflowExecution(request *persistence.GetWorkflowExecutionRequest) (*persistence.GetWorkflowExecutionResponse, error)
- func (_m *ExecutionManager) RangeCompleteTimerTask(request *persistence.RangeCompleteTimerTaskRequest) error
- func (_m *ExecutionManager) RangeCompleteTransferTask(request *persistence.RangeCompleteTransferTaskRequest) error
- func (_m *ExecutionManager) ResetMutableState(request *persistence.ResetMutableStateRequest) error
- func (_m *ExecutionManager) UpdateWorkflowExecution(request *persistence.UpdateWorkflowExecutionRequest) (*persistence.UpdateWorkflowExecutionResponse, error)
- type ExecutionManagerFactory
- type HistoryClient
- func (_m *HistoryClient) DescribeHistoryHost(ctx context.Context, request *shared.DescribeHistoryHostRequest, ...) (*shared.DescribeHistoryHostResponse, error)
- func (_m *HistoryClient) DescribeMutableState(ctx context.Context, request *history.DescribeMutableStateRequest, ...) (*history.DescribeMutableStateResponse, error)
- func (_m *HistoryClient) DescribeWorkflowExecution(ctx context.Context, request *history.DescribeWorkflowExecutionRequest, ...) (*shared.DescribeWorkflowExecutionResponse, error)
- func (_m *HistoryClient) GetMutableState(ctx context.Context, getRequest *history.GetMutableStateRequest, ...) (*history.GetMutableStateResponse, error)
- func (_m *HistoryClient) RecordActivityTaskHeartbeat(ctx context.Context, ...) (*shared.RecordActivityTaskHeartbeatResponse, error)
- func (_m *HistoryClient) RecordActivityTaskStarted(ctx context.Context, addRequest *history.RecordActivityTaskStartedRequest, ...) (*history.RecordActivityTaskStartedResponse, error)
- func (_m *HistoryClient) RecordChildExecutionCompleted(ctx context.Context, request *history.RecordChildExecutionCompletedRequest, ...) error
- func (_m *HistoryClient) RecordDecisionTaskStarted(ctx context.Context, addRequest *history.RecordDecisionTaskStartedRequest, ...) (*history.RecordDecisionTaskStartedResponse, error)
- func (_m *HistoryClient) RemoveSignalMutableState(ctx context.Context, removeRequest *history.RemoveSignalMutableStateRequest, ...) error
- func (_m *HistoryClient) ReplicateEvents(ctx context.Context, request *history.ReplicateEventsRequest, ...) error
- func (_m *HistoryClient) RequestCancelWorkflowExecution(ctx context.Context, request *history.RequestCancelWorkflowExecutionRequest, ...) error
- func (_m *HistoryClient) ResetStickyTaskList(ctx context.Context, request *history.ResetStickyTaskListRequest, ...) (*history.ResetStickyTaskListResponse, error)
- func (_m *HistoryClient) RespondActivityTaskCanceled(ctx context.Context, ...) error
- func (_m *HistoryClient) RespondActivityTaskCompleted(ctx context.Context, ...) error
- func (_m *HistoryClient) RespondActivityTaskFailed(ctx context.Context, failRequest *history.RespondActivityTaskFailedRequest, ...) error
- func (_m *HistoryClient) RespondDecisionTaskCompleted(ctx context.Context, ...) (*history.RespondDecisionTaskCompletedResponse, error)
- func (_m *HistoryClient) RespondDecisionTaskFailed(ctx context.Context, failedRequest *history.RespondDecisionTaskFailedRequest, ...) error
- func (_m *HistoryClient) ScheduleDecisionTask(ctx context.Context, request *history.ScheduleDecisionTaskRequest, ...) error
- func (_m *HistoryClient) SignalWithStartWorkflowExecution(ctx context.Context, ...) (*shared.StartWorkflowExecutionResponse, error)
- func (_m *HistoryClient) SignalWorkflowExecution(ctx context.Context, signalRequest *history.SignalWorkflowExecutionRequest, ...) error
- func (_m *HistoryClient) StartWorkflowExecution(ctx context.Context, startRequest *history.StartWorkflowExecutionRequest, ...) (*shared.StartWorkflowExecutionResponse, error)
- func (_m *HistoryClient) SyncActivity(ctx context.Context, request *history.SyncActivityRequest, ...) error
- func (_m *HistoryClient) SyncShardStatus(ctx context.Context, request *history.SyncShardStatusRequest, ...) error
- func (_m *HistoryClient) TerminateWorkflowExecution(ctx context.Context, ...) error
- type HistoryManager
- func (_m *HistoryManager) AppendHistoryEvents(request *persistence.AppendHistoryEventsRequest) (*persistence.AppendHistoryEventsResponse, error)
- func (_m *HistoryManager) Close()
- func (_m *HistoryManager) DeleteWorkflowExecutionHistory(request *persistence.DeleteWorkflowExecutionHistoryRequest) error
- func (_m *HistoryManager) GetName() string
- func (_m *HistoryManager) GetWorkflowExecutionHistory(request *persistence.GetWorkflowExecutionHistoryRequest) (*persistence.GetWorkflowExecutionHistoryResponse, error)
- type KafkaProducer
- type MatchingClient
- func (_m *MatchingClient) AddActivityTask(ctx context.Context, addRequest *matching.AddActivityTaskRequest, ...) error
- func (_m *MatchingClient) AddDecisionTask(ctx context.Context, addRequest *matching.AddDecisionTaskRequest, ...) error
- func (_m *MatchingClient) CancelOutstandingPoll(ctx context.Context, request *matching.CancelOutstandingPollRequest, ...) error
- func (_m *MatchingClient) DescribeTaskList(ctx context.Context, request *matching.DescribeTaskListRequest, ...) (*shared.DescribeTaskListResponse, error)
- func (_m *MatchingClient) PollForActivityTask(ctx context.Context, pollRequest *matching.PollForActivityTaskRequest, ...) (*shared.PollForActivityTaskResponse, error)
- func (_m *MatchingClient) PollForDecisionTask(ctx context.Context, pollRequest *matching.PollForDecisionTaskRequest, ...) (*matching.PollForDecisionTaskResponse, error)
- func (_m *MatchingClient) QueryWorkflow(ctx context.Context, queryRequest *matching.QueryWorkflowRequest, ...) (*shared.QueryWorkflowResponse, error)
- func (_m *MatchingClient) RespondQueryTaskCompleted(ctx context.Context, request *matching.RespondQueryTaskCompletedRequest, ...) error
- type MessagingClient
- type MetadataManager
- func (_m *MetadataManager) Close()
- func (_m *MetadataManager) CreateDomain(request *persistence.CreateDomainRequest) (*persistence.CreateDomainResponse, error)
- func (_m *MetadataManager) DeleteDomain(request *persistence.DeleteDomainRequest) error
- func (_m *MetadataManager) DeleteDomainByName(request *persistence.DeleteDomainByNameRequest) error
- func (_m *MetadataManager) GetDomain(request *persistence.GetDomainRequest) (*persistence.GetDomainResponse, error)
- func (_m *MetadataManager) GetMetadata() (*persistence.GetMetadataResponse, error)
- func (_m *MetadataManager) GetName() string
- func (_m *MetadataManager) ListDomains(request *persistence.ListDomainsRequest) (*persistence.ListDomainsResponse, error)
- func (_m *MetadataManager) UpdateDomain(request *persistence.UpdateDomainRequest) error
- type ServiceResolver
- type ShardManager
- func (_m *ShardManager) Close()
- func (_m *ShardManager) CreateShard(request *persistence.CreateShardRequest) error
- func (_m *ShardManager) GetName() string
- func (_m *ShardManager) GetShard(request *persistence.GetShardRequest) (*persistence.GetShardResponse, error)
- func (_m *ShardManager) UpdateShard(request *persistence.UpdateShardRequest) error
- type TaskManager
- func (_m *TaskManager) Close()
- func (_m *TaskManager) CompleteTask(request *persistence.CompleteTaskRequest) error
- func (_m *TaskManager) CreateTasks(request *persistence.CreateTasksRequest) (*persistence.CreateTasksResponse, error)
- func (_m *TaskManager) GetName() string
- func (_m *TaskManager) GetTasks(request *persistence.GetTasksRequest) (*persistence.GetTasksResponse, error)
- func (_m *TaskManager) LeaseTaskList(request *persistence.LeaseTaskListRequest) (*persistence.LeaseTaskListResponse, error)
- func (_m *TaskManager) UpdateTaskList(request *persistence.UpdateTaskListRequest) (*persistence.UpdateTaskListResponse, error)
- type VisibilityManager
- func (_m *VisibilityManager) Close()
- func (_m *VisibilityManager) GetClosedWorkflowExecution(request *persistence.GetClosedWorkflowExecutionRequest) (*persistence.GetClosedWorkflowExecutionResponse, error)
- func (_m *VisibilityManager) GetName() string
- func (_m *VisibilityManager) ListClosedWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequest) (*persistence.ListWorkflowExecutionsResponse, error)
- func (_m *VisibilityManager) ListClosedWorkflowExecutionsByStatus(request *persistence.ListClosedWorkflowExecutionsByStatusRequest) (*persistence.ListWorkflowExecutionsResponse, error)
- func (_m *VisibilityManager) ListClosedWorkflowExecutionsByType(request *persistence.ListWorkflowExecutionsByTypeRequest) (*persistence.ListWorkflowExecutionsResponse, error)
- func (_m *VisibilityManager) ListClosedWorkflowExecutionsByWorkflowID(request *persistence.ListWorkflowExecutionsByWorkflowIDRequest) (*persistence.ListWorkflowExecutionsResponse, error)
- func (_m *VisibilityManager) ListOpenWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequest) (*persistence.ListWorkflowExecutionsResponse, error)
- func (_m *VisibilityManager) ListOpenWorkflowExecutionsByType(request *persistence.ListWorkflowExecutionsByTypeRequest) (*persistence.ListWorkflowExecutionsResponse, error)
- func (_m *VisibilityManager) ListOpenWorkflowExecutionsByWorkflowID(request *persistence.ListWorkflowExecutionsByWorkflowIDRequest) (*persistence.ListWorkflowExecutionsResponse, error)
- func (_m *VisibilityManager) RecordWorkflowExecutionClosed(request *persistence.RecordWorkflowExecutionClosedRequest) error
- func (_m *VisibilityManager) RecordWorkflowExecutionStarted(request *persistence.RecordWorkflowExecutionStartedRequest) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ClusterMetadata ¶ added in v0.3.11
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 ¶
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) GetName ¶ added in v0.4.0
func (_m *ExecutionManager) GetName() string
GetName provides a mock function with given fields:
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) 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) 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) (*persistence.UpdateWorkflowExecutionResponse, error)
UpdateWorkflowExecution provides a mock function with given fields: request
type ExecutionManagerFactory ¶
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 HistoryClient ¶
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) SyncActivity ¶ added in v0.4.0
func (_m *HistoryClient) SyncActivity(ctx context.Context, request *history.SyncActivityRequest, opts ...yarpc.CallOption) error
SyncActivity provides a mock function with given fields: ctx, request
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 ¶
func (*HistoryManager) AppendHistoryEvents ¶
func (_m *HistoryManager) AppendHistoryEvents(request *persistence.AppendHistoryEventsRequest) (*persistence.AppendHistoryEventsResponse, 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) GetName ¶ added in v0.4.0
func (_m *HistoryManager) GetName() string
GetName provides a mock function with given fields:
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
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 ¶
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) (messaging.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 ¶
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 ¶
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 ¶
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 ¶
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) 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) UpdateTaskList ¶
func (_m *TaskManager) UpdateTaskList(request *persistence.UpdateTaskListRequest) (*persistence.UpdateTaskListResponse, error)
UpdateTaskList provides a mock function with given fields: request
type VisibilityManager ¶
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) 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) 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