history

package
v0.17.0 Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2021 License: MIT Imports: 64 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 (
	// ErrDuplicate is exported temporarily for integration test
	ErrDuplicate = errors.New("duplicate task, completing it")
	// ErrMaxAttemptsExceeded is exported temporarily for integration test
	ErrMaxAttemptsExceeded = errors.New("maximum attempts exceeded to update history")
	// ErrStaleState is the error returned during state update indicating that cached mutable state could be stale
	ErrStaleState = errors.New("cache mutable state could potentially be stale")
	// ErrActivityTaskNotFound is the error to indicate activity task could be duplicate and activity already completed
	ErrActivityTaskNotFound = &workflow.EntityNotExistsError{Message: "activity task not found"}
	// ErrWorkflowCompleted is the error to indicate workflow execution already completed
	ErrWorkflowCompleted = &workflow.EntityNotExistsError{Message: "workflow execution already completed"}
	// ErrWorkflowParent is the error to parent execution is given and mismatch
	ErrWorkflowParent = &workflow.EntityNotExistsError{Message: "workflow parent does not match"}
	// ErrDeserializingToken is the error to indicate task token is invalid
	ErrDeserializingToken = &workflow.BadRequestError{Message: "error deserializing task token"}
	// ErrSerializingToken is the error to indicate task token can not be serialized
	ErrSerializingToken = &workflow.BadRequestError{Message: "error serializing task token"}
	// ErrSignalOverSize is the error to indicate signal input size is > 256K
	ErrSignalOverSize = &workflow.BadRequestError{Message: "signal input size is over 256K"}
	// ErrCancellationAlreadyRequested is the error indicating cancellation for target workflow is already requested
	ErrCancellationAlreadyRequested = &workflow.CancellationAlreadyRequestedError{Message: "cancellation already requested for this workflow execution"}
	// ErrSignalsLimitExceeded is the error indicating limit reached for maximum number of signal events
	ErrSignalsLimitExceeded = &workflow.LimitExceededError{Message: "exceeded workflow execution limit for signal events"}
	// ErrQueryEnteredInvalidState is error indicating query entered invalid state
	ErrQueryEnteredInvalidState = &workflow.BadRequestError{Message: "query entered invalid state, this should be impossible"}
	// ErrQueryWorkflowBeforeFirstDecision is error indicating that query was attempted before first decision task completed
	ErrQueryWorkflowBeforeFirstDecision = &workflow.QueryFailedError{Message: "workflow must handle at least one decision task before it can be queried"}
	// ErrConsistentQueryNotEnabled is error indicating that consistent query was requested but either cluster or domain does not enable consistent query
	ErrConsistentQueryNotEnabled = &workflow.BadRequestError{Message: "cluster or domain does not enable strongly consistent query but strongly consistent query was requested"}
	// ErrConsistentQueryBufferExceeded is error indicating that too many consistent queries have been buffered and until buffered queries are finished new consistent queries cannot be buffered
	ErrConsistentQueryBufferExceeded = &workflow.InternalServiceError{Message: "consistent query buffer is full, cannot accept new consistent queries"}
	// ErrConcurrentStartRequest is error indicating there is an outstanding start workflow request. The incoming request fails to acquires the lock before the outstanding request finishes.
	ErrConcurrentStartRequest = &workflow.ServiceBusyError{Message: "an outstanding start workflow request is in-progress. Failed to acquire the resource."}

	// 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,
	historyClient hc.Client,
	publicClient workflowserviceclient.Interface,
	historyEventNotifier events.Notifier,
	config *config.Config,
	replicationTaskFetchers replication.TaskFetchers,
	rawMatchingClient matching.Client,
	queueTaskProcessor task.Processor,
	failoverCoordinator failover.Coordinator,
) engine.Engine

NewEngineWithShardContext creates an instance of history engine

func NewHandler 

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

NewHandler creates a thrift handler for the history service

func NewService 

func NewService(
	params *service.BootstrapParams,
) (resource.Resource, error)

NewService builds a new cadence-history service

Types

type Handler 

