Documentation
¶
Overview ¶
Package history is a generated GoMock package.
Index ¶
- Constants
- Variables
- func NewEngineWithShardContext(shard shard.Context, visibilityMgr persistence.VisibilityManager, ...) engine.Engine
- func NewHandler(resource resource.Resource, config *config.Config) *handlerImpl
- func NewService(params *service.BootstrapParams) (resource.Resource, error)
- type Handler
- type MockHandler
- func (m *MockHandler) CloseShard(arg0 context.Context, arg1 *shared.CloseShardRequest) error
- func (m *MockHandler) DescribeHistoryHost(arg0 context.Context, arg1 *shared.DescribeHistoryHostRequest) (*shared.DescribeHistoryHostResponse, error)
- func (m *MockHandler) DescribeMutableState(arg0 context.Context, arg1 *history.DescribeMutableStateRequest) (*history.DescribeMutableStateResponse, error)
- func (m *MockHandler) DescribeQueue(arg0 context.Context, arg1 *shared.DescribeQueueRequest) (*shared.DescribeQueueResponse, error)
- func (m *MockHandler) DescribeWorkflowExecution(arg0 context.Context, arg1 *history.DescribeWorkflowExecutionRequest) (*shared.DescribeWorkflowExecutionResponse, error)
- func (m *MockHandler) EXPECT() *MockHandlerMockRecorder
- func (m *MockHandler) GetDLQReplicationMessages(arg0 context.Context, arg1 *replicator.GetDLQReplicationMessagesRequest) (*replicator.GetDLQReplicationMessagesResponse, error)
- func (m *MockHandler) GetMutableState(arg0 context.Context, arg1 *history.GetMutableStateRequest) (*history.GetMutableStateResponse, error)
- func (m *MockHandler) GetReplicationMessages(arg0 context.Context, arg1 *replicator.GetReplicationMessagesRequest) (*replicator.GetReplicationMessagesResponse, error)
- func (m *MockHandler) Health(arg0 context.Context) (*health.HealthStatus, error)
- func (m *MockHandler) MergeDLQMessages(arg0 context.Context, arg1 *replicator.MergeDLQMessagesRequest) (*replicator.MergeDLQMessagesResponse, error)
- func (m *MockHandler) NotifyFailoverMarkers(arg0 context.Context, arg1 *history.NotifyFailoverMarkersRequest) error
- func (m *MockHandler) PollMutableState(arg0 context.Context, arg1 *history.PollMutableStateRequest) (*history.PollMutableStateResponse, error)
- func (m *MockHandler) PurgeDLQMessages(arg0 context.Context, arg1 *replicator.PurgeDLQMessagesRequest) error
- func (m *MockHandler) QueryWorkflow(arg0 context.Context, arg1 *history.QueryWorkflowRequest) (*history.QueryWorkflowResponse, error)
- func (m *MockHandler) ReadDLQMessages(arg0 context.Context, arg1 *replicator.ReadDLQMessagesRequest) (*replicator.ReadDLQMessagesResponse, error)
- func (m *MockHandler) ReapplyEvents(arg0 context.Context, arg1 *history.ReapplyEventsRequest) error
- func (m *MockHandler) RecordActivityTaskHeartbeat(arg0 context.Context, arg1 *history.RecordActivityTaskHeartbeatRequest) (*shared.RecordActivityTaskHeartbeatResponse, error)
- func (m *MockHandler) RecordActivityTaskStarted(arg0 context.Context, arg1 *history.RecordActivityTaskStartedRequest) (*history.RecordActivityTaskStartedResponse, error)
- func (m *MockHandler) RecordChildExecutionCompleted(arg0 context.Context, arg1 *history.RecordChildExecutionCompletedRequest) error
- func (m *MockHandler) RecordDecisionTaskStarted(arg0 context.Context, arg1 *history.RecordDecisionTaskStartedRequest) (*history.RecordDecisionTaskStartedResponse, error)
- func (m *MockHandler) RefreshWorkflowTasks(arg0 context.Context, arg1 *history.RefreshWorkflowTasksRequest) error
- func (m *MockHandler) RemoveSignalMutableState(arg0 context.Context, arg1 *history.RemoveSignalMutableStateRequest) error
- func (m *MockHandler) RemoveTask(arg0 context.Context, arg1 *shared.RemoveTaskRequest) error
- func (m *MockHandler) ReplicateEventsV2(arg0 context.Context, arg1 *history.ReplicateEventsV2Request) error
- func (m *MockHandler) RequestCancelWorkflowExecution(arg0 context.Context, arg1 *history.RequestCancelWorkflowExecutionRequest) error
- func (m *MockHandler) ResetQueue(arg0 context.Context, arg1 *shared.ResetQueueRequest) error
- func (m *MockHandler) ResetStickyTaskList(arg0 context.Context, arg1 *history.ResetStickyTaskListRequest) (*history.ResetStickyTaskListResponse, error)
- func (m *MockHandler) ResetWorkflowExecution(arg0 context.Context, arg1 *history.ResetWorkflowExecutionRequest) (*shared.ResetWorkflowExecutionResponse, error)
- func (m *MockHandler) RespondActivityTaskCanceled(arg0 context.Context, arg1 *history.RespondActivityTaskCanceledRequest) error
- func (m *MockHandler) RespondActivityTaskCompleted(arg0 context.Context, arg1 *history.RespondActivityTaskCompletedRequest) error
- func (m *MockHandler) RespondActivityTaskFailed(arg0 context.Context, arg1 *history.RespondActivityTaskFailedRequest) error
- func (m *MockHandler) RespondDecisionTaskCompleted(arg0 context.Context, arg1 *history.RespondDecisionTaskCompletedRequest) (*history.RespondDecisionTaskCompletedResponse, error)
- func (m *MockHandler) RespondDecisionTaskFailed(arg0 context.Context, arg1 *history.RespondDecisionTaskFailedRequest) error
- func (m *MockHandler) ScheduleDecisionTask(arg0 context.Context, arg1 *history.ScheduleDecisionTaskRequest) error
- func (m *MockHandler) SignalWithStartWorkflowExecution(arg0 context.Context, arg1 *history.SignalWithStartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)
- func (m *MockHandler) SignalWorkflowExecution(arg0 context.Context, arg1 *history.SignalWorkflowExecutionRequest) error
- func (m *MockHandler) StartWorkflowExecution(arg0 context.Context, arg1 *history.StartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)
- func (m *MockHandler) SyncActivity(arg0 context.Context, arg1 *history.SyncActivityRequest) error
- func (m *MockHandler) SyncShardStatus(arg0 context.Context, arg1 *history.SyncShardStatusRequest) error
- func (m *MockHandler) TerminateWorkflowExecution(arg0 context.Context, arg1 *history.TerminateWorkflowExecutionRequest) error
- type MockHandlerMockRecorder
- func (mr *MockHandlerMockRecorder) CloseShard(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeHistoryHost(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeMutableState(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetDLQReplicationMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetMutableState(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetReplicationMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) Health(arg0 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) MergeDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) NotifyFailoverMarkers(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) PollMutableState(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) PurgeDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) QueryWorkflow(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ReadDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ReapplyEvents(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RecordActivityTaskHeartbeat(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RecordActivityTaskStarted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RecordChildExecutionCompleted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RecordDecisionTaskStarted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RefreshWorkflowTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RemoveSignalMutableState(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RemoveTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ReplicateEventsV2(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RequestCancelWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ResetQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ResetStickyTaskList(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ResetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondActivityTaskCanceled(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondActivityTaskCompleted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondActivityTaskFailed(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondDecisionTaskCompleted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondDecisionTaskFailed(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ScheduleDecisionTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) SignalWithStartWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) SignalWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) StartWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) SyncActivity(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) SyncShardStatus(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) TerminateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- type MockProcessor
- type MockQueueAckMgr
- type MockTimerProcessor
- type MockTimerQueueAckMgr
- type QueueProcessorOptions
- type ReplicatorQueueProcessor
- type Service
- type ThriftHandler
- func (t ThriftHandler) CloseShard(ctx context.Context, request *shared.CloseShardRequest) (err error)
- func (t ThriftHandler) DescribeHistoryHost(ctx context.Context, request *shared.DescribeHistoryHostRequest) (response *shared.DescribeHistoryHostResponse, err error)
- func (t ThriftHandler) DescribeMutableState(ctx context.Context, request *h.DescribeMutableStateRequest) (response *h.DescribeMutableStateResponse, err error)
- func (t ThriftHandler) DescribeQueue(ctx context.Context, request *shared.DescribeQueueRequest) (response *shared.DescribeQueueResponse, err error)
- func (t ThriftHandler) DescribeWorkflowExecution(ctx context.Context, request *h.DescribeWorkflowExecutionRequest) (response *shared.DescribeWorkflowExecutionResponse, err error)
- func (t ThriftHandler) GetDLQReplicationMessages(ctx context.Context, request *replicator.GetDLQReplicationMessagesRequest) (response *replicator.GetDLQReplicationMessagesResponse, err error)
- func (t ThriftHandler) GetMutableState(ctx context.Context, request *h.GetMutableStateRequest) (response *h.GetMutableStateResponse, err error)
- func (t ThriftHandler) GetReplicationMessages(ctx context.Context, request *replicator.GetReplicationMessagesRequest) (response *replicator.GetReplicationMessagesResponse, err error)
- func (t ThriftHandler) Health(ctx context.Context) (response *health.HealthStatus, err error)
- func (t ThriftHandler) MergeDLQMessages(ctx context.Context, request *replicator.MergeDLQMessagesRequest) (response *replicator.MergeDLQMessagesResponse, err error)
- func (t ThriftHandler) NotifyFailoverMarkers(ctx context.Context, request *h.NotifyFailoverMarkersRequest) (err error)
- func (t ThriftHandler) PollMutableState(ctx context.Context, request *h.PollMutableStateRequest) (response *h.PollMutableStateResponse, err error)
- func (t ThriftHandler) PurgeDLQMessages(ctx context.Context, request *replicator.PurgeDLQMessagesRequest) (err error)
- func (t ThriftHandler) QueryWorkflow(ctx context.Context, request *h.QueryWorkflowRequest) (response *h.QueryWorkflowResponse, err error)
- func (t ThriftHandler) ReadDLQMessages(ctx context.Context, request *replicator.ReadDLQMessagesRequest) (response *replicator.ReadDLQMessagesResponse, err error)
- func (t ThriftHandler) ReapplyEvents(ctx context.Context, request *h.ReapplyEventsRequest) (err error)
- func (t ThriftHandler) RecordActivityTaskHeartbeat(ctx context.Context, request *h.RecordActivityTaskHeartbeatRequest) (response *shared.RecordActivityTaskHeartbeatResponse, err error)
- func (t ThriftHandler) RecordActivityTaskStarted(ctx context.Context, request *h.RecordActivityTaskStartedRequest) (response *h.RecordActivityTaskStartedResponse, err error)
- func (t ThriftHandler) RecordChildExecutionCompleted(ctx context.Context, request *h.RecordChildExecutionCompletedRequest) (err error)
- func (t ThriftHandler) RecordDecisionTaskStarted(ctx context.Context, request *h.RecordDecisionTaskStartedRequest) (response *h.RecordDecisionTaskStartedResponse, err error)
- func (t ThriftHandler) RefreshWorkflowTasks(ctx context.Context, request *h.RefreshWorkflowTasksRequest) (err error)
- func (t ThriftHandler) RemoveSignalMutableState(ctx context.Context, request *h.RemoveSignalMutableStateRequest) (err error)
- func (t ThriftHandler) RemoveTask(ctx context.Context, request *shared.RemoveTaskRequest) (err error)
- func (t ThriftHandler) ReplicateEventsV2(ctx context.Context, request *h.ReplicateEventsV2Request) (err error)
- func (t ThriftHandler) RequestCancelWorkflowExecution(ctx context.Context, request *h.RequestCancelWorkflowExecutionRequest) (err error)
- func (t ThriftHandler) ResetQueue(ctx context.Context, request *shared.ResetQueueRequest) (err error)
- func (t ThriftHandler) ResetStickyTaskList(ctx context.Context, request *h.ResetStickyTaskListRequest) (response *h.ResetStickyTaskListResponse, err error)
- func (t ThriftHandler) ResetWorkflowExecution(ctx context.Context, request *h.ResetWorkflowExecutionRequest) (response *shared.ResetWorkflowExecutionResponse, err error)
- func (t ThriftHandler) RespondActivityTaskCanceled(ctx context.Context, request *h.RespondActivityTaskCanceledRequest) (err error)
- func (t ThriftHandler) RespondActivityTaskCompleted(ctx context.Context, request *h.RespondActivityTaskCompletedRequest) (err error)
- func (t ThriftHandler) RespondActivityTaskFailed(ctx context.Context, request *h.RespondActivityTaskFailedRequest) (err error)
- func (t ThriftHandler) RespondDecisionTaskCompleted(ctx context.Context, request *h.RespondDecisionTaskCompletedRequest) (response *h.RespondDecisionTaskCompletedResponse, err error)
- func (t ThriftHandler) RespondDecisionTaskFailed(ctx context.Context, request *h.RespondDecisionTaskFailedRequest) (err error)
- func (t ThriftHandler) ScheduleDecisionTask(ctx context.Context, request *h.ScheduleDecisionTaskRequest) (err error)
- func (t ThriftHandler) SignalWithStartWorkflowExecution(ctx context.Context, request *h.SignalWithStartWorkflowExecutionRequest) (response *shared.StartWorkflowExecutionResponse, err error)
- func (t ThriftHandler) SignalWorkflowExecution(ctx context.Context, request *h.SignalWorkflowExecutionRequest) (err error)
- func (t ThriftHandler) StartWorkflowExecution(ctx context.Context, request *h.StartWorkflowExecutionRequest) (response *shared.StartWorkflowExecutionResponse, err error)
- func (t ThriftHandler) SyncActivity(ctx context.Context, request *h.SyncActivityRequest) (err error)
- func (t ThriftHandler) SyncShardStatus(ctx context.Context, request *h.SyncShardStatusRequest) (err error)
- func (t ThriftHandler) TerminateWorkflowExecution(ctx context.Context, request *h.TerminateWorkflowExecutionRequest) (err error)
Constants ¶
const ( // TerminateIfRunningReason reason for terminateIfRunning TerminateIfRunningReason = "TerminateIfRunning Policy" // TerminateIfRunningDetailsTemplate details template for terminateIfRunning TerminateIfRunningDetailsTemplate = "New runID: %s" )
Variables ¶
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 ¶
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
MockProcessor is used as mock implementation for Processor
type MockQueueAckMgr ¶ added in v0.3.12
MockQueueAckMgr is used as mock implementation for QueueAckMgr
type MockTimerProcessor ¶ added in v0.4.0
MockTimerProcessor is used as mock implementation for timerProcessor
type MockTimerQueueAckMgr ¶ added in v0.3.11
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 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
¶
- MockProcessor.go
- MockQueueAckMgr.go
- MockTimerProcessor.go
- MockTimerQueueAckMgr.go
- decisionChecker.go
- decisionHandler.go
- decisionTaskHandler.go
- handler.go
- handler_mock.go
- historyEngine.go
- historyEngineInterfaces.go
- queueAckMgr.go
- queueProcessor.go
- service.go
- taskProcessor.go
- thriftHandler.go
- timerQueueAckMgr.go
- timerQueueActiveProcessor.go
- timerQueueProcessor.go
- timerQueueProcessorBase.go
- timerQueueStandbyProcessor.go
- transferQueueActiveProcessor.go
- transferQueueProcessor.go
- transferQueueProcessorBase.go
- transferQueueStandbyProcessor.go
- workflowExecutionUtil.go
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. |