history

package
v1.2.15-prerelease02 Latest Latest
Warning

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

 Go to latest Published: Nov 15, 2024 License: MIT Imports: 18 Imported by: 14

Documentation

Overview

Package history is a generated GoMock package.

Package history is a generated GoMock package.

Index

Constants

This section is empty.

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)
	CountDLQMessages(context.Context, *types.CountDLQMessagesRequest, ...yarpc.CallOption) (*types.HistoryCountDLQMessagesResponse, 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
	GetFailoverInfo(context.Context, *types.GetFailoverInfoRequest, ...yarpc.CallOption) (*types.GetFailoverInfoResponse, error)

	// RatelimitUpdate pushes usage info for the passed ratelimit keys, and requests updated weight info from aggregating hosts.
	// Exact semantics beyond this depend on the load-balanced ratelimit implementation.
	//
	// A peer (via yarpc.WithShardkey) MUST be determined before calling and passed in yarpc opts,
	// and unlike most endpoints this will NOT be forwarded to a new peer if the ring membership changes.
	// To correctly forward keys to the new hosts, they must be re-sharded to find their new hosts.
	RatelimitUpdate(ctx context.Context, request *types.RatelimitUpdateRequest, opts ...yarpc.CallOption) (*types.RatelimitUpdateResponse, error)
}

Client is the interface exposed by history service client

func NewClient 

func NewClient(
	numberOfShards int,
	rpcMaxSizeInBytes int,
	client Client,
	peerResolver PeerResolver,
	logger log.Logger,
) Client

NewClient creates a new history service TChannel client

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) CountDLQMessages added in v0.25.0 

func (m *MockClient) CountDLQMessages(arg0 context.Context, arg1 *types.CountDLQMessagesRequest, arg2 ...yarpc.CallOption) (*types.HistoryCountDLQMessagesResponse, error)

CountDLQMessages 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) GetFailoverInfo added in v0.24.0 

func (m *MockClient) GetFailoverInfo(arg0 context.Context, arg1 *types.GetFailoverInfoRequest, arg2 ...yarpc.CallOption) (*types.GetFailoverInfoResponse, error)

GetFailoverInfo 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) RatelimitUpdate added in v1.2.12 

func (m *MockClient) RatelimitUpdate(ctx context.Context, request *types.RatelimitUpdateRequest, opts ...yarpc.CallOption) (*types.RatelimitUpdateResponse, error)

RatelimitUpdate 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) CountDLQMessages added in v0.25.0 

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

CountDLQMessages indicates an expected call of CountDLQMessages.

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) GetFailoverInfo added in v0.24.0 

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

GetFailoverInfo indicates an expected call of GetFailoverInfo.

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) RatelimitUpdate added in v1.2.12 

func (mr *MockClientMockRecorder) RatelimitUpdate(ctx, request interface{}, opts ...interface{}) *gomock.Call

RatelimitUpdate indicates an expected call of RatelimitUpdate.

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.

type MockPeerResolver added in v1.2.9 

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

MockPeerResolver is a mock of PeerResolver interface.

func NewMockPeerResolver added in v1.2.9 

func NewMockPeerResolver(ctrl *gomock.Controller) *MockPeerResolver

NewMockPeerResolver creates a new mock instance.

func (*MockPeerResolver) EXPECT added in v1.2.9 

func (m *MockPeerResolver) EXPECT() *MockPeerResolverMockRecorder

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

func (*MockPeerResolver) FromDomainID added in v1.2.9 

func (m *MockPeerResolver) FromDomainID(domainID string) (string, error)

FromDomainID mocks base method.

func (*MockPeerResolver) FromHostAddress added in v1.2.9 

func (m *MockPeerResolver) FromHostAddress(hostAddress string) (string, error)

FromHostAddress mocks base method.

func (*MockPeerResolver) FromShardID added in v1.2.9 

func (m *MockPeerResolver) FromShardID(shardID int) (string, error)

FromShardID mocks base method.

func (*MockPeerResolver) FromWorkflowID added in v1.2.9 

func (m *MockPeerResolver) FromWorkflowID(workflowID string) (string, error)

FromWorkflowID mocks base method.

func (*MockPeerResolver) GetAllPeers added in v1.2.9 

func (m *MockPeerResolver) GetAllPeers() ([]string, error)

GetAllPeers mocks base method.

func (*MockPeerResolver) GlobalRatelimitPeers added in v1.2.12 

func (m *MockPeerResolver) GlobalRatelimitPeers(ratelimits []string) (map[Peer][]string, error)

GlobalRatelimitPeers mocks base method.

type MockPeerResolverMockRecorder added in v1.2.9 

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

MockPeerResolverMockRecorder is the mock recorder for MockPeerResolver.

func (*MockPeerResolverMockRecorder) FromDomainID added in v1.2.9 

func (mr *MockPeerResolverMockRecorder) FromDomainID(domainID interface{}) *gomock.Call

FromDomainID indicates an expected call of FromDomainID.

func (*MockPeerResolverMockRecorder) FromHostAddress added in v1.2.9 

func (mr *MockPeerResolverMockRecorder) FromHostAddress(hostAddress interface{}) *gomock.Call

FromHostAddress indicates an expected call of FromHostAddress.

func (*MockPeerResolverMockRecorder) FromShardID added in v1.2.9 

func (mr *MockPeerResolverMockRecorder) FromShardID(shardID interface{}) *gomock.Call

FromShardID indicates an expected call of FromShardID.

func (*MockPeerResolverMockRecorder) FromWorkflowID added in v1.2.9 

func (mr *MockPeerResolverMockRecorder) FromWorkflowID(workflowID interface{}) *gomock.Call

FromWorkflowID indicates an expected call of FromWorkflowID.

func (*MockPeerResolverMockRecorder) GetAllPeers added in v1.2.9 

func (mr *MockPeerResolverMockRecorder) GetAllPeers() *gomock.Call

GetAllPeers indicates an expected call of GetAllPeers.

func (*MockPeerResolverMockRecorder) GlobalRatelimitPeers added in v1.2.12 

func (mr *MockPeerResolverMockRecorder) GlobalRatelimitPeers(ratelimits interface{}) *gomock.Call

GlobalRatelimitPeers indicates an expected call of GlobalRatelimitPeers.

type Peer added in v1.2.12 

type Peer string

Peer is used to mark a string as the routing information to a peer process.

This is essentially the host:port address of the peer to be contacted, but it is meant to be treated as an opaque blob until given to yarpc via ToYarpcShardKey.

func (Peer) ToYarpcShardKey added in v1.2.12 

func (s Peer) ToYarpcShardKey() yarpc.CallOption

type PeerResolver added in v0.24.0 

type PeerResolver interface {
	FromWorkflowID(workflowID string) (string, error)
	FromDomainID(domainID string) (string, error)
	FromShardID(shardID int) (string, error)
	FromHostAddress(hostAddress string) (string, error)
	GetAllPeers() ([]string, error)

	// GlobalRatelimitPeers partitions the ratelimit keys into map[yarpc peer][]limits_for_peer
	GlobalRatelimitPeers(ratelimits []string) (ratelimitsByPeer map[Peer][]string, err error)
}

PeerResolver is used to resolve history peers. Those are deployed instances of Cadence history services that participate in the cluster ring. The resulting peer is simply an address of form ip:port where RPC calls can be routed to.

func NewPeerResolver added in v0.24.0 

func NewPeerResolver(numberOfShards int, resolver membership.Resolver, namedPort string) PeerResolver

NewPeerResolver creates a new history peer resolver.

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.