type Handler interface {
	Health(context.Context) (*health.HealthStatus, error)
	CloseShard(context.Context, *gen.CloseShardRequest) error
	DescribeHistoryHost(context.Context, *gen.DescribeHistoryHostRequest) (*gen.DescribeHistoryHostResponse, error)
	DescribeMutableState(context.Context, *hist.DescribeMutableStateRequest) (*hist.DescribeMutableStateResponse, error)
	DescribeQueue(context.Context, *gen.DescribeQueueRequest) (*gen.DescribeQueueResponse, error)
	DescribeWorkflowExecution(context.Context, *hist.DescribeWorkflowExecutionRequest) (*gen.DescribeWorkflowExecutionResponse, error)
	GetDLQReplicationMessages(context.Context, *r.GetDLQReplicationMessagesRequest) (*r.GetDLQReplicationMessagesResponse, error)
	GetMutableState(context.Context, *hist.GetMutableStateRequest) (*hist.GetMutableStateResponse, error)
	GetReplicationMessages(context.Context, *r.GetReplicationMessagesRequest) (*r.GetReplicationMessagesResponse, error)
	MergeDLQMessages(context.Context, *r.MergeDLQMessagesRequest) (*r.MergeDLQMessagesResponse, error)
	NotifyFailoverMarkers(context.Context, *hist.NotifyFailoverMarkersRequest) error
	PollMutableState(context.Context, *hist.PollMutableStateRequest) (*hist.PollMutableStateResponse, error)
	PurgeDLQMessages(context.Context, *r.PurgeDLQMessagesRequest) error
	QueryWorkflow(context.Context, *hist.QueryWorkflowRequest) (*hist.QueryWorkflowResponse, error)
	ReadDLQMessages(context.Context, *r.ReadDLQMessagesRequest) (*r.ReadDLQMessagesResponse, error)
	ReapplyEvents(context.Context, *hist.ReapplyEventsRequest) error
	RecordActivityTaskHeartbeat(context.Context, *hist.RecordActivityTaskHeartbeatRequest) (*gen.RecordActivityTaskHeartbeatResponse, error)
	RecordActivityTaskStarted(context.Context, *hist.RecordActivityTaskStartedRequest) (*hist.RecordActivityTaskStartedResponse, error)
	RecordChildExecutionCompleted(context.Context, *hist.RecordChildExecutionCompletedRequest) error
	RecordDecisionTaskStarted(context.Context, *hist.RecordDecisionTaskStartedRequest) (*hist.RecordDecisionTaskStartedResponse, error)
	RefreshWorkflowTasks(context.Context, *hist.RefreshWorkflowTasksRequest) error
	RemoveSignalMutableState(context.Context, *hist.RemoveSignalMutableStateRequest) error
	RemoveTask(context.Context, *gen.RemoveTaskRequest) error
	ReplicateEventsV2(context.Context, *hist.ReplicateEventsV2Request) error
	RequestCancelWorkflowExecution(context.Context, *hist.RequestCancelWorkflowExecutionRequest) error
	ResetQueue(context.Context, *gen.ResetQueueRequest) error
	ResetStickyTaskList(context.Context, *hist.ResetStickyTaskListRequest) (*hist.ResetStickyTaskListResponse, error)
	ResetWorkflowExecution(context.Context, *hist.ResetWorkflowExecutionRequest) (*gen.ResetWorkflowExecutionResponse, error)
	RespondActivityTaskCanceled(context.Context, *hist.RespondActivityTaskCanceledRequest) error
	RespondActivityTaskCompleted(context.Context, *hist.RespondActivityTaskCompletedRequest) error
	RespondActivityTaskFailed(context.Context, *hist.RespondActivityTaskFailedRequest) error
	RespondDecisionTaskCompleted(context.Context, *hist.RespondDecisionTaskCompletedRequest) (*hist.RespondDecisionTaskCompletedResponse, error)
	RespondDecisionTaskFailed(context.Context, *hist.RespondDecisionTaskFailedRequest) error
	ScheduleDecisionTask(context.Context, *hist.ScheduleDecisionTaskRequest) error
	SignalWithStartWorkflowExecution(context.Context, *hist.SignalWithStartWorkflowExecutionRequest) (*gen.StartWorkflowExecutionResponse, error)
	SignalWorkflowExecution(context.Context, *hist.SignalWorkflowExecutionRequest) error
	StartWorkflowExecution(context.Context, *hist.StartWorkflowExecutionRequest) (*gen.StartWorkflowExecutionResponse, error)
	SyncActivity(context.Context, *hist.SyncActivityRequest) error
	SyncShardStatus(context.Context, *hist.SyncShardStatusRequest) error
	TerminateWorkflowExecution(context.Context, *hist.TerminateWorkflowExecutionRequest) error
}

