Documentation ¶
Overview ¶
Package frontend is a generated GoMock package.
Index ¶
- Constants
- func NewService(params *service.BootstrapParams) common.Daemon
- type AdminHandler
- func (adh *AdminHandler) AddSearchAttribute(ctx context.Context, request *admin.AddSearchAttributeRequest) error
- func (adh *AdminHandler) CloseShard(ctx context.Context, request *gen.CloseShardRequest) (retError error)
- func (adh *AdminHandler) DescribeHistoryHost(ctx context.Context, request *gen.DescribeHistoryHostRequest) (resp *gen.DescribeHistoryHostResponse, retError error)
- func (adh *AdminHandler) DescribeWorkflowExecution(ctx context.Context, request *admin.DescribeWorkflowExecutionRequest) (resp *admin.DescribeWorkflowExecutionResponse, retError error)
- func (adh *AdminHandler) GetWorkflowExecutionRawHistory(ctx context.Context, request *admin.GetWorkflowExecutionRawHistoryRequest) (resp *admin.GetWorkflowExecutionRawHistoryResponse, retError error)
- func (adh *AdminHandler) GetWorkflowExecutionRawHistoryV2(ctx context.Context, request *admin.GetWorkflowExecutionRawHistoryV2Request) (resp *admin.GetWorkflowExecutionRawHistoryV2Response, retError error)
- func (adh *AdminHandler) RegisterHandler()
- func (adh *AdminHandler) RemoveTask(ctx context.Context, request *gen.RemoveTaskRequest) (retError error)
- func (adh *AdminHandler) Start() error
- func (adh *AdminHandler) Stop()
- type Config
- type DCRedirectionHandlerImpl
- func (handler *DCRedirectionHandlerImpl) CountWorkflowExecutions(ctx context.Context, request *shared.CountWorkflowExecutionsRequest) (resp *shared.CountWorkflowExecutionsResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) DeprecateDomain(ctx context.Context, request *shared.DeprecateDomainRequest) (retError error)
- func (handler *DCRedirectionHandlerImpl) DescribeDomain(ctx context.Context, request *shared.DescribeDomainRequest) (resp *shared.DescribeDomainResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) DescribeTaskList(ctx context.Context, request *shared.DescribeTaskListRequest) (resp *shared.DescribeTaskListResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) DescribeWorkflowExecution(ctx context.Context, request *shared.DescribeWorkflowExecutionRequest) (resp *shared.DescribeWorkflowExecutionResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) GetDomainReplicationMessages(ctx context.Context, request *replicator.GetDomainReplicationMessagesRequest) (*replicator.GetDomainReplicationMessagesResponse, error)
- func (handler *DCRedirectionHandlerImpl) GetReplicationMessages(ctx context.Context, request *replicator.GetReplicationMessagesRequest) (*replicator.GetReplicationMessagesResponse, error)
- func (handler *DCRedirectionHandlerImpl) GetSearchAttributes(ctx context.Context) (resp *shared.GetSearchAttributesResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) GetWorkflowExecutionHistory(ctx context.Context, request *shared.GetWorkflowExecutionHistoryRequest) (resp *shared.GetWorkflowExecutionHistoryResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) Health(ctx context.Context) (*health.HealthStatus, error)
- func (handler *DCRedirectionHandlerImpl) ListArchivedWorkflowExecutions(ctx context.Context, request *shared.ListArchivedWorkflowExecutionsRequest) (resp *shared.ListArchivedWorkflowExecutionsResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) ListClosedWorkflowExecutions(ctx context.Context, request *shared.ListClosedWorkflowExecutionsRequest) (resp *shared.ListClosedWorkflowExecutionsResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) ListDomains(ctx context.Context, request *shared.ListDomainsRequest) (resp *shared.ListDomainsResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) ListOpenWorkflowExecutions(ctx context.Context, request *shared.ListOpenWorkflowExecutionsRequest) (resp *shared.ListOpenWorkflowExecutionsResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) ListWorkflowExecutions(ctx context.Context, request *shared.ListWorkflowExecutionsRequest) (resp *shared.ListWorkflowExecutionsResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) PollForActivityTask(ctx context.Context, request *shared.PollForActivityTaskRequest) (resp *shared.PollForActivityTaskResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) PollForDecisionTask(ctx context.Context, request *shared.PollForDecisionTaskRequest) (resp *shared.PollForDecisionTaskResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) QueryWorkflow(ctx context.Context, request *shared.QueryWorkflowRequest) (resp *shared.QueryWorkflowResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) ReapplyEvents(ctx context.Context, request *shared.ReapplyEventsRequest) error
- func (handler *DCRedirectionHandlerImpl) RecordActivityTaskHeartbeat(ctx context.Context, request *shared.RecordActivityTaskHeartbeatRequest) (resp *shared.RecordActivityTaskHeartbeatResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) RecordActivityTaskHeartbeatByID(ctx context.Context, request *shared.RecordActivityTaskHeartbeatByIDRequest) (resp *shared.RecordActivityTaskHeartbeatResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) RegisterDomain(ctx context.Context, request *shared.RegisterDomainRequest) (retError error)
- func (handler *DCRedirectionHandlerImpl) RegisterHandler()
- func (handler *DCRedirectionHandlerImpl) RequestCancelWorkflowExecution(ctx context.Context, request *shared.RequestCancelWorkflowExecutionRequest) (retError error)
- func (handler *DCRedirectionHandlerImpl) ResetStickyTaskList(ctx context.Context, request *shared.ResetStickyTaskListRequest) (resp *shared.ResetStickyTaskListResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) ResetWorkflowExecution(ctx context.Context, request *shared.ResetWorkflowExecutionRequest) (resp *shared.ResetWorkflowExecutionResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) RespondActivityTaskCanceled(ctx context.Context, request *shared.RespondActivityTaskCanceledRequest) (retError error)
- func (handler *DCRedirectionHandlerImpl) RespondActivityTaskCanceledByID(ctx context.Context, request *shared.RespondActivityTaskCanceledByIDRequest) (retError error)
- func (handler *DCRedirectionHandlerImpl) RespondActivityTaskCompleted(ctx context.Context, request *shared.RespondActivityTaskCompletedRequest) (retError error)
- func (handler *DCRedirectionHandlerImpl) RespondActivityTaskCompletedByID(ctx context.Context, request *shared.RespondActivityTaskCompletedByIDRequest) (retError error)
- func (handler *DCRedirectionHandlerImpl) RespondActivityTaskFailed(ctx context.Context, request *shared.RespondActivityTaskFailedRequest) (retError error)
- func (handler *DCRedirectionHandlerImpl) RespondActivityTaskFailedByID(ctx context.Context, request *shared.RespondActivityTaskFailedByIDRequest) (retError error)
- func (handler *DCRedirectionHandlerImpl) RespondDecisionTaskCompleted(ctx context.Context, request *shared.RespondDecisionTaskCompletedRequest) (resp *shared.RespondDecisionTaskCompletedResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) RespondDecisionTaskFailed(ctx context.Context, request *shared.RespondDecisionTaskFailedRequest) (retError error)
- func (handler *DCRedirectionHandlerImpl) RespondQueryTaskCompleted(ctx context.Context, request *shared.RespondQueryTaskCompletedRequest) (retError error)
- func (handler *DCRedirectionHandlerImpl) ScanWorkflowExecutions(ctx context.Context, request *shared.ListWorkflowExecutionsRequest) (resp *shared.ListWorkflowExecutionsResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) SignalWithStartWorkflowExecution(ctx context.Context, request *shared.SignalWithStartWorkflowExecutionRequest) (resp *shared.StartWorkflowExecutionResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) SignalWorkflowExecution(ctx context.Context, request *shared.SignalWorkflowExecutionRequest) (retError error)
- func (handler *DCRedirectionHandlerImpl) Start() error
- func (handler *DCRedirectionHandlerImpl) StartWorkflowExecution(ctx context.Context, request *shared.StartWorkflowExecutionRequest) (resp *shared.StartWorkflowExecutionResponse, retError error)
- func (handler *DCRedirectionHandlerImpl) Stop()
- func (handler *DCRedirectionHandlerImpl) TerminateWorkflowExecution(ctx context.Context, request *shared.TerminateWorkflowExecutionRequest) (retError error)
- func (handler *DCRedirectionHandlerImpl) UpdateDomain(ctx context.Context, request *shared.UpdateDomainRequest) (resp *shared.UpdateDomainResponse, retError error)
- type DCRedirectionPolicy
- type MockDCRedirectionPolicy
- type MockWorkflowHandler
- func (m *MockWorkflowHandler) CountWorkflowExecutions(ctx context.Context, CountRequest *shared.CountWorkflowExecutionsRequest) (*shared.CountWorkflowExecutionsResponse, error)
- func (m *MockWorkflowHandler) DeprecateDomain(ctx context.Context, DeprecateRequest *shared.DeprecateDomainRequest) error
- func (m *MockWorkflowHandler) DescribeDomain(ctx context.Context, DescribeRequest *shared.DescribeDomainRequest) (*shared.DescribeDomainResponse, error)
- func (m *MockWorkflowHandler) DescribeTaskList(ctx context.Context, Request *shared.DescribeTaskListRequest) (*shared.DescribeTaskListResponse, error)
- func (m *MockWorkflowHandler) DescribeWorkflowExecution(ctx context.Context, DescribeRequest *shared.DescribeWorkflowExecutionRequest) (*shared.DescribeWorkflowExecutionResponse, error)
- func (m *MockWorkflowHandler) EXPECT() *MockWorkflowHandlerMockRecorder
- func (m *MockWorkflowHandler) GetDomainReplicationMessages(ctx context.Context, Request *replicator.GetDomainReplicationMessagesRequest) (*replicator.GetDomainReplicationMessagesResponse, error)
- func (m *MockWorkflowHandler) GetReplicationMessages(ctx context.Context, Request *replicator.GetReplicationMessagesRequest) (*replicator.GetReplicationMessagesResponse, error)
- func (m *MockWorkflowHandler) GetSearchAttributes(ctx context.Context) (*shared.GetSearchAttributesResponse, error)
- func (m *MockWorkflowHandler) GetWorkflowExecutionHistory(ctx context.Context, GetRequest *shared.GetWorkflowExecutionHistoryRequest) (*shared.GetWorkflowExecutionHistoryResponse, error)
- func (m *MockWorkflowHandler) ListArchivedWorkflowExecutions(ctx context.Context, ListRequest *shared.ListArchivedWorkflowExecutionsRequest) (*shared.ListArchivedWorkflowExecutionsResponse, error)
- func (m *MockWorkflowHandler) ListClosedWorkflowExecutions(ctx context.Context, ListRequest *shared.ListClosedWorkflowExecutionsRequest) (*shared.ListClosedWorkflowExecutionsResponse, error)
- func (m *MockWorkflowHandler) ListDomains(ctx context.Context, ListRequest *shared.ListDomainsRequest) (*shared.ListDomainsResponse, error)
- func (m *MockWorkflowHandler) ListOpenWorkflowExecutions(ctx context.Context, ListRequest *shared.ListOpenWorkflowExecutionsRequest) (*shared.ListOpenWorkflowExecutionsResponse, error)
- func (m *MockWorkflowHandler) ListWorkflowExecutions(ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, error)
- func (m *MockWorkflowHandler) PollForActivityTask(ctx context.Context, PollRequest *shared.PollForActivityTaskRequest) (*shared.PollForActivityTaskResponse, error)
- func (m *MockWorkflowHandler) PollForDecisionTask(ctx context.Context, PollRequest *shared.PollForDecisionTaskRequest) (*shared.PollForDecisionTaskResponse, error)
- func (m *MockWorkflowHandler) QueryWorkflow(ctx context.Context, QueryRequest *shared.QueryWorkflowRequest) (*shared.QueryWorkflowResponse, error)
- func (m *MockWorkflowHandler) ReapplyEvents(ctx context.Context, ReapplyEventsRequest *shared.ReapplyEventsRequest) error
- func (m *MockWorkflowHandler) RecordActivityTaskHeartbeat(ctx context.Context, ...) (*shared.RecordActivityTaskHeartbeatResponse, error)
- func (m *MockWorkflowHandler) RecordActivityTaskHeartbeatByID(ctx context.Context, ...) (*shared.RecordActivityTaskHeartbeatResponse, error)
- func (m *MockWorkflowHandler) RegisterDomain(ctx context.Context, RegisterRequest *shared.RegisterDomainRequest) error
- func (m *MockWorkflowHandler) RequestCancelWorkflowExecution(ctx context.Context, ...) error
- func (m *MockWorkflowHandler) ResetStickyTaskList(ctx context.Context, ResetRequest *shared.ResetStickyTaskListRequest) (*shared.ResetStickyTaskListResponse, error)
- func (m *MockWorkflowHandler) ResetWorkflowExecution(ctx context.Context, ResetRequest *shared.ResetWorkflowExecutionRequest) (*shared.ResetWorkflowExecutionResponse, error)
- func (m *MockWorkflowHandler) RespondActivityTaskCanceled(ctx context.Context, ...) error
- func (m *MockWorkflowHandler) RespondActivityTaskCanceledByID(ctx context.Context, ...) error
- func (m *MockWorkflowHandler) RespondActivityTaskCompleted(ctx context.Context, ...) error
- func (m *MockWorkflowHandler) RespondActivityTaskCompletedByID(ctx context.Context, ...) error
- func (m *MockWorkflowHandler) RespondActivityTaskFailed(ctx context.Context, FailRequest *shared.RespondActivityTaskFailedRequest) error
- func (m *MockWorkflowHandler) RespondActivityTaskFailedByID(ctx context.Context, FailRequest *shared.RespondActivityTaskFailedByIDRequest) error
- func (m *MockWorkflowHandler) RespondDecisionTaskCompleted(ctx context.Context, ...) (*shared.RespondDecisionTaskCompletedResponse, error)
- func (m *MockWorkflowHandler) RespondDecisionTaskFailed(ctx context.Context, FailedRequest *shared.RespondDecisionTaskFailedRequest) error
- func (m *MockWorkflowHandler) RespondQueryTaskCompleted(ctx context.Context, CompleteRequest *shared.RespondQueryTaskCompletedRequest) error
- func (m *MockWorkflowHandler) ScanWorkflowExecutions(ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, error)
- func (m *MockWorkflowHandler) SignalWithStartWorkflowExecution(ctx context.Context, ...) (*shared.StartWorkflowExecutionResponse, error)
- func (m *MockWorkflowHandler) SignalWorkflowExecution(ctx context.Context, SignalRequest *shared.SignalWorkflowExecutionRequest) error
- func (m *MockWorkflowHandler) StartWorkflowExecution(ctx context.Context, StartRequest *shared.StartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)
- func (m *MockWorkflowHandler) TerminateWorkflowExecution(ctx context.Context, ...) error
- func (m *MockWorkflowHandler) UpdateDomain(ctx context.Context, UpdateRequest *shared.UpdateDomainRequest) (*shared.UpdateDomainResponse, error)
- type MockWorkflowHandlerMockRecorder
- func (mr *MockWorkflowHandlerMockRecorder) CountWorkflowExecutions(ctx, CountRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) DeprecateDomain(ctx, DeprecateRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) DescribeDomain(ctx, DescribeRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) DescribeTaskList(ctx, Request interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) DescribeWorkflowExecution(ctx, DescribeRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) GetDomainReplicationMessages(ctx, Request interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) GetReplicationMessages(ctx, Request interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) GetSearchAttributes(ctx interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) GetWorkflowExecutionHistory(ctx, GetRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) ListArchivedWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) ListClosedWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) ListDomains(ctx, ListRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) ListOpenWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) ListWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) PollForActivityTask(ctx, PollRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) PollForDecisionTask(ctx, PollRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) QueryWorkflow(ctx, QueryRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) RecordActivityTaskHeartbeat(ctx, HeartbeatRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) RecordActivityTaskHeartbeatByID(ctx, HeartbeatRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) RegisterDomain(ctx, RegisterRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) RequestCancelWorkflowExecution(ctx, CancelRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) ResetStickyTaskList(ctx, ResetRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) ResetWorkflowExecution(ctx, ResetRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) RespondActivityTaskCanceled(ctx, CanceledRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) RespondActivityTaskCanceledByID(ctx, CanceledRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) RespondActivityTaskCompleted(ctx, CompleteRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) RespondActivityTaskCompletedByID(ctx, CompleteRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) RespondActivityTaskFailed(ctx, FailRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) RespondActivityTaskFailedByID(ctx, FailRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) RespondDecisionTaskCompleted(ctx, CompleteRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) RespondDecisionTaskFailed(ctx, FailedRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) RespondQueryTaskCompleted(ctx, CompleteRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) ScanWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) SignalWithStartWorkflowExecution(ctx, SignalWithStartRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) SignalWorkflowExecution(ctx, SignalRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) StartWorkflowExecution(ctx, StartRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) TerminateWorkflowExecution(ctx, TerminateRequest interface{}) *gomock.Call
- func (mr *MockWorkflowHandlerMockRecorder) UpdateDomain(ctx, UpdateRequest interface{}) *gomock.Call
- type NoopRedirectionPolicy
- type SelectedAPIsForwardingRedirectionPolicy
- func (policy *SelectedAPIsForwardingRedirectionPolicy) WithDomainIDRedirect(ctx context.Context, domainID string, apiName string, call func(string) error) error
- func (policy *SelectedAPIsForwardingRedirectionPolicy) WithDomainNameRedirect(ctx context.Context, domainName string, apiName string, ...) error
- type Service
- type WorkflowHandler
- func (wh *WorkflowHandler) CountWorkflowExecutions(ctx context.Context, countRequest *gen.CountWorkflowExecutionsRequest) (resp *gen.CountWorkflowExecutionsResponse, retError error)
- func (wh *WorkflowHandler) DeprecateDomain(ctx context.Context, deprecateRequest *gen.DeprecateDomainRequest) (retError error)
- func (wh *WorkflowHandler) DescribeDomain(ctx context.Context, describeRequest *gen.DescribeDomainRequest) (response *gen.DescribeDomainResponse, retError error)
- func (wh *WorkflowHandler) DescribeTaskList(ctx context.Context, request *gen.DescribeTaskListRequest) (resp *gen.DescribeTaskListResponse, retError error)
- func (wh *WorkflowHandler) DescribeWorkflowExecution(ctx context.Context, request *gen.DescribeWorkflowExecutionRequest) (resp *gen.DescribeWorkflowExecutionResponse, retError error)
- func (wh *WorkflowHandler) GetDomainReplicationMessages(ctx context.Context, request *replicator.GetDomainReplicationMessagesRequest) (resp *replicator.GetDomainReplicationMessagesResponse, err error)
- func (wh *WorkflowHandler) GetReplicationMessages(ctx context.Context, request *replicator.GetReplicationMessagesRequest) (resp *replicator.GetReplicationMessagesResponse, err error)
- func (wh *WorkflowHandler) GetSearchAttributes(ctx context.Context) (resp *gen.GetSearchAttributesResponse, retError error)
- func (wh *WorkflowHandler) GetWorkflowExecutionHistory(ctx context.Context, getRequest *gen.GetWorkflowExecutionHistoryRequest) (resp *gen.GetWorkflowExecutionHistoryResponse, retError error)
- func (wh *WorkflowHandler) Health(ctx context.Context) (*health.HealthStatus, error)
- func (wh *WorkflowHandler) ListArchivedWorkflowExecutions(ctx context.Context, listRequest *gen.ListArchivedWorkflowExecutionsRequest) (resp *gen.ListArchivedWorkflowExecutionsResponse, retError error)
- func (wh *WorkflowHandler) ListClosedWorkflowExecutions(ctx context.Context, listRequest *gen.ListClosedWorkflowExecutionsRequest) (resp *gen.ListClosedWorkflowExecutionsResponse, retError error)
- func (wh *WorkflowHandler) ListDomains(ctx context.Context, listRequest *gen.ListDomainsRequest) (response *gen.ListDomainsResponse, retError error)
- func (wh *WorkflowHandler) ListOpenWorkflowExecutions(ctx context.Context, listRequest *gen.ListOpenWorkflowExecutionsRequest) (resp *gen.ListOpenWorkflowExecutionsResponse, retError error)
- func (wh *WorkflowHandler) ListWorkflowExecutions(ctx context.Context, listRequest *gen.ListWorkflowExecutionsRequest) (resp *gen.ListWorkflowExecutionsResponse, retError error)
- func (wh *WorkflowHandler) PollForActivityTask(ctx context.Context, pollRequest *gen.PollForActivityTaskRequest) (resp *gen.PollForActivityTaskResponse, retError error)
- func (wh *WorkflowHandler) PollForDecisionTask(ctx context.Context, pollRequest *gen.PollForDecisionTaskRequest) (resp *gen.PollForDecisionTaskResponse, retError error)
- func (wh *WorkflowHandler) QueryWorkflow(ctx context.Context, queryRequest *gen.QueryWorkflowRequest) (resp *gen.QueryWorkflowResponse, retError error)
- func (wh *WorkflowHandler) ReapplyEvents(ctx context.Context, request *shared.ReapplyEventsRequest) (err error)
- func (wh *WorkflowHandler) RecordActivityTaskHeartbeat(ctx context.Context, heartbeatRequest *gen.RecordActivityTaskHeartbeatRequest) (resp *gen.RecordActivityTaskHeartbeatResponse, retError error)
- func (wh *WorkflowHandler) RecordActivityTaskHeartbeatByID(ctx context.Context, ...) (resp *gen.RecordActivityTaskHeartbeatResponse, retError error)
- func (wh *WorkflowHandler) RegisterDomain(ctx context.Context, registerRequest *gen.RegisterDomainRequest) (retError error)
- func (wh *WorkflowHandler) RegisterHandler()
- func (wh *WorkflowHandler) RequestCancelWorkflowExecution(ctx context.Context, cancelRequest *gen.RequestCancelWorkflowExecutionRequest) (retError error)
- func (wh *WorkflowHandler) ResetStickyTaskList(ctx context.Context, resetRequest *gen.ResetStickyTaskListRequest) (resp *gen.ResetStickyTaskListResponse, retError error)
- func (wh *WorkflowHandler) ResetWorkflowExecution(ctx context.Context, resetRequest *gen.ResetWorkflowExecutionRequest) (resp *gen.ResetWorkflowExecutionResponse, retError error)
- func (wh *WorkflowHandler) RespondActivityTaskCanceled(ctx context.Context, cancelRequest *gen.RespondActivityTaskCanceledRequest) (retError error)
- func (wh *WorkflowHandler) RespondActivityTaskCanceledByID(ctx context.Context, cancelRequest *gen.RespondActivityTaskCanceledByIDRequest) (retError error)
- func (wh *WorkflowHandler) RespondActivityTaskCompleted(ctx context.Context, completeRequest *gen.RespondActivityTaskCompletedRequest) (retError error)
- func (wh *WorkflowHandler) RespondActivityTaskCompletedByID(ctx context.Context, ...) (retError error)
- func (wh *WorkflowHandler) RespondActivityTaskFailed(ctx context.Context, failedRequest *gen.RespondActivityTaskFailedRequest) (retError error)
- func (wh *WorkflowHandler) RespondActivityTaskFailedByID(ctx context.Context, failedRequest *gen.RespondActivityTaskFailedByIDRequest) (retError error)
- func (wh *WorkflowHandler) RespondDecisionTaskCompleted(ctx context.Context, completeRequest *gen.RespondDecisionTaskCompletedRequest) (resp *gen.RespondDecisionTaskCompletedResponse, retError error)
- func (wh *WorkflowHandler) RespondDecisionTaskFailed(ctx context.Context, failedRequest *gen.RespondDecisionTaskFailedRequest) (retError error)
- func (wh *WorkflowHandler) RespondQueryTaskCompleted(ctx context.Context, completeRequest *gen.RespondQueryTaskCompletedRequest) (retError error)
- func (wh *WorkflowHandler) ScanWorkflowExecutions(ctx context.Context, listRequest *gen.ListWorkflowExecutionsRequest) (resp *gen.ListWorkflowExecutionsResponse, retError error)
- func (wh *WorkflowHandler) SignalWithStartWorkflowExecution(ctx context.Context, ...) (resp *gen.StartWorkflowExecutionResponse, retError error)
- func (wh *WorkflowHandler) SignalWorkflowExecution(ctx context.Context, signalRequest *gen.SignalWorkflowExecutionRequest) (retError error)
- func (wh *WorkflowHandler) Start() error
- func (wh *WorkflowHandler) StartWorkflowExecution(ctx context.Context, startRequest *gen.StartWorkflowExecutionRequest) (resp *gen.StartWorkflowExecutionResponse, retError error)
- func (wh *WorkflowHandler) Stop()
- func (wh *WorkflowHandler) TerminateWorkflowExecution(ctx context.Context, terminateRequest *gen.TerminateWorkflowExecutionRequest) (retError error)
- func (wh *WorkflowHandler) UpdateDomain(ctx context.Context, updateRequest *gen.UpdateDomainRequest) (resp *gen.UpdateDomainResponse, retError error)
Constants ¶
const ( // DCRedirectionPolicyDefault means no redirection DCRedirectionPolicyDefault = "" // DCRedirectionPolicyNoop means no redirection DCRedirectionPolicyNoop = "noop" // DCRedirectionPolicySelectedAPIsForwarding means forwarding the following APIs based domain // 1. StartWorkflowExecution // 2. SignalWithStartWorkflowExecution // 3. SignalWorkflowExecution // 4. RequestCancelWorkflowExecution // 5. TerminateWorkflowExecution // please also reference selectedAPIsForwardingRedirectionPolicyWhitelistedAPIs DCRedirectionPolicySelectedAPIsForwarding = "selected-apis-forwarding" )
Variables ¶
This section is empty.
Functions ¶
func NewService ¶
func NewService(params *service.BootstrapParams) common.Daemon
NewService builds a new cadence-frontend service
Types ¶
type AdminHandler ¶ added in v0.3.12
AdminHandler - Thrift handler interface for admin service
func NewAdminHandler ¶ added in v0.3.12
func NewAdminHandler( sVice service.Service, numberOfHistoryShards int, domainCache cache.DomainCache, historyV2Mgr persistence.HistoryManager, params *service.BootstrapParams, ) *AdminHandler
NewAdminHandler creates a thrift handler for the cadence admin service
func (*AdminHandler) AddSearchAttribute ¶ added in v0.6.0
func (adh *AdminHandler) AddSearchAttribute(ctx context.Context, request *admin.AddSearchAttributeRequest) error
AddSearchAttribute add search attribute to whitelist
func (*AdminHandler) CloseShard ¶ added in v0.9.0
func (adh *AdminHandler) CloseShard(ctx context.Context, request *gen.CloseShardRequest) (retError error)
CloseShard returns information about the internal states of a history host
func (*AdminHandler) DescribeHistoryHost ¶ added in v0.3.13
func (adh *AdminHandler) DescribeHistoryHost(ctx context.Context, request *gen.DescribeHistoryHostRequest) (resp *gen.DescribeHistoryHostResponse, retError error)
DescribeHistoryHost returns information about the internal states of a history host
func (*AdminHandler) DescribeWorkflowExecution ¶ added in v0.3.13
func (adh *AdminHandler) DescribeWorkflowExecution(ctx context.Context, request *admin.DescribeWorkflowExecutionRequest) (resp *admin.DescribeWorkflowExecutionResponse, retError error)
DescribeWorkflowExecution returns information about the specified workflow execution.
func (*AdminHandler) GetWorkflowExecutionRawHistory ¶ added in v0.5.0
func (adh *AdminHandler) GetWorkflowExecutionRawHistory( ctx context.Context, request *admin.GetWorkflowExecutionRawHistoryRequest, ) (resp *admin.GetWorkflowExecutionRawHistoryResponse, retError error)
GetWorkflowExecutionRawHistory - retrieves the history of workflow execution
func (*AdminHandler) GetWorkflowExecutionRawHistoryV2 ¶ added in v0.10.0
func (adh *AdminHandler) GetWorkflowExecutionRawHistoryV2( ctx context.Context, request *admin.GetWorkflowExecutionRawHistoryV2Request, ) (resp *admin.GetWorkflowExecutionRawHistoryV2Response, retError error)
GetWorkflowExecutionRawHistoryV2 - retrieves the history of workflow execution
func (*AdminHandler) RegisterHandler ¶ added in v0.5.8
func (adh *AdminHandler) RegisterHandler()
RegisterHandler register this handler, must be called before Start()
func (*AdminHandler) RemoveTask ¶ added in v0.9.0
func (adh *AdminHandler) RemoveTask(ctx context.Context, request *gen.RemoveTaskRequest) (retError error)
RemoveTask returns information about the internal states of a history host
func (*AdminHandler) Start ¶ added in v0.3.12
func (adh *AdminHandler) Start() error
Start starts the handler
type Config ¶ added in v0.3.0
type Config struct { NumHistoryShards int PersistenceMaxQPS dynamicconfig.IntPropertyFn VisibilityMaxPageSize dynamicconfig.IntPropertyFnWithDomainFilter EnableVisibilitySampling dynamicconfig.BoolPropertyFn EnableReadFromClosedExecutionV2 dynamicconfig.BoolPropertyFn VisibilityListMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter EnableReadVisibilityFromES dynamicconfig.BoolPropertyFnWithDomainFilter ESVisibilityListMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter ESIndexMaxResultWindow dynamicconfig.IntPropertyFn HistoryMaxPageSize dynamicconfig.IntPropertyFnWithDomainFilter RPS dynamicconfig.IntPropertyFn DomainRPS dynamicconfig.IntPropertyFnWithDomainFilter MaxIDLengthLimit dynamicconfig.IntPropertyFn EnableClientVersionCheck dynamicconfig.BoolPropertyFn MinRetentionDays dynamicconfig.IntPropertyFn DisallowQuery dynamicconfig.BoolPropertyFnWithDomainFilter EnablePollForMutableState dynamicconfig.BoolPropertyFn // Persistence settings HistoryMgrNumConns dynamicconfig.IntPropertyFn MaxBadBinaries dynamicconfig.IntPropertyFnWithDomainFilter // security protection settings EnableAdminProtection dynamicconfig.BoolPropertyFn AdminOperationToken dynamicconfig.StringPropertyFn DisableListVisibilityByFilter dynamicconfig.BoolPropertyFnWithDomainFilter // size limit system protection BlobSizeLimitError dynamicconfig.IntPropertyFnWithDomainFilter BlobSizeLimitWarn dynamicconfig.IntPropertyFnWithDomainFilter ThrottledLogRPS dynamicconfig.IntPropertyFn // Domain specific config EnableDomainNotActiveAutoForwarding dynamicconfig.BoolPropertyFnWithDomainFilter // ValidSearchAttributes is legal indexed keys that can be used in list APIs ValidSearchAttributes dynamicconfig.MapPropertyFn SearchAttributesNumberOfKeysLimit dynamicconfig.IntPropertyFnWithDomainFilter SearchAttributesSizeOfValueLimit dynamicconfig.IntPropertyFnWithDomainFilter SearchAttributesTotalSizeLimit dynamicconfig.IntPropertyFnWithDomainFilter }
Config represents configuration for cadence-frontend service
func NewConfig ¶ added in v0.3.0
func NewConfig(dc *dynamicconfig.Collection, numHistoryShards int, enableReadFromES bool) *Config
NewConfig returns new service config with default values
type DCRedirectionHandlerImpl ¶ added in v0.5.2
type DCRedirectionHandlerImpl struct {
// contains filtered or unexported fields
}
DCRedirectionHandlerImpl is simple wrapper over frontend service, doing redirection based on policy
func NewDCRedirectionHandler ¶ added in v0.5.2
func NewDCRedirectionHandler(wfHandler *WorkflowHandler, policy config.DCRedirectionPolicy) *DCRedirectionHandlerImpl
NewDCRedirectionHandler creates a thrift handler for the cadence service, frontend
func (*DCRedirectionHandlerImpl) CountWorkflowExecutions ¶ added in v0.5.8
func (handler *DCRedirectionHandlerImpl) CountWorkflowExecutions( ctx context.Context, request *shared.CountWorkflowExecutionsRequest, ) (resp *shared.CountWorkflowExecutionsResponse, retError error)
CountWorkflowExecutions API call
func (*DCRedirectionHandlerImpl) DeprecateDomain ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) DeprecateDomain( ctx context.Context, request *shared.DeprecateDomainRequest, ) (retError error)
DeprecateDomain API call
func (*DCRedirectionHandlerImpl) DescribeDomain ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) DescribeDomain( ctx context.Context, request *shared.DescribeDomainRequest, ) (resp *shared.DescribeDomainResponse, retError error)
DescribeDomain API call
func (*DCRedirectionHandlerImpl) DescribeTaskList ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) DescribeTaskList( ctx context.Context, request *shared.DescribeTaskListRequest, ) (resp *shared.DescribeTaskListResponse, retError error)
DescribeTaskList API call
func (*DCRedirectionHandlerImpl) DescribeWorkflowExecution ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) DescribeWorkflowExecution( ctx context.Context, request *shared.DescribeWorkflowExecutionRequest, ) (resp *shared.DescribeWorkflowExecutionResponse, retError error)
DescribeWorkflowExecution API call
func (*DCRedirectionHandlerImpl) GetDomainReplicationMessages ¶ added in v0.9.3
func (handler *DCRedirectionHandlerImpl) GetDomainReplicationMessages( ctx context.Context, request *replicator.GetDomainReplicationMessagesRequest, ) (*replicator.GetDomainReplicationMessagesResponse, error)
GetDomainReplicationMessages API call
func (*DCRedirectionHandlerImpl) GetReplicationMessages ¶ added in v0.9.0
func (handler *DCRedirectionHandlerImpl) GetReplicationMessages( ctx context.Context, request *replicator.GetReplicationMessagesRequest, ) (*replicator.GetReplicationMessagesResponse, error)
GetReplicationMessages API call
func (*DCRedirectionHandlerImpl) GetSearchAttributes ¶ added in v0.5.9
func (handler *DCRedirectionHandlerImpl) GetSearchAttributes( ctx context.Context, ) (resp *shared.GetSearchAttributesResponse, retError error)
GetSearchAttributes API call
func (*DCRedirectionHandlerImpl) GetWorkflowExecutionHistory ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) GetWorkflowExecutionHistory( ctx context.Context, request *shared.GetWorkflowExecutionHistoryRequest, ) (resp *shared.GetWorkflowExecutionHistoryResponse, retError error)
GetWorkflowExecutionHistory API call
func (*DCRedirectionHandlerImpl) Health ¶ added in v0.5.8
func (handler *DCRedirectionHandlerImpl) Health(ctx context.Context) (*health.HealthStatus, error)
Health is for health check
func (*DCRedirectionHandlerImpl) ListArchivedWorkflowExecutions ¶ added in v0.9.0
func (handler *DCRedirectionHandlerImpl) ListArchivedWorkflowExecutions( ctx context.Context, request *shared.ListArchivedWorkflowExecutionsRequest, ) (resp *shared.ListArchivedWorkflowExecutionsResponse, retError error)
ListArchivedWorkflowExecutions API call
func (*DCRedirectionHandlerImpl) ListClosedWorkflowExecutions ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) ListClosedWorkflowExecutions( ctx context.Context, request *shared.ListClosedWorkflowExecutionsRequest, ) (resp *shared.ListClosedWorkflowExecutionsResponse, retError error)
ListClosedWorkflowExecutions API call
func (*DCRedirectionHandlerImpl) ListDomains ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) ListDomains( ctx context.Context, request *shared.ListDomainsRequest, ) (resp *shared.ListDomainsResponse, retError error)
ListDomains API call
func (*DCRedirectionHandlerImpl) ListOpenWorkflowExecutions ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) ListOpenWorkflowExecutions( ctx context.Context, request *shared.ListOpenWorkflowExecutionsRequest, ) (resp *shared.ListOpenWorkflowExecutionsResponse, retError error)
ListOpenWorkflowExecutions API call
func (*DCRedirectionHandlerImpl) ListWorkflowExecutions ¶ added in v0.5.7
func (handler *DCRedirectionHandlerImpl) ListWorkflowExecutions( ctx context.Context, request *shared.ListWorkflowExecutionsRequest, ) (resp *shared.ListWorkflowExecutionsResponse, retError error)
ListWorkflowExecutions API call
func (*DCRedirectionHandlerImpl) PollForActivityTask ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) PollForActivityTask( ctx context.Context, request *shared.PollForActivityTaskRequest, ) (resp *shared.PollForActivityTaskResponse, retError error)
PollForActivityTask API call
func (*DCRedirectionHandlerImpl) PollForDecisionTask ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) PollForDecisionTask( ctx context.Context, request *shared.PollForDecisionTaskRequest, ) (resp *shared.PollForDecisionTaskResponse, retError error)
PollForDecisionTask API call
func (*DCRedirectionHandlerImpl) QueryWorkflow ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) QueryWorkflow( ctx context.Context, request *shared.QueryWorkflowRequest, ) (resp *shared.QueryWorkflowResponse, retError error)
QueryWorkflow API call
func (*DCRedirectionHandlerImpl) ReapplyEvents ¶ added in v0.9.3
func (handler *DCRedirectionHandlerImpl) ReapplyEvents( ctx context.Context, request *shared.ReapplyEventsRequest, ) error
ReapplyEvents API call
func (*DCRedirectionHandlerImpl) RecordActivityTaskHeartbeat ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) RecordActivityTaskHeartbeat( ctx context.Context, request *shared.RecordActivityTaskHeartbeatRequest, ) (resp *shared.RecordActivityTaskHeartbeatResponse, retError error)
RecordActivityTaskHeartbeat API call
func (*DCRedirectionHandlerImpl) RecordActivityTaskHeartbeatByID ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) RecordActivityTaskHeartbeatByID( ctx context.Context, request *shared.RecordActivityTaskHeartbeatByIDRequest, ) (resp *shared.RecordActivityTaskHeartbeatResponse, retError error)
RecordActivityTaskHeartbeatByID API call
func (*DCRedirectionHandlerImpl) RegisterDomain ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) RegisterDomain( ctx context.Context, request *shared.RegisterDomainRequest, ) (retError error)
RegisterDomain API call
func (*DCRedirectionHandlerImpl) RegisterHandler ¶ added in v0.5.8
func (handler *DCRedirectionHandlerImpl) RegisterHandler()
RegisterHandler register this handler, must be called before Start()
func (*DCRedirectionHandlerImpl) RequestCancelWorkflowExecution ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) RequestCancelWorkflowExecution( ctx context.Context, request *shared.RequestCancelWorkflowExecutionRequest, ) (retError error)
RequestCancelWorkflowExecution API call
func (*DCRedirectionHandlerImpl) ResetStickyTaskList ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) ResetStickyTaskList( ctx context.Context, request *shared.ResetStickyTaskListRequest, ) (resp *shared.ResetStickyTaskListResponse, retError error)
ResetStickyTaskList API call
func (*DCRedirectionHandlerImpl) ResetWorkflowExecution ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) ResetWorkflowExecution( ctx context.Context, request *shared.ResetWorkflowExecutionRequest, ) (resp *shared.ResetWorkflowExecutionResponse, retError error)
ResetWorkflowExecution API call
func (*DCRedirectionHandlerImpl) RespondActivityTaskCanceled ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) RespondActivityTaskCanceled( ctx context.Context, request *shared.RespondActivityTaskCanceledRequest, ) (retError error)
RespondActivityTaskCanceled API call
func (*DCRedirectionHandlerImpl) RespondActivityTaskCanceledByID ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) RespondActivityTaskCanceledByID( ctx context.Context, request *shared.RespondActivityTaskCanceledByIDRequest, ) (retError error)
RespondActivityTaskCanceledByID API call
func (*DCRedirectionHandlerImpl) RespondActivityTaskCompleted ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) RespondActivityTaskCompleted( ctx context.Context, request *shared.RespondActivityTaskCompletedRequest, ) (retError error)
RespondActivityTaskCompleted API call
func (*DCRedirectionHandlerImpl) RespondActivityTaskCompletedByID ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) RespondActivityTaskCompletedByID( ctx context.Context, request *shared.RespondActivityTaskCompletedByIDRequest, ) (retError error)
RespondActivityTaskCompletedByID API call
func (*DCRedirectionHandlerImpl) RespondActivityTaskFailed ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) RespondActivityTaskFailed( ctx context.Context, request *shared.RespondActivityTaskFailedRequest, ) (retError error)
RespondActivityTaskFailed API call
func (*DCRedirectionHandlerImpl) RespondActivityTaskFailedByID ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) RespondActivityTaskFailedByID( ctx context.Context, request *shared.RespondActivityTaskFailedByIDRequest, ) (retError error)
RespondActivityTaskFailedByID API call
func (*DCRedirectionHandlerImpl) RespondDecisionTaskCompleted ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) RespondDecisionTaskCompleted( ctx context.Context, request *shared.RespondDecisionTaskCompletedRequest, ) (resp *shared.RespondDecisionTaskCompletedResponse, retError error)
RespondDecisionTaskCompleted API call
func (*DCRedirectionHandlerImpl) RespondDecisionTaskFailed ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) RespondDecisionTaskFailed( ctx context.Context, request *shared.RespondDecisionTaskFailedRequest, ) (retError error)
RespondDecisionTaskFailed API call
func (*DCRedirectionHandlerImpl) RespondQueryTaskCompleted ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) RespondQueryTaskCompleted( ctx context.Context, request *shared.RespondQueryTaskCompletedRequest, ) (retError error)
RespondQueryTaskCompleted API call
func (*DCRedirectionHandlerImpl) ScanWorkflowExecutions ¶ added in v0.5.8
func (handler *DCRedirectionHandlerImpl) ScanWorkflowExecutions( ctx context.Context, request *shared.ListWorkflowExecutionsRequest, ) (resp *shared.ListWorkflowExecutionsResponse, retError error)
ScanWorkflowExecutions API call
func (*DCRedirectionHandlerImpl) SignalWithStartWorkflowExecution ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) SignalWithStartWorkflowExecution( ctx context.Context, request *shared.SignalWithStartWorkflowExecutionRequest, ) (resp *shared.StartWorkflowExecutionResponse, retError error)
SignalWithStartWorkflowExecution API call
func (*DCRedirectionHandlerImpl) SignalWorkflowExecution ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) SignalWorkflowExecution( ctx context.Context, request *shared.SignalWorkflowExecutionRequest, ) (retError error)
SignalWorkflowExecution API call
func (*DCRedirectionHandlerImpl) Start ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) Start() error
Start starts the handler
func (*DCRedirectionHandlerImpl) StartWorkflowExecution ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) StartWorkflowExecution( ctx context.Context, request *shared.StartWorkflowExecutionRequest, ) (resp *shared.StartWorkflowExecutionResponse, retError error)
StartWorkflowExecution API call
func (*DCRedirectionHandlerImpl) Stop ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) Stop()
Stop stops the handler
func (*DCRedirectionHandlerImpl) TerminateWorkflowExecution ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) TerminateWorkflowExecution( ctx context.Context, request *shared.TerminateWorkflowExecutionRequest, ) (retError error)
TerminateWorkflowExecution API call
func (*DCRedirectionHandlerImpl) UpdateDomain ¶ added in v0.5.2
func (handler *DCRedirectionHandlerImpl) UpdateDomain( ctx context.Context, request *shared.UpdateDomainRequest, ) (resp *shared.UpdateDomainResponse, retError error)
UpdateDomain API call
type DCRedirectionPolicy ¶ added in v0.5.2
type DCRedirectionPolicy interface { WithDomainIDRedirect(ctx context.Context, domainID string, apiName string, call func(string) error) error WithDomainNameRedirect(ctx context.Context, domainName string, apiName string, call func(string) error) error }
DCRedirectionPolicy is a DC redirection policy interface
func RedirectionPolicyGenerator ¶ added in v0.5.2
func RedirectionPolicyGenerator(clusterMetadata cluster.Metadata, config *Config, domainCache cache.DomainCache, policy config.DCRedirectionPolicy) DCRedirectionPolicy
RedirectionPolicyGenerator generate corresponding redirection policy
type MockDCRedirectionPolicy ¶ added in v0.5.9
MockDCRedirectionPolicy is an autogenerated mock type for the DCRedirectionPolicy type
func (*MockDCRedirectionPolicy) WithDomainIDRedirect ¶ added in v0.5.9
func (_m *MockDCRedirectionPolicy) WithDomainIDRedirect(ctx context.Context, domainID string, apiName string, call func(string) error) error
WithDomainIDRedirect provides a mock function with given fields: domainID, apiName, call
func (*MockDCRedirectionPolicy) WithDomainNameRedirect ¶ added in v0.5.9
func (_m *MockDCRedirectionPolicy) WithDomainNameRedirect(ctx context.Context, domainName string, apiName string, call func(string) error) error
WithDomainNameRedirect provides a mock function with given fields: domainName, apiName, call
type MockWorkflowHandler ¶ added in v0.5.9
type MockWorkflowHandler struct {
// contains filtered or unexported fields
}
MockWorkflowHandler is a mock of Interface interface
func NewMockWorkflowHandler ¶ added in v0.9.0
func NewMockWorkflowHandler(ctrl *gomock.Controller) *MockWorkflowHandler
NewMockWorkflowHandler creates a new mock instance
func (*MockWorkflowHandler) CountWorkflowExecutions ¶ added in v0.5.9
func (m *MockWorkflowHandler) CountWorkflowExecutions(ctx context.Context, CountRequest *shared.CountWorkflowExecutionsRequest) (*shared.CountWorkflowExecutionsResponse, error)
CountWorkflowExecutions mocks base method
func (*MockWorkflowHandler) DeprecateDomain ¶ added in v0.5.9
func (m *MockWorkflowHandler) DeprecateDomain(ctx context.Context, DeprecateRequest *shared.DeprecateDomainRequest) error
DeprecateDomain mocks base method
func (*MockWorkflowHandler) DescribeDomain ¶ added in v0.5.9
func (m *MockWorkflowHandler) DescribeDomain(ctx context.Context, DescribeRequest *shared.DescribeDomainRequest) (*shared.DescribeDomainResponse, error)
DescribeDomain mocks base method
func (*MockWorkflowHandler) DescribeTaskList ¶ added in v0.5.9
func (m *MockWorkflowHandler) DescribeTaskList(ctx context.Context, Request *shared.DescribeTaskListRequest) (*shared.DescribeTaskListResponse, error)
DescribeTaskList mocks base method
func (*MockWorkflowHandler) DescribeWorkflowExecution ¶ added in v0.5.9
func (m *MockWorkflowHandler) DescribeWorkflowExecution(ctx context.Context, DescribeRequest *shared.DescribeWorkflowExecutionRequest) (*shared.DescribeWorkflowExecutionResponse, error)
DescribeWorkflowExecution mocks base method
func (*MockWorkflowHandler) EXPECT ¶ added in v0.9.0
func (m *MockWorkflowHandler) EXPECT() *MockWorkflowHandlerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockWorkflowHandler) GetDomainReplicationMessages ¶ added in v0.9.3
func (m *MockWorkflowHandler) GetDomainReplicationMessages(ctx context.Context, Request *replicator.GetDomainReplicationMessagesRequest) (*replicator.GetDomainReplicationMessagesResponse, error)
GetDomainReplicationMessages mocks base method
func (*MockWorkflowHandler) GetReplicationMessages ¶ added in v0.9.0
func (m *MockWorkflowHandler) GetReplicationMessages(ctx context.Context, Request *replicator.GetReplicationMessagesRequest) (*replicator.GetReplicationMessagesResponse, error)
GetReplicationMessages mocks base method
func (*MockWorkflowHandler) GetSearchAttributes ¶ added in v0.5.9
func (m *MockWorkflowHandler) GetSearchAttributes(ctx context.Context) (*shared.GetSearchAttributesResponse, error)
GetSearchAttributes mocks base method
func (*MockWorkflowHandler) GetWorkflowExecutionHistory ¶ added in v0.5.9
func (m *MockWorkflowHandler) GetWorkflowExecutionHistory(ctx context.Context, GetRequest *shared.GetWorkflowExecutionHistoryRequest) (*shared.GetWorkflowExecutionHistoryResponse, error)
GetWorkflowExecutionHistory mocks base method
func (*MockWorkflowHandler) ListArchivedWorkflowExecutions ¶ added in v0.9.0
func (m *MockWorkflowHandler) ListArchivedWorkflowExecutions(ctx context.Context, ListRequest *shared.ListArchivedWorkflowExecutionsRequest) (*shared.ListArchivedWorkflowExecutionsResponse, error)
ListArchivedWorkflowExecutions mocks base method
func (*MockWorkflowHandler) ListClosedWorkflowExecutions ¶ added in v0.5.9
func (m *MockWorkflowHandler) ListClosedWorkflowExecutions(ctx context.Context, ListRequest *shared.ListClosedWorkflowExecutionsRequest) (*shared.ListClosedWorkflowExecutionsResponse, error)
ListClosedWorkflowExecutions mocks base method
func (*MockWorkflowHandler) ListDomains ¶ added in v0.5.9
func (m *MockWorkflowHandler) ListDomains(ctx context.Context, ListRequest *shared.ListDomainsRequest) (*shared.ListDomainsResponse, error)
ListDomains mocks base method
func (*MockWorkflowHandler) ListOpenWorkflowExecutions ¶ added in v0.5.9
func (m *MockWorkflowHandler) ListOpenWorkflowExecutions(ctx context.Context, ListRequest *shared.ListOpenWorkflowExecutionsRequest) (*shared.ListOpenWorkflowExecutionsResponse, error)
ListOpenWorkflowExecutions mocks base method
func (*MockWorkflowHandler) ListWorkflowExecutions ¶ added in v0.5.9
func (m *MockWorkflowHandler) ListWorkflowExecutions(ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, error)
ListWorkflowExecutions mocks base method
func (*MockWorkflowHandler) PollForActivityTask ¶ added in v0.5.9
func (m *MockWorkflowHandler) PollForActivityTask(ctx context.Context, PollRequest *shared.PollForActivityTaskRequest) (*shared.PollForActivityTaskResponse, error)
PollForActivityTask mocks base method
func (*MockWorkflowHandler) PollForDecisionTask ¶ added in v0.5.9
func (m *MockWorkflowHandler) PollForDecisionTask(ctx context.Context, PollRequest *shared.PollForDecisionTaskRequest) (*shared.PollForDecisionTaskResponse, error)
PollForDecisionTask mocks base method
func (*MockWorkflowHandler) QueryWorkflow ¶ added in v0.5.9
func (m *MockWorkflowHandler) QueryWorkflow(ctx context.Context, QueryRequest *shared.QueryWorkflowRequest) (*shared.QueryWorkflowResponse, error)
QueryWorkflow mocks base method
func (*MockWorkflowHandler) ReapplyEvents ¶ added in v0.9.3
func (m *MockWorkflowHandler) ReapplyEvents(ctx context.Context, ReapplyEventsRequest *shared.ReapplyEventsRequest) error
UpdateDomain mocks base method
func (*MockWorkflowHandler) RecordActivityTaskHeartbeat ¶ added in v0.5.9
func (m *MockWorkflowHandler) RecordActivityTaskHeartbeat(ctx context.Context, HeartbeatRequest *shared.RecordActivityTaskHeartbeatRequest) (*shared.RecordActivityTaskHeartbeatResponse, error)
RecordActivityTaskHeartbeat mocks base method
func (*MockWorkflowHandler) RecordActivityTaskHeartbeatByID ¶ added in v0.5.9
func (m *MockWorkflowHandler) RecordActivityTaskHeartbeatByID(ctx context.Context, HeartbeatRequest *shared.RecordActivityTaskHeartbeatByIDRequest) (*shared.RecordActivityTaskHeartbeatResponse, error)
RecordActivityTaskHeartbeatByID mocks base method
func (*MockWorkflowHandler) RegisterDomain ¶ added in v0.5.9
func (m *MockWorkflowHandler) RegisterDomain(ctx context.Context, RegisterRequest *shared.RegisterDomainRequest) error
RegisterDomain mocks base method
func (*MockWorkflowHandler) RequestCancelWorkflowExecution ¶ added in v0.5.9
func (m *MockWorkflowHandler) RequestCancelWorkflowExecution(ctx context.Context, CancelRequest *shared.RequestCancelWorkflowExecutionRequest) error
RequestCancelWorkflowExecution mocks base method
func (*MockWorkflowHandler) ResetStickyTaskList ¶ added in v0.5.9
func (m *MockWorkflowHandler) ResetStickyTaskList(ctx context.Context, ResetRequest *shared.ResetStickyTaskListRequest) (*shared.ResetStickyTaskListResponse, error)
ResetStickyTaskList mocks base method
func (*MockWorkflowHandler) ResetWorkflowExecution ¶ added in v0.5.9
func (m *MockWorkflowHandler) ResetWorkflowExecution(ctx context.Context, ResetRequest *shared.ResetWorkflowExecutionRequest) (*shared.ResetWorkflowExecutionResponse, error)
ResetWorkflowExecution mocks base method
func (*MockWorkflowHandler) RespondActivityTaskCanceled ¶ added in v0.5.9
func (m *MockWorkflowHandler) RespondActivityTaskCanceled(ctx context.Context, CanceledRequest *shared.RespondActivityTaskCanceledRequest) error
RespondActivityTaskCanceled mocks base method
func (*MockWorkflowHandler) RespondActivityTaskCanceledByID ¶ added in v0.5.9
func (m *MockWorkflowHandler) RespondActivityTaskCanceledByID(ctx context.Context, CanceledRequest *shared.RespondActivityTaskCanceledByIDRequest) error
RespondActivityTaskCanceledByID mocks base method
func (*MockWorkflowHandler) RespondActivityTaskCompleted ¶ added in v0.5.9
func (m *MockWorkflowHandler) RespondActivityTaskCompleted(ctx context.Context, CompleteRequest *shared.RespondActivityTaskCompletedRequest) error
RespondActivityTaskCompleted mocks base method
func (*MockWorkflowHandler) RespondActivityTaskCompletedByID ¶ added in v0.5.9
func (m *MockWorkflowHandler) RespondActivityTaskCompletedByID(ctx context.Context, CompleteRequest *shared.RespondActivityTaskCompletedByIDRequest) error
RespondActivityTaskCompletedByID mocks base method
func (*MockWorkflowHandler) RespondActivityTaskFailed ¶ added in v0.5.9
func (m *MockWorkflowHandler) RespondActivityTaskFailed(ctx context.Context, FailRequest *shared.RespondActivityTaskFailedRequest) error
RespondActivityTaskFailed mocks base method
func (*MockWorkflowHandler) RespondActivityTaskFailedByID ¶ added in v0.5.9
func (m *MockWorkflowHandler) RespondActivityTaskFailedByID(ctx context.Context, FailRequest *shared.RespondActivityTaskFailedByIDRequest) error
RespondActivityTaskFailedByID mocks base method
func (*MockWorkflowHandler) RespondDecisionTaskCompleted ¶ added in v0.5.9
func (m *MockWorkflowHandler) RespondDecisionTaskCompleted(ctx context.Context, CompleteRequest *shared.RespondDecisionTaskCompletedRequest) (*shared.RespondDecisionTaskCompletedResponse, error)
RespondDecisionTaskCompleted mocks base method
func (*MockWorkflowHandler) RespondDecisionTaskFailed ¶ added in v0.5.9
func (m *MockWorkflowHandler) RespondDecisionTaskFailed(ctx context.Context, FailedRequest *shared.RespondDecisionTaskFailedRequest) error
RespondDecisionTaskFailed mocks base method
func (*MockWorkflowHandler) RespondQueryTaskCompleted ¶ added in v0.5.9
func (m *MockWorkflowHandler) RespondQueryTaskCompleted(ctx context.Context, CompleteRequest *shared.RespondQueryTaskCompletedRequest) error
RespondQueryTaskCompleted mocks base method
func (*MockWorkflowHandler) ScanWorkflowExecutions ¶ added in v0.5.9
func (m *MockWorkflowHandler) ScanWorkflowExecutions(ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, error)
ScanWorkflowExecutions mocks base method
func (*MockWorkflowHandler) SignalWithStartWorkflowExecution ¶ added in v0.5.9
func (m *MockWorkflowHandler) SignalWithStartWorkflowExecution(ctx context.Context, SignalWithStartRequest *shared.SignalWithStartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)
SignalWithStartWorkflowExecution mocks base method
func (*MockWorkflowHandler) SignalWorkflowExecution ¶ added in v0.5.9
func (m *MockWorkflowHandler) SignalWorkflowExecution(ctx context.Context, SignalRequest *shared.SignalWorkflowExecutionRequest) error
SignalWorkflowExecution mocks base method
func (*MockWorkflowHandler) StartWorkflowExecution ¶ added in v0.5.9
func (m *MockWorkflowHandler) StartWorkflowExecution(ctx context.Context, StartRequest *shared.StartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)
StartWorkflowExecution mocks base method
func (*MockWorkflowHandler) TerminateWorkflowExecution ¶ added in v0.5.9
func (m *MockWorkflowHandler) TerminateWorkflowExecution(ctx context.Context, TerminateRequest *shared.TerminateWorkflowExecutionRequest) error
TerminateWorkflowExecution mocks base method
func (*MockWorkflowHandler) UpdateDomain ¶ added in v0.5.9
func (m *MockWorkflowHandler) UpdateDomain(ctx context.Context, UpdateRequest *shared.UpdateDomainRequest) (*shared.UpdateDomainResponse, error)
UpdateDomain mocks base method
type MockWorkflowHandlerMockRecorder ¶ added in v0.9.0
type MockWorkflowHandlerMockRecorder struct {
// contains filtered or unexported fields
}
MockWorkflowHandlerMockRecorder is the mock recorder for MockWorkflowHandler
func (*MockWorkflowHandlerMockRecorder) CountWorkflowExecutions ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) CountWorkflowExecutions(ctx, CountRequest interface{}) *gomock.Call
CountWorkflowExecutions indicates an expected call of CountWorkflowExecutions
func (*MockWorkflowHandlerMockRecorder) DeprecateDomain ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) DeprecateDomain(ctx, DeprecateRequest interface{}) *gomock.Call
DeprecateDomain indicates an expected call of DeprecateDomain
func (*MockWorkflowHandlerMockRecorder) DescribeDomain ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) DescribeDomain(ctx, DescribeRequest interface{}) *gomock.Call
DescribeDomain indicates an expected call of DescribeDomain
func (*MockWorkflowHandlerMockRecorder) DescribeTaskList ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) DescribeTaskList(ctx, Request interface{}) *gomock.Call
DescribeTaskList indicates an expected call of DescribeTaskList
func (*MockWorkflowHandlerMockRecorder) DescribeWorkflowExecution ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) DescribeWorkflowExecution(ctx, DescribeRequest interface{}) *gomock.Call
DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution
func (*MockWorkflowHandlerMockRecorder) GetDomainReplicationMessages ¶ added in v0.9.3
func (mr *MockWorkflowHandlerMockRecorder) GetDomainReplicationMessages(ctx, Request interface{}) *gomock.Call
GetDomainReplicationMessages indicates an expected call of GetDomainReplicationMessages
func (*MockWorkflowHandlerMockRecorder) GetReplicationMessages ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) GetReplicationMessages(ctx, Request interface{}) *gomock.Call
GetReplicationMessages indicates an expected call of GetReplicationMessages
func (*MockWorkflowHandlerMockRecorder) GetSearchAttributes ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) GetSearchAttributes(ctx interface{}) *gomock.Call
GetSearchAttributes indicates an expected call of GetSearchAttributes
func (*MockWorkflowHandlerMockRecorder) GetWorkflowExecutionHistory ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) GetWorkflowExecutionHistory(ctx, GetRequest interface{}) *gomock.Call
GetWorkflowExecutionHistory indicates an expected call of GetWorkflowExecutionHistory
func (*MockWorkflowHandlerMockRecorder) ListArchivedWorkflowExecutions ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) ListArchivedWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
ListArchivedWorkflowExecutions indicates an expected call of ListArchivedWorkflowExecutions
func (*MockWorkflowHandlerMockRecorder) ListClosedWorkflowExecutions ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) ListClosedWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
ListClosedWorkflowExecutions indicates an expected call of ListClosedWorkflowExecutions
func (*MockWorkflowHandlerMockRecorder) ListDomains ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) ListDomains(ctx, ListRequest interface{}) *gomock.Call
ListDomains indicates an expected call of ListDomains
func (*MockWorkflowHandlerMockRecorder) ListOpenWorkflowExecutions ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) ListOpenWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
ListOpenWorkflowExecutions indicates an expected call of ListOpenWorkflowExecutions
func (*MockWorkflowHandlerMockRecorder) ListWorkflowExecutions ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) ListWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
ListWorkflowExecutions indicates an expected call of ListWorkflowExecutions
func (*MockWorkflowHandlerMockRecorder) PollForActivityTask ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) PollForActivityTask(ctx, PollRequest interface{}) *gomock.Call
PollForActivityTask indicates an expected call of PollForActivityTask
func (*MockWorkflowHandlerMockRecorder) PollForDecisionTask ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) PollForDecisionTask(ctx, PollRequest interface{}) *gomock.Call
PollForDecisionTask indicates an expected call of PollForDecisionTask
func (*MockWorkflowHandlerMockRecorder) QueryWorkflow ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) QueryWorkflow(ctx, QueryRequest interface{}) *gomock.Call
QueryWorkflow indicates an expected call of QueryWorkflow
func (*MockWorkflowHandlerMockRecorder) RecordActivityTaskHeartbeat ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) RecordActivityTaskHeartbeat(ctx, HeartbeatRequest interface{}) *gomock.Call
RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat
func (*MockWorkflowHandlerMockRecorder) RecordActivityTaskHeartbeatByID ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) RecordActivityTaskHeartbeatByID(ctx, HeartbeatRequest interface{}) *gomock.Call
RecordActivityTaskHeartbeatByID indicates an expected call of RecordActivityTaskHeartbeatByID
func (*MockWorkflowHandlerMockRecorder) RegisterDomain ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) RegisterDomain(ctx, RegisterRequest interface{}) *gomock.Call
RegisterDomain indicates an expected call of RegisterDomain
func (*MockWorkflowHandlerMockRecorder) RequestCancelWorkflowExecution ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) RequestCancelWorkflowExecution(ctx, CancelRequest interface{}) *gomock.Call
RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution
func (*MockWorkflowHandlerMockRecorder) ResetStickyTaskList ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) ResetStickyTaskList(ctx, ResetRequest interface{}) *gomock.Call
ResetStickyTaskList indicates an expected call of ResetStickyTaskList
func (*MockWorkflowHandlerMockRecorder) ResetWorkflowExecution ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) ResetWorkflowExecution(ctx, ResetRequest interface{}) *gomock.Call
ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution
func (*MockWorkflowHandlerMockRecorder) RespondActivityTaskCanceled ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) RespondActivityTaskCanceled(ctx, CanceledRequest interface{}) *gomock.Call
RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled
func (*MockWorkflowHandlerMockRecorder) RespondActivityTaskCanceledByID ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) RespondActivityTaskCanceledByID(ctx, CanceledRequest interface{}) *gomock.Call
RespondActivityTaskCanceledByID indicates an expected call of RespondActivityTaskCanceledByID
func (*MockWorkflowHandlerMockRecorder) RespondActivityTaskCompleted ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) RespondActivityTaskCompleted(ctx, CompleteRequest interface{}) *gomock.Call
RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted
func (*MockWorkflowHandlerMockRecorder) RespondActivityTaskCompletedByID ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) RespondActivityTaskCompletedByID(ctx, CompleteRequest interface{}) *gomock.Call
RespondActivityTaskCompletedByID indicates an expected call of RespondActivityTaskCompletedByID
func (*MockWorkflowHandlerMockRecorder) RespondActivityTaskFailed ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) RespondActivityTaskFailed(ctx, FailRequest interface{}) *gomock.Call
RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed
func (*MockWorkflowHandlerMockRecorder) RespondActivityTaskFailedByID ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) RespondActivityTaskFailedByID(ctx, FailRequest interface{}) *gomock.Call
RespondActivityTaskFailedByID indicates an expected call of RespondActivityTaskFailedByID
func (*MockWorkflowHandlerMockRecorder) RespondDecisionTaskCompleted ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) RespondDecisionTaskCompleted(ctx, CompleteRequest interface{}) *gomock.Call
RespondDecisionTaskCompleted indicates an expected call of RespondDecisionTaskCompleted
func (*MockWorkflowHandlerMockRecorder) RespondDecisionTaskFailed ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) RespondDecisionTaskFailed(ctx, FailedRequest interface{}) *gomock.Call
RespondDecisionTaskFailed indicates an expected call of RespondDecisionTaskFailed
func (*MockWorkflowHandlerMockRecorder) RespondQueryTaskCompleted ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) RespondQueryTaskCompleted(ctx, CompleteRequest interface{}) *gomock.Call
RespondQueryTaskCompleted indicates an expected call of RespondQueryTaskCompleted
func (*MockWorkflowHandlerMockRecorder) ScanWorkflowExecutions ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) ScanWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
ScanWorkflowExecutions indicates an expected call of ScanWorkflowExecutions
func (*MockWorkflowHandlerMockRecorder) SignalWithStartWorkflowExecution ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) SignalWithStartWorkflowExecution(ctx, SignalWithStartRequest interface{}) *gomock.Call
SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution
func (*MockWorkflowHandlerMockRecorder) SignalWorkflowExecution ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) SignalWorkflowExecution(ctx, SignalRequest interface{}) *gomock.Call
SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution
func (*MockWorkflowHandlerMockRecorder) StartWorkflowExecution ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) StartWorkflowExecution(ctx, StartRequest interface{}) *gomock.Call
StartWorkflowExecution indicates an expected call of StartWorkflowExecution
func (*MockWorkflowHandlerMockRecorder) TerminateWorkflowExecution ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) TerminateWorkflowExecution(ctx, TerminateRequest interface{}) *gomock.Call
TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution
func (*MockWorkflowHandlerMockRecorder) UpdateDomain ¶ added in v0.9.0
func (mr *MockWorkflowHandlerMockRecorder) UpdateDomain(ctx, UpdateRequest interface{}) *gomock.Call
UpdateDomain indicates an expected call of UpdateDomain
type NoopRedirectionPolicy ¶ added in v0.5.2
type NoopRedirectionPolicy struct {
// contains filtered or unexported fields
}
NoopRedirectionPolicy is DC redirection policy which does nothing
func NewNoopRedirectionPolicy ¶ added in v0.5.2
func NewNoopRedirectionPolicy(currentClusterName string) *NoopRedirectionPolicy
NewNoopRedirectionPolicy is DC redirection policy which does nothing
func (*NoopRedirectionPolicy) WithDomainIDRedirect ¶ added in v0.5.9
func (policy *NoopRedirectionPolicy) WithDomainIDRedirect(ctx context.Context, domainID string, apiName string, call func(string) error) error
WithDomainIDRedirect redirect the API call based on domain ID
func (*NoopRedirectionPolicy) WithDomainNameRedirect ¶ added in v0.5.9
func (policy *NoopRedirectionPolicy) WithDomainNameRedirect(ctx context.Context, domainName string, apiName string, call func(string) error) error
WithDomainNameRedirect redirect the API call based on domain name
type SelectedAPIsForwardingRedirectionPolicy ¶ added in v0.5.9
type SelectedAPIsForwardingRedirectionPolicy struct {
// contains filtered or unexported fields
}
SelectedAPIsForwardingRedirectionPolicy is a DC redirection policy which (based on domain) forwards selected APIs calls to active cluster
func NewSelectedAPIsForwardingPolicy ¶ added in v0.5.9
func NewSelectedAPIsForwardingPolicy(currentClusterName string, config *Config, domainCache cache.DomainCache) *SelectedAPIsForwardingRedirectionPolicy
NewSelectedAPIsForwardingPolicy creates a forwarding policy for selected APIs based on domain
func (*SelectedAPIsForwardingRedirectionPolicy) WithDomainIDRedirect ¶ added in v0.5.9
func (policy *SelectedAPIsForwardingRedirectionPolicy) WithDomainIDRedirect(ctx context.Context, domainID string, apiName string, call func(string) error) error
WithDomainIDRedirect redirect the API call based on domain ID
func (*SelectedAPIsForwardingRedirectionPolicy) WithDomainNameRedirect ¶ added in v0.5.9
func (policy *SelectedAPIsForwardingRedirectionPolicy) WithDomainNameRedirect(ctx context.Context, domainName string, apiName string, call func(string) error) error
WithDomainNameRedirect redirect the API call based on domain name
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service represents the cadence-frontend service
type WorkflowHandler ¶
WorkflowHandler - Thrift handler interface for workflow service
func NewWorkflowHandler ¶
func NewWorkflowHandler( sVice service.Service, config *Config, metadataMgr persistence.MetadataManager, historyV2Mgr persistence.HistoryManager, visibilityMgr persistence.VisibilityManager, replicationMessageSink messaging.Producer, domainReplicationQueue persistence.DomainReplicationQueue, domainCache cache.DomainCache, ) *WorkflowHandler
NewWorkflowHandler creates a thrift handler for the cadence service
func (*WorkflowHandler) CountWorkflowExecutions ¶ added in v0.5.8
func (wh *WorkflowHandler) CountWorkflowExecutions( ctx context.Context, countRequest *gen.CountWorkflowExecutionsRequest, ) (resp *gen.CountWorkflowExecutionsResponse, retError error)
CountWorkflowExecutions - count number of workflow executions in a domain
func (*WorkflowHandler) DeprecateDomain ¶
func (wh *WorkflowHandler) DeprecateDomain(ctx context.Context, deprecateRequest *gen.DeprecateDomainRequest) (retError error)
DeprecateDomain us used to update status of a registered domain to DEPRECATED. Once the domain is deprecated it cannot be used to start new workflow executions. Existing workflow executions will continue to run on deprecated domains.
func (*WorkflowHandler) DescribeDomain ¶
func (wh *WorkflowHandler) DescribeDomain( ctx context.Context, describeRequest *gen.DescribeDomainRequest, ) (response *gen.DescribeDomainResponse, retError error)
DescribeDomain returns the information and configuration for a registered domain.
func (*WorkflowHandler) DescribeTaskList ¶ added in v0.3.5
func (wh *WorkflowHandler) DescribeTaskList( ctx context.Context, request *gen.DescribeTaskListRequest, ) (resp *gen.DescribeTaskListResponse, retError error)
DescribeTaskList returns information about the target tasklist, right now this API returns the pollers which polled this tasklist in last few minutes. If includeTaskListStatus field is true, it will also return status of tasklist's ackManager (readLevel, ackLevel, backlogCountHint and taskIDBlock).
func (*WorkflowHandler) DescribeWorkflowExecution ¶ added in v0.3.3
func (wh *WorkflowHandler) DescribeWorkflowExecution( ctx context.Context, request *gen.DescribeWorkflowExecutionRequest, ) (resp *gen.DescribeWorkflowExecutionResponse, retError error)
DescribeWorkflowExecution returns information about the specified workflow execution.
func (*WorkflowHandler) GetDomainReplicationMessages ¶ added in v0.9.3
func (wh *WorkflowHandler) GetDomainReplicationMessages( ctx context.Context, request *replicator.GetDomainReplicationMessagesRequest, ) (resp *replicator.GetDomainReplicationMessagesResponse, err error)
GetDomainReplicationMessages returns new domain replication tasks since last retrieved task ID.
func (*WorkflowHandler) GetReplicationMessages ¶ added in v0.9.0
func (wh *WorkflowHandler) GetReplicationMessages( ctx context.Context, request *replicator.GetReplicationMessagesRequest, ) (resp *replicator.GetReplicationMessagesResponse, err error)
GetReplicationMessages returns new replication tasks since the read level provided in the token.
func (*WorkflowHandler) GetSearchAttributes ¶ added in v0.5.9
func (wh *WorkflowHandler) GetSearchAttributes(ctx context.Context) (resp *gen.GetSearchAttributesResponse, retError error)
GetSearchAttributes return valid indexed keys
func (*WorkflowHandler) GetWorkflowExecutionHistory ¶
func (wh *WorkflowHandler) GetWorkflowExecutionHistory( ctx context.Context, getRequest *gen.GetWorkflowExecutionHistoryRequest, ) (resp *gen.GetWorkflowExecutionHistoryResponse, retError error)
GetWorkflowExecutionHistory - retrieves the history of workflow execution
func (*WorkflowHandler) Health ¶ added in v0.3.0
func (wh *WorkflowHandler) Health(ctx context.Context) (*health.HealthStatus, error)
Health is for health check
func (*WorkflowHandler) ListArchivedWorkflowExecutions ¶ added in v0.9.0
func (wh *WorkflowHandler) ListArchivedWorkflowExecutions( ctx context.Context, listRequest *gen.ListArchivedWorkflowExecutionsRequest, ) (resp *gen.ListArchivedWorkflowExecutionsResponse, retError error)
ListArchivedWorkflowExecutions - retrieves archived info for closed workflow executions in a domain
func (*WorkflowHandler) ListClosedWorkflowExecutions ¶
func (wh *WorkflowHandler) ListClosedWorkflowExecutions( ctx context.Context, listRequest *gen.ListClosedWorkflowExecutionsRequest, ) (resp *gen.ListClosedWorkflowExecutionsResponse, retError error)
ListClosedWorkflowExecutions - retrieves info for closed workflow executions in a domain
func (*WorkflowHandler) ListDomains ¶ added in v0.3.14
func (wh *WorkflowHandler) ListDomains( ctx context.Context, listRequest *gen.ListDomainsRequest, ) (response *gen.ListDomainsResponse, retError error)
ListDomains returns the information and configuration for a registered domain.
func (*WorkflowHandler) ListOpenWorkflowExecutions ¶
func (wh *WorkflowHandler) ListOpenWorkflowExecutions( ctx context.Context, listRequest *gen.ListOpenWorkflowExecutionsRequest, ) (resp *gen.ListOpenWorkflowExecutionsResponse, retError error)
ListOpenWorkflowExecutions - retrieves info for open workflow executions in a domain
func (*WorkflowHandler) ListWorkflowExecutions ¶ added in v0.5.7
func (wh *WorkflowHandler) ListWorkflowExecutions( ctx context.Context, listRequest *gen.ListWorkflowExecutionsRequest, ) (resp *gen.ListWorkflowExecutionsResponse, retError error)
ListWorkflowExecutions - retrieves info for workflow executions in a domain
func (*WorkflowHandler) PollForActivityTask ¶
func (wh *WorkflowHandler) PollForActivityTask( ctx context.Context, pollRequest *gen.PollForActivityTaskRequest, ) (resp *gen.PollForActivityTaskResponse, retError error)
PollForActivityTask - Poll for an activity task.
func (*WorkflowHandler) PollForDecisionTask ¶
func (wh *WorkflowHandler) PollForDecisionTask( ctx context.Context, pollRequest *gen.PollForDecisionTaskRequest, ) (resp *gen.PollForDecisionTaskResponse, retError error)
PollForDecisionTask - Poll for a decision task.
func (*WorkflowHandler) QueryWorkflow ¶ added in v0.3.2
func (wh *WorkflowHandler) QueryWorkflow( ctx context.Context, queryRequest *gen.QueryWorkflowRequest, ) (resp *gen.QueryWorkflowResponse, retError error)
QueryWorkflow returns query result for a specified workflow execution
func (*WorkflowHandler) ReapplyEvents ¶ added in v0.9.3
func (wh *WorkflowHandler) ReapplyEvents( ctx context.Context, request *shared.ReapplyEventsRequest, ) (err error)
ReapplyEvents applies stale events to the current workflow and the current run
func (*WorkflowHandler) RecordActivityTaskHeartbeat ¶
func (wh *WorkflowHandler) RecordActivityTaskHeartbeat( ctx context.Context, heartbeatRequest *gen.RecordActivityTaskHeartbeatRequest, ) (resp *gen.RecordActivityTaskHeartbeatResponse, retError error)
RecordActivityTaskHeartbeat - Record Activity Task Heart beat.
func (*WorkflowHandler) RecordActivityTaskHeartbeatByID ¶ added in v0.3.7
func (wh *WorkflowHandler) RecordActivityTaskHeartbeatByID( ctx context.Context, heartbeatRequest *gen.RecordActivityTaskHeartbeatByIDRequest, ) (resp *gen.RecordActivityTaskHeartbeatResponse, retError error)
RecordActivityTaskHeartbeatByID - Record Activity Task Heart beat.
func (*WorkflowHandler) RegisterDomain ¶
func (wh *WorkflowHandler) RegisterDomain(ctx context.Context, registerRequest *gen.RegisterDomainRequest) (retError error)
RegisterDomain creates a new domain which can be used as a container for all resources. Domain is a top level entity within Cadence, used as a container for all resources like workflow executions, tasklists, etc. Domain acts as a sandbox and provides isolation for all resources within the domain. All resources belongs to exactly one domain.
func (*WorkflowHandler) RegisterHandler ¶ added in v0.5.8
func (wh *WorkflowHandler) RegisterHandler()
RegisterHandler register this handler, must be called before Start() if DCRedirectionHandler is also used, use RegisterHandler in DCRedirectionHandler instead
func (*WorkflowHandler) RequestCancelWorkflowExecution ¶
func (wh *WorkflowHandler) RequestCancelWorkflowExecution( ctx context.Context, cancelRequest *gen.RequestCancelWorkflowExecutionRequest, ) (retError error)
RequestCancelWorkflowExecution - requests to cancel a workflow execution
func (*WorkflowHandler) ResetStickyTaskList ¶ added in v0.3.12
func (wh *WorkflowHandler) ResetStickyTaskList( ctx context.Context, resetRequest *gen.ResetStickyTaskListRequest, ) (resp *gen.ResetStickyTaskListResponse, retError error)
ResetStickyTaskList reset the volatile information in mutable state of a given workflow.
func (*WorkflowHandler) ResetWorkflowExecution ¶ added in v0.5.2
func (wh *WorkflowHandler) ResetWorkflowExecution( ctx context.Context, resetRequest *gen.ResetWorkflowExecutionRequest, ) (resp *gen.ResetWorkflowExecutionResponse, retError error)
ResetWorkflowExecution reset an existing workflow execution to the nextFirstEventID in the history and immediately terminating the current execution instance.
func (*WorkflowHandler) RespondActivityTaskCanceled ¶
func (wh *WorkflowHandler) RespondActivityTaskCanceled( ctx context.Context, cancelRequest *gen.RespondActivityTaskCanceledRequest, ) (retError error)
RespondActivityTaskCanceled - called to cancel an activity task
func (*WorkflowHandler) RespondActivityTaskCanceledByID ¶ added in v0.3.3
func (wh *WorkflowHandler) RespondActivityTaskCanceledByID( ctx context.Context, cancelRequest *gen.RespondActivityTaskCanceledByIDRequest, ) (retError error)
RespondActivityTaskCanceledByID - called to cancel an activity task
func (*WorkflowHandler) RespondActivityTaskCompleted ¶
func (wh *WorkflowHandler) RespondActivityTaskCompleted( ctx context.Context, completeRequest *gen.RespondActivityTaskCompletedRequest, ) (retError error)
RespondActivityTaskCompleted - response to an activity task
func (*WorkflowHandler) RespondActivityTaskCompletedByID ¶ added in v0.3.3
func (wh *WorkflowHandler) RespondActivityTaskCompletedByID( ctx context.Context, completeRequest *gen.RespondActivityTaskCompletedByIDRequest, ) (retError error)
RespondActivityTaskCompletedByID - response to an activity task
func (*WorkflowHandler) RespondActivityTaskFailed ¶
func (wh *WorkflowHandler) RespondActivityTaskFailed( ctx context.Context, failedRequest *gen.RespondActivityTaskFailedRequest, ) (retError error)
RespondActivityTaskFailed - response to an activity task failure
func (*WorkflowHandler) RespondActivityTaskFailedByID ¶ added in v0.3.3
func (wh *WorkflowHandler) RespondActivityTaskFailedByID( ctx context.Context, failedRequest *gen.RespondActivityTaskFailedByIDRequest, ) (retError error)
RespondActivityTaskFailedByID - response to an activity task failure
func (*WorkflowHandler) RespondDecisionTaskCompleted ¶
func (wh *WorkflowHandler) RespondDecisionTaskCompleted( ctx context.Context, completeRequest *gen.RespondDecisionTaskCompletedRequest, ) (resp *gen.RespondDecisionTaskCompletedResponse, retError error)
RespondDecisionTaskCompleted - response to a decision task
func (*WorkflowHandler) RespondDecisionTaskFailed ¶ added in v0.3.3
func (wh *WorkflowHandler) RespondDecisionTaskFailed( ctx context.Context, failedRequest *gen.RespondDecisionTaskFailedRequest, ) (retError error)
RespondDecisionTaskFailed - failed response to a decision task
func (*WorkflowHandler) RespondQueryTaskCompleted ¶ added in v0.3.2
func (wh *WorkflowHandler) RespondQueryTaskCompleted( ctx context.Context, completeRequest *gen.RespondQueryTaskCompletedRequest, ) (retError error)
RespondQueryTaskCompleted - response to a query task
func (*WorkflowHandler) ScanWorkflowExecutions ¶ added in v0.5.8
func (wh *WorkflowHandler) ScanWorkflowExecutions( ctx context.Context, listRequest *gen.ListWorkflowExecutionsRequest, ) (resp *gen.ListWorkflowExecutionsResponse, retError error)
ScanWorkflowExecutions - retrieves info for large amount of workflow executions in a domain without order
func (*WorkflowHandler) SignalWithStartWorkflowExecution ¶ added in v0.3.11
func (wh *WorkflowHandler) SignalWithStartWorkflowExecution( ctx context.Context, signalWithStartRequest *gen.SignalWithStartWorkflowExecutionRequest, ) (resp *gen.StartWorkflowExecutionResponse, retError error)
SignalWithStartWorkflowExecution is used to ensure sending a signal event to a workflow execution. If workflow is running, this results in WorkflowExecutionSignaled event recorded in the history and a decision task being created for the execution. If workflow is not running or not found, this results in WorkflowExecutionStarted and WorkflowExecutionSignaled event recorded in history, and a decision task being created for the execution
func (*WorkflowHandler) SignalWorkflowExecution ¶
func (wh *WorkflowHandler) SignalWorkflowExecution( ctx context.Context, signalRequest *gen.SignalWorkflowExecutionRequest, ) (retError error)
SignalWorkflowExecution is used to send a signal event to running workflow execution. This results in WorkflowExecutionSignaled event recorded in the history and a decision task being created for the execution.
func (*WorkflowHandler) StartWorkflowExecution ¶
func (wh *WorkflowHandler) StartWorkflowExecution( ctx context.Context, startRequest *gen.StartWorkflowExecutionRequest, ) (resp *gen.StartWorkflowExecutionResponse, retError error)
StartWorkflowExecution - Creates a new workflow execution
func (*WorkflowHandler) TerminateWorkflowExecution ¶
func (wh *WorkflowHandler) TerminateWorkflowExecution( ctx context.Context, terminateRequest *gen.TerminateWorkflowExecutionRequest, ) (retError error)
TerminateWorkflowExecution terminates an existing workflow execution by recording WorkflowExecutionTerminated event in the history and immediately terminating the execution instance.
func (*WorkflowHandler) UpdateDomain ¶
func (wh *WorkflowHandler) UpdateDomain( ctx context.Context, updateRequest *gen.UpdateDomainRequest, ) (resp *gen.UpdateDomainResponse, retError error)
UpdateDomain is used to update the information and configuration for a registered domain.