history

package
v1.2.8-prerelease4 Latest Latest
Warning

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

Go to latest
Published: Feb 12, 2024 License: MIT Imports: 66 Imported by: 9

Documentation

Overview

Package history is a generated GoMock package.

Index

Constants

View Source
const (

	// TerminateIfRunningReason reason for terminateIfRunning
	TerminateIfRunningReason = "TerminateIfRunning Policy"
	// TerminateIfRunningDetailsTemplate details template for terminateIfRunning
	TerminateIfRunningDetailsTemplate = "New runID: %s"
)

Variables

View Source
var (
	// FailedWorkflowCloseState is a set of failed workflow close states, used for start workflow policy
	// for start workflow execution API
	FailedWorkflowCloseState = map[int]bool{
		persistence.WorkflowCloseStatusFailed:     true,
		persistence.WorkflowCloseStatusCanceled:   true,
		persistence.WorkflowCloseStatusTerminated: true,
		persistence.WorkflowCloseStatusTimedOut:   true,
	}
)

Functions

func NewEngineWithShardContext

func NewEngineWithShardContext(
	shard shard.Context,
	visibilityMgr persistence.VisibilityManager,
	matching matching.Client,
	publicClient workflowserviceclient.Interface,
	historyEventNotifier events.Notifier,
	config *config.Config,
	crossClusterTaskFetchers task.Fetchers,
	replicationTaskFetchers replication.TaskFetchers,
	rawMatchingClient matching.Client,
	queueTaskProcessor task.Processor,
	failoverCoordinator failover.Coordinator,
	wfIDCache workflowcache.WFCache,
) engine.Engine

NewEngineWithShardContext creates an instance of history engine

func NewService

func NewService(
	params *commonResource.Params,
) (resource.Resource, error)

NewService builds a new cadence-history service

Types

type GRPCHandler added in v1.2.7

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

func NewGRPCHandler added in v1.2.7

func NewGRPCHandler(h Handler) GRPCHandler

func (GRPCHandler) CloseShard added in v1.2.7

func (GRPCHandler) CountDLQMessages added in v1.2.7

func (GRPCHandler) DescribeHistoryHost added in v1.2.7

func (GRPCHandler) DescribeMutableState added in v1.2.7

func (GRPCHandler) DescribeQueue added in v1.2.7

func (GRPCHandler) DescribeWorkflowExecution added in v1.2.7

func (GRPCHandler) GetCrossClusterTasks added in v1.2.7

func (GRPCHandler) GetDLQReplicationMessages added in v1.2.7

func (GRPCHandler) GetFailoverInfo added in v1.2.7

func (GRPCHandler) GetMutableState added in v1.2.7

func (GRPCHandler) GetReplicationMessages added in v1.2.7

func (GRPCHandler) Health added in v1.2.7

func (GRPCHandler) MergeDLQMessages added in v1.2.7

func (GRPCHandler) NotifyFailoverMarkers added in v1.2.7

func (GRPCHandler) PollMutableState added in v1.2.7

func (GRPCHandler) PurgeDLQMessages added in v1.2.7

func (GRPCHandler) QueryWorkflow added in v1.2.7

func (GRPCHandler) ReadDLQMessages added in v1.2.7

func (GRPCHandler) ReapplyEvents added in v1.2.7

func (GRPCHandler) RecordActivityTaskHeartbeat added in v1.2.7

func (GRPCHandler) RecordActivityTaskStarted added in v1.2.7

func (GRPCHandler) RecordChildExecutionCompleted added in v1.2.7

func (GRPCHandler) RecordDecisionTaskStarted added in v1.2.7

func (GRPCHandler) RefreshWorkflowTasks added in v1.2.7

func (GRPCHandler) Register added in v1.2.7

func (g GRPCHandler) Register(dispatcher *yarpc.Dispatcher)

func (GRPCHandler) RemoveSignalMutableState added in v1.2.7

func (GRPCHandler) RemoveTask added in v1.2.7

func (GRPCHandler) ReplicateEventsV2 added in v1.2.7

func (GRPCHandler) RequestCancelWorkflowExecution added in v1.2.7

func (GRPCHandler) ResetQueue added in v1.2.7

func (GRPCHandler) ResetStickyTaskList added in v1.2.7

func (GRPCHandler) ResetWorkflowExecution added in v1.2.7

func (GRPCHandler) RespondActivityTaskCanceled added in v1.2.7

func (GRPCHandler) RespondActivityTaskCompleted added in v1.2.7

func (GRPCHandler) RespondActivityTaskFailed added in v1.2.7

func (GRPCHandler) RespondDecisionTaskCompleted added in v1.2.7

func (GRPCHandler) RespondDecisionTaskFailed added in v1.2.7

func (GRPCHandler) ScheduleDecisionTask added in v1.2.7

func (GRPCHandler) SignalWorkflowExecution added in v1.2.7

func (GRPCHandler) StartWorkflowExecution added in v1.2.7

func (GRPCHandler) SyncActivity added in v1.2.7

func (GRPCHandler) SyncShardStatus added in v1.2.7

func (GRPCHandler) TerminateWorkflowExecution added in v1.2.7

type Handler

type Handler interface {
	// Do not use embeded methods, otherwise, we got the following error from gowrap
	// and we only get this error from history/interface.go, not sure why
	//failed to parse interface declaration: Daemon: target declaration not found
	//service/history/interface.go:22: running "gowrap": exit status 1
	//common.Daemon
	Start()
	Stop()

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

Handler interface for history service

func NewHandler

func NewHandler(
	resource resource.Resource,
	config *config.Config,
) Handler

NewHandler creates a thrift handler for the history service

type MockHandler added in v0.17.0

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

MockHandler is a mock of Handler interface.

func NewMockHandler added in v0.17.0

func NewMockHandler(ctrl *gomock.Controller) *MockHandler

NewMockHandler creates a new mock instance.

func (*MockHandler) CloseShard added in v0.17.0

func (m *MockHandler) CloseShard(arg0 context.Context, arg1 *types.CloseShardRequest) error

CloseShard mocks base method.

func (*MockHandler) CountDLQMessages added in v0.25.0

CountDLQMessages mocks base method.

func (*MockHandler) DescribeHistoryHost added in v0.17.0

DescribeHistoryHost mocks base method.

func (*MockHandler) DescribeMutableState added in v0.17.0

DescribeMutableState mocks base method.

func (*MockHandler) DescribeQueue added in v0.17.0

DescribeQueue mocks base method.

func (*MockHandler) DescribeWorkflowExecution added in v0.17.0

DescribeWorkflowExecution mocks base method.

func (*MockHandler) EXPECT added in v0.17.0

func (m *MockHandler) EXPECT() *MockHandlerMockRecorder

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

func (*MockHandler) GetCrossClusterTasks added in v0.23.1

GetCrossClusterTasks mocks base method.

func (*MockHandler) GetDLQReplicationMessages added in v0.17.0

GetDLQReplicationMessages mocks base method.

func (*MockHandler) GetFailoverInfo added in v0.24.0

GetFailoverInfo mocks base method.

func (*MockHandler) GetMutableState added in v0.17.0

GetMutableState mocks base method.

func (*MockHandler) GetReplicationMessages added in v0.17.0

GetReplicationMessages mocks base method.

func (*MockHandler) Health added in v0.17.0

func (m *MockHandler) Health(arg0 context.Context) (*types.HealthStatus, error)

Health mocks base method.

func (*MockHandler) MergeDLQMessages added in v0.17.0

MergeDLQMessages mocks base method.

func (*MockHandler) NotifyFailoverMarkers added in v0.17.0

func (m *MockHandler) NotifyFailoverMarkers(arg0 context.Context, arg1 *types.NotifyFailoverMarkersRequest) error

NotifyFailoverMarkers mocks base method.

func (*MockHandler) PollMutableState added in v0.17.0

PollMutableState mocks base method.

func (*MockHandler) PrepareToStop added in v0.23.1

func (m *MockHandler) PrepareToStop(arg0 time.Duration) time.Duration

PrepareToStop mocks base method.

func (*MockHandler) PurgeDLQMessages added in v0.17.0

func (m *MockHandler) PurgeDLQMessages(arg0 context.Context, arg1 *types.PurgeDLQMessagesRequest) error

PurgeDLQMessages mocks base method.

func (*MockHandler) QueryWorkflow added in v0.17.0

QueryWorkflow mocks base method.

func (*MockHandler) ReadDLQMessages added in v0.17.0

ReadDLQMessages mocks base method.

func (*MockHandler) ReapplyEvents added in v0.17.0

func (m *MockHandler) ReapplyEvents(arg0 context.Context, arg1 *types.HistoryReapplyEventsRequest) error

ReapplyEvents mocks base method.

func (*MockHandler) RecordActivityTaskHeartbeat added in v0.17.0

RecordActivityTaskHeartbeat mocks base method.

func (*MockHandler) RecordActivityTaskStarted added in v0.17.0

RecordActivityTaskStarted mocks base method.

func (*MockHandler) RecordChildExecutionCompleted added in v0.17.0

func (m *MockHandler) RecordChildExecutionCompleted(arg0 context.Context, arg1 *types.RecordChildExecutionCompletedRequest) error

RecordChildExecutionCompleted mocks base method.

func (*MockHandler) RecordDecisionTaskStarted added in v0.17.0

RecordDecisionTaskStarted mocks base method.

func (*MockHandler) RefreshWorkflowTasks added in v0.17.0

func (m *MockHandler) RefreshWorkflowTasks(arg0 context.Context, arg1 *types.HistoryRefreshWorkflowTasksRequest) error

RefreshWorkflowTasks mocks base method.

func (*MockHandler) RemoveSignalMutableState added in v0.17.0

func (m *MockHandler) RemoveSignalMutableState(arg0 context.Context, arg1 *types.RemoveSignalMutableStateRequest) error

RemoveSignalMutableState mocks base method.

func (*MockHandler) RemoveTask added in v0.17.0

func (m *MockHandler) RemoveTask(arg0 context.Context, arg1 *types.RemoveTaskRequest) error

RemoveTask mocks base method.

func (*MockHandler) ReplicateEventsV2 added in v0.17.0

func (m *MockHandler) ReplicateEventsV2(arg0 context.Context, arg1 *types.ReplicateEventsV2Request) error

ReplicateEventsV2 mocks base method.

func (*MockHandler) RequestCancelWorkflowExecution added in v0.17.0

func (m *MockHandler) RequestCancelWorkflowExecution(arg0 context.Context, arg1 *types.HistoryRequestCancelWorkflowExecutionRequest) error

RequestCancelWorkflowExecution mocks base method.

func (*MockHandler) ResetQueue added in v0.17.0

func (m *MockHandler) ResetQueue(arg0 context.Context, arg1 *types.ResetQueueRequest) error

ResetQueue mocks base method.

func (*MockHandler) ResetStickyTaskList added in v0.17.0

ResetStickyTaskList mocks base method.

func (*MockHandler) ResetWorkflowExecution added in v0.17.0

ResetWorkflowExecution mocks base method.

func (*MockHandler) RespondActivityTaskCanceled added in v0.17.0

func (m *MockHandler) RespondActivityTaskCanceled(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskCanceledRequest) error

RespondActivityTaskCanceled mocks base method.

func (*MockHandler) RespondActivityTaskCompleted added in v0.17.0

func (m *MockHandler) RespondActivityTaskCompleted(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskCompletedRequest) error

RespondActivityTaskCompleted mocks base method.

func (*MockHandler) RespondActivityTaskFailed added in v0.17.0

func (m *MockHandler) RespondActivityTaskFailed(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskFailedRequest) error

RespondActivityTaskFailed mocks base method.

func (*MockHandler) RespondCrossClusterTasksCompleted added in v0.23.1

RespondCrossClusterTasksCompleted mocks base method.

func (*MockHandler) RespondDecisionTaskCompleted added in v0.17.0

RespondDecisionTaskCompleted mocks base method.

func (*MockHandler) RespondDecisionTaskFailed added in v0.17.0

func (m *MockHandler) RespondDecisionTaskFailed(arg0 context.Context, arg1 *types.HistoryRespondDecisionTaskFailedRequest) error

RespondDecisionTaskFailed mocks base method.

func (*MockHandler) ScheduleDecisionTask added in v0.17.0

func (m *MockHandler) ScheduleDecisionTask(arg0 context.Context, arg1 *types.ScheduleDecisionTaskRequest) error

ScheduleDecisionTask mocks base method.

func (*MockHandler) SignalWithStartWorkflowExecution added in v0.17.0

SignalWithStartWorkflowExecution mocks base method.

func (*MockHandler) SignalWorkflowExecution added in v0.17.0

func (m *MockHandler) SignalWorkflowExecution(arg0 context.Context, arg1 *types.HistorySignalWorkflowExecutionRequest) error

SignalWorkflowExecution mocks base method.

func (*MockHandler) Start added in v0.23.1

func (m *MockHandler) Start()

Start mocks base method.

func (*MockHandler) StartWorkflowExecution added in v0.17.0

StartWorkflowExecution mocks base method.

func (*MockHandler) Stop added in v0.23.1

func (m *MockHandler) Stop()

Stop mocks base method.

func (*MockHandler) SyncActivity added in v0.17.0

func (m *MockHandler) SyncActivity(arg0 context.Context, arg1 *types.SyncActivityRequest) error

SyncActivity mocks base method.

func (*MockHandler) SyncShardStatus added in v0.17.0

func (m *MockHandler) SyncShardStatus(arg0 context.Context, arg1 *types.SyncShardStatusRequest) error

SyncShardStatus mocks base method.

func (*MockHandler) TerminateWorkflowExecution added in v0.17.0

func (m *MockHandler) TerminateWorkflowExecution(arg0 context.Context, arg1 *types.HistoryTerminateWorkflowExecutionRequest) error

TerminateWorkflowExecution mocks base method.

type MockHandlerMockRecorder added in v0.17.0

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

MockHandlerMockRecorder is the mock recorder for MockHandler.

func (*MockHandlerMockRecorder) CloseShard added in v0.17.0

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

CloseShard indicates an expected call of CloseShard.

func (*MockHandlerMockRecorder) CountDLQMessages added in v0.25.0

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

CountDLQMessages indicates an expected call of CountDLQMessages.

func (*MockHandlerMockRecorder) DescribeHistoryHost added in v0.17.0

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

DescribeHistoryHost indicates an expected call of DescribeHistoryHost.

func (*MockHandlerMockRecorder) DescribeMutableState added in v0.17.0

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

DescribeMutableState indicates an expected call of DescribeMutableState.

func (*MockHandlerMockRecorder) DescribeQueue added in v0.17.0

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

DescribeQueue indicates an expected call of DescribeQueue.

func (*MockHandlerMockRecorder) DescribeWorkflowExecution added in v0.17.0

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

DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.

func (*MockHandlerMockRecorder) GetCrossClusterTasks added in v0.23.1

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

GetCrossClusterTasks indicates an expected call of GetCrossClusterTasks.

func (*MockHandlerMockRecorder) GetDLQReplicationMessages added in v0.17.0

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

GetDLQReplicationMessages indicates an expected call of GetDLQReplicationMessages.

func (*MockHandlerMockRecorder) GetFailoverInfo added in v0.24.0

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

GetFailoverInfo indicates an expected call of GetFailoverInfo.

func (*MockHandlerMockRecorder) GetMutableState added in v0.17.0

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

GetMutableState indicates an expected call of GetMutableState.

func (*MockHandlerMockRecorder) GetReplicationMessages added in v0.17.0

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

GetReplicationMessages indicates an expected call of GetReplicationMessages.

func (*MockHandlerMockRecorder) Health added in v0.17.0

func (mr *MockHandlerMockRecorder) Health(arg0 interface{}) *gomock.Call

Health indicates an expected call of Health.

func (*MockHandlerMockRecorder) MergeDLQMessages added in v0.17.0

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

MergeDLQMessages indicates an expected call of MergeDLQMessages.

func (*MockHandlerMockRecorder) NotifyFailoverMarkers added in v0.17.0

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

NotifyFailoverMarkers indicates an expected call of NotifyFailoverMarkers.

func (*MockHandlerMockRecorder) PollMutableState added in v0.17.0

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

PollMutableState indicates an expected call of PollMutableState.

func (*MockHandlerMockRecorder) PrepareToStop added in v0.23.1

func (mr *MockHandlerMockRecorder) PrepareToStop(arg0 interface{}) *gomock.Call

PrepareToStop indicates an expected call of PrepareToStop.

func (*MockHandlerMockRecorder) PurgeDLQMessages added in v0.17.0

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

PurgeDLQMessages indicates an expected call of PurgeDLQMessages.

func (*MockHandlerMockRecorder) QueryWorkflow added in v0.17.0

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

QueryWorkflow indicates an expected call of QueryWorkflow.

func (*MockHandlerMockRecorder) ReadDLQMessages added in v0.17.0

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

ReadDLQMessages indicates an expected call of ReadDLQMessages.

func (*MockHandlerMockRecorder) ReapplyEvents added in v0.17.0

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

ReapplyEvents indicates an expected call of ReapplyEvents.

func (*MockHandlerMockRecorder) RecordActivityTaskHeartbeat added in v0.17.0

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

RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat.

func (*MockHandlerMockRecorder) RecordActivityTaskStarted added in v0.17.0

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

RecordActivityTaskStarted indicates an expected call of RecordActivityTaskStarted.

func (*MockHandlerMockRecorder) RecordChildExecutionCompleted added in v0.17.0

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

RecordChildExecutionCompleted indicates an expected call of RecordChildExecutionCompleted.

func (*MockHandlerMockRecorder) RecordDecisionTaskStarted added in v0.17.0

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

RecordDecisionTaskStarted indicates an expected call of RecordDecisionTaskStarted.

func (*MockHandlerMockRecorder) RefreshWorkflowTasks added in v0.17.0

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

RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks.

func (*MockHandlerMockRecorder) RemoveSignalMutableState added in v0.17.0

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

RemoveSignalMutableState indicates an expected call of RemoveSignalMutableState.

func (*MockHandlerMockRecorder) RemoveTask added in v0.17.0

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

RemoveTask indicates an expected call of RemoveTask.

func (*MockHandlerMockRecorder) ReplicateEventsV2 added in v0.17.0

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

ReplicateEventsV2 indicates an expected call of ReplicateEventsV2.

func (*MockHandlerMockRecorder) RequestCancelWorkflowExecution added in v0.17.0

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

RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution.

func (*MockHandlerMockRecorder) ResetQueue added in v0.17.0

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

ResetQueue indicates an expected call of ResetQueue.

func (*MockHandlerMockRecorder) ResetStickyTaskList added in v0.17.0

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

ResetStickyTaskList indicates an expected call of ResetStickyTaskList.

func (*MockHandlerMockRecorder) ResetWorkflowExecution added in v0.17.0

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

ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.

func (*MockHandlerMockRecorder) RespondActivityTaskCanceled added in v0.17.0

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

RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled.

func (*MockHandlerMockRecorder) RespondActivityTaskCompleted added in v0.17.0

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

RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted.

func (*MockHandlerMockRecorder) RespondActivityTaskFailed added in v0.17.0

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

RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed.

func (*MockHandlerMockRecorder) RespondCrossClusterTasksCompleted added in v0.23.1

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

RespondCrossClusterTasksCompleted indicates an expected call of RespondCrossClusterTasksCompleted.

func (*MockHandlerMockRecorder) RespondDecisionTaskCompleted added in v0.17.0

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

RespondDecisionTaskCompleted indicates an expected call of RespondDecisionTaskCompleted.

func (*MockHandlerMockRecorder) RespondDecisionTaskFailed added in v0.17.0

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

RespondDecisionTaskFailed indicates an expected call of RespondDecisionTaskFailed.

func (*MockHandlerMockRecorder) ScheduleDecisionTask added in v0.17.0

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

ScheduleDecisionTask indicates an expected call of ScheduleDecisionTask.

func (*MockHandlerMockRecorder) SignalWithStartWorkflowExecution added in v0.17.0

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

SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution.

func (*MockHandlerMockRecorder) SignalWorkflowExecution added in v0.17.0

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

SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution.

func (*MockHandlerMockRecorder) Start added in v0.23.1

func (mr *MockHandlerMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockHandlerMockRecorder) StartWorkflowExecution added in v0.17.0

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

StartWorkflowExecution indicates an expected call of StartWorkflowExecution.

func (*MockHandlerMockRecorder) Stop added in v0.23.1

func (mr *MockHandlerMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

func (*MockHandlerMockRecorder) SyncActivity added in v0.17.0

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

SyncActivity indicates an expected call of SyncActivity.

func (*MockHandlerMockRecorder) SyncShardStatus added in v0.17.0

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

SyncShardStatus indicates an expected call of SyncShardStatus.

func (*MockHandlerMockRecorder) TerminateWorkflowExecution added in v0.17.0

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

TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution.

type Service

type Service struct {
	resource.Resource
	// contains filtered or unexported fields
}

Service represents the cadence-history service

func (*Service) Start

func (s *Service) Start()

Start starts the service

func (*Service) Stop

func (s *Service) Stop()

Stop stops the service

type ThriftHandler added in v0.17.0

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

func NewThriftHandler added in v0.17.0

func NewThriftHandler(h Handler) ThriftHandler

func (ThriftHandler) CloseShard added in v0.17.0

func (g ThriftHandler) CloseShard(ctx context.Context, Request *shared.CloseShardRequest) (err error)

func (ThriftHandler) DescribeHistoryHost added in v0.17.0

func (g ThriftHandler) DescribeHistoryHost(ctx context.Context, Request *shared.DescribeHistoryHostRequest) (dp1 *shared.DescribeHistoryHostResponse, err error)

func (ThriftHandler) DescribeMutableState added in v0.17.0

func (ThriftHandler) DescribeQueue added in v0.17.0

func (g ThriftHandler) DescribeQueue(ctx context.Context, Request *shared.DescribeQueueRequest) (dp1 *shared.DescribeQueueResponse, err error)

func (ThriftHandler) DescribeWorkflowExecution added in v0.17.0

func (g ThriftHandler) DescribeWorkflowExecution(ctx context.Context, DescribeRequest *history.DescribeWorkflowExecutionRequest) (dp1 *shared.DescribeWorkflowExecutionResponse, err error)

func (ThriftHandler) GetCrossClusterTasks added in v0.22.0

func (g ThriftHandler) GetCrossClusterTasks(ctx context.Context, Request *shared.GetCrossClusterTasksRequest) (gp1 *shared.GetCrossClusterTasksResponse, err error)

func (ThriftHandler) GetDLQReplicationMessages added in v0.17.0

func (ThriftHandler) GetFailoverInfo added in v0.24.0

func (g ThriftHandler) GetFailoverInfo(ctx context.Context, Request *history.GetFailoverInfoRequest) (gp1 *history.GetFailoverInfoResponse, err error)

func (ThriftHandler) GetMutableState added in v0.17.0

func (g ThriftHandler) GetMutableState(ctx context.Context, GetRequest *history.GetMutableStateRequest) (gp1 *history.GetMutableStateResponse, err error)

func (ThriftHandler) GetReplicationMessages added in v0.17.0

func (ThriftHandler) Health added in v0.17.0

func (ThriftHandler) MergeDLQMessages added in v0.17.0

func (ThriftHandler) NotifyFailoverMarkers added in v0.17.0

func (g ThriftHandler) NotifyFailoverMarkers(ctx context.Context, Request *history.NotifyFailoverMarkersRequest) (err error)

func (ThriftHandler) PollMutableState added in v0.17.0

func (g ThriftHandler) PollMutableState(ctx context.Context, PollRequest *history.PollMutableStateRequest) (pp1 *history.PollMutableStateResponse, err error)

func (ThriftHandler) PurgeDLQMessages added in v0.17.0

func (g ThriftHandler) PurgeDLQMessages(ctx context.Context, Request *replicator.PurgeDLQMessagesRequest) (err error)

func (ThriftHandler) QueryWorkflow added in v0.17.0

func (g ThriftHandler) QueryWorkflow(ctx context.Context, QueryRequest *history.QueryWorkflowRequest) (qp1 *history.QueryWorkflowResponse, err error)

func (ThriftHandler) ReadDLQMessages added in v0.17.0

func (ThriftHandler) ReapplyEvents added in v0.17.0

func (g ThriftHandler) ReapplyEvents(ctx context.Context, ReapplyEventsRequest *history.ReapplyEventsRequest) (err error)

func (ThriftHandler) RecordActivityTaskHeartbeat added in v0.17.0

func (g ThriftHandler) RecordActivityTaskHeartbeat(ctx context.Context, HeartbeatRequest *history.RecordActivityTaskHeartbeatRequest) (rp1 *shared.RecordActivityTaskHeartbeatResponse, err error)

func (ThriftHandler) RecordActivityTaskStarted added in v0.17.0

func (g ThriftHandler) RecordActivityTaskStarted(ctx context.Context, AddRequest *history.RecordActivityTaskStartedRequest) (rp1 *history.RecordActivityTaskStartedResponse, err error)

func (ThriftHandler) RecordChildExecutionCompleted added in v0.17.0

func (g ThriftHandler) RecordChildExecutionCompleted(ctx context.Context, CompletionRequest *history.RecordChildExecutionCompletedRequest) (err error)

func (ThriftHandler) RecordDecisionTaskStarted added in v0.17.0

func (g ThriftHandler) RecordDecisionTaskStarted(ctx context.Context, AddRequest *history.RecordDecisionTaskStartedRequest) (rp1 *history.RecordDecisionTaskStartedResponse, err error)

func (ThriftHandler) RefreshWorkflowTasks added in v0.17.0

func (g ThriftHandler) RefreshWorkflowTasks(ctx context.Context, Request *history.RefreshWorkflowTasksRequest) (err error)

func (ThriftHandler) Register added in v1.2.7

func (t ThriftHandler) Register(dispatcher *yarpc.Dispatcher)

func (ThriftHandler) RemoveSignalMutableState added in v0.17.0

func (g ThriftHandler) RemoveSignalMutableState(ctx context.Context, RemoveRequest *history.RemoveSignalMutableStateRequest) (err error)

func (ThriftHandler) RemoveTask added in v0.17.0

func (g ThriftHandler) RemoveTask(ctx context.Context, Request *shared.RemoveTaskRequest) (err error)

func (ThriftHandler) ReplicateEventsV2 added in v0.17.0

func (g ThriftHandler) ReplicateEventsV2(ctx context.Context, ReplicateV2Request *history.ReplicateEventsV2Request) (err error)

func (ThriftHandler) RequestCancelWorkflowExecution added in v0.17.0

func (g ThriftHandler) RequestCancelWorkflowExecution(ctx context.Context, CancelRequest *history.RequestCancelWorkflowExecutionRequest) (err error)

func (ThriftHandler) ResetQueue added in v0.17.0

func (g ThriftHandler) ResetQueue(ctx context.Context, Request *shared.ResetQueueRequest) (err error)

func (ThriftHandler) ResetStickyTaskList added in v0.17.0

func (g ThriftHandler) ResetStickyTaskList(ctx context.Context, ResetRequest *history.ResetStickyTaskListRequest) (rp1 *history.ResetStickyTaskListResponse, err error)

func (ThriftHandler) ResetWorkflowExecution added in v0.17.0

func (g ThriftHandler) ResetWorkflowExecution(ctx context.Context, ResetRequest *history.ResetWorkflowExecutionRequest) (rp1 *shared.ResetWorkflowExecutionResponse, err error)

func (ThriftHandler) RespondActivityTaskCanceled added in v0.17.0

func (g ThriftHandler) RespondActivityTaskCanceled(ctx context.Context, CanceledRequest *history.RespondActivityTaskCanceledRequest) (err error)

func (ThriftHandler) RespondActivityTaskCompleted added in v0.17.0

func (g ThriftHandler) RespondActivityTaskCompleted(ctx context.Context, CompleteRequest *history.RespondActivityTaskCompletedRequest) (err error)

func (ThriftHandler) RespondActivityTaskFailed added in v0.17.0

func (g ThriftHandler) RespondActivityTaskFailed(ctx context.Context, FailRequest *history.RespondActivityTaskFailedRequest) (err error)

func (ThriftHandler) RespondCrossClusterTasksCompleted added in v0.22.0

func (ThriftHandler) RespondDecisionTaskCompleted added in v0.17.0

func (g ThriftHandler) RespondDecisionTaskCompleted(ctx context.Context, CompleteRequest *history.RespondDecisionTaskCompletedRequest) (rp1 *history.RespondDecisionTaskCompletedResponse, err error)

func (ThriftHandler) RespondDecisionTaskFailed added in v0.17.0

func (g ThriftHandler) RespondDecisionTaskFailed(ctx context.Context, FailedRequest *history.RespondDecisionTaskFailedRequest) (err error)

func (ThriftHandler) ScheduleDecisionTask added in v0.17.0

func (g ThriftHandler) ScheduleDecisionTask(ctx context.Context, ScheduleRequest *history.ScheduleDecisionTaskRequest) (err error)

func (ThriftHandler) SignalWithStartWorkflowExecution added in v0.17.0

func (g ThriftHandler) SignalWithStartWorkflowExecution(ctx context.Context, SignalWithStartRequest *history.SignalWithStartWorkflowExecutionRequest) (sp1 *shared.StartWorkflowExecutionResponse, err error)

func (ThriftHandler) SignalWorkflowExecution added in v0.17.0

func (g ThriftHandler) SignalWorkflowExecution(ctx context.Context, SignalRequest *history.SignalWorkflowExecutionRequest) (err error)

func (ThriftHandler) StartWorkflowExecution added in v0.17.0

func (g ThriftHandler) StartWorkflowExecution(ctx context.Context, StartRequest *history.StartWorkflowExecutionRequest) (sp1 *shared.StartWorkflowExecutionResponse, err error)

func (ThriftHandler) SyncActivity added in v0.17.0

func (g ThriftHandler) SyncActivity(ctx context.Context, SyncActivityRequest *history.SyncActivityRequest) (err error)

func (ThriftHandler) SyncShardStatus added in v0.17.0

func (g ThriftHandler) SyncShardStatus(ctx context.Context, SyncShardStatusRequest *history.SyncShardStatusRequest) (err error)

func (ThriftHandler) TerminateWorkflowExecution added in v0.17.0

func (g ThriftHandler) TerminateWorkflowExecution(ctx context.Context, TerminateRequest *history.TerminateWorkflowExecutionRequest) (err error)

Directories

Path Synopsis
Package engine is a generated GoMock package.
Package engine is a generated GoMock package.
Package events is a generated GoMock package.
Package events is a generated GoMock package.
Package execution is a generated GoMock package.
Package execution is a generated GoMock package.
Package failover is a generated GoMock package.
Package failover is a generated GoMock package.
Package ndc is a generated GoMock package.
Package ndc is a generated GoMock package.
Package queue is a generated GoMock package.
Package queue is a generated GoMock package.
Package reset is a generated GoMock package.
Package reset is a generated GoMock package.
Package shard is a generated GoMock package.
Package shard is a generated GoMock package.
Package task is a generated GoMock package.
Package task is a generated GoMock package.
Package workflowcache is a generated GoMock package.
Package workflowcache is a generated GoMock package.

Jump to

Keyboard shortcuts

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