mocks

package
v0.6.0 Latest Latest
Warning

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

Go to latest
Published: Jul 24, 2019 License: MIT Imports: 17 Imported by: 4

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMockMessagingClient added in v0.3.11

func NewMockMessagingClient(publisher messaging.Producer, consumer messaging.Consumer) messaging.Client

NewMockMessagingClient generate a dummy implementation of messaging client

Types

type AdminClient added in v0.5.0

type AdminClient struct {
	mock.Mock
}

AdminClient is an autogenerated mock type for the Client type

func (*AdminClient) AddSearchAttribute added in v0.6.0

func (_m *AdminClient) AddSearchAttribute(ctx context.Context, Request *admin.AddSearchAttributeRequest, opts ...yarpc.CallOption) error

AddSearchAttribute provides a mock function with given fields: ctx, Request, opts

func (*AdminClient) DescribeHistoryHost added in v0.5.0

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

func (*AdminClient) DescribeWorkflowExecution added in v0.5.0

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

func (*AdminClient) GetWorkflowExecutionRawHistory added in v0.5.0

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

type BlobstoreClient added in v0.5.2

type BlobstoreClient struct {
	mock.Mock
}

BlobstoreClient is an autogenerated mock type for the blobstore.Client type

func (*BlobstoreClient) BucketExists added in v0.5.7

func (_m *BlobstoreClient) BucketExists(ctx context.Context, bucket string) (bool, error)

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

func (*BlobstoreClient) Delete added in v0.5.2

func (_m *BlobstoreClient) Delete(ctx context.Context, bucket string, key blob.Key) (bool, error)

Delete provides a mock function with given fields: ctx, bucket, key

func (*BlobstoreClient) Download added in v0.5.2

func (_m *BlobstoreClient) Download(ctx context.Context, bucket string, key blob.Key) (*blob.Blob, error)

Download provides a mock function with given fields: ctx, bucket, key

func (*BlobstoreClient) Exists added in v0.5.2

func (_m *BlobstoreClient) Exists(ctx context.Context, bucket string, key blob.Key) (bool, error)

Exists provides a mock function with given fields: ctx, bucket, key

func (*BlobstoreClient) GetRetryPolicy added in v0.5.7

func (_m *BlobstoreClient) GetRetryPolicy() backoff.RetryPolicy

GetRetryPolicy provides a mock function with given fields:

func (*BlobstoreClient) GetTags added in v0.5.7

func (_m *BlobstoreClient) GetTags(ctx context.Context, bucket string, key blob.Key) (map[string]string, error)

GetTags provides a mock function with given fields: ctx, bucket, key

func (*BlobstoreClient) IsRetryableError added in v0.5.7

func (_m *BlobstoreClient) IsRetryableError(err error) bool

IsRetryableError provides a mock function with given fields: err

func (*BlobstoreClient) ListByPrefix added in v0.5.2

func (_m *BlobstoreClient) ListByPrefix(ctx context.Context, bucket string, prefix string) ([]blob.Key, error)

ListByPrefix provides a mock function with given fields: ctx, bucket, prefix

func (*BlobstoreClient) Upload added in v0.5.2

func (_m *BlobstoreClient) Upload(ctx context.Context, bucket string, key blob.Key, _a3 *blob.Blob) error

Upload provides a mock function with given fields: ctx, bucket, key, _a3

type ClusterMetadata added in v0.3.11

type ClusterMetadata struct {
	mock.Mock
}

ClusterMetadata is an autogenerated mock type for the Metadata type

func (*ClusterMetadata) ArchivalConfig added in v0.5.4

func (_m *ClusterMetadata) ArchivalConfig() *cluster.ArchivalConfig

ArchivalConfig provides a mock function with given fields:

func (*ClusterMetadata) ClusterNameForFailoverVersion added in v0.3.11

func (_m *ClusterMetadata) ClusterNameForFailoverVersion(failoverVersion int64) string

ClusterNameForFailoverVersion provides a mock function with given fields:

func (*ClusterMetadata) GetAllClusterInfo added in v0.5.8

func (_m *ClusterMetadata) GetAllClusterInfo() map[string]config.ClusterInformation

GetAllClusterInfo provides a mock function with given fields:

func (*ClusterMetadata) GetCurrentClusterName added in v0.3.11

func (_m *ClusterMetadata) GetCurrentClusterName() string

GetCurrentClusterName provides a mock function with given fields:

func (*ClusterMetadata) GetDeploymentGroup added in v0.5.0

func (_m *ClusterMetadata) GetDeploymentGroup() string

GetDeploymentGroup provides a mock function with given fields:

func (*ClusterMetadata) GetMasterClusterName added in v0.3.11

func (_m *ClusterMetadata) GetMasterClusterName() string

GetMasterClusterName provides a mock function with given fields:

func (*ClusterMetadata) GetNextFailoverVersion added in v0.3.11

func (_m *ClusterMetadata) GetNextFailoverVersion(_a0 string, _a1 int64) int64

GetNextFailoverVersion provides a mock function with given fields: _a0, _a1

func (*ClusterMetadata) IsGlobalDomainEnabled added in v0.3.11

func (_m *ClusterMetadata) IsGlobalDomainEnabled() bool

IsGlobalDomainEnabled provides a mock function with given fields:

func (*ClusterMetadata) IsMasterCluster added in v0.3.11

func (_m *ClusterMetadata) IsMasterCluster() bool

IsMasterCluster provides a mock function with given fields:

func (*ClusterMetadata) IsVersionFromSameCluster added in v0.3.14

func (_m *ClusterMetadata) IsVersionFromSameCluster(_a0 int64, _a1 int64) bool

IsVersionFromSameCluster provides a mock function with given fields: _a0, _a1

type ExecutionManager

type ExecutionManager struct {
	mock.Mock
}

ExecutionManager mock implementation

func (*ExecutionManager) Close

func (_m *ExecutionManager) Close()

Close provides a mock function with given fields:

func (*ExecutionManager) CompleteReplicationTask added in v0.3.11

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

CompleteReplicationTask provides a mock function with given fields: request

func (*ExecutionManager) CompleteTimerTask

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

CompleteTimerTask provides a mock function with given fields: request

func (*ExecutionManager) CompleteTransferTask

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

CompleteTransferTask provides a mock function with given fields: request

func (*ExecutionManager) CreateWorkflowExecution

CreateWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) DeleteCurrentWorkflowExecution added in v0.5.8

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

DeleteCurrentWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) DeleteWorkflowExecution

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

DeleteWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) GetCurrentExecution

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

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

GetTimerIndexTasks provides a mock function with given fields: request

func (*ExecutionManager) GetTransferTasks

GetTransferTasks provides a mock function with given fields: request

func (*ExecutionManager) GetWorkflowExecution

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) ResetWorkflowExecution added in v0.5.2

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

ResetWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) UpdateWorkflowExecution

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) CountWorkflowExecutions added in v0.5.8

CountWorkflowExecutions provides a mock function with given fields: ctx, CountRequest, opts

func (*FrontendClient) DeprecateDomain added in v0.5.0

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

DeprecateDomain provides a mock function with given fields: ctx, DeprecateRequest, opts

func (*FrontendClient) DescribeDomain added in v0.5.0

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

DescribeDomain provides a mock function with given fields: ctx, DescribeRequest, opts

func (*FrontendClient) DescribeTaskList added in v0.5.0

DescribeTaskList provides a mock function with given fields: ctx, Request, opts

func (*FrontendClient) DescribeWorkflowExecution added in v0.5.0

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

DescribeWorkflowExecution provides a mock function with given fields: ctx, DescribeRequest, opts

func (*FrontendClient) GetSearchAttributes added in v0.5.9

func (_m *FrontendClient) GetSearchAttributes(ctx context.Context, opts ...yarpc.CallOption) (*shared.GetSearchAttributesResponse, error)

GetSearchAttributes provides a mock function with given fields: ctx, opts

func (*FrontendClient) GetWorkflowExecutionHistory added in v0.5.0

GetWorkflowExecutionHistory provides a mock function with given fields: ctx, GetRequest, opts

func (*FrontendClient) ListClosedWorkflowExecutions added in v0.5.0

ListClosedWorkflowExecutions provides a mock function with given fields: ctx, ListRequest, opts

func (*FrontendClient) ListDomains added in v0.5.0

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

ListDomains provides a mock function with given fields: ctx, ListRequest, opts

func (*FrontendClient) ListOpenWorkflowExecutions added in v0.5.0

ListOpenWorkflowExecutions provides a mock function with given fields: ctx, ListRequest, opts

func (*FrontendClient) ListWorkflowExecutions added in v0.5.7

ListWorkflowExecutions provides a mock function with given fields: ctx, ListRequest, opts

func (*FrontendClient) PollForActivityTask added in v0.5.0

PollForActivityTask provides a mock function with given fields: ctx, PollRequest, opts

func (*FrontendClient) PollForDecisionTask added in v0.5.0

PollForDecisionTask provides a mock function with given fields: ctx, PollRequest, opts

func (*FrontendClient) QueryWorkflow added in v0.5.0

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

QueryWorkflow provides a mock function with given fields: ctx, QueryRequest, opts

func (*FrontendClient) RecordActivityTaskHeartbeat added in v0.5.0

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

RecordActivityTaskHeartbeat provides a mock function with given fields: ctx, HeartbeatRequest, opts

func (*FrontendClient) RecordActivityTaskHeartbeatByID added in v0.5.0

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

RecordActivityTaskHeartbeatByID provides a mock function with given fields: ctx, HeartbeatRequest, opts

func (*FrontendClient) RegisterDomain added in v0.5.0

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

RegisterDomain provides a mock function with given fields: ctx, RegisterRequest, opts

func (*FrontendClient) RequestCancelWorkflowExecution added in v0.5.0

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

RequestCancelWorkflowExecution provides a mock function with given fields: ctx, CancelRequest, opts

func (*FrontendClient) ResetStickyTaskList added in v0.5.0

ResetStickyTaskList provides a mock function with given fields: ctx, ResetRequest, opts

func (*FrontendClient) ResetWorkflowExecution added in v0.5.7

ResetWorkflowExecution provides a mock function with given fields: ctx, ResetRequest, opts

func (*FrontendClient) RespondActivityTaskCanceled added in v0.5.0

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

RespondActivityTaskCanceled provides a mock function with given fields: ctx, CanceledRequest, opts

func (*FrontendClient) RespondActivityTaskCanceledByID added in v0.5.0

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

RespondActivityTaskCanceledByID provides a mock function with given fields: ctx, CanceledRequest, opts

func (*FrontendClient) RespondActivityTaskCompleted added in v0.5.0

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

RespondActivityTaskCompleted provides a mock function with given fields: ctx, CompleteRequest, opts

func (*FrontendClient) RespondActivityTaskCompletedByID added in v0.5.0

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

RespondActivityTaskCompletedByID provides a mock function with given fields: ctx, CompleteRequest, opts

func (*FrontendClient) RespondActivityTaskFailed added in v0.5.0

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

RespondActivityTaskFailed provides a mock function with given fields: ctx, FailRequest, opts

func (*FrontendClient) RespondActivityTaskFailedByID added in v0.5.0

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

RespondActivityTaskFailedByID provides a mock function with given fields: ctx, FailRequest, opts

func (*FrontendClient) RespondDecisionTaskCompleted added in v0.5.0

RespondDecisionTaskCompleted provides a mock function with given fields: ctx, CompleteRequest, opts

func (*FrontendClient) RespondDecisionTaskFailed added in v0.5.0

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

RespondDecisionTaskFailed provides a mock function with given fields: ctx, FailedRequest, opts

func (*FrontendClient) RespondQueryTaskCompleted added in v0.5.0

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

RespondQueryTaskCompleted provides a mock function with given fields: ctx, CompleteRequest, opts

func (*FrontendClient) ScanWorkflowExecutions added in v0.5.8

ScanWorkflowExecutions provides a mock function with given fields: ctx, ListRequest, opts

func (*FrontendClient) SignalWithStartWorkflowExecution added in v0.5.0

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

SignalWithStartWorkflowExecution provides a mock function with given fields: ctx, SignalWithStartRequest, opts

func (*FrontendClient) SignalWorkflowExecution added in v0.5.0

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

SignalWorkflowExecution provides a mock function with given fields: ctx, SignalRequest, opts

func (*FrontendClient) StartWorkflowExecution added in v0.5.0

StartWorkflowExecution provides a mock function with given fields: ctx, StartRequest, opts

func (*FrontendClient) TerminateWorkflowExecution added in v0.5.0

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

TerminateWorkflowExecution provides a mock function with given fields: ctx, TerminateRequest, opts

func (*FrontendClient) UpdateDomain added in v0.5.0

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

UpdateDomain provides a mock function with given fields: ctx, UpdateRequest, opts

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

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

func (*HistoryClient) DescribeMutableState added in v0.3.13

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

func (*HistoryClient) DescribeWorkflowExecution added in v0.3.3

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

func (*HistoryClient) GetMutableState added in v0.3.5

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

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

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

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

func (*HistoryClient) ResetWorkflowExecution added in v0.5.2

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

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

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

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

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

GetWorkflowExecutionHistory provides a mock function with given fields: request

func (*HistoryManager) GetWorkflowExecutionHistoryByBatch added in v0.5.0

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

AppendHistoryNodes provides a mock function with given fields: request

func (*HistoryV2Manager) Close added in v0.5.0

func (_m *HistoryV2Manager) Close()

Close provides a mock function with given fields:

func (*HistoryV2Manager) CompleteForkBranch added in v0.5.2

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

CompleteForkBranch provides a mock function with given fields: request

func (*HistoryV2Manager) DeleteHistoryBranch added in v0.5.0

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

DeleteHistoryBranch provides a mock function with given fields: request

func (*HistoryV2Manager) ForkHistoryBranch added in v0.5.0

ForkHistoryBranch provides a mock function with given fields: request

func (*HistoryV2Manager) GetHistoryTree added in v0.5.0

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

ReadHistoryBranch provides a mock function with given fields: request

func (*HistoryV2Manager) ReadHistoryBranchByBatch added in v0.5.0

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

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

func (*MatchingClient) PollForActivityTask

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

func (*MatchingClient) PollForDecisionTask

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

NewConsumer generates a dummy implementation of kafka consumer

func (*MessagingClient) NewConsumerWithClusterName added in v0.5.2

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

NewConsumerWithClusterName generates a dummy implementation of kafka consumer

func (*MessagingClient) NewProducer added in v0.3.11

func (c *MessagingClient) NewProducer(appName string) (messaging.Producer, error)

NewProducer generates a dummy implementation of kafka producer

func (*MessagingClient) NewProducerWithClusterName added in v0.5.0

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

NewProducerWithClusterName generates a dummy implementation of kafka producer

type MetadataManager

type MetadataManager struct {
	mock.Mock
}

MetadataManager is an autogenerated mock type for the MetadataManager type

func (*MetadataManager) Close

func (_m *MetadataManager) Close()

Close provides a mock function with given fields:

func (*MetadataManager) CreateDomain

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

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

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

GetShard provides a mock function with given fields: request

func (*ShardManager) UpdateShard

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

UpdateShard provides a mock function with given fields: request

type TaskManager

type TaskManager struct {
	mock.Mock
}

TaskManager is an autogenerated mock type for the TaskManager type

func (*TaskManager) Close

func (_m *TaskManager) Close()

Close provides a mock function with given fields:

func (*TaskManager) CompleteTask

func (_m *TaskManager) CompleteTask(request *persistence.CompleteTaskRequest) error

CompleteTask provides a mock function with given fields: request

func (*TaskManager) CompleteTasksLessThan added in v0.5.7

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

CompleteTasksLessThan

func (*TaskManager) CreateTasks

CreateTasks provides a mock function with given fields: request

func (*TaskManager) DeleteTaskList added in v0.5.7

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

func (*TaskManager) GetName added in v0.4.0

func (_m *TaskManager) GetName() string

GetName provides a mock function with given fields:

func (*TaskManager) GetTasks

GetTasks provides a mock function with given fields: request

func (*TaskManager) LeaseTaskList

LeaseTaskList provides a mock function with given fields: request

func (*TaskManager) ListTaskList added in v0.5.7

func (*TaskManager) UpdateTaskList

UpdateTaskList provides a mock function with given fields: request

type VisibilityManager

type VisibilityManager struct {
	mock.Mock
}

VisibilityManager is an autogenerated mock type for the VisibilityManager type

func (*VisibilityManager) Close

func (_m *VisibilityManager) Close()

Close provides a mock function with given fields:

func (*VisibilityManager) CountWorkflowExecutions added in v0.5.8

CountWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) DeleteWorkflowExecution added in v0.5.7

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

DeleteWorkflowExecution provides a mock function with given fields: request

func (*VisibilityManager) GetClosedWorkflowExecution

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

ListClosedWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutionsByStatus

ListClosedWorkflowExecutionsByStatus provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutionsByType

ListClosedWorkflowExecutionsByType provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutionsByWorkflowID

ListClosedWorkflowExecutionsByWorkflowID provides a mock function with given fields: request

func (*VisibilityManager) ListOpenWorkflowExecutions

ListOpenWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) ListOpenWorkflowExecutionsByType

ListOpenWorkflowExecutionsByType provides a mock function with given fields: request

func (*VisibilityManager) ListOpenWorkflowExecutionsByWorkflowID

ListOpenWorkflowExecutionsByWorkflowID provides a mock function with given fields: request

func (*VisibilityManager) ListWorkflowExecutions added in v0.5.7

ListWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) RecordWorkflowExecutionClosed

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

RecordWorkflowExecutionClosed provides a mock function with given fields: request

func (*VisibilityManager) RecordWorkflowExecutionStarted

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

RecordWorkflowExecutionStarted provides a mock function with given fields: request

func (*VisibilityManager) ScanWorkflowExecutions added in v0.5.8

ScanWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) UpsertWorkflowExecution added in v0.6.0

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

UpsertWorkflowExecution provides a mock function with given fields: request

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL