mocks

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jan 7, 2019 License: MIT Imports: 17 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 AdminClient added in v0.5.0 

type AdminClient struct {
	mock.Mock
}

AdminClient is an autogenerated mock type for the Client type

func (*AdminClient) DescribeHistoryHost added in v0.5.0 

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

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

func (*AdminClient) DescribeWorkflowExecution added in v0.5.0 

func (_m *AdminClient) DescribeWorkflowExecution(ctx context.Context, request *admin.DescribeWorkflowExecutionRequest, opts ...yarpc.CallOption) (*admin.DescribeWorkflowExecutionResponse, error)

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

func (*AdminClient) GetWorkflowExecutionRawHistory added in v0.5.0 

func (_m *AdminClient) GetWorkflowExecutionRawHistory(ctx context.Context, request *admin.GetWorkflowExecutionRawHistoryRequest, opts ...yarpc.CallOption) (*admin.GetWorkflowExecutionRawHistoryResponse, error)

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

type ArchivalClient added in v0.5.0 

type ArchivalClient struct {
	mock.Mock
}

ArchivalClient is an autogenerated mock type for the ArchivalClient type

func (*ArchivalClient) Archive added in v0.5.0 

func (_m *ArchivalClient) Archive(_a0 *sysworkflow.ArchiveRequest) error

Archive provides a mock function with given fields: _a0

func (*ArchivalClient) Backfill added in v0.5.0 

func (_m *ArchivalClient) Backfill(_a0 *sysworkflow.BackfillRequest) error

Backfill provides a mock function with given fields: _a0

type Client added in v0.5.0 

type Client struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func (*Client) BucketMetadata added in v0.5.0 

func (_m *Client) BucketMetadata(ctx context.Context, bucket string) (*blobstore.BucketMetadataResponse, error)

BucketMetadata provides a mock function with given fields: ctx, bucket

func (*Client) DownloadBlob added in v0.5.0 

func (_m *Client) DownloadBlob(ctx context.Context, bucket string, path string) (*blobstore.Blob, error)

DownloadBlob provides a mock function with given fields: ctx, bucket, path

func (*Client) UploadBlob added in v0.5.0 

func (_m *Client) UploadBlob(ctx context.Context, bucket string, path string, blob *blobstore.Blob) error

UploadBlob provides a mock function with given fields: ctx, bucket, path, blob

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) GetAllClientAddress added in v0.5.0 

func (_m *ClusterMetadata) GetAllClientAddress() map[string]config.Address

GetAllClientAddress 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) GetDefaultArchivalBucket added in v0.5.0 

func (_m *ClusterMetadata) GetDefaultArchivalBucket() string

GetDefaultArchivalBucket 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) IsArchivalEnabled added in v0.5.0 

func (_m *ClusterMetadata) IsArchivalEnabled() bool

IsArchivalEnabled provides a mock function with given fields:

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

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 FrontendClient added in v0.5.0 

type FrontendClient struct {
	mock.Mock
}

FrontendClient is an autogenerated mock type for the Client type

func (*FrontendClient) DeprecateDomain added in v0.5.0 

func (_m *FrontendClient) DeprecateDomain(ctx context.Context, request *shared.DeprecateDomainRequest, opts ...yarpc.CallOption) error

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

func (*FrontendClient) DescribeDomain added in v0.5.0 

func (_m *FrontendClient) DescribeDomain(ctx context.Context, request *shared.DescribeDomainRequest, opts ...yarpc.CallOption) (*shared.DescribeDomainResponse, error)

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

func (*FrontendClient) DescribeTaskList added in v0.5.0 

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

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

func (*FrontendClient) DescribeWorkflowExecution added in v0.5.0 

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

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

func (*FrontendClient) GetWorkflowExecutionHistory added in v0.5.0 

func (_m *FrontendClient) GetWorkflowExecutionHistory(ctx context.Context, request *shared.GetWorkflowExecutionHistoryRequest, opts ...yarpc.CallOption) (*shared.GetWorkflowExecutionHistoryResponse, error)

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

func (*FrontendClient) ListClosedWorkflowExecutions added in v0.5.0 

func (_m *FrontendClient) ListClosedWorkflowExecutions(ctx context.Context, request *shared.ListClosedWorkflowExecutionsRequest, opts ...yarpc.CallOption) (*shared.ListClosedWorkflowExecutionsResponse, error)

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

func (*FrontendClient) ListDomains added in v0.5.0 

func (_m *FrontendClient) ListDomains(ctx context.Context, request *shared.ListDomainsRequest, opts ...yarpc.CallOption) (*shared.ListDomainsResponse, error)

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

func (*FrontendClient) ListOpenWorkflowExecutions added in v0.5.0 

func (_m *FrontendClient) ListOpenWorkflowExecutions(ctx context.Context, request *shared.ListOpenWorkflowExecutionsRequest, opts ...yarpc.CallOption) (*shared.ListOpenWorkflowExecutionsResponse, error)

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

func (*FrontendClient) PollForActivityTask added in v0.5.0 

func (_m *FrontendClient) PollForActivityTask(ctx context.Context, request *shared.PollForActivityTaskRequest, opts ...yarpc.CallOption) (*shared.PollForActivityTaskResponse, error)

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

func (*FrontendClient) PollForDecisionTask added in v0.5.0 

func (_m *FrontendClient) PollForDecisionTask(ctx context.Context, request *shared.PollForDecisionTaskRequest, opts ...yarpc.CallOption) (*shared.PollForDecisionTaskResponse, error)

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

func (*FrontendClient) QueryWorkflow added in v0.5.0 

func (_m *FrontendClient) QueryWorkflow(ctx context.Context, request *shared.QueryWorkflowRequest, opts ...yarpc.CallOption) (*shared.QueryWorkflowResponse, error)

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

func (*FrontendClient) RecordActivityTaskHeartbeat added in v0.5.0 

func (_m *FrontendClient) RecordActivityTaskHeartbeat(ctx context.Context, request *shared.RecordActivityTaskHeartbeatRequest, opts ...yarpc.CallOption) (*shared.RecordActivityTaskHeartbeatResponse, error)

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

func (*FrontendClient) RecordActivityTaskHeartbeatByID added in v0.5.0 

func (_m *FrontendClient) RecordActivityTaskHeartbeatByID(ctx context.Context, request *shared.RecordActivityTaskHeartbeatByIDRequest, opts ...yarpc.CallOption) (*shared.RecordActivityTaskHeartbeatResponse, error)

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

func (*FrontendClient) RegisterDomain added in v0.5.0 

func (_m *FrontendClient) RegisterDomain(ctx context.Context, request *shared.RegisterDomainRequest, opts ...yarpc.CallOption) error

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

func (*FrontendClient) RequestCancelWorkflowExecution added in v0.5.0 

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

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

func (*FrontendClient) ResetStickyTaskList added in v0.5.0 

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

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

func (*FrontendClient) RespondActivityTaskCanceled added in v0.5.0 

func (_m *FrontendClient) RespondActivityTaskCanceled(ctx context.Context, request *shared.RespondActivityTaskCanceledRequest, opts ...yarpc.CallOption) error

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

func (*FrontendClient) RespondActivityTaskCanceledByID added in v0.5.0 

func (_m *FrontendClient) RespondActivityTaskCanceledByID(ctx context.Context, request *shared.RespondActivityTaskCanceledByIDRequest, opts ...yarpc.CallOption) error

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

func (*FrontendClient) RespondActivityTaskCompleted added in v0.5.0 

func (_m *FrontendClient) RespondActivityTaskCompleted(ctx context.Context, request *shared.RespondActivityTaskCompletedRequest, opts ...yarpc.CallOption) error

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

func (*FrontendClient) RespondActivityTaskCompletedByID added in v0.5.0 

func (_m *FrontendClient) RespondActivityTaskCompletedByID(ctx context.Context, request *shared.RespondActivityTaskCompletedByIDRequest, opts ...yarpc.CallOption) error

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

func (*FrontendClient) RespondActivityTaskFailed added in v0.5.0 

func (_m *FrontendClient) RespondActivityTaskFailed(ctx context.Context, request *shared.RespondActivityTaskFailedRequest, opts ...yarpc.CallOption) error

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

func (*FrontendClient) RespondActivityTaskFailedByID added in v0.5.0 

func (_m *FrontendClient) RespondActivityTaskFailedByID(ctx context.Context, request *shared.RespondActivityTaskFailedByIDRequest, opts ...yarpc.CallOption) error

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

func (*FrontendClient) RespondDecisionTaskCompleted added in v0.5.0 

func (_m *FrontendClient) RespondDecisionTaskCompleted(ctx context.Context, request *shared.RespondDecisionTaskCompletedRequest, opts ...yarpc.CallOption) (*shared.RespondDecisionTaskCompletedResponse, error)

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

func (*FrontendClient) RespondDecisionTaskFailed added in v0.5.0 

func (_m *FrontendClient) RespondDecisionTaskFailed(ctx context.Context, request *shared.RespondDecisionTaskFailedRequest, opts ...yarpc.CallOption) error

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

func (*FrontendClient) RespondQueryTaskCompleted added in v0.5.0 

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

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

func (*FrontendClient) SignalWithStartWorkflowExecution added in v0.5.0 

func (_m *FrontendClient) SignalWithStartWorkflowExecution(ctx context.Context, request *shared.SignalWithStartWorkflowExecutionRequest, opts ...yarpc.CallOption) (*shared.StartWorkflowExecutionResponse, error)

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

func (*FrontendClient) SignalWorkflowExecution added in v0.5.0 

func (_m *FrontendClient) SignalWorkflowExecution(ctx context.Context, request *shared.SignalWorkflowExecutionRequest, opts ...yarpc.CallOption) error

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

func (*FrontendClient) StartWorkflowExecution added in v0.5.0 

func (_m *FrontendClient) StartWorkflowExecution(ctx context.Context, request *shared.StartWorkflowExecutionRequest, opts ...yarpc.CallOption) (*shared.StartWorkflowExecutionResponse, error)

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

func (*FrontendClient) TerminateWorkflowExecution added in v0.5.0 

func (_m *FrontendClient) TerminateWorkflowExecution(ctx context.Context, request *shared.TerminateWorkflowExecutionRequest, opts ...yarpc.CallOption) error

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

func (*FrontendClient) UpdateDomain added in v0.5.0 

func (_m *FrontendClient) UpdateDomain(ctx context.Context, request *shared.UpdateDomainRequest, opts ...yarpc.CallOption) (*shared.UpdateDomainResponse, error)

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

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) ReplicateRawEvents added in v0.5.0 

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

ReplicateRawEvents 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 

type HistoryManager struct {
	mock.Mock
}

HistoryManager mock implementation

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

func (*HistoryManager) GetWorkflowExecutionHistoryByBatch added in v0.5.0 

func (_m *HistoryManager) GetWorkflowExecutionHistoryByBatch(request *persistence.GetWorkflowExecutionHistoryRequest) (*persistence.GetWorkflowExecutionHistoryByBatchResponse, error)

GetWorkflowExecutionHistoryByBatch provides a mock function with given fields: request

type HistoryV2Manager added in v0.5.0 

type HistoryV2Manager struct {
	mock.Mock
}

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

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

func (*KafkaProducer) PublishBatch added in v0.3.7 

func (_m *KafkaProducer) PublishBatch(msgs []interface{}) 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) (messaging.Consumer, error)

NewConsumer generates a dummy implementation of kafka consumer

func (*MessagingClient) NewProducer added in v0.3.11 

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

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

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.