history

package
v0.23.1 Latest Latest
Warning

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

 Go to latest Published: Nov 18, 2021 License: MIT Imports: 20 Imported by: 14

Documentation

Overview

Package history is a generated GoMock package.

Index

Constants

View Source 
const (
	// DefaultTimeout is the default timeout used to make calls
	DefaultTimeout = time.Second * 30
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client interface {
	CloseShard(context.Context, *types.CloseShardRequest, ...yarpc.CallOption) error
	DescribeHistoryHost(context.Context, *types.DescribeHistoryHostRequest, ...yarpc.CallOption) (*types.DescribeHistoryHostResponse, error)
	DescribeMutableState(context.Context, *types.DescribeMutableStateRequest, ...yarpc.CallOption) (*types.DescribeMutableStateResponse, error)
	DescribeQueue(context.Context, *types.DescribeQueueRequest, ...yarpc.CallOption) (*types.DescribeQueueResponse, error)
	DescribeWorkflowExecution(context.Context, *types.HistoryDescribeWorkflowExecutionRequest, ...yarpc.CallOption) (*types.DescribeWorkflowExecutionResponse, error)
	GetCrossClusterTasks(context.Context, *types.GetCrossClusterTasksRequest, ...yarpc.CallOption) (*types.GetCrossClusterTasksResponse, error)
	GetDLQReplicationMessages(context.Context, *types.GetDLQReplicationMessagesRequest, ...yarpc.CallOption) (*types.GetDLQReplicationMessagesResponse, error)
	GetMutableState(context.Context, *types.GetMutableStateRequest, ...yarpc.CallOption) (*types.GetMutableStateResponse, error)
	GetReplicationMessages(context.Context, *types.GetReplicationMessagesRequest, ...yarpc.CallOption) (*types.GetReplicationMessagesResponse, error)
	MergeDLQMessages(context.Context, *types.MergeDLQMessagesRequest, ...yarpc.CallOption) (*types.MergeDLQMessagesResponse, error)
	NotifyFailoverMarkers(context.Context, *types.NotifyFailoverMarkersRequest, ...yarpc.CallOption) error
	PollMutableState(context.Context, *types.PollMutableStateRequest, ...yarpc.CallOption) (*types.PollMutableStateResponse, error)
	PurgeDLQMessages(context.Context, *types.PurgeDLQMessagesRequest, ...yarpc.CallOption) error
	QueryWorkflow(context.Context, *types.HistoryQueryWorkflowRequest, ...yarpc.CallOption) (*types.HistoryQueryWorkflowResponse, error)
	ReadDLQMessages(context.Context, *types.ReadDLQMessagesRequest, ...yarpc.CallOption) (*types.ReadDLQMessagesResponse, error)
	ReapplyEvents(context.Context, *types.HistoryReapplyEventsRequest, ...yarpc.CallOption) error
	RecordActivityTaskHeartbeat(context.Context, *types.HistoryRecordActivityTaskHeartbeatRequest, ...yarpc.CallOption) (*types.RecordActivityTaskHeartbeatResponse, error)
	RecordActivityTaskStarted(context.Context, *types.RecordActivityTaskStartedRequest, ...yarpc.CallOption) (*types.RecordActivityTaskStartedResponse, error)
	RecordChildExecutionCompleted(context.Context, *types.RecordChildExecutionCompletedRequest, ...yarpc.CallOption) error
	RecordDecisionTaskStarted(context.Context, *types.RecordDecisionTaskStartedRequest, ...yarpc.CallOption) (*types.RecordDecisionTaskStartedResponse, error)
	RefreshWorkflowTasks(context.Context, *types.HistoryRefreshWorkflowTasksRequest, ...yarpc.CallOption) error
	RemoveSignalMutableState(context.Context, *types.RemoveSignalMutableStateRequest, ...yarpc.CallOption) error
	RemoveTask(context.Context, *types.RemoveTaskRequest, ...yarpc.CallOption) error
	ReplicateEventsV2(context.Context, *types.ReplicateEventsV2Request, ...yarpc.CallOption) error
	RequestCancelWorkflowExecution(context.Context, *types.HistoryRequestCancelWorkflowExecutionRequest, ...yarpc.CallOption) error
	ResetQueue(context.Context, *types.ResetQueueRequest, ...yarpc.CallOption) error
	ResetStickyTaskList(context.Context, *types.HistoryResetStickyTaskListRequest, ...yarpc.CallOption) (*types.HistoryResetStickyTaskListResponse, error)
	ResetWorkflowExecution(context.Context, *types.HistoryResetWorkflowExecutionRequest, ...yarpc.CallOption) (*types.ResetWorkflowExecutionResponse, error)
	RespondActivityTaskCanceled(context.Context, *types.HistoryRespondActivityTaskCanceledRequest, ...yarpc.CallOption) error
	RespondActivityTaskCompleted(context.Context, *types.HistoryRespondActivityTaskCompletedRequest, ...yarpc.CallOption) error
	RespondActivityTaskFailed(context.Context, *types.HistoryRespondActivityTaskFailedRequest, ...yarpc.CallOption) error
	RespondCrossClusterTasksCompleted(context.Context, *types.RespondCrossClusterTasksCompletedRequest, ...yarpc.CallOption) (*types.RespondCrossClusterTasksCompletedResponse, error)
	RespondDecisionTaskCompleted(context.Context, *types.HistoryRespondDecisionTaskCompletedRequest, ...yarpc.CallOption) (*types.HistoryRespondDecisionTaskCompletedResponse, error)
	RespondDecisionTaskFailed(context.Context, *types.HistoryRespondDecisionTaskFailedRequest, ...yarpc.CallOption) error
	ScheduleDecisionTask(context.Context, *types.ScheduleDecisionTaskRequest, ...yarpc.CallOption) error
	SignalWithStartWorkflowExecution(context.Context, *types.HistorySignalWithStartWorkflowExecutionRequest, ...yarpc.CallOption) (*types.StartWorkflowExecutionResponse, error)
	SignalWorkflowExecution(context.Context, *types.HistorySignalWorkflowExecutionRequest, ...yarpc.CallOption) error
	StartWorkflowExecution(context.Context, *types.HistoryStartWorkflowExecutionRequest, ...yarpc.CallOption) (*types.StartWorkflowExecutionResponse, error)
	SyncActivity(context.Context, *types.SyncActivityRequest, ...yarpc.CallOption) error
	SyncShardStatus(context.Context, *types.SyncShardStatusRequest, ...yarpc.CallOption) error
	TerminateWorkflowExecution(context.Context, *types.HistoryTerminateWorkflowExecutionRequest, ...yarpc.CallOption) error
}

Client is the interface exposed by history service client

func NewClient 

func NewClient(
	numberOfShards int,
	rpcMaxSizeInBytes dynamicconfig.IntPropertyFn,
	timeout time.Duration,
	clients common.ClientCache,
	logger log.Logger,
) Client

NewClient creates a new history service TChannel client

func NewErrorInjectionClient added in v0.18.0 

func NewErrorInjectionClient(
	client Client,
	errorRate float64,
	logger log.Logger,
) Client

NewErrorInjectionClient creates a new instance of Client that injects fake error

func NewGRPCClient added in v0.21.0 

func NewGRPCClient(c historyv1.HistoryAPIYARPCClient) Client

func NewMetricClient 

func NewMetricClient(client Client, metricsClient metrics.Client) Client

NewMetricClient creates a new instance of Client that emits metrics

func NewRetryableClient added in v0.3.14 

func NewRetryableClient(
	client Client,
	policy backoff.RetryPolicy,
	isRetryable backoff.IsRetryable,
) Client

NewRetryableClient creates a new instance of Client with retry policy

func NewThriftClient added in v0.17.0 

func NewThriftClient(c historyserviceclient.Interface) Client

NewThriftClient creates a new instance of Client with thrift protocol

type MockClient added in v0.17.0 

type MockClient struct {
	// contains filtered or unexported fields
}

MockClient is a mock of Client interface

func NewMockClient added in v0.17.0 

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance

func (*MockClient) CloseShard added in v0.17.0 

func (m *MockClient) CloseShard(arg0 context.Context, arg1 *types.CloseShardRequest, arg2 ...yarpc.CallOption) error

CloseShard mocks base method

func (*MockClient) DescribeHistoryHost added in v0.17.0 

func (m *MockClient) DescribeHistoryHost(arg0 context.Context, arg1 *types.DescribeHistoryHostRequest, arg2 ...yarpc.CallOption) (*types.DescribeHistoryHostResponse, error)

DescribeHistoryHost mocks base method

func (*MockClient) DescribeMutableState added in v0.17.0 

func (m *MockClient) DescribeMutableState(arg0 context.Context, arg1 *types.DescribeMutableStateRequest, arg2 ...yarpc.CallOption) (*types.DescribeMutableStateResponse, error)

DescribeMutableState mocks base method

func (*MockClient) DescribeQueue added in v0.17.0 

func (m *MockClient) DescribeQueue(arg0 context.Context, arg1 *types.DescribeQueueRequest, arg2 ...yarpc.CallOption) (*types.DescribeQueueResponse, error)

DescribeQueue mocks base method

func (*MockClient) DescribeWorkflowExecution added in v0.17.0 

func (m *MockClient) DescribeWorkflowExecution(arg0 context.Context, arg1 *types.HistoryDescribeWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*types.DescribeWorkflowExecutionResponse, error)

DescribeWorkflowExecution mocks base method

func (*MockClient) EXPECT added in v0.17.0 

func (m *MockClient) EXPECT() *MockClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockClient) GetCrossClusterTasks added in v0.23.1 

func (m *MockClient) GetCrossClusterTasks(arg0 context.Context, arg1 *types.GetCrossClusterTasksRequest, arg2 ...yarpc.CallOption) (*types.GetCrossClusterTasksResponse, error)

GetCrossClusterTasks mocks base method

func (*MockClient) GetDLQReplicationMessages added in v0.17.0 

func (m *MockClient) GetDLQReplicationMessages(arg0 context.Context, arg1 *types.GetDLQReplicationMessagesRequest, arg2 ...yarpc.CallOption) (*types.GetDLQReplicationMessagesResponse, error)

GetDLQReplicationMessages mocks base method

func (*MockClient) GetMutableState added in v0.17.0 

func (m *MockClient) GetMutableState(arg0 context.Context, arg1 *types.GetMutableStateRequest, arg2 ...yarpc.CallOption) (*types.GetMutableStateResponse, error)

GetMutableState mocks base method

func (*MockClient) GetReplicationMessages added in v0.17.0 

func (m *MockClient) GetReplicationMessages(arg0 context.Context, arg1 *types.GetReplicationMessagesRequest, arg2 ...yarpc.CallOption) (*types.GetReplicationMessagesResponse, error)

GetReplicationMessages mocks base method

func (*MockClient) MergeDLQMessages added in v0.17.0 

func (m *MockClient) MergeDLQMessages(arg0 context.Context, arg1 *types.MergeDLQMessagesRequest, arg2 ...yarpc.CallOption) (*types.MergeDLQMessagesResponse, error)

MergeDLQMessages mocks base method

func (*MockClient) NotifyFailoverMarkers added in v0.17.0 

func (m *MockClient) NotifyFailoverMarkers(arg0 context.Context, arg1 *types.NotifyFailoverMarkersRequest, arg2 ...yarpc.CallOption) error

NotifyFailoverMarkers mocks base method

func (*MockClient) PollMutableState added in v0.17.0 

func (m *MockClient) PollMutableState(arg0 context.Context, arg1 *types.PollMutableStateRequest, arg2 ...yarpc.CallOption) (*types.PollMutableStateResponse, error)

PollMutableState mocks base method

func (*MockClient) PurgeDLQMessages added in v0.17.0 

func (m *MockClient) PurgeDLQMessages(arg0 context.Context, arg1 *types.PurgeDLQMessagesRequest, arg2 ...yarpc.CallOption) error

PurgeDLQMessages mocks base method

func (*MockClient) QueryWorkflow added in v0.17.0 

func (m *MockClient) QueryWorkflow(arg0 context.Context, arg1 *types.HistoryQueryWorkflowRequest, arg2 ...yarpc.CallOption) (*types.HistoryQueryWorkflowResponse, error)

QueryWorkflow mocks base method

func (*MockClient) ReadDLQMessages added in v0.17.0 

func (m *MockClient) ReadDLQMessages(arg0 context.Context, arg1 *types.ReadDLQMessagesRequest, arg2 ...yarpc.CallOption) (*types.ReadDLQMessagesResponse, error)

ReadDLQMessages mocks base method

func (*MockClient) ReapplyEvents added in v0.17.0 

func (m *MockClient) ReapplyEvents(arg0 context.Context, arg1 *types.HistoryReapplyEventsRequest, arg2 ...yarpc.CallOption) error

ReapplyEvents mocks base method

func (*MockClient) RecordActivityTaskHeartbeat added in v0.17.0 

func (m *MockClient) RecordActivityTaskHeartbeat(arg0 context.Context, arg1 *types.HistoryRecordActivityTaskHeartbeatRequest, arg2 ...yarpc.CallOption) (*types.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeat mocks base method

func (*MockClient) RecordActivityTaskStarted added in v0.17.0 

func (m *MockClient) RecordActivityTaskStarted(arg0 context.Context, arg1 *types.RecordActivityTaskStartedRequest, arg2 ...yarpc.CallOption) (*types.RecordActivityTaskStartedResponse, error)

RecordActivityTaskStarted mocks base method

func (*MockClient) RecordChildExecutionCompleted added in v0.17.0 

func (m *MockClient) RecordChildExecutionCompleted(arg0 context.Context, arg1 *types.RecordChildExecutionCompletedRequest, arg2 ...yarpc.CallOption) error

RecordChildExecutionCompleted mocks base method

func (*MockClient) RecordDecisionTaskStarted added in v0.17.0 

func (m *MockClient) RecordDecisionTaskStarted(arg0 context.Context, arg1 *types.RecordDecisionTaskStartedRequest, arg2 ...yarpc.CallOption) (*types.RecordDecisionTaskStartedResponse, error)

RecordDecisionTaskStarted mocks base method

func (*MockClient) RefreshWorkflowTasks added in v0.17.0 

func (m *MockClient) RefreshWorkflowTasks(arg0 context.Context, arg1 *types.HistoryRefreshWorkflowTasksRequest, arg2 ...yarpc.CallOption) error

RefreshWorkflowTasks mocks base method

func (*MockClient) RemoveSignalMutableState added in v0.17.0 

func (m *MockClient) RemoveSignalMutableState(arg0 context.Context, arg1 *types.RemoveSignalMutableStateRequest, arg2 ...yarpc.CallOption) error

RemoveSignalMutableState mocks base method

func (*MockClient) RemoveTask added in v0.17.0 

func (m *MockClient) RemoveTask(arg0 context.Context, arg1 *types.RemoveTaskRequest, arg2 ...yarpc.CallOption) error

RemoveTask mocks base method

func (*MockClient) ReplicateEventsV2 added in v0.17.0 

func (m *MockClient) ReplicateEventsV2(arg0 context.Context, arg1 *types.ReplicateEventsV2Request, arg2 ...yarpc.CallOption) error

ReplicateEventsV2 mocks base method

func (*MockClient) RequestCancelWorkflowExecution added in v0.17.0 

func (m *MockClient) RequestCancelWorkflowExecution(arg0 context.Context, arg1 *types.HistoryRequestCancelWorkflowExecutionRequest, arg2 ...yarpc.CallOption) error

RequestCancelWorkflowExecution mocks base method

func (*MockClient) ResetQueue added in v0.17.0 

func (m *MockClient) ResetQueue(arg0 context.Context, arg1 *types.ResetQueueRequest, arg2 ...yarpc.CallOption) error

ResetQueue mocks base method

func (*MockClient) ResetStickyTaskList added in v0.17.0 

func (m *MockClient) ResetStickyTaskList(arg0 context.Context, arg1 *types.HistoryResetStickyTaskListRequest, arg2 ...yarpc.CallOption) (*types.HistoryResetStickyTaskListResponse, error)

ResetStickyTaskList mocks base method

func (*MockClient) ResetWorkflowExecution added in v0.17.0 

func (m *MockClient) ResetWorkflowExecution(arg0 context.Context, arg1 *types.HistoryResetWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*types.ResetWorkflowExecutionResponse, error)

ResetWorkflowExecution mocks base method

func (*MockClient) RespondActivityTaskCanceled added in v0.17.0 

func (m *MockClient) RespondActivityTaskCanceled(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskCanceledRequest, arg2 ...yarpc.CallOption) error

RespondActivityTaskCanceled mocks base method

func (*MockClient) RespondActivityTaskCompleted added in v0.17.0 

func (m *MockClient) RespondActivityTaskCompleted(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskCompletedRequest, arg2 ...yarpc.CallOption) error

RespondActivityTaskCompleted mocks base method

func (*MockClient) RespondActivityTaskFailed added in v0.17.0 

func (m *MockClient) RespondActivityTaskFailed(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskFailedRequest, arg2 ...yarpc.CallOption) error

RespondActivityTaskFailed mocks base method

func (*MockClient) RespondCrossClusterTasksCompleted added in v0.23.1 

func (m *MockClient) RespondCrossClusterTasksCompleted(arg0 context.Context, arg1 *types.RespondCrossClusterTasksCompletedRequest, arg2 ...yarpc.CallOption) (*types.RespondCrossClusterTasksCompletedResponse, error)

RespondCrossClusterTasksCompleted mocks base method

func (*MockClient) RespondDecisionTaskCompleted added in v0.17.0 

func (m *MockClient) RespondDecisionTaskCompleted(arg0 context.Context, arg1 *types.HistoryRespondDecisionTaskCompletedRequest, arg2 ...yarpc.CallOption) (*types.HistoryRespondDecisionTaskCompletedResponse, error)

RespondDecisionTaskCompleted mocks base method

func (*MockClient) RespondDecisionTaskFailed added in v0.17.0 

func (m *MockClient) RespondDecisionTaskFailed(arg0 context.Context, arg1 *types.HistoryRespondDecisionTaskFailedRequest, arg2 ...yarpc.CallOption) error

RespondDecisionTaskFailed mocks base method

func (*MockClient) ScheduleDecisionTask added in v0.17.0 

func (m *MockClient) ScheduleDecisionTask(arg0 context.Context, arg1 *types.ScheduleDecisionTaskRequest, arg2 ...yarpc.CallOption) error

ScheduleDecisionTask mocks base method

func (*MockClient) SignalWithStartWorkflowExecution added in v0.17.0 

func (m *MockClient) SignalWithStartWorkflowExecution(arg0 context.Context, arg1 *types.HistorySignalWithStartWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*types.StartWorkflowExecutionResponse, error)

SignalWithStartWorkflowExecution mocks base method

func (*MockClient) SignalWorkflowExecution added in v0.17.0 

func (m *MockClient) SignalWorkflowExecution(arg0 context.Context, arg1 *types.HistorySignalWorkflowExecutionRequest, arg2 ...yarpc.CallOption) error

SignalWorkflowExecution mocks base method

func (*MockClient) StartWorkflowExecution added in v0.17.0 

func (m *MockClient) StartWorkflowExecution(arg0 context.Context, arg1 *types.HistoryStartWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*types.StartWorkflowExecutionResponse, error)

StartWorkflowExecution mocks base method

func (*MockClient) SyncActivity added in v0.17.0 

func (m *MockClient) SyncActivity(arg0 context.Context, arg1 *types.SyncActivityRequest, arg2 ...yarpc.CallOption) error

SyncActivity mocks base method

func (*MockClient) SyncShardStatus added in v0.17.0 

func (m *MockClient) SyncShardStatus(arg0 context.Context, arg1 *types.SyncShardStatusRequest, arg2 ...yarpc.CallOption) error

SyncShardStatus mocks base method

func (*MockClient) TerminateWorkflowExecution added in v0.17.0 

func (m *MockClient) TerminateWorkflowExecution(arg0 context.Context, arg1 *types.HistoryTerminateWorkflowExecutionRequest, arg2 ...yarpc.CallOption) error

TerminateWorkflowExecution mocks base method

type MockClientMockRecorder added in v0.17.0 

type MockClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockClientMockRecorder is the mock recorder for MockClient

func (*MockClientMockRecorder) CloseShard added in v0.17.0 

func (mr *MockClientMockRecorder) CloseShard(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

CloseShard indicates an expected call of CloseShard

func (*MockClientMockRecorder) DescribeHistoryHost added in v0.17.0 

func (mr *MockClientMockRecorder) DescribeHistoryHost(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DescribeHistoryHost indicates an expected call of DescribeHistoryHost

func (*MockClientMockRecorder) DescribeMutableState added in v0.17.0 

func (mr *MockClientMockRecorder) DescribeMutableState(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DescribeMutableState indicates an expected call of DescribeMutableState

func (*MockClientMockRecorder) DescribeQueue added in v0.17.0 

func (mr *MockClientMockRecorder) DescribeQueue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DescribeQueue indicates an expected call of DescribeQueue

func (*MockClientMockRecorder) DescribeWorkflowExecution added in v0.17.0 

func (mr *MockClientMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution

func (*MockClientMockRecorder) GetCrossClusterTasks added in v0.23.1 

func (mr *MockClientMockRecorder) GetCrossClusterTasks(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetCrossClusterTasks indicates an expected call of GetCrossClusterTasks

func (*MockClientMockRecorder) GetDLQReplicationMessages added in v0.17.0 

func (mr *MockClientMockRecorder) GetDLQReplicationMessages(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetDLQReplicationMessages indicates an expected call of GetDLQReplicationMessages

func (*MockClientMockRecorder) GetMutableState added in v0.17.0 

func (mr *MockClientMockRecorder) GetMutableState(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetMutableState indicates an expected call of GetMutableState

func (*MockClientMockRecorder) GetReplicationMessages added in v0.17.0 

func (mr *MockClientMockRecorder) GetReplicationMessages(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetReplicationMessages indicates an expected call of GetReplicationMessages

func (*MockClientMockRecorder) MergeDLQMessages added in v0.17.0 

func (mr *MockClientMockRecorder) MergeDLQMessages(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

MergeDLQMessages indicates an expected call of MergeDLQMessages

func (*MockClientMockRecorder) NotifyFailoverMarkers added in v0.17.0 

func (mr *MockClientMockRecorder) NotifyFailoverMarkers(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

NotifyFailoverMarkers indicates an expected call of NotifyFailoverMarkers

func (*MockClientMockRecorder) PollMutableState added in v0.17.0 

func (mr *MockClientMockRecorder) PollMutableState(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PollMutableState indicates an expected call of PollMutableState

func (*MockClientMockRecorder) PurgeDLQMessages added in v0.17.0 

func (mr *MockClientMockRecorder) PurgeDLQMessages(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PurgeDLQMessages indicates an expected call of PurgeDLQMessages

func (*MockClientMockRecorder) QueryWorkflow added in v0.17.0 

func (mr *MockClientMockRecorder) QueryWorkflow(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

QueryWorkflow indicates an expected call of QueryWorkflow

func (*MockClientMockRecorder) ReadDLQMessages added in v0.17.0 

func (mr *MockClientMockRecorder) ReadDLQMessages(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ReadDLQMessages indicates an expected call of ReadDLQMessages

func (*MockClientMockRecorder) ReapplyEvents added in v0.17.0 

func (mr *MockClientMockRecorder) ReapplyEvents(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ReapplyEvents indicates an expected call of ReapplyEvents

func (*MockClientMockRecorder) RecordActivityTaskHeartbeat added in v0.17.0 

func (mr *MockClientMockRecorder) RecordActivityTaskHeartbeat(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat

func (*MockClientMockRecorder) RecordActivityTaskStarted added in v0.17.0 

func (mr *MockClientMockRecorder) RecordActivityTaskStarted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RecordActivityTaskStarted indicates an expected call of RecordActivityTaskStarted

func (*MockClientMockRecorder) RecordChildExecutionCompleted added in v0.17.0 

func (mr *MockClientMockRecorder) RecordChildExecutionCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RecordChildExecutionCompleted indicates an expected call of RecordChildExecutionCompleted

func (*MockClientMockRecorder) RecordDecisionTaskStarted added in v0.17.0 

func (mr *MockClientMockRecorder) RecordDecisionTaskStarted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RecordDecisionTaskStarted indicates an expected call of RecordDecisionTaskStarted

func (*MockClientMockRecorder) RefreshWorkflowTasks added in v0.17.0 

func (mr *MockClientMockRecorder) RefreshWorkflowTasks(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks

func (*MockClientMockRecorder) RemoveSignalMutableState added in v0.17.0 

func (mr *MockClientMockRecorder) RemoveSignalMutableState(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RemoveSignalMutableState indicates an expected call of RemoveSignalMutableState

func (*MockClientMockRecorder) RemoveTask added in v0.17.0 

func (mr *MockClientMockRecorder) RemoveTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RemoveTask indicates an expected call of RemoveTask

func (*MockClientMockRecorder) ReplicateEventsV2 added in v0.17.0 

func (mr *MockClientMockRecorder) ReplicateEventsV2(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ReplicateEventsV2 indicates an expected call of ReplicateEventsV2

func (*MockClientMockRecorder) RequestCancelWorkflowExecution added in v0.17.0 

func (mr *MockClientMockRecorder) RequestCancelWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution

func (*MockClientMockRecorder) ResetQueue added in v0.17.0 

func (mr *MockClientMockRecorder) ResetQueue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ResetQueue indicates an expected call of ResetQueue

func (*MockClientMockRecorder) ResetStickyTaskList added in v0.17.0 

func (mr *MockClientMockRecorder) ResetStickyTaskList(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ResetStickyTaskList indicates an expected call of ResetStickyTaskList

func (*MockClientMockRecorder) ResetWorkflowExecution added in v0.17.0 

func (mr *MockClientMockRecorder) ResetWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution

func (*MockClientMockRecorder) RespondActivityTaskCanceled added in v0.17.0 

func (mr *MockClientMockRecorder) RespondActivityTaskCanceled(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled

func (*MockClientMockRecorder) RespondActivityTaskCompleted added in v0.17.0 

func (mr *MockClientMockRecorder) RespondActivityTaskCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted

func (*MockClientMockRecorder) RespondActivityTaskFailed added in v0.17.0 

func (mr *MockClientMockRecorder) RespondActivityTaskFailed(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed

func (*MockClientMockRecorder) RespondCrossClusterTasksCompleted added in v0.23.1 

func (mr *MockClientMockRecorder) RespondCrossClusterTasksCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondCrossClusterTasksCompleted indicates an expected call of RespondCrossClusterTasksCompleted

func (*MockClientMockRecorder) RespondDecisionTaskCompleted added in v0.17.0 

func (mr *MockClientMockRecorder) RespondDecisionTaskCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondDecisionTaskCompleted indicates an expected call of RespondDecisionTaskCompleted

func (*MockClientMockRecorder) RespondDecisionTaskFailed added in v0.17.0 

func (mr *MockClientMockRecorder) RespondDecisionTaskFailed(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondDecisionTaskFailed indicates an expected call of RespondDecisionTaskFailed

func (*MockClientMockRecorder) ScheduleDecisionTask added in v0.17.0 

func (mr *MockClientMockRecorder) ScheduleDecisionTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ScheduleDecisionTask indicates an expected call of ScheduleDecisionTask

func (*MockClientMockRecorder) SignalWithStartWorkflowExecution added in v0.17.0 

func (mr *MockClientMockRecorder) SignalWithStartWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution

func (*MockClientMockRecorder) SignalWorkflowExecution added in v0.17.0 

func (mr *MockClientMockRecorder) SignalWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution

func (*MockClientMockRecorder) StartWorkflowExecution added in v0.17.0 

func (mr *MockClientMockRecorder) StartWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

StartWorkflowExecution indicates an expected call of StartWorkflowExecution

func (*MockClientMockRecorder) SyncActivity added in v0.17.0 

func (mr *MockClientMockRecorder) SyncActivity(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

SyncActivity indicates an expected call of SyncActivity

func (*MockClientMockRecorder) SyncShardStatus added in v0.17.0 

func (mr *MockClientMockRecorder) SyncShardStatus(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

SyncShardStatus indicates an expected call of SyncShardStatus

func (*MockClientMockRecorder) TerminateWorkflowExecution added in v0.17.0 

func (mr *MockClientMockRecorder) TerminateWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution

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.