Handler interface for 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 *shared.CloseShardRequest) error

CloseShard mocks base method

func (*MockHandler) DescribeHistoryHost added in v0.17.0 

func (m *MockHandler) DescribeHistoryHost(arg0 context.Context, arg1 *shared.DescribeHistoryHostRequest) (*shared.DescribeHistoryHostResponse, error)

DescribeHistoryHost mocks base method

func (*MockHandler) DescribeMutableState added in v0.17.0 

func (m *MockHandler) DescribeMutableState(arg0 context.Context, arg1 *history.DescribeMutableStateRequest) (*history.DescribeMutableStateResponse, error)

DescribeMutableState mocks base method

func (*MockHandler) DescribeQueue added in v0.17.0 

func (m *MockHandler) DescribeQueue(arg0 context.Context, arg1 *shared.DescribeQueueRequest) (*shared.DescribeQueueResponse, error)

DescribeQueue mocks base method

func (*MockHandler) DescribeWorkflowExecution added in v0.17.0 

func (m *MockHandler) DescribeWorkflowExecution(arg0 context.Context, arg1 *history.DescribeWorkflowExecutionRequest) (*shared.DescribeWorkflowExecutionResponse, error)

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) GetDLQReplicationMessages added in v0.17.0 

func (m *MockHandler) GetDLQReplicationMessages(arg0 context.Context, arg1 *replicator.GetDLQReplicationMessagesRequest) (*replicator.GetDLQReplicationMessagesResponse, error)

GetDLQReplicationMessages mocks base method

func (*MockHandler) GetMutableState added in v0.17.0 

func (m *MockHandler) GetMutableState(arg0 context.Context, arg1 *history.GetMutableStateRequest) (*history.GetMutableStateResponse, error)

GetMutableState mocks base method

func (*MockHandler) GetReplicationMessages added in v0.17.0 

func (m *MockHandler) GetReplicationMessages(arg0 context.Context, arg1 *replicator.GetReplicationMessagesRequest) (*replicator.GetReplicationMessagesResponse, error)

GetReplicationMessages mocks base method

func (*MockHandler) Health added in v0.17.0 

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

Health mocks base method

func (*MockHandler) MergeDLQMessages added in v0.17.0 

func (m *MockHandler) MergeDLQMessages(arg0 context.Context, arg1 *replicator.MergeDLQMessagesRequest) (*replicator.MergeDLQMessagesResponse, error)

MergeDLQMessages mocks base method

func (*MockHandler) NotifyFailoverMarkers added in v0.17.0 

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

NotifyFailoverMarkers mocks base method

func (*MockHandler) PollMutableState added in v0.17.0 

func (m *MockHandler) PollMutableState(arg0 context.Context, arg1 *history.PollMutableStateRequest) (*history.PollMutableStateResponse, error)

PollMutableState mocks base method

func (*MockHandler) PurgeDLQMessages added in v0.17.0 

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

PurgeDLQMessages mocks base method

func (*MockHandler) QueryWorkflow added in v0.17.0 

func (m *MockHandler) QueryWorkflow(arg0 context.Context, arg1 *history.QueryWorkflowRequest) (*history.QueryWorkflowResponse, error)

QueryWorkflow mocks base method

func (*MockHandler) ReadDLQMessages added in v0.17.0 

func (m *MockHandler) ReadDLQMessages(arg0 context.Context, arg1 *replicator.ReadDLQMessagesRequest) (*replicator.ReadDLQMessagesResponse, error)

ReadDLQMessages mocks base method

func (*MockHandler) ReapplyEvents added in v0.17.0 

func (m *MockHandler) ReapplyEvents(arg0 context.Context, arg1 *history.ReapplyEventsRequest) error

ReapplyEvents mocks base method

func (*MockHandler) RecordActivityTaskHeartbeat added in v0.17.0 

func (m *MockHandler) RecordActivityTaskHeartbeat(arg0 context.Context, arg1 *history.RecordActivityTaskHeartbeatRequest) (*shared.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeat mocks base method

func (*MockHandler) RecordActivityTaskStarted added in v0.17.0 

func (m *MockHandler) RecordActivityTaskStarted(arg0 context.Context, arg1 *history.RecordActivityTaskStartedRequest) (*history.RecordActivityTaskStartedResponse, error)

RecordActivityTaskStarted mocks base method

func (*MockHandler) RecordChildExecutionCompleted added in v0.17.0 

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

RecordChildExecutionCompleted mocks base method

func (*MockHandler) RecordDecisionTaskStarted added in v0.17.0 

func (m *MockHandler) RecordDecisionTaskStarted(arg0 context.Context, arg1 *history.RecordDecisionTaskStartedRequest) (*history.RecordDecisionTaskStartedResponse, error)

RecordDecisionTaskStarted mocks base method

func (*MockHandler) RefreshWorkflowTasks added in v0.17.0 

func (m *MockHandler) RefreshWorkflowTasks(arg0 context.Context, arg1 *history.RefreshWorkflowTasksRequest) error

RefreshWorkflowTasks mocks base method

func (*MockHandler) RemoveSignalMutableState added in v0.17.0 

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

RemoveSignalMutableState mocks base method

func (*MockHandler) RemoveTask added in v0.17.0 

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

RemoveTask mocks base method

func (*MockHandler) ReplicateEventsV2 added in v0.17.0 

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

ReplicateEventsV2 mocks base method

func (*MockHandler) RequestCancelWorkflowExecution added in v0.17.0 

func (m *MockHandler) RequestCancelWorkflowExecution(arg0 context.Context, arg1 *history.RequestCancelWorkflowExecutionRequest) error

RequestCancelWorkflowExecution mocks base method

func (*MockHandler) ResetQueue added in v0.17.0 

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

ResetQueue mocks base method

func (*MockHandler) ResetStickyTaskList added in v0.17.0 

func (m *MockHandler) ResetStickyTaskList(arg0 context.Context, arg1 *history.ResetStickyTaskListRequest) (*history.ResetStickyTaskListResponse, error)

ResetStickyTaskList mocks base method

func (*MockHandler) ResetWorkflowExecution added in v0.17.0 

func (m *MockHandler) ResetWorkflowExecution(arg0 context.Context, arg1 *history.ResetWorkflowExecutionRequest) (*shared.ResetWorkflowExecutionResponse, error)

ResetWorkflowExecution mocks base method

func (*MockHandler) RespondActivityTaskCanceled added in v0.17.0 

func (m *MockHandler) RespondActivityTaskCanceled(arg0 context.Context, arg1 *history.RespondActivityTaskCanceledRequest) error

RespondActivityTaskCanceled mocks base method

func (*MockHandler) RespondActivityTaskCompleted added in v0.17.0 

func (m *MockHandler) RespondActivityTaskCompleted(arg0 context.Context, arg1 *history.RespondActivityTaskCompletedRequest) error

RespondActivityTaskCompleted mocks base method

func (*MockHandler) RespondActivityTaskFailed added in v0.17.0 

func (m *MockHandler) RespondActivityTaskFailed(arg0 context.Context, arg1 *history.RespondActivityTaskFailedRequest) error

RespondActivityTaskFailed mocks base method

func (*MockHandler) RespondDecisionTaskCompleted added in v0.17.0 

func (m *MockHandler) RespondDecisionTaskCompleted(arg0 context.Context, arg1 *history.RespondDecisionTaskCompletedRequest) (*history.RespondDecisionTaskCompletedResponse, error)

RespondDecisionTaskCompleted mocks base method

func (*MockHandler) RespondDecisionTaskFailed added in v0.17.0 

func (m *MockHandler) RespondDecisionTaskFailed(arg0 context.Context, arg1 *history.RespondDecisionTaskFailedRequest) error

RespondDecisionTaskFailed mocks base method

func (*MockHandler) ScheduleDecisionTask added in v0.17.0 

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

ScheduleDecisionTask mocks base method

func (*MockHandler) SignalWithStartWorkflowExecution added in v0.17.0 

func (m *MockHandler) SignalWithStartWorkflowExecution(arg0 context.Context, arg1 *history.SignalWithStartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)

SignalWithStartWorkflowExecution mocks base method

func (*MockHandler) SignalWorkflowExecution added in v0.17.0 

func (m *MockHandler) SignalWorkflowExecution(arg0 context.Context, arg1 *history.SignalWorkflowExecutionRequest) error

SignalWorkflowExecution mocks base method

func (*MockHandler) StartWorkflowExecution added in v0.17.0 

func (m *MockHandler) StartWorkflowExecution(arg0 context.Context, arg1 *history.StartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)

StartWorkflowExecution mocks base method

func (*MockHandler) SyncActivity added in v0.17.0 

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

SyncActivity mocks base method

func (*MockHandler) SyncShardStatus added in v0.17.0 

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

SyncShardStatus mocks base method

func (*MockHandler) TerminateWorkflowExecution added in v0.17.0 

func (m *MockHandler) TerminateWorkflowExecution(arg0 context.Context, arg1 *history.TerminateWorkflowExecutionRequest) 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) 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) GetDLQReplicationMessages added in v0.17.0 

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

GetDLQReplicationMessages indicates an expected call of GetDLQReplicationMessages

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) 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) 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) StartWorkflowExecution added in v0.17.0 

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

StartWorkflowExecution indicates an expected call of StartWorkflowExecution

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 MockProcessor added in v0.3.12 

type MockProcessor struct {
	mock.Mock
}

MockProcessor is used as mock implementation for Processor

type MockQueueAckMgr added in v0.3.12 

type MockQueueAckMgr struct {
	mock.Mock
}

MockQueueAckMgr is used as mock implementation for QueueAckMgr

type MockTimerProcessor added in v0.4.0 

type MockTimerProcessor struct {
	mock.Mock
}

MockTimerProcessor is used as mock implementation for timerProcessor

type MockTimerQueueAckMgr added in v0.3.11 

type MockTimerQueueAckMgr struct {
	mock.Mock
}

MockTimerQueueAckMgr is used as mock implementation for TimerQueueAckMgr

type QueueProcessorOptions added in v0.3.11 

type QueueProcessorOptions struct {
	BatchSize                           dynamicconfig.IntPropertyFn
	WorkerCount                         dynamicconfig.IntPropertyFn
	MaxPollRPS                          dynamicconfig.IntPropertyFn
	MaxPollInterval                     dynamicconfig.DurationPropertyFn
	MaxPollIntervalJitterCoefficient    dynamicconfig.FloatPropertyFn
	UpdateAckInterval                   dynamicconfig.DurationPropertyFn
	UpdateAckIntervalJitterCoefficient  dynamicconfig.FloatPropertyFn
	MaxRetryCount                       dynamicconfig.IntPropertyFn
	RedispatchInterval                  dynamicconfig.DurationPropertyFn
	RedispatchIntervalJitterCoefficient dynamicconfig.FloatPropertyFn
	MaxRedispatchQueueSize              dynamicconfig.IntPropertyFn
	EnablePriorityTaskProcessor         dynamicconfig.BoolPropertyFn
	MetricScope                         int
	QueueType                           task.QueueType
}

QueueProcessorOptions is options passed to queue processor implementation

type ReplicatorQueueProcessor added in v0.9.0 

type ReplicatorQueueProcessor interface {
	// contains filtered or unexported methods
}

ReplicatorQueueProcessor is the interface for replicator queue processor

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
}

ThriftHandler wrap underlying handler and handles Thrift related type conversions

func NewThriftHandler added in v0.17.0 

func NewThriftHandler(h Handler) ThriftHandler

NewThriftHandler creates Thrift handler on top of underlying handler

func (ThriftHandler) CloseShard added in v0.17.0 

func (t ThriftHandler) CloseShard(ctx context.Context, request *shared.CloseShardRequest) (err error)

CloseShard forwards request to the underlying handler

func (ThriftHandler) DescribeHistoryHost added in v0.17.0 

func (t ThriftHandler) DescribeHistoryHost(ctx context.Context, request *shared.DescribeHistoryHostRequest) (response *shared.DescribeHistoryHostResponse, err error)

DescribeHistoryHost forwards request to the underlying handler

func (ThriftHandler) DescribeMutableState added in v0.17.0 

func (t ThriftHandler) DescribeMutableState(ctx context.Context, request *h.DescribeMutableStateRequest) (response *h.DescribeMutableStateResponse, err error)

DescribeMutableState forwards request to the underlying handler

func (ThriftHandler) DescribeQueue added in v0.17.0 

func (t ThriftHandler) DescribeQueue(ctx context.Context, request *shared.DescribeQueueRequest) (response *shared.DescribeQueueResponse, err error)

DescribeQueue forwards request to the underlying handler

func (ThriftHandler) DescribeWorkflowExecution added in v0.17.0 

func (t ThriftHandler) DescribeWorkflowExecution(ctx context.Context, request *h.DescribeWorkflowExecutionRequest) (response *shared.DescribeWorkflowExecutionResponse, err error)

DescribeWorkflowExecution forwards request to the underlying handler

func (ThriftHandler) GetDLQReplicationMessages added in v0.17.0 

func (t ThriftHandler) GetDLQReplicationMessages(ctx context.Context, request *replicator.GetDLQReplicationMessagesRequest) (response *replicator.GetDLQReplicationMessagesResponse, err error)

GetDLQReplicationMessages forwards request to the underlying handler

func (ThriftHandler) GetMutableState added in v0.17.0 

func (t ThriftHandler) GetMutableState(ctx context.Context, request *h.GetMutableStateRequest) (response *h.GetMutableStateResponse, err error)

GetMutableState forwards request to the underlying handler

func (ThriftHandler) GetReplicationMessages added in v0.17.0 

func (t ThriftHandler) GetReplicationMessages(ctx context.Context, request *replicator.GetReplicationMessagesRequest) (response *replicator.GetReplicationMessagesResponse, err error)

GetReplicationMessages forwards request to the underlying handler

func (ThriftHandler) Health added in v0.17.0 

func (t ThriftHandler) Health(ctx context.Context) (response *health.HealthStatus, err error)

Health forwards request to the underlying handler

func (ThriftHandler) MergeDLQMessages added in v0.17.0 

func (t ThriftHandler) MergeDLQMessages(ctx context.Context, request *replicator.MergeDLQMessagesRequest) (response *replicator.MergeDLQMessagesResponse, err error)

MergeDLQMessages forwards request to the underlying handler

func (ThriftHandler) NotifyFailoverMarkers added in v0.17.0 

func (t ThriftHandler) NotifyFailoverMarkers(ctx context.Context, request *h.NotifyFailoverMarkersRequest) (err error)

NotifyFailoverMarkers forwards request to the underlying handler

func (ThriftHandler) PollMutableState added in v0.17.0 

func (t ThriftHandler) PollMutableState(ctx context.Context, request *h.PollMutableStateRequest) (response *h.PollMutableStateResponse, err error)

PollMutableState forwards request to the underlying handler

func (ThriftHandler) PurgeDLQMessages added in v0.17.0 

func (t ThriftHandler) PurgeDLQMessages(ctx context.Context, request *replicator.PurgeDLQMessagesRequest) (err error)

PurgeDLQMessages forwards request to the underlying handler

func (ThriftHandler) QueryWorkflow added in v0.17.0 

func (t ThriftHandler) QueryWorkflow(ctx context.Context, request *h.QueryWorkflowRequest) (response *h.QueryWorkflowResponse, err error)

QueryWorkflow forwards request to the underlying handler

func (ThriftHandler) ReadDLQMessages added in v0.17.0 

func (t ThriftHandler) ReadDLQMessages(ctx context.Context, request *replicator.ReadDLQMessagesRequest) (response *replicator.ReadDLQMessagesResponse, err error)

ReadDLQMessages forwards request to the underlying handler

func (ThriftHandler) ReapplyEvents added in v0.17.0 

func (t ThriftHandler) ReapplyEvents(ctx context.Context, request *h.ReapplyEventsRequest) (err error)

ReapplyEvents forwards request to the underlying handler

func (ThriftHandler) RecordActivityTaskHeartbeat added in v0.17.0 

func (t ThriftHandler) RecordActivityTaskHeartbeat(ctx context.Context, request *h.RecordActivityTaskHeartbeatRequest) (response *shared.RecordActivityTaskHeartbeatResponse, err error)

RecordActivityTaskHeartbeat forwards request to the underlying handler

func (ThriftHandler) RecordActivityTaskStarted added in v0.17.0 

func (t ThriftHandler) RecordActivityTaskStarted(ctx context.Context, request *h.RecordActivityTaskStartedRequest) (response *h.RecordActivityTaskStartedResponse, err error)

RecordActivityTaskStarted forwards request to the underlying handler

func (ThriftHandler) RecordChildExecutionCompleted added in v0.17.0 

func (t ThriftHandler) RecordChildExecutionCompleted(ctx context.Context, request *h.RecordChildExecutionCompletedRequest) (err error)

RecordChildExecutionCompleted forwards request to the underlying handler

func (ThriftHandler) RecordDecisionTaskStarted added in v0.17.0 

func (t ThriftHandler) RecordDecisionTaskStarted(ctx context.Context, request *h.RecordDecisionTaskStartedRequest) (response *h.RecordDecisionTaskStartedResponse, err error)

RecordDecisionTaskStarted forwards request to the underlying handler

func (ThriftHandler) RefreshWorkflowTasks added in v0.17.0 

func (t ThriftHandler) RefreshWorkflowTasks(ctx context.Context, request *h.RefreshWorkflowTasksRequest) (err error)

RefreshWorkflowTasks forwards request to the underlying handler

func (ThriftHandler) RemoveSignalMutableState added in v0.17.0 

func (t ThriftHandler) RemoveSignalMutableState(ctx context.Context, request *h.RemoveSignalMutableStateRequest) (err error)

RemoveSignalMutableState forwards request to the underlying handler

func (ThriftHandler) RemoveTask added in v0.17.0 

func (t ThriftHandler) RemoveTask(ctx context.Context, request *shared.RemoveTaskRequest) (err error)

RemoveTask forwards request to the underlying handler

func (ThriftHandler) ReplicateEventsV2 added in v0.17.0 

func (t ThriftHandler) ReplicateEventsV2(ctx context.Context, request *h.ReplicateEventsV2Request) (err error)

ReplicateEventsV2 forwards request to the underlying handler

func (ThriftHandler) RequestCancelWorkflowExecution added in v0.17.0 

func (t ThriftHandler) RequestCancelWorkflowExecution(ctx context.Context, request *h.RequestCancelWorkflowExecutionRequest) (err error)

RequestCancelWorkflowExecution forwards request to the underlying handler

func (ThriftHandler) ResetQueue added in v0.17.0 

func (t ThriftHandler) ResetQueue(ctx context.Context, request *shared.ResetQueueRequest) (err error)

ResetQueue forwards request to the underlying handler

func (ThriftHandler) ResetStickyTaskList added in v0.17.0 

func (t ThriftHandler) ResetStickyTaskList(ctx context.Context, request *h.ResetStickyTaskListRequest) (response *h.ResetStickyTaskListResponse, err error)

ResetStickyTaskList forwards request to the underlying handler

func (ThriftHandler) ResetWorkflowExecution added in v0.17.0 

func (t ThriftHandler) ResetWorkflowExecution(ctx context.Context, request *h.ResetWorkflowExecutionRequest) (response *shared.ResetWorkflowExecutionResponse, err error)

ResetWorkflowExecution forwards request to the underlying handler

func (ThriftHandler) RespondActivityTaskCanceled added in v0.17.0 

func (t ThriftHandler) RespondActivityTaskCanceled(ctx context.Context, request *h.RespondActivityTaskCanceledRequest) (err error)

RespondActivityTaskCanceled forwards request to the underlying handler

func (ThriftHandler) RespondActivityTaskCompleted added in v0.17.0 

func (t ThriftHandler) RespondActivityTaskCompleted(ctx context.Context, request *h.RespondActivityTaskCompletedRequest) (err error)

RespondActivityTaskCompleted forwards request to the underlying handler

func (ThriftHandler) RespondActivityTaskFailed added in v0.17.0 

func (t ThriftHandler) RespondActivityTaskFailed(ctx context.Context, request *h.RespondActivityTaskFailedRequest) (err error)

RespondActivityTaskFailed forwards request to the underlying handler

func (ThriftHandler) RespondDecisionTaskCompleted added in v0.17.0 

func (t ThriftHandler) RespondDecisionTaskCompleted(ctx context.Context, request *h.RespondDecisionTaskCompletedRequest) (response *h.RespondDecisionTaskCompletedResponse, err error)

RespondDecisionTaskCompleted forwards request to the underlying handler

func (ThriftHandler) RespondDecisionTaskFailed added in v0.17.0 

func (t ThriftHandler) RespondDecisionTaskFailed(ctx context.Context, request *h.RespondDecisionTaskFailedRequest) (err error)

RespondDecisionTaskFailed forwards request to the underlying handler

func (ThriftHandler) ScheduleDecisionTask added in v0.17.0 

func (t ThriftHandler) ScheduleDecisionTask(ctx context.Context, request *h.ScheduleDecisionTaskRequest) (err error)

ScheduleDecisionTask forwards request to the underlying handler

func (ThriftHandler) SignalWithStartWorkflowExecution added in v0.17.0 

func (t ThriftHandler) SignalWithStartWorkflowExecution(ctx context.Context, request *h.SignalWithStartWorkflowExecutionRequest) (response *shared.StartWorkflowExecutionResponse, err error)

SignalWithStartWorkflowExecution forwards request to the underlying handler

func (ThriftHandler) SignalWorkflowExecution added in v0.17.0 

func (t ThriftHandler) SignalWorkflowExecution(ctx context.Context, request *h.SignalWorkflowExecutionRequest) (err error)

SignalWorkflowExecution forwards request to the underlying handler

func (ThriftHandler) StartWorkflowExecution added in v0.17.0 

func (t ThriftHandler) StartWorkflowExecution(ctx context.Context, request *h.StartWorkflowExecutionRequest) (response *shared.StartWorkflowExecutionResponse, err error)

StartWorkflowExecution forwards request to the underlying handler

func (ThriftHandler) SyncActivity added in v0.17.0 

func (t ThriftHandler) SyncActivity(ctx context.Context, request *h.SyncActivityRequest) (err error)

SyncActivity forwards request to the underlying handler

func (ThriftHandler) SyncShardStatus added in v0.17.0 

func (t ThriftHandler) SyncShardStatus(ctx context.Context, request *h.SyncShardStatusRequest) (err error)

SyncShardStatus forwards request to the underlying handler

func (ThriftHandler) TerminateWorkflowExecution added in v0.17.0 

func (t ThriftHandler) TerminateWorkflowExecution(ctx context.Context, request *h.TerminateWorkflowExecutionRequest) (err error)

TerminateWorkflowExecution forwards request to the underlying handler

Source Files

View all Source files

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 replication is a generated GoMock package.
 Package replication 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.

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.