Documentation ¶
Overview ¶
Package frontend is a generated GoMock package.
Package frontend is a generated GoMock package.
Index ¶
- Constants
- func NewAdminHandler(resource resource.Resource, params *service.BootstrapParams, config *Config) *adminHandlerImpl
- func NewService(params *service.BootstrapParams) (resource.Resource, error)
- type AccessControlledWorkflowHandler
- func (a *AccessControlledWorkflowHandler) CountWorkflowExecutions(ctx context.Context, request *shared.CountWorkflowExecutionsRequest) (*shared.CountWorkflowExecutionsResponse, error)
- func (a *AccessControlledWorkflowHandler) DeprecateDomain(ctx context.Context, request *shared.DeprecateDomainRequest) error
- func (a *AccessControlledWorkflowHandler) DescribeDomain(ctx context.Context, request *shared.DescribeDomainRequest) (*shared.DescribeDomainResponse, error)
- func (a *AccessControlledWorkflowHandler) DescribeTaskList(ctx context.Context, request *shared.DescribeTaskListRequest) (*shared.DescribeTaskListResponse, error)
- func (a *AccessControlledWorkflowHandler) DescribeWorkflowExecution(ctx context.Context, request *shared.DescribeWorkflowExecutionRequest) (*shared.DescribeWorkflowExecutionResponse, error)
- func (a *AccessControlledWorkflowHandler) GetClusterInfo(ctx context.Context) (*shared.ClusterInfo, error)
- func (a *AccessControlledWorkflowHandler) GetSearchAttributes(ctx context.Context) (*shared.GetSearchAttributesResponse, error)
- func (a *AccessControlledWorkflowHandler) GetWorkflowExecutionHistory(ctx context.Context, request *shared.GetWorkflowExecutionHistoryRequest) (*shared.GetWorkflowExecutionHistoryResponse, error)
- func (a *AccessControlledWorkflowHandler) Health(ctx context.Context) (*health.HealthStatus, error)
- func (a *AccessControlledWorkflowHandler) ListArchivedWorkflowExecutions(ctx context.Context, request *shared.ListArchivedWorkflowExecutionsRequest) (*shared.ListArchivedWorkflowExecutionsResponse, error)
- func (a *AccessControlledWorkflowHandler) ListClosedWorkflowExecutions(ctx context.Context, request *shared.ListClosedWorkflowExecutionsRequest) (*shared.ListClosedWorkflowExecutionsResponse, error)
- func (a *AccessControlledWorkflowHandler) ListDomains(ctx context.Context, request *shared.ListDomainsRequest) (*shared.ListDomainsResponse, error)
- func (a *AccessControlledWorkflowHandler) ListOpenWorkflowExecutions(ctx context.Context, request *shared.ListOpenWorkflowExecutionsRequest) (*shared.ListOpenWorkflowExecutionsResponse, error)
- func (a *AccessControlledWorkflowHandler) ListTaskListPartitions(ctx context.Context, request *shared.ListTaskListPartitionsRequest) (*shared.ListTaskListPartitionsResponse, error)
- func (a *AccessControlledWorkflowHandler) ListWorkflowExecutions(ctx context.Context, request *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, error)
- func (a *AccessControlledWorkflowHandler) PollForActivityTask(ctx context.Context, request *shared.PollForActivityTaskRequest) (*shared.PollForActivityTaskResponse, error)
- func (a *AccessControlledWorkflowHandler) PollForDecisionTask(ctx context.Context, request *shared.PollForDecisionTaskRequest) (*shared.PollForDecisionTaskResponse, error)
- func (a *AccessControlledWorkflowHandler) QueryWorkflow(ctx context.Context, request *shared.QueryWorkflowRequest) (*shared.QueryWorkflowResponse, error)
- func (a *AccessControlledWorkflowHandler) RecordActivityTaskHeartbeat(ctx context.Context, request *shared.RecordActivityTaskHeartbeatRequest) (*shared.RecordActivityTaskHeartbeatResponse, error)
- func (a *AccessControlledWorkflowHandler) RecordActivityTaskHeartbeatByID(ctx context.Context, request *shared.RecordActivityTaskHeartbeatByIDRequest) (*shared.RecordActivityTaskHeartbeatResponse, error)
- func (a *AccessControlledWorkflowHandler) RegisterDomain(ctx context.Context, request *shared.RegisterDomainRequest) error
- func (a *AccessControlledWorkflowHandler) RequestCancelWorkflowExecution(ctx context.Context, request *shared.RequestCancelWorkflowExecutionRequest) error
- func (a *AccessControlledWorkflowHandler) ResetStickyTaskList(ctx context.Context, request *shared.ResetStickyTaskListRequest) (*shared.ResetStickyTaskListResponse, error)
- func (a *AccessControlledWorkflowHandler) ResetWorkflowExecution(ctx context.Context, request *shared.ResetWorkflowExecutionRequest) (*shared.ResetWorkflowExecutionResponse, error)
- func (a *AccessControlledWorkflowHandler) RespondActivityTaskCanceled(ctx context.Context, request *shared.RespondActivityTaskCanceledRequest) error
- func (a *AccessControlledWorkflowHandler) RespondActivityTaskCanceledByID(ctx context.Context, request *shared.RespondActivityTaskCanceledByIDRequest) error
- func (a *AccessControlledWorkflowHandler) RespondActivityTaskCompleted(ctx context.Context, request *shared.RespondActivityTaskCompletedRequest) error
- func (a *AccessControlledWorkflowHandler) RespondActivityTaskCompletedByID(ctx context.Context, request *shared.RespondActivityTaskCompletedByIDRequest) error
- func (a *AccessControlledWorkflowHandler) RespondActivityTaskFailed(ctx context.Context, request *shared.RespondActivityTaskFailedRequest) error
- func (a *AccessControlledWorkflowHandler) RespondActivityTaskFailedByID(ctx context.Context, request *shared.RespondActivityTaskFailedByIDRequest) error
- func (a *AccessControlledWorkflowHandler) RespondDecisionTaskCompleted(ctx context.Context, request *shared.RespondDecisionTaskCompletedRequest) (*shared.RespondDecisionTaskCompletedResponse, error)
- func (a *AccessControlledWorkflowHandler) RespondDecisionTaskFailed(ctx context.Context, request *shared.RespondDecisionTaskFailedRequest) error
- func (a *AccessControlledWorkflowHandler) RespondQueryTaskCompleted(ctx context.Context, request *shared.RespondQueryTaskCompletedRequest) error
- func (a *AccessControlledWorkflowHandler) ScanWorkflowExecutions(ctx context.Context, request *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, error)
- func (a *AccessControlledWorkflowHandler) SignalWithStartWorkflowExecution(ctx context.Context, request *shared.SignalWithStartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)
- func (a *AccessControlledWorkflowHandler) SignalWorkflowExecution(ctx context.Context, request *shared.SignalWorkflowExecutionRequest) error
- func (a *AccessControlledWorkflowHandler) StartWorkflowExecution(ctx context.Context, request *shared.StartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)
- func (a *AccessControlledWorkflowHandler) TerminateWorkflowExecution(ctx context.Context, request *shared.TerminateWorkflowExecutionRequest) error
- func (a *AccessControlledWorkflowHandler) UpdateDomain(ctx context.Context, request *shared.UpdateDomainRequest) (*shared.UpdateDomainResponse, error)
- type AdminHandler
- type AdminThriftHandler
- func (t AdminThriftHandler) AddSearchAttribute(ctx context.Context, request *admin.AddSearchAttributeRequest) (err error)
- func (t AdminThriftHandler) CloseShard(ctx context.Context, request *shared.CloseShardRequest) (err error)
- func (t AdminThriftHandler) DescribeCluster(ctx context.Context) (response *admin.DescribeClusterResponse, err error)
- func (t AdminThriftHandler) DescribeHistoryHost(ctx context.Context, request *shared.DescribeHistoryHostRequest) (response *shared.DescribeHistoryHostResponse, err error)
- func (t AdminThriftHandler) DescribeQueue(ctx context.Context, request *shared.DescribeQueueRequest) (response *shared.DescribeQueueResponse, err error)
- func (t AdminThriftHandler) DescribeWorkflowExecution(ctx context.Context, request *admin.DescribeWorkflowExecutionRequest) (response *admin.DescribeWorkflowExecutionResponse, err error)
- func (t AdminThriftHandler) GetDLQReplicationMessages(ctx context.Context, request *replicator.GetDLQReplicationMessagesRequest) (response *replicator.GetDLQReplicationMessagesResponse, err error)
- func (t AdminThriftHandler) GetDomainReplicationMessages(ctx context.Context, request *replicator.GetDomainReplicationMessagesRequest) (response *replicator.GetDomainReplicationMessagesResponse, err error)
- func (t AdminThriftHandler) GetReplicationMessages(ctx context.Context, request *replicator.GetReplicationMessagesRequest) (response *replicator.GetReplicationMessagesResponse, err error)
- func (t AdminThriftHandler) GetWorkflowExecutionRawHistoryV2(ctx context.Context, request *admin.GetWorkflowExecutionRawHistoryV2Request) (response *admin.GetWorkflowExecutionRawHistoryV2Response, err error)
- func (t AdminThriftHandler) MergeDLQMessages(ctx context.Context, request *replicator.MergeDLQMessagesRequest) (response *replicator.MergeDLQMessagesResponse, err error)
- func (t AdminThriftHandler) PurgeDLQMessages(ctx context.Context, request *replicator.PurgeDLQMessagesRequest) (err error)
- func (t AdminThriftHandler) ReadDLQMessages(ctx context.Context, request *replicator.ReadDLQMessagesRequest) (response *replicator.ReadDLQMessagesResponse, err error)
- func (t AdminThriftHandler) ReapplyEvents(ctx context.Context, request *shared.ReapplyEventsRequest) (err error)
- func (t AdminThriftHandler) RefreshWorkflowTasks(ctx context.Context, request *shared.RefreshWorkflowTasksRequest) (err error)
- func (t AdminThriftHandler) RemoveTask(ctx context.Context, request *shared.RemoveTaskRequest) (err error)
- func (t AdminThriftHandler) ResendReplicationTasks(ctx context.Context, request *admin.ResendReplicationTasksRequest) (err error)
- func (t AdminThriftHandler) ResetQueue(ctx context.Context, request *shared.ResetQueueRequest) (err error)
- 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) GetClusterInfo(ctx context.Context) (*shared.ClusterInfo, 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) ListTaskListPartitions(ctx context.Context, request *shared.ListTaskListPartitionsRequest) (resp *shared.ListTaskListPartitionsResponse, 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) 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) 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) StartWorkflowExecution(ctx context.Context, request *shared.StartWorkflowExecutionRequest) (resp *shared.StartWorkflowExecutionResponse, retError error)
- 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 Handler
- type HealthStatus
- type MockAdminHandler
- func (m *MockAdminHandler) AddSearchAttribute(arg0 context.Context, arg1 *admin.AddSearchAttributeRequest) error
- func (m *MockAdminHandler) CloseShard(arg0 context.Context, arg1 *shared.CloseShardRequest) error
- func (m *MockAdminHandler) DescribeCluster(arg0 context.Context) (*admin.DescribeClusterResponse, error)
- func (m *MockAdminHandler) DescribeHistoryHost(arg0 context.Context, arg1 *shared.DescribeHistoryHostRequest) (*shared.DescribeHistoryHostResponse, error)
- func (m *MockAdminHandler) DescribeQueue(arg0 context.Context, arg1 *shared.DescribeQueueRequest) (*shared.DescribeQueueResponse, error)
- func (m *MockAdminHandler) DescribeWorkflowExecution(arg0 context.Context, arg1 *admin.DescribeWorkflowExecutionRequest) (*admin.DescribeWorkflowExecutionResponse, error)
- func (m *MockAdminHandler) EXPECT() *MockAdminHandlerMockRecorder
- func (m *MockAdminHandler) GetDLQReplicationMessages(arg0 context.Context, arg1 *replicator.GetDLQReplicationMessagesRequest) (*replicator.GetDLQReplicationMessagesResponse, error)
- func (m *MockAdminHandler) GetDomainReplicationMessages(arg0 context.Context, arg1 *replicator.GetDomainReplicationMessagesRequest) (*replicator.GetDomainReplicationMessagesResponse, error)
- func (m *MockAdminHandler) GetReplicationMessages(arg0 context.Context, arg1 *replicator.GetReplicationMessagesRequest) (*replicator.GetReplicationMessagesResponse, error)
- func (m *MockAdminHandler) GetWorkflowExecutionRawHistoryV2(arg0 context.Context, arg1 *admin.GetWorkflowExecutionRawHistoryV2Request) (*admin.GetWorkflowExecutionRawHistoryV2Response, error)
- func (m *MockAdminHandler) MergeDLQMessages(arg0 context.Context, arg1 *replicator.MergeDLQMessagesRequest) (*replicator.MergeDLQMessagesResponse, error)
- func (m *MockAdminHandler) PurgeDLQMessages(arg0 context.Context, arg1 *replicator.PurgeDLQMessagesRequest) error
- func (m *MockAdminHandler) ReadDLQMessages(arg0 context.Context, arg1 *replicator.ReadDLQMessagesRequest) (*replicator.ReadDLQMessagesResponse, error)
- func (m *MockAdminHandler) ReapplyEvents(arg0 context.Context, arg1 *shared.ReapplyEventsRequest) error
- func (m *MockAdminHandler) RefreshWorkflowTasks(arg0 context.Context, arg1 *shared.RefreshWorkflowTasksRequest) error
- func (m *MockAdminHandler) RemoveTask(arg0 context.Context, arg1 *shared.RemoveTaskRequest) error
- func (m *MockAdminHandler) ResendReplicationTasks(arg0 context.Context, arg1 *admin.ResendReplicationTasksRequest) error
- func (m *MockAdminHandler) ResetQueue(arg0 context.Context, arg1 *shared.ResetQueueRequest) error
- type MockAdminHandlerMockRecorder
- func (mr *MockAdminHandlerMockRecorder) AddSearchAttribute(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) CloseShard(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) DescribeCluster(arg0 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) DescribeHistoryHost(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) DescribeQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) GetDLQReplicationMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) GetDomainReplicationMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) GetReplicationMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) GetWorkflowExecutionRawHistoryV2(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) MergeDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) PurgeDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) ReadDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) ReapplyEvents(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) RefreshWorkflowTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) RemoveTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) ResendReplicationTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminHandlerMockRecorder) ResetQueue(arg0, arg1 interface{}) *gomock.Call
- type MockDCRedirectionPolicy
- type MockHandler
- func (m *MockHandler) CountWorkflowExecutions(ctx context.Context, CountRequest *shared.CountWorkflowExecutionsRequest) (*shared.CountWorkflowExecutionsResponse, error)
- func (m *MockHandler) DeprecateDomain(ctx context.Context, DeprecateRequest *shared.DeprecateDomainRequest) error
- func (m *MockHandler) DescribeDomain(ctx context.Context, DescribeRequest *shared.DescribeDomainRequest) (*shared.DescribeDomainResponse, error)
- func (m *MockHandler) DescribeTaskList(ctx context.Context, Request *shared.DescribeTaskListRequest) (*shared.DescribeTaskListResponse, error)
- func (m *MockHandler) DescribeWorkflowExecution(ctx context.Context, DescribeRequest *shared.DescribeWorkflowExecutionRequest) (*shared.DescribeWorkflowExecutionResponse, error)
- func (m *MockHandler) EXPECT() *MockHandlerMockRecorder
- func (m *MockHandler) GetClusterInfo(ctx context.Context) (*shared.ClusterInfo, error)
- func (m *MockHandler) GetSearchAttributes(ctx context.Context) (*shared.GetSearchAttributesResponse, error)
- func (m *MockHandler) GetWorkflowExecutionHistory(ctx context.Context, GetRequest *shared.GetWorkflowExecutionHistoryRequest) (*shared.GetWorkflowExecutionHistoryResponse, error)
- func (m *MockHandler) Health(ctx context.Context) (*health.HealthStatus, error)
- func (m *MockHandler) ListArchivedWorkflowExecutions(ctx context.Context, ListRequest *shared.ListArchivedWorkflowExecutionsRequest) (*shared.ListArchivedWorkflowExecutionsResponse, error)
- func (m *MockHandler) ListClosedWorkflowExecutions(ctx context.Context, ListRequest *shared.ListClosedWorkflowExecutionsRequest) (*shared.ListClosedWorkflowExecutionsResponse, error)
- func (m *MockHandler) ListDomains(ctx context.Context, ListRequest *shared.ListDomainsRequest) (*shared.ListDomainsResponse, error)
- func (m *MockHandler) ListOpenWorkflowExecutions(ctx context.Context, ListRequest *shared.ListOpenWorkflowExecutionsRequest) (*shared.ListOpenWorkflowExecutionsResponse, error)
- func (m *MockHandler) ListTaskListPartitions(ctx context.Context, Request *shared.ListTaskListPartitionsRequest) (*shared.ListTaskListPartitionsResponse, error)
- func (m *MockHandler) ListWorkflowExecutions(ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, error)
- func (m *MockHandler) PollForActivityTask(ctx context.Context, PollRequest *shared.PollForActivityTaskRequest) (*shared.PollForActivityTaskResponse, error)
- func (m *MockHandler) PollForDecisionTask(ctx context.Context, PollRequest *shared.PollForDecisionTaskRequest) (*shared.PollForDecisionTaskResponse, error)
- func (m *MockHandler) QueryWorkflow(ctx context.Context, QueryRequest *shared.QueryWorkflowRequest) (*shared.QueryWorkflowResponse, error)
- func (m *MockHandler) RecordActivityTaskHeartbeat(ctx context.Context, ...) (*shared.RecordActivityTaskHeartbeatResponse, error)
- func (m *MockHandler) RecordActivityTaskHeartbeatByID(ctx context.Context, ...) (*shared.RecordActivityTaskHeartbeatResponse, error)
- func (m *MockHandler) RegisterDomain(ctx context.Context, RegisterRequest *shared.RegisterDomainRequest) error
- func (m *MockHandler) RequestCancelWorkflowExecution(ctx context.Context, ...) error
- func (m *MockHandler) ResetStickyTaskList(ctx context.Context, ResetRequest *shared.ResetStickyTaskListRequest) (*shared.ResetStickyTaskListResponse, error)
- func (m *MockHandler) ResetWorkflowExecution(ctx context.Context, ResetRequest *shared.ResetWorkflowExecutionRequest) (*shared.ResetWorkflowExecutionResponse, error)
- func (m *MockHandler) RespondActivityTaskCanceled(ctx context.Context, ...) error
- func (m *MockHandler) RespondActivityTaskCanceledByID(ctx context.Context, ...) error
- func (m *MockHandler) RespondActivityTaskCompleted(ctx context.Context, ...) error
- func (m *MockHandler) RespondActivityTaskCompletedByID(ctx context.Context, ...) error
- func (m *MockHandler) RespondActivityTaskFailed(ctx context.Context, FailRequest *shared.RespondActivityTaskFailedRequest) error
- func (m *MockHandler) RespondActivityTaskFailedByID(ctx context.Context, FailRequest *shared.RespondActivityTaskFailedByIDRequest) error
- func (m *MockHandler) RespondDecisionTaskCompleted(ctx context.Context, ...) (*shared.RespondDecisionTaskCompletedResponse, error)
- func (m *MockHandler) RespondDecisionTaskFailed(ctx context.Context, FailedRequest *shared.RespondDecisionTaskFailedRequest) error
- func (m *MockHandler) RespondQueryTaskCompleted(ctx context.Context, CompleteRequest *shared.RespondQueryTaskCompletedRequest) error
- func (m *MockHandler) ScanWorkflowExecutions(ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, error)
- func (m *MockHandler) SignalWithStartWorkflowExecution(ctx context.Context, ...) (*shared.StartWorkflowExecutionResponse, error)
- func (m *MockHandler) SignalWorkflowExecution(ctx context.Context, SignalRequest *shared.SignalWorkflowExecutionRequest) error
- func (m *MockHandler) StartWorkflowExecution(ctx context.Context, StartRequest *shared.StartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)
- func (m *MockHandler) TerminateWorkflowExecution(ctx context.Context, ...) error
- func (m *MockHandler) UpdateDomain(ctx context.Context, UpdateRequest *shared.UpdateDomainRequest) (*shared.UpdateDomainResponse, error)
- type MockHandlerMockRecorder
- func (mr *MockHandlerMockRecorder) CountWorkflowExecutions(ctx, CountRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DeprecateDomain(ctx, DeprecateRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeDomain(ctx, DescribeRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeTaskList(ctx, Request interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeWorkflowExecution(ctx, DescribeRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetClusterInfo(ctx interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetSearchAttributes(ctx interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetWorkflowExecutionHistory(ctx, GetRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) Health(ctx interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ListArchivedWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ListClosedWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ListDomains(ctx, ListRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ListOpenWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ListTaskListPartitions(ctx, Request interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ListWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) PollForActivityTask(ctx, PollRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) PollForDecisionTask(ctx, PollRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) QueryWorkflow(ctx, QueryRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RecordActivityTaskHeartbeat(ctx, HeartbeatRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RecordActivityTaskHeartbeatByID(ctx, HeartbeatRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RegisterDomain(ctx, RegisterRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RequestCancelWorkflowExecution(ctx, CancelRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ResetStickyTaskList(ctx, ResetRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ResetWorkflowExecution(ctx, ResetRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondActivityTaskCanceled(ctx, CanceledRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondActivityTaskCanceledByID(ctx, CanceledRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondActivityTaskCompleted(ctx, CompleteRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondActivityTaskCompletedByID(ctx, CompleteRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondActivityTaskFailed(ctx, FailRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondActivityTaskFailedByID(ctx, FailRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondDecisionTaskCompleted(ctx, CompleteRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondDecisionTaskFailed(ctx, FailedRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondQueryTaskCompleted(ctx, CompleteRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ScanWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) SignalWithStartWorkflowExecution(ctx, SignalWithStartRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) SignalWorkflowExecution(ctx, SignalRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) StartWorkflowExecution(ctx, StartRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) TerminateWorkflowExecution(ctx, TerminateRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) 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 ThriftHandler
- func (t ThriftHandler) CountWorkflowExecutions(ctx context.Context, request *shared.CountWorkflowExecutionsRequest) (response *shared.CountWorkflowExecutionsResponse, err error)
- func (t ThriftHandler) DeprecateDomain(ctx context.Context, request *shared.DeprecateDomainRequest) (err error)
- func (t ThriftHandler) DescribeDomain(ctx context.Context, request *shared.DescribeDomainRequest) (response *shared.DescribeDomainResponse, err error)
- func (t ThriftHandler) DescribeTaskList(ctx context.Context, request *shared.DescribeTaskListRequest) (response *shared.DescribeTaskListResponse, err error)
- func (t ThriftHandler) DescribeWorkflowExecution(ctx context.Context, request *shared.DescribeWorkflowExecutionRequest) (response *shared.DescribeWorkflowExecutionResponse, err error)
- func (t ThriftHandler) GetClusterInfo(ctx context.Context) (response *shared.ClusterInfo, err error)
- func (t ThriftHandler) GetSearchAttributes(ctx context.Context) (response *shared.GetSearchAttributesResponse, err error)
- func (t ThriftHandler) GetWorkflowExecutionHistory(ctx context.Context, request *shared.GetWorkflowExecutionHistoryRequest) (response *shared.GetWorkflowExecutionHistoryResponse, err error)
- func (t ThriftHandler) Health(ctx context.Context) (response *health.HealthStatus, err error)
- func (t ThriftHandler) ListArchivedWorkflowExecutions(ctx context.Context, request *shared.ListArchivedWorkflowExecutionsRequest) (response *shared.ListArchivedWorkflowExecutionsResponse, err error)
- func (t ThriftHandler) ListClosedWorkflowExecutions(ctx context.Context, request *shared.ListClosedWorkflowExecutionsRequest) (response *shared.ListClosedWorkflowExecutionsResponse, err error)
- func (t ThriftHandler) ListDomains(ctx context.Context, request *shared.ListDomainsRequest) (response *shared.ListDomainsResponse, err error)
- func (t ThriftHandler) ListOpenWorkflowExecutions(ctx context.Context, request *shared.ListOpenWorkflowExecutionsRequest) (response *shared.ListOpenWorkflowExecutionsResponse, err error)
- func (t ThriftHandler) ListTaskListPartitions(ctx context.Context, request *shared.ListTaskListPartitionsRequest) (response *shared.ListTaskListPartitionsResponse, err error)
- func (t ThriftHandler) ListWorkflowExecutions(ctx context.Context, request *shared.ListWorkflowExecutionsRequest) (response *shared.ListWorkflowExecutionsResponse, err error)
- func (t ThriftHandler) PollForActivityTask(ctx context.Context, request *shared.PollForActivityTaskRequest) (response *shared.PollForActivityTaskResponse, err error)
- func (t ThriftHandler) PollForDecisionTask(ctx context.Context, request *shared.PollForDecisionTaskRequest) (response *shared.PollForDecisionTaskResponse, err error)
- func (t ThriftHandler) QueryWorkflow(ctx context.Context, request *shared.QueryWorkflowRequest) (response *shared.QueryWorkflowResponse, err error)
- func (t ThriftHandler) RecordActivityTaskHeartbeat(ctx context.Context, request *shared.RecordActivityTaskHeartbeatRequest) (response *shared.RecordActivityTaskHeartbeatResponse, err error)
- func (t ThriftHandler) RecordActivityTaskHeartbeatByID(ctx context.Context, request *shared.RecordActivityTaskHeartbeatByIDRequest) (response *shared.RecordActivityTaskHeartbeatResponse, err error)
- func (t ThriftHandler) RegisterDomain(ctx context.Context, request *shared.RegisterDomainRequest) (err error)
- func (t ThriftHandler) RequestCancelWorkflowExecution(ctx context.Context, request *shared.RequestCancelWorkflowExecutionRequest) (err error)
- func (t ThriftHandler) ResetStickyTaskList(ctx context.Context, request *shared.ResetStickyTaskListRequest) (response *shared.ResetStickyTaskListResponse, err error)
- func (t ThriftHandler) ResetWorkflowExecution(ctx context.Context, request *shared.ResetWorkflowExecutionRequest) (response *shared.ResetWorkflowExecutionResponse, err error)
- func (t ThriftHandler) RespondActivityTaskCanceled(ctx context.Context, request *shared.RespondActivityTaskCanceledRequest) (err error)
- func (t ThriftHandler) RespondActivityTaskCanceledByID(ctx context.Context, request *shared.RespondActivityTaskCanceledByIDRequest) (err error)
- func (t ThriftHandler) RespondActivityTaskCompleted(ctx context.Context, request *shared.RespondActivityTaskCompletedRequest) (err error)
- func (t ThriftHandler) RespondActivityTaskCompletedByID(ctx context.Context, request *shared.RespondActivityTaskCompletedByIDRequest) (err error)
- func (t ThriftHandler) RespondActivityTaskFailed(ctx context.Context, request *shared.RespondActivityTaskFailedRequest) (err error)
- func (t ThriftHandler) RespondActivityTaskFailedByID(ctx context.Context, request *shared.RespondActivityTaskFailedByIDRequest) (err error)
- func (t ThriftHandler) RespondDecisionTaskCompleted(ctx context.Context, request *shared.RespondDecisionTaskCompletedRequest) (response *shared.RespondDecisionTaskCompletedResponse, err error)
- func (t ThriftHandler) RespondDecisionTaskFailed(ctx context.Context, request *shared.RespondDecisionTaskFailedRequest) (err error)
- func (t ThriftHandler) RespondQueryTaskCompleted(ctx context.Context, request *shared.RespondQueryTaskCompletedRequest) (err error)
- func (t ThriftHandler) ScanWorkflowExecutions(ctx context.Context, request *shared.ListWorkflowExecutionsRequest) (response *shared.ListWorkflowExecutionsResponse, err error)
- func (t ThriftHandler) SignalWithStartWorkflowExecution(ctx context.Context, request *shared.SignalWithStartWorkflowExecutionRequest) (response *shared.StartWorkflowExecutionResponse, err error)
- func (t ThriftHandler) SignalWorkflowExecution(ctx context.Context, request *shared.SignalWorkflowExecutionRequest) (err error)
- func (t ThriftHandler) StartWorkflowExecution(ctx context.Context, request *shared.StartWorkflowExecutionRequest) (response *shared.StartWorkflowExecutionResponse, err error)
- func (t ThriftHandler) TerminateWorkflowExecution(ctx context.Context, request *shared.TerminateWorkflowExecutionRequest) (err error)
- func (t ThriftHandler) UpdateDomain(ctx context.Context, request *shared.UpdateDomainRequest) (response *shared.UpdateDomainResponse, err error)
- 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) GetClusterInfo(ctx context.Context) (resp *gen.ClusterInfo, 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) ListTaskListPartitions(ctx context.Context, request *gen.ListTaskListPartitionsRequest) (resp *gen.ListTaskListPartitionsResponse, 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) 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) 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()
- 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)
- func (wh *WorkflowHandler) UpdateHealthStatus(status HealthStatus)
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 // 6. QueryWorkflow // please also reference selectedAPIsForwardingRedirectionPolicyWhitelistedAPIs DCRedirectionPolicySelectedAPIsForwarding = "selected-apis-forwarding" )
Variables ¶
This section is empty.
Functions ¶
func NewAdminHandler ¶ added in v0.3.12
func NewAdminHandler( resource resource.Resource, params *service.BootstrapParams, config *Config, ) *adminHandlerImpl
NewAdminHandler creates a thrift handler for the cadence admin service
func NewService ¶
func NewService( params *service.BootstrapParams, ) (resource.Resource, error)
NewService builds a new cadence-frontend service
Types ¶
type AccessControlledWorkflowHandler ¶ added in v0.11.0
type AccessControlledWorkflowHandler struct { resource.Resource // contains filtered or unexported fields }
AccessControlledWorkflowHandler frontend handler wrapper for authentication and authorization
func NewAccessControlledHandlerImpl ¶ added in v0.11.0
func NewAccessControlledHandlerImpl(wfHandler Handler, resource resource.Resource, authorizer authorization.Authorizer) *AccessControlledWorkflowHandler
NewAccessControlledHandlerImpl creates frontend handler with authentication support
func (*AccessControlledWorkflowHandler) CountWorkflowExecutions ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) CountWorkflowExecutions( ctx context.Context, request *shared.CountWorkflowExecutionsRequest, ) (*shared.CountWorkflowExecutionsResponse, error)
CountWorkflowExecutions API call
func (*AccessControlledWorkflowHandler) DeprecateDomain ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) DeprecateDomain( ctx context.Context, request *shared.DeprecateDomainRequest, ) error
DeprecateDomain API call
func (*AccessControlledWorkflowHandler) DescribeDomain ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) DescribeDomain( ctx context.Context, request *shared.DescribeDomainRequest, ) (*shared.DescribeDomainResponse, error)
DescribeDomain API call
func (*AccessControlledWorkflowHandler) DescribeTaskList ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) DescribeTaskList( ctx context.Context, request *shared.DescribeTaskListRequest, ) (*shared.DescribeTaskListResponse, error)
DescribeTaskList API call
func (*AccessControlledWorkflowHandler) DescribeWorkflowExecution ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) DescribeWorkflowExecution( ctx context.Context, request *shared.DescribeWorkflowExecutionRequest, ) (*shared.DescribeWorkflowExecutionResponse, error)
DescribeWorkflowExecution API call
func (*AccessControlledWorkflowHandler) GetClusterInfo ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) GetClusterInfo( ctx context.Context, ) (*shared.ClusterInfo, error)
GetClusterInfo API call
func (*AccessControlledWorkflowHandler) GetSearchAttributes ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) GetSearchAttributes( ctx context.Context, ) (*shared.GetSearchAttributesResponse, error)
GetSearchAttributes API call
func (*AccessControlledWorkflowHandler) GetWorkflowExecutionHistory ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) GetWorkflowExecutionHistory( ctx context.Context, request *shared.GetWorkflowExecutionHistoryRequest, ) (*shared.GetWorkflowExecutionHistoryResponse, error)
GetWorkflowExecutionHistory API call
func (*AccessControlledWorkflowHandler) Health ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) Health(ctx context.Context) (*health.HealthStatus, error)
Health callback for for health check
func (*AccessControlledWorkflowHandler) ListArchivedWorkflowExecutions ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) ListArchivedWorkflowExecutions( ctx context.Context, request *shared.ListArchivedWorkflowExecutionsRequest, ) (*shared.ListArchivedWorkflowExecutionsResponse, error)
ListArchivedWorkflowExecutions API call
func (*AccessControlledWorkflowHandler) ListClosedWorkflowExecutions ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) ListClosedWorkflowExecutions( ctx context.Context, request *shared.ListClosedWorkflowExecutionsRequest, ) (*shared.ListClosedWorkflowExecutionsResponse, error)
ListClosedWorkflowExecutions API call
func (*AccessControlledWorkflowHandler) ListDomains ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) ListDomains( ctx context.Context, request *shared.ListDomainsRequest, ) (*shared.ListDomainsResponse, error)
ListDomains API call
func (*AccessControlledWorkflowHandler) ListOpenWorkflowExecutions ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) ListOpenWorkflowExecutions( ctx context.Context, request *shared.ListOpenWorkflowExecutionsRequest, ) (*shared.ListOpenWorkflowExecutionsResponse, error)
ListOpenWorkflowExecutions API call
func (*AccessControlledWorkflowHandler) ListTaskListPartitions ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) ListTaskListPartitions( ctx context.Context, request *shared.ListTaskListPartitionsRequest, ) (*shared.ListTaskListPartitionsResponse, error)
ListTaskListPartitions API call
func (*AccessControlledWorkflowHandler) ListWorkflowExecutions ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) ListWorkflowExecutions( ctx context.Context, request *shared.ListWorkflowExecutionsRequest, ) (*shared.ListWorkflowExecutionsResponse, error)
ListWorkflowExecutions API call
func (*AccessControlledWorkflowHandler) PollForActivityTask ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) PollForActivityTask( ctx context.Context, request *shared.PollForActivityTaskRequest, ) (*shared.PollForActivityTaskResponse, error)
PollForActivityTask API call
func (*AccessControlledWorkflowHandler) PollForDecisionTask ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) PollForDecisionTask( ctx context.Context, request *shared.PollForDecisionTaskRequest, ) (*shared.PollForDecisionTaskResponse, error)
PollForDecisionTask API call
func (*AccessControlledWorkflowHandler) QueryWorkflow ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) QueryWorkflow( ctx context.Context, request *shared.QueryWorkflowRequest, ) (*shared.QueryWorkflowResponse, error)
QueryWorkflow API call
func (*AccessControlledWorkflowHandler) RecordActivityTaskHeartbeat ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) RecordActivityTaskHeartbeat( ctx context.Context, request *shared.RecordActivityTaskHeartbeatRequest, ) (*shared.RecordActivityTaskHeartbeatResponse, error)
RecordActivityTaskHeartbeat API call
func (*AccessControlledWorkflowHandler) RecordActivityTaskHeartbeatByID ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) RecordActivityTaskHeartbeatByID( ctx context.Context, request *shared.RecordActivityTaskHeartbeatByIDRequest, ) (*shared.RecordActivityTaskHeartbeatResponse, error)
RecordActivityTaskHeartbeatByID API call
func (*AccessControlledWorkflowHandler) RegisterDomain ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) RegisterDomain( ctx context.Context, request *shared.RegisterDomainRequest, ) error
RegisterDomain API call
func (*AccessControlledWorkflowHandler) RequestCancelWorkflowExecution ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) RequestCancelWorkflowExecution( ctx context.Context, request *shared.RequestCancelWorkflowExecutionRequest, ) error
RequestCancelWorkflowExecution API call
func (*AccessControlledWorkflowHandler) ResetStickyTaskList ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) ResetStickyTaskList( ctx context.Context, request *shared.ResetStickyTaskListRequest, ) (*shared.ResetStickyTaskListResponse, error)
ResetStickyTaskList API call
func (*AccessControlledWorkflowHandler) ResetWorkflowExecution ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) ResetWorkflowExecution( ctx context.Context, request *shared.ResetWorkflowExecutionRequest, ) (*shared.ResetWorkflowExecutionResponse, error)
ResetWorkflowExecution API call
func (*AccessControlledWorkflowHandler) RespondActivityTaskCanceled ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) RespondActivityTaskCanceled( ctx context.Context, request *shared.RespondActivityTaskCanceledRequest, ) error
RespondActivityTaskCanceled API call
func (*AccessControlledWorkflowHandler) RespondActivityTaskCanceledByID ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) RespondActivityTaskCanceledByID( ctx context.Context, request *shared.RespondActivityTaskCanceledByIDRequest, ) error
RespondActivityTaskCanceledByID API call
func (*AccessControlledWorkflowHandler) RespondActivityTaskCompleted ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) RespondActivityTaskCompleted( ctx context.Context, request *shared.RespondActivityTaskCompletedRequest, ) error
RespondActivityTaskCompleted API call
func (*AccessControlledWorkflowHandler) RespondActivityTaskCompletedByID ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) RespondActivityTaskCompletedByID( ctx context.Context, request *shared.RespondActivityTaskCompletedByIDRequest, ) error
RespondActivityTaskCompletedByID API call
func (*AccessControlledWorkflowHandler) RespondActivityTaskFailed ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) RespondActivityTaskFailed( ctx context.Context, request *shared.RespondActivityTaskFailedRequest, ) error
RespondActivityTaskFailed API call
func (*AccessControlledWorkflowHandler) RespondActivityTaskFailedByID ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) RespondActivityTaskFailedByID( ctx context.Context, request *shared.RespondActivityTaskFailedByIDRequest, ) error
RespondActivityTaskFailedByID API call
func (*AccessControlledWorkflowHandler) RespondDecisionTaskCompleted ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) RespondDecisionTaskCompleted( ctx context.Context, request *shared.RespondDecisionTaskCompletedRequest, ) (*shared.RespondDecisionTaskCompletedResponse, error)
RespondDecisionTaskCompleted API call
func (*AccessControlledWorkflowHandler) RespondDecisionTaskFailed ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) RespondDecisionTaskFailed( ctx context.Context, request *shared.RespondDecisionTaskFailedRequest, ) error
RespondDecisionTaskFailed API call
func (*AccessControlledWorkflowHandler) RespondQueryTaskCompleted ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) RespondQueryTaskCompleted( ctx context.Context, request *shared.RespondQueryTaskCompletedRequest, ) error
RespondQueryTaskCompleted API call
func (*AccessControlledWorkflowHandler) ScanWorkflowExecutions ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) ScanWorkflowExecutions( ctx context.Context, request *shared.ListWorkflowExecutionsRequest, ) (*shared.ListWorkflowExecutionsResponse, error)
ScanWorkflowExecutions API call
func (*AccessControlledWorkflowHandler) SignalWithStartWorkflowExecution ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) SignalWithStartWorkflowExecution( ctx context.Context, request *shared.SignalWithStartWorkflowExecutionRequest, ) (*shared.StartWorkflowExecutionResponse, error)
SignalWithStartWorkflowExecution API call
func (*AccessControlledWorkflowHandler) SignalWorkflowExecution ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) SignalWorkflowExecution( ctx context.Context, request *shared.SignalWorkflowExecutionRequest, ) error
SignalWorkflowExecution API call
func (*AccessControlledWorkflowHandler) StartWorkflowExecution ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) StartWorkflowExecution( ctx context.Context, request *shared.StartWorkflowExecutionRequest, ) (*shared.StartWorkflowExecutionResponse, error)
StartWorkflowExecution API call
func (*AccessControlledWorkflowHandler) TerminateWorkflowExecution ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) TerminateWorkflowExecution( ctx context.Context, request *shared.TerminateWorkflowExecutionRequest, ) error
TerminateWorkflowExecution API call
func (*AccessControlledWorkflowHandler) UpdateDomain ¶ added in v0.11.0
func (a *AccessControlledWorkflowHandler) UpdateDomain( ctx context.Context, request *shared.UpdateDomainRequest, ) (*shared.UpdateDomainResponse, error)
UpdateDomain API call
type AdminHandler ¶ added in v0.3.12
type AdminHandler interface { AddSearchAttribute(context.Context, *admin.AddSearchAttributeRequest) error CloseShard(context.Context, *gen.CloseShardRequest) error DescribeCluster(context.Context) (*admin.DescribeClusterResponse, error) DescribeHistoryHost(context.Context, *gen.DescribeHistoryHostRequest) (*gen.DescribeHistoryHostResponse, error) DescribeQueue(context.Context, *gen.DescribeQueueRequest) (*gen.DescribeQueueResponse, error) DescribeWorkflowExecution(context.Context, *admin.DescribeWorkflowExecutionRequest) (*admin.DescribeWorkflowExecutionResponse, error) GetDLQReplicationMessages(context.Context, *replicator.GetDLQReplicationMessagesRequest) (*replicator.GetDLQReplicationMessagesResponse, error) GetDomainReplicationMessages(context.Context, *replicator.GetDomainReplicationMessagesRequest) (*replicator.GetDomainReplicationMessagesResponse, error) GetReplicationMessages(context.Context, *replicator.GetReplicationMessagesRequest) (*replicator.GetReplicationMessagesResponse, error) GetWorkflowExecutionRawHistoryV2(context.Context, *admin.GetWorkflowExecutionRawHistoryV2Request) (*admin.GetWorkflowExecutionRawHistoryV2Response, error) MergeDLQMessages(context.Context, *replicator.MergeDLQMessagesRequest) (*replicator.MergeDLQMessagesResponse, error) PurgeDLQMessages(context.Context, *replicator.PurgeDLQMessagesRequest) error ReadDLQMessages(context.Context, *replicator.ReadDLQMessagesRequest) (*replicator.ReadDLQMessagesResponse, error) ReapplyEvents(context.Context, *gen.ReapplyEventsRequest) error RefreshWorkflowTasks(context.Context, *gen.RefreshWorkflowTasksRequest) error RemoveTask(context.Context, *gen.RemoveTaskRequest) error ResendReplicationTasks(context.Context, *admin.ResendReplicationTasksRequest) error ResetQueue(context.Context, *gen.ResetQueueRequest) error }
AdminHandler interface for admin service
type AdminThriftHandler ¶ added in v0.17.0
type AdminThriftHandler struct {
// contains filtered or unexported fields
}
AdminThriftHandler wrap underlying handler and handles Thrift related type conversions
func NewAdminThriftHandler ¶ added in v0.17.0
func NewAdminThriftHandler(h AdminHandler) AdminThriftHandler
NewAdminThriftHandler creates Thrift handler on top of underlying handler
func (AdminThriftHandler) AddSearchAttribute ¶ added in v0.17.0
func (t AdminThriftHandler) AddSearchAttribute(ctx context.Context, request *admin.AddSearchAttributeRequest) (err error)
AddSearchAttribute forwards request to the underlying handler
func (AdminThriftHandler) CloseShard ¶ added in v0.17.0
func (t AdminThriftHandler) CloseShard(ctx context.Context, request *shared.CloseShardRequest) (err error)
CloseShard forwards request to the underlying handler
func (AdminThriftHandler) DescribeCluster ¶ added in v0.17.0
func (t AdminThriftHandler) DescribeCluster(ctx context.Context) (response *admin.DescribeClusterResponse, err error)
DescribeCluster forwards request to the underlying handler
func (AdminThriftHandler) DescribeHistoryHost ¶ added in v0.17.0
func (t AdminThriftHandler) DescribeHistoryHost(ctx context.Context, request *shared.DescribeHistoryHostRequest) (response *shared.DescribeHistoryHostResponse, err error)
DescribeHistoryHost forwards request to the underlying handler
func (AdminThriftHandler) DescribeQueue ¶ added in v0.17.0
func (t AdminThriftHandler) DescribeQueue(ctx context.Context, request *shared.DescribeQueueRequest) (response *shared.DescribeQueueResponse, err error)
DescribeQueue forwards request to the underlying handler
func (AdminThriftHandler) DescribeWorkflowExecution ¶ added in v0.17.0
func (t AdminThriftHandler) DescribeWorkflowExecution(ctx context.Context, request *admin.DescribeWorkflowExecutionRequest) (response *admin.DescribeWorkflowExecutionResponse, err error)
DescribeWorkflowExecution forwards request to the underlying handler
func (AdminThriftHandler) GetDLQReplicationMessages ¶ added in v0.17.0
func (t AdminThriftHandler) GetDLQReplicationMessages(ctx context.Context, request *replicator.GetDLQReplicationMessagesRequest) (response *replicator.GetDLQReplicationMessagesResponse, err error)
GetDLQReplicationMessages forwards request to the underlying handler
func (AdminThriftHandler) GetDomainReplicationMessages ¶ added in v0.17.0
func (t AdminThriftHandler) GetDomainReplicationMessages(ctx context.Context, request *replicator.GetDomainReplicationMessagesRequest) (response *replicator.GetDomainReplicationMessagesResponse, err error)
GetDomainReplicationMessages forwards request to the underlying handler
func (AdminThriftHandler) GetReplicationMessages ¶ added in v0.17.0
func (t AdminThriftHandler) GetReplicationMessages(ctx context.Context, request *replicator.GetReplicationMessagesRequest) (response *replicator.GetReplicationMessagesResponse, err error)
GetReplicationMessages forwards request to the underlying handler
func (AdminThriftHandler) GetWorkflowExecutionRawHistoryV2 ¶ added in v0.17.0
func (t AdminThriftHandler) GetWorkflowExecutionRawHistoryV2(ctx context.Context, request *admin.GetWorkflowExecutionRawHistoryV2Request) (response *admin.GetWorkflowExecutionRawHistoryV2Response, err error)
GetWorkflowExecutionRawHistoryV2 forwards request to the underlying handler
func (AdminThriftHandler) MergeDLQMessages ¶ added in v0.17.0
func (t AdminThriftHandler) MergeDLQMessages(ctx context.Context, request *replicator.MergeDLQMessagesRequest) (response *replicator.MergeDLQMessagesResponse, err error)
MergeDLQMessages forwards request to the underlying handler
func (AdminThriftHandler) PurgeDLQMessages ¶ added in v0.17.0
func (t AdminThriftHandler) PurgeDLQMessages(ctx context.Context, request *replicator.PurgeDLQMessagesRequest) (err error)
PurgeDLQMessages forwards request to the underlying handler
func (AdminThriftHandler) ReadDLQMessages ¶ added in v0.17.0
func (t AdminThriftHandler) ReadDLQMessages(ctx context.Context, request *replicator.ReadDLQMessagesRequest) (response *replicator.ReadDLQMessagesResponse, err error)
ReadDLQMessages forwards request to the underlying handler
func (AdminThriftHandler) ReapplyEvents ¶ added in v0.17.0
func (t AdminThriftHandler) ReapplyEvents(ctx context.Context, request *shared.ReapplyEventsRequest) (err error)
ReapplyEvents forwards request to the underlying handler
func (AdminThriftHandler) RefreshWorkflowTasks ¶ added in v0.17.0
func (t AdminThriftHandler) RefreshWorkflowTasks(ctx context.Context, request *shared.RefreshWorkflowTasksRequest) (err error)
RefreshWorkflowTasks forwards request to the underlying handler
func (AdminThriftHandler) RemoveTask ¶ added in v0.17.0
func (t AdminThriftHandler) RemoveTask(ctx context.Context, request *shared.RemoveTaskRequest) (err error)
RemoveTask forwards request to the underlying handler
func (AdminThriftHandler) ResendReplicationTasks ¶ added in v0.17.0
func (t AdminThriftHandler) ResendReplicationTasks(ctx context.Context, request *admin.ResendReplicationTasksRequest) (err error)
ResendReplicationTasks forwards request to the underlying handler
func (AdminThriftHandler) ResetQueue ¶ added in v0.17.0
func (t AdminThriftHandler) ResetQueue(ctx context.Context, request *shared.ResetQueueRequest) (err error)
ResetQueue forwards request to the underlying handler
type Config ¶ added in v0.3.0
type Config struct { NumHistoryShards int PersistenceMaxQPS dynamicconfig.IntPropertyFn PersistenceGlobalMaxQPS 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 MaxDomainRPSPerInstance dynamicconfig.IntPropertyFnWithDomainFilter GlobalDomainRPS dynamicconfig.IntPropertyFnWithDomainFilter MaxIDLengthLimit dynamicconfig.IntPropertyFnWithDomainFilter MaxIDLengthWarnLimit dynamicconfig.IntPropertyFn MaxRawTaskListNameLimit dynamicconfig.IntPropertyFnWithDomainFilter EnableClientVersionCheck dynamicconfig.BoolPropertyFn DisallowQuery dynamicconfig.BoolPropertyFnWithDomainFilter ShutdownDrainDuration dynamicconfig.DurationPropertyFn // Persistence settings HistoryMgrNumConns dynamicconfig.IntPropertyFn // 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 EnableGracefulFailover dynamicconfig.BoolPropertyFn DomainFailoverRefreshInterval dynamicconfig.DurationPropertyFn DomainFailoverRefreshTimerJitterCoefficient dynamicconfig.FloatPropertyFn // ValidSearchAttributes is legal indexed keys that can be used in list APIs ValidSearchAttributes dynamicconfig.MapPropertyFn SearchAttributesNumberOfKeysLimit dynamicconfig.IntPropertyFnWithDomainFilter SearchAttributesSizeOfValueLimit dynamicconfig.IntPropertyFnWithDomainFilter SearchAttributesTotalSizeLimit dynamicconfig.IntPropertyFnWithDomainFilter // VisibilityArchival system protection VisibilityArchivalQueryMaxPageSize dynamicconfig.IntPropertyFn SendRawWorkflowHistory dynamicconfig.BoolPropertyFnWithDomainFilter // contains filtered or unexported fields }
Config represents configuration for cadence-frontend service
func NewConfig ¶ added in v0.3.0
func NewConfig(dc *dynamicconfig.Collection, numHistoryShards int, enableReadFromES bool, sendRawWorkflowHistory bool) *Config
NewConfig returns new service config with default values
type DCRedirectionHandlerImpl ¶ added in v0.5.2
type DCRedirectionHandlerImpl struct { resource.Resource // 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 Handler, resource resource.Resource, config *Config, 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) GetClusterInfo ¶ added in v0.11.0
func (handler *DCRedirectionHandlerImpl) GetClusterInfo( ctx context.Context, ) (*shared.ClusterInfo, error)
GetClusterInfo 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) ListTaskListPartitions ¶ added in v0.11.0
func (handler *DCRedirectionHandlerImpl) ListTaskListPartitions( ctx context.Context, request *shared.ListTaskListPartitionsRequest, ) (resp *shared.ListTaskListPartitionsResponse, retError error)
ListTaskListPartitions 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) 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) 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) 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) 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 Handler ¶ added in v0.13.0
type Handler interface { metaserver.Interface workflowserviceserver.Interface }
Handler is interface wrapping frontend handler
type HealthStatus ¶ added in v0.12.0
type HealthStatus int32
HealthStatus is an enum that refers to the rpc handler health status
const ( // HealthStatusOK is used when this node is healthy and rpc requests are allowed HealthStatusOK HealthStatus = iota + 1 // HealthStatusWarmingUp is used when the rpc handler is warming up HealthStatusWarmingUp // HealthStatusShuttingDown is used when the rpc handler is shutting down HealthStatusShuttingDown )
func (HealthStatus) String ¶ added in v0.12.0
func (hs HealthStatus) String() string
type MockAdminHandler ¶ added in v0.17.0
type MockAdminHandler struct {
// contains filtered or unexported fields
}
MockAdminHandler is a mock of AdminHandler interface
func NewMockAdminHandler ¶ added in v0.17.0
func NewMockAdminHandler(ctrl *gomock.Controller) *MockAdminHandler
NewMockAdminHandler creates a new mock instance
func (*MockAdminHandler) AddSearchAttribute ¶ added in v0.17.0
func (m *MockAdminHandler) AddSearchAttribute(arg0 context.Context, arg1 *admin.AddSearchAttributeRequest) error
AddSearchAttribute mocks base method
func (*MockAdminHandler) CloseShard ¶ added in v0.17.0
func (m *MockAdminHandler) CloseShard(arg0 context.Context, arg1 *shared.CloseShardRequest) error
CloseShard mocks base method
func (*MockAdminHandler) DescribeCluster ¶ added in v0.17.0
func (m *MockAdminHandler) DescribeCluster(arg0 context.Context) (*admin.DescribeClusterResponse, error)
DescribeCluster mocks base method
func (*MockAdminHandler) DescribeHistoryHost ¶ added in v0.17.0
func (m *MockAdminHandler) DescribeHistoryHost(arg0 context.Context, arg1 *shared.DescribeHistoryHostRequest) (*shared.DescribeHistoryHostResponse, error)
DescribeHistoryHost mocks base method
func (*MockAdminHandler) DescribeQueue ¶ added in v0.17.0
func (m *MockAdminHandler) DescribeQueue(arg0 context.Context, arg1 *shared.DescribeQueueRequest) (*shared.DescribeQueueResponse, error)
DescribeQueue mocks base method
func (*MockAdminHandler) DescribeWorkflowExecution ¶ added in v0.17.0
func (m *MockAdminHandler) DescribeWorkflowExecution(arg0 context.Context, arg1 *admin.DescribeWorkflowExecutionRequest) (*admin.DescribeWorkflowExecutionResponse, error)
DescribeWorkflowExecution mocks base method
func (*MockAdminHandler) EXPECT ¶ added in v0.17.0
func (m *MockAdminHandler) EXPECT() *MockAdminHandlerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockAdminHandler) GetDLQReplicationMessages ¶ added in v0.17.0
func (m *MockAdminHandler) GetDLQReplicationMessages(arg0 context.Context, arg1 *replicator.GetDLQReplicationMessagesRequest) (*replicator.GetDLQReplicationMessagesResponse, error)
GetDLQReplicationMessages mocks base method
func (*MockAdminHandler) GetDomainReplicationMessages ¶ added in v0.17.0
func (m *MockAdminHandler) GetDomainReplicationMessages(arg0 context.Context, arg1 *replicator.GetDomainReplicationMessagesRequest) (*replicator.GetDomainReplicationMessagesResponse, error)
GetDomainReplicationMessages mocks base method
func (*MockAdminHandler) GetReplicationMessages ¶ added in v0.17.0
func (m *MockAdminHandler) GetReplicationMessages(arg0 context.Context, arg1 *replicator.GetReplicationMessagesRequest) (*replicator.GetReplicationMessagesResponse, error)
GetReplicationMessages mocks base method
func (*MockAdminHandler) GetWorkflowExecutionRawHistoryV2 ¶ added in v0.17.0
func (m *MockAdminHandler) GetWorkflowExecutionRawHistoryV2(arg0 context.Context, arg1 *admin.GetWorkflowExecutionRawHistoryV2Request) (*admin.GetWorkflowExecutionRawHistoryV2Response, error)
GetWorkflowExecutionRawHistoryV2 mocks base method
func (*MockAdminHandler) MergeDLQMessages ¶ added in v0.17.0
func (m *MockAdminHandler) MergeDLQMessages(arg0 context.Context, arg1 *replicator.MergeDLQMessagesRequest) (*replicator.MergeDLQMessagesResponse, error)
MergeDLQMessages mocks base method
func (*MockAdminHandler) PurgeDLQMessages ¶ added in v0.17.0
func (m *MockAdminHandler) PurgeDLQMessages(arg0 context.Context, arg1 *replicator.PurgeDLQMessagesRequest) error
PurgeDLQMessages mocks base method
func (*MockAdminHandler) ReadDLQMessages ¶ added in v0.17.0
func (m *MockAdminHandler) ReadDLQMessages(arg0 context.Context, arg1 *replicator.ReadDLQMessagesRequest) (*replicator.ReadDLQMessagesResponse, error)
ReadDLQMessages mocks base method
func (*MockAdminHandler) ReapplyEvents ¶ added in v0.17.0
func (m *MockAdminHandler) ReapplyEvents(arg0 context.Context, arg1 *shared.ReapplyEventsRequest) error
ReapplyEvents mocks base method
func (*MockAdminHandler) RefreshWorkflowTasks ¶ added in v0.17.0
func (m *MockAdminHandler) RefreshWorkflowTasks(arg0 context.Context, arg1 *shared.RefreshWorkflowTasksRequest) error
RefreshWorkflowTasks mocks base method
func (*MockAdminHandler) RemoveTask ¶ added in v0.17.0
func (m *MockAdminHandler) RemoveTask(arg0 context.Context, arg1 *shared.RemoveTaskRequest) error
RemoveTask mocks base method
func (*MockAdminHandler) ResendReplicationTasks ¶ added in v0.17.0
func (m *MockAdminHandler) ResendReplicationTasks(arg0 context.Context, arg1 *admin.ResendReplicationTasksRequest) error
ResendReplicationTasks mocks base method
func (*MockAdminHandler) ResetQueue ¶ added in v0.17.0
func (m *MockAdminHandler) ResetQueue(arg0 context.Context, arg1 *shared.ResetQueueRequest) error
ResetQueue mocks base method
type MockAdminHandlerMockRecorder ¶ added in v0.17.0
type MockAdminHandlerMockRecorder struct {
// contains filtered or unexported fields
}
MockAdminHandlerMockRecorder is the mock recorder for MockAdminHandler
func (*MockAdminHandlerMockRecorder) AddSearchAttribute ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) AddSearchAttribute(arg0, arg1 interface{}) *gomock.Call
AddSearchAttribute indicates an expected call of AddSearchAttribute
func (*MockAdminHandlerMockRecorder) CloseShard ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) CloseShard(arg0, arg1 interface{}) *gomock.Call
CloseShard indicates an expected call of CloseShard
func (*MockAdminHandlerMockRecorder) DescribeCluster ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) DescribeCluster(arg0 interface{}) *gomock.Call
DescribeCluster indicates an expected call of DescribeCluster
func (*MockAdminHandlerMockRecorder) DescribeHistoryHost ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) DescribeHistoryHost(arg0, arg1 interface{}) *gomock.Call
DescribeHistoryHost indicates an expected call of DescribeHistoryHost
func (*MockAdminHandlerMockRecorder) DescribeQueue ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) DescribeQueue(arg0, arg1 interface{}) *gomock.Call
DescribeQueue indicates an expected call of DescribeQueue
func (*MockAdminHandlerMockRecorder) DescribeWorkflowExecution ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution
func (*MockAdminHandlerMockRecorder) GetDLQReplicationMessages ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) GetDLQReplicationMessages(arg0, arg1 interface{}) *gomock.Call
GetDLQReplicationMessages indicates an expected call of GetDLQReplicationMessages
func (*MockAdminHandlerMockRecorder) GetDomainReplicationMessages ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) GetDomainReplicationMessages(arg0, arg1 interface{}) *gomock.Call
GetDomainReplicationMessages indicates an expected call of GetDomainReplicationMessages
func (*MockAdminHandlerMockRecorder) GetReplicationMessages ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) GetReplicationMessages(arg0, arg1 interface{}) *gomock.Call
GetReplicationMessages indicates an expected call of GetReplicationMessages
func (*MockAdminHandlerMockRecorder) GetWorkflowExecutionRawHistoryV2 ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) GetWorkflowExecutionRawHistoryV2(arg0, arg1 interface{}) *gomock.Call
GetWorkflowExecutionRawHistoryV2 indicates an expected call of GetWorkflowExecutionRawHistoryV2
func (*MockAdminHandlerMockRecorder) MergeDLQMessages ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) MergeDLQMessages(arg0, arg1 interface{}) *gomock.Call
MergeDLQMessages indicates an expected call of MergeDLQMessages
func (*MockAdminHandlerMockRecorder) PurgeDLQMessages ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) PurgeDLQMessages(arg0, arg1 interface{}) *gomock.Call
PurgeDLQMessages indicates an expected call of PurgeDLQMessages
func (*MockAdminHandlerMockRecorder) ReadDLQMessages ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) ReadDLQMessages(arg0, arg1 interface{}) *gomock.Call
ReadDLQMessages indicates an expected call of ReadDLQMessages
func (*MockAdminHandlerMockRecorder) ReapplyEvents ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) ReapplyEvents(arg0, arg1 interface{}) *gomock.Call
ReapplyEvents indicates an expected call of ReapplyEvents
func (*MockAdminHandlerMockRecorder) RefreshWorkflowTasks ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) RefreshWorkflowTasks(arg0, arg1 interface{}) *gomock.Call
RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks
func (*MockAdminHandlerMockRecorder) RemoveTask ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) RemoveTask(arg0, arg1 interface{}) *gomock.Call
RemoveTask indicates an expected call of RemoveTask
func (*MockAdminHandlerMockRecorder) ResendReplicationTasks ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) ResendReplicationTasks(arg0, arg1 interface{}) *gomock.Call
ResendReplicationTasks indicates an expected call of ResendReplicationTasks
func (*MockAdminHandlerMockRecorder) ResetQueue ¶ added in v0.17.0
func (mr *MockAdminHandlerMockRecorder) ResetQueue(arg0, arg1 interface{}) *gomock.Call
ResetQueue indicates an expected call of ResetQueue
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 MockHandler ¶ added in v0.13.0
type MockHandler struct {
// contains filtered or unexported fields
}
MockHandler is a mock of Handler interface
func NewMockHandler ¶ added in v0.13.0
func NewMockHandler(ctrl *gomock.Controller) *MockHandler
NewMockHandler creates a new mock instance
func (*MockHandler) CountWorkflowExecutions ¶ added in v0.13.0
func (m *MockHandler) CountWorkflowExecutions(ctx context.Context, CountRequest *shared.CountWorkflowExecutionsRequest) (*shared.CountWorkflowExecutionsResponse, error)
CountWorkflowExecutions mocks base method
func (*MockHandler) DeprecateDomain ¶ added in v0.13.0
func (m *MockHandler) DeprecateDomain(ctx context.Context, DeprecateRequest *shared.DeprecateDomainRequest) error
DeprecateDomain mocks base method
func (*MockHandler) DescribeDomain ¶ added in v0.13.0
func (m *MockHandler) DescribeDomain(ctx context.Context, DescribeRequest *shared.DescribeDomainRequest) (*shared.DescribeDomainResponse, error)
DescribeDomain mocks base method
func (*MockHandler) DescribeTaskList ¶ added in v0.13.0
func (m *MockHandler) DescribeTaskList(ctx context.Context, Request *shared.DescribeTaskListRequest) (*shared.DescribeTaskListResponse, error)
DescribeTaskList mocks base method
func (*MockHandler) DescribeWorkflowExecution ¶ added in v0.13.0
func (m *MockHandler) DescribeWorkflowExecution(ctx context.Context, DescribeRequest *shared.DescribeWorkflowExecutionRequest) (*shared.DescribeWorkflowExecutionResponse, error)
DescribeWorkflowExecution mocks base method
func (*MockHandler) EXPECT ¶ added in v0.13.0
func (m *MockHandler) EXPECT() *MockHandlerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockHandler) GetClusterInfo ¶ added in v0.13.0
func (m *MockHandler) GetClusterInfo(ctx context.Context) (*shared.ClusterInfo, error)
GetClusterInfo mocks base method
func (*MockHandler) GetSearchAttributes ¶ added in v0.13.0
func (m *MockHandler) GetSearchAttributes(ctx context.Context) (*shared.GetSearchAttributesResponse, error)
GetSearchAttributes mocks base method
func (*MockHandler) GetWorkflowExecutionHistory ¶ added in v0.13.0
func (m *MockHandler) GetWorkflowExecutionHistory(ctx context.Context, GetRequest *shared.GetWorkflowExecutionHistoryRequest) (*shared.GetWorkflowExecutionHistoryResponse, error)
GetWorkflowExecutionHistory mocks base method
func (*MockHandler) Health ¶ added in v0.13.0
func (m *MockHandler) Health(ctx context.Context) (*health.HealthStatus, error)
Health mocks base method
func (*MockHandler) ListArchivedWorkflowExecutions ¶ added in v0.13.0
func (m *MockHandler) ListArchivedWorkflowExecutions(ctx context.Context, ListRequest *shared.ListArchivedWorkflowExecutionsRequest) (*shared.ListArchivedWorkflowExecutionsResponse, error)
ListArchivedWorkflowExecutions mocks base method
func (*MockHandler) ListClosedWorkflowExecutions ¶ added in v0.13.0
func (m *MockHandler) ListClosedWorkflowExecutions(ctx context.Context, ListRequest *shared.ListClosedWorkflowExecutionsRequest) (*shared.ListClosedWorkflowExecutionsResponse, error)
ListClosedWorkflowExecutions mocks base method
func (*MockHandler) ListDomains ¶ added in v0.13.0
func (m *MockHandler) ListDomains(ctx context.Context, ListRequest *shared.ListDomainsRequest) (*shared.ListDomainsResponse, error)
ListDomains mocks base method
func (*MockHandler) ListOpenWorkflowExecutions ¶ added in v0.13.0
func (m *MockHandler) ListOpenWorkflowExecutions(ctx context.Context, ListRequest *shared.ListOpenWorkflowExecutionsRequest) (*shared.ListOpenWorkflowExecutionsResponse, error)
ListOpenWorkflowExecutions mocks base method
func (*MockHandler) ListTaskListPartitions ¶ added in v0.13.0
func (m *MockHandler) ListTaskListPartitions(ctx context.Context, Request *shared.ListTaskListPartitionsRequest) (*shared.ListTaskListPartitionsResponse, error)
ListTaskListPartitions mocks base method
func (*MockHandler) ListWorkflowExecutions ¶ added in v0.13.0
func (m *MockHandler) ListWorkflowExecutions(ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, error)
ListWorkflowExecutions mocks base method
func (*MockHandler) PollForActivityTask ¶ added in v0.13.0
func (m *MockHandler) PollForActivityTask(ctx context.Context, PollRequest *shared.PollForActivityTaskRequest) (*shared.PollForActivityTaskResponse, error)
PollForActivityTask mocks base method
func (*MockHandler) PollForDecisionTask ¶ added in v0.13.0
func (m *MockHandler) PollForDecisionTask(ctx context.Context, PollRequest *shared.PollForDecisionTaskRequest) (*shared.PollForDecisionTaskResponse, error)
PollForDecisionTask mocks base method
func (*MockHandler) QueryWorkflow ¶ added in v0.13.0
func (m *MockHandler) QueryWorkflow(ctx context.Context, QueryRequest *shared.QueryWorkflowRequest) (*shared.QueryWorkflowResponse, error)
QueryWorkflow mocks base method
func (*MockHandler) RecordActivityTaskHeartbeat ¶ added in v0.13.0
func (m *MockHandler) RecordActivityTaskHeartbeat(ctx context.Context, HeartbeatRequest *shared.RecordActivityTaskHeartbeatRequest) (*shared.RecordActivityTaskHeartbeatResponse, error)
RecordActivityTaskHeartbeat mocks base method
func (*MockHandler) RecordActivityTaskHeartbeatByID ¶ added in v0.13.0
func (m *MockHandler) RecordActivityTaskHeartbeatByID(ctx context.Context, HeartbeatRequest *shared.RecordActivityTaskHeartbeatByIDRequest) (*shared.RecordActivityTaskHeartbeatResponse, error)
RecordActivityTaskHeartbeatByID mocks base method
func (*MockHandler) RegisterDomain ¶ added in v0.13.0
func (m *MockHandler) RegisterDomain(ctx context.Context, RegisterRequest *shared.RegisterDomainRequest) error
RegisterDomain mocks base method
func (*MockHandler) RequestCancelWorkflowExecution ¶ added in v0.13.0
func (m *MockHandler) RequestCancelWorkflowExecution(ctx context.Context, CancelRequest *shared.RequestCancelWorkflowExecutionRequest) error
RequestCancelWorkflowExecution mocks base method
func (*MockHandler) ResetStickyTaskList ¶ added in v0.13.0
func (m *MockHandler) ResetStickyTaskList(ctx context.Context, ResetRequest *shared.ResetStickyTaskListRequest) (*shared.ResetStickyTaskListResponse, error)
ResetStickyTaskList mocks base method
func (*MockHandler) ResetWorkflowExecution ¶ added in v0.13.0
func (m *MockHandler) ResetWorkflowExecution(ctx context.Context, ResetRequest *shared.ResetWorkflowExecutionRequest) (*shared.ResetWorkflowExecutionResponse, error)
ResetWorkflowExecution mocks base method
func (*MockHandler) RespondActivityTaskCanceled ¶ added in v0.13.0
func (m *MockHandler) RespondActivityTaskCanceled(ctx context.Context, CanceledRequest *shared.RespondActivityTaskCanceledRequest) error
RespondActivityTaskCanceled mocks base method
func (*MockHandler) RespondActivityTaskCanceledByID ¶ added in v0.13.0
func (m *MockHandler) RespondActivityTaskCanceledByID(ctx context.Context, CanceledRequest *shared.RespondActivityTaskCanceledByIDRequest) error
RespondActivityTaskCanceledByID mocks base method
func (*MockHandler) RespondActivityTaskCompleted ¶ added in v0.13.0
func (m *MockHandler) RespondActivityTaskCompleted(ctx context.Context, CompleteRequest *shared.RespondActivityTaskCompletedRequest) error
RespondActivityTaskCompleted mocks base method
func (*MockHandler) RespondActivityTaskCompletedByID ¶ added in v0.13.0
func (m *MockHandler) RespondActivityTaskCompletedByID(ctx context.Context, CompleteRequest *shared.RespondActivityTaskCompletedByIDRequest) error
RespondActivityTaskCompletedByID mocks base method
func (*MockHandler) RespondActivityTaskFailed ¶ added in v0.13.0
func (m *MockHandler) RespondActivityTaskFailed(ctx context.Context, FailRequest *shared.RespondActivityTaskFailedRequest) error
RespondActivityTaskFailed mocks base method
func (*MockHandler) RespondActivityTaskFailedByID ¶ added in v0.13.0
func (m *MockHandler) RespondActivityTaskFailedByID(ctx context.Context, FailRequest *shared.RespondActivityTaskFailedByIDRequest) error
RespondActivityTaskFailedByID mocks base method
func (*MockHandler) RespondDecisionTaskCompleted ¶ added in v0.13.0
func (m *MockHandler) RespondDecisionTaskCompleted(ctx context.Context, CompleteRequest *shared.RespondDecisionTaskCompletedRequest) (*shared.RespondDecisionTaskCompletedResponse, error)
RespondDecisionTaskCompleted mocks base method
func (*MockHandler) RespondDecisionTaskFailed ¶ added in v0.13.0
func (m *MockHandler) RespondDecisionTaskFailed(ctx context.Context, FailedRequest *shared.RespondDecisionTaskFailedRequest) error
RespondDecisionTaskFailed mocks base method
func (*MockHandler) RespondQueryTaskCompleted ¶ added in v0.13.0
func (m *MockHandler) RespondQueryTaskCompleted(ctx context.Context, CompleteRequest *shared.RespondQueryTaskCompletedRequest) error
RespondQueryTaskCompleted mocks base method
func (*MockHandler) ScanWorkflowExecutions ¶ added in v0.13.0
func (m *MockHandler) ScanWorkflowExecutions(ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, error)
ScanWorkflowExecutions mocks base method
func (*MockHandler) SignalWithStartWorkflowExecution ¶ added in v0.13.0
func (m *MockHandler) SignalWithStartWorkflowExecution(ctx context.Context, SignalWithStartRequest *shared.SignalWithStartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)
SignalWithStartWorkflowExecution mocks base method
func (*MockHandler) SignalWorkflowExecution ¶ added in v0.13.0
func (m *MockHandler) SignalWorkflowExecution(ctx context.Context, SignalRequest *shared.SignalWorkflowExecutionRequest) error
SignalWorkflowExecution mocks base method
func (*MockHandler) StartWorkflowExecution ¶ added in v0.13.0
func (m *MockHandler) StartWorkflowExecution(ctx context.Context, StartRequest *shared.StartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)
StartWorkflowExecution mocks base method
func (*MockHandler) TerminateWorkflowExecution ¶ added in v0.13.0
func (m *MockHandler) TerminateWorkflowExecution(ctx context.Context, TerminateRequest *shared.TerminateWorkflowExecutionRequest) error
TerminateWorkflowExecution mocks base method
func (*MockHandler) UpdateDomain ¶ added in v0.13.0
func (m *MockHandler) UpdateDomain(ctx context.Context, UpdateRequest *shared.UpdateDomainRequest) (*shared.UpdateDomainResponse, error)
UpdateDomain mocks base method
type MockHandlerMockRecorder ¶ added in v0.13.0
type MockHandlerMockRecorder struct {
// contains filtered or unexported fields
}
MockHandlerMockRecorder is the mock recorder for MockHandler
func (*MockHandlerMockRecorder) CountWorkflowExecutions ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) CountWorkflowExecutions(ctx, CountRequest interface{}) *gomock.Call
CountWorkflowExecutions indicates an expected call of CountWorkflowExecutions
func (*MockHandlerMockRecorder) DeprecateDomain ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) DeprecateDomain(ctx, DeprecateRequest interface{}) *gomock.Call
DeprecateDomain indicates an expected call of DeprecateDomain
func (*MockHandlerMockRecorder) DescribeDomain ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) DescribeDomain(ctx, DescribeRequest interface{}) *gomock.Call
DescribeDomain indicates an expected call of DescribeDomain
func (*MockHandlerMockRecorder) DescribeTaskList ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) DescribeTaskList(ctx, Request interface{}) *gomock.Call
DescribeTaskList indicates an expected call of DescribeTaskList
func (*MockHandlerMockRecorder) DescribeWorkflowExecution ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) DescribeWorkflowExecution(ctx, DescribeRequest interface{}) *gomock.Call
DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution
func (*MockHandlerMockRecorder) GetClusterInfo ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) GetClusterInfo(ctx interface{}) *gomock.Call
GetClusterInfo indicates an expected call of GetClusterInfo
func (*MockHandlerMockRecorder) GetSearchAttributes ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) GetSearchAttributes(ctx interface{}) *gomock.Call
GetSearchAttributes indicates an expected call of GetSearchAttributes
func (*MockHandlerMockRecorder) GetWorkflowExecutionHistory ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) GetWorkflowExecutionHistory(ctx, GetRequest interface{}) *gomock.Call
GetWorkflowExecutionHistory indicates an expected call of GetWorkflowExecutionHistory
func (*MockHandlerMockRecorder) Health ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) Health(ctx interface{}) *gomock.Call
Health indicates an expected call of Health
func (*MockHandlerMockRecorder) ListArchivedWorkflowExecutions ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) ListArchivedWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
ListArchivedWorkflowExecutions indicates an expected call of ListArchivedWorkflowExecutions
func (*MockHandlerMockRecorder) ListClosedWorkflowExecutions ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) ListClosedWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
ListClosedWorkflowExecutions indicates an expected call of ListClosedWorkflowExecutions
func (*MockHandlerMockRecorder) ListDomains ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) ListDomains(ctx, ListRequest interface{}) *gomock.Call
ListDomains indicates an expected call of ListDomains
func (*MockHandlerMockRecorder) ListOpenWorkflowExecutions ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) ListOpenWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
ListOpenWorkflowExecutions indicates an expected call of ListOpenWorkflowExecutions
func (*MockHandlerMockRecorder) ListTaskListPartitions ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) ListTaskListPartitions(ctx, Request interface{}) *gomock.Call
ListTaskListPartitions indicates an expected call of ListTaskListPartitions
func (*MockHandlerMockRecorder) ListWorkflowExecutions ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) ListWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
ListWorkflowExecutions indicates an expected call of ListWorkflowExecutions
func (*MockHandlerMockRecorder) PollForActivityTask ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) PollForActivityTask(ctx, PollRequest interface{}) *gomock.Call
PollForActivityTask indicates an expected call of PollForActivityTask
func (*MockHandlerMockRecorder) PollForDecisionTask ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) PollForDecisionTask(ctx, PollRequest interface{}) *gomock.Call
PollForDecisionTask indicates an expected call of PollForDecisionTask
func (*MockHandlerMockRecorder) QueryWorkflow ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) QueryWorkflow(ctx, QueryRequest interface{}) *gomock.Call
QueryWorkflow indicates an expected call of QueryWorkflow
func (*MockHandlerMockRecorder) RecordActivityTaskHeartbeat ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) RecordActivityTaskHeartbeat(ctx, HeartbeatRequest interface{}) *gomock.Call
RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat
func (*MockHandlerMockRecorder) RecordActivityTaskHeartbeatByID ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) RecordActivityTaskHeartbeatByID(ctx, HeartbeatRequest interface{}) *gomock.Call
RecordActivityTaskHeartbeatByID indicates an expected call of RecordActivityTaskHeartbeatByID
func (*MockHandlerMockRecorder) RegisterDomain ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) RegisterDomain(ctx, RegisterRequest interface{}) *gomock.Call
RegisterDomain indicates an expected call of RegisterDomain
func (*MockHandlerMockRecorder) RequestCancelWorkflowExecution ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) RequestCancelWorkflowExecution(ctx, CancelRequest interface{}) *gomock.Call
RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution
func (*MockHandlerMockRecorder) ResetStickyTaskList ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) ResetStickyTaskList(ctx, ResetRequest interface{}) *gomock.Call
ResetStickyTaskList indicates an expected call of ResetStickyTaskList
func (*MockHandlerMockRecorder) ResetWorkflowExecution ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) ResetWorkflowExecution(ctx, ResetRequest interface{}) *gomock.Call
ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution
func (*MockHandlerMockRecorder) RespondActivityTaskCanceled ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) RespondActivityTaskCanceled(ctx, CanceledRequest interface{}) *gomock.Call
RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled
func (*MockHandlerMockRecorder) RespondActivityTaskCanceledByID ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) RespondActivityTaskCanceledByID(ctx, CanceledRequest interface{}) *gomock.Call
RespondActivityTaskCanceledByID indicates an expected call of RespondActivityTaskCanceledByID
func (*MockHandlerMockRecorder) RespondActivityTaskCompleted ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) RespondActivityTaskCompleted(ctx, CompleteRequest interface{}) *gomock.Call
RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted
func (*MockHandlerMockRecorder) RespondActivityTaskCompletedByID ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) RespondActivityTaskCompletedByID(ctx, CompleteRequest interface{}) *gomock.Call
RespondActivityTaskCompletedByID indicates an expected call of RespondActivityTaskCompletedByID
func (*MockHandlerMockRecorder) RespondActivityTaskFailed ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) RespondActivityTaskFailed(ctx, FailRequest interface{}) *gomock.Call
RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed
func (*MockHandlerMockRecorder) RespondActivityTaskFailedByID ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) RespondActivityTaskFailedByID(ctx, FailRequest interface{}) *gomock.Call
RespondActivityTaskFailedByID indicates an expected call of RespondActivityTaskFailedByID
func (*MockHandlerMockRecorder) RespondDecisionTaskCompleted ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) RespondDecisionTaskCompleted(ctx, CompleteRequest interface{}) *gomock.Call
RespondDecisionTaskCompleted indicates an expected call of RespondDecisionTaskCompleted
func (*MockHandlerMockRecorder) RespondDecisionTaskFailed ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) RespondDecisionTaskFailed(ctx, FailedRequest interface{}) *gomock.Call
RespondDecisionTaskFailed indicates an expected call of RespondDecisionTaskFailed
func (*MockHandlerMockRecorder) RespondQueryTaskCompleted ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) RespondQueryTaskCompleted(ctx, CompleteRequest interface{}) *gomock.Call
RespondQueryTaskCompleted indicates an expected call of RespondQueryTaskCompleted
func (*MockHandlerMockRecorder) ScanWorkflowExecutions ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) ScanWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call
ScanWorkflowExecutions indicates an expected call of ScanWorkflowExecutions
func (*MockHandlerMockRecorder) SignalWithStartWorkflowExecution ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) SignalWithStartWorkflowExecution(ctx, SignalWithStartRequest interface{}) *gomock.Call
SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution
func (*MockHandlerMockRecorder) SignalWorkflowExecution ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) SignalWorkflowExecution(ctx, SignalRequest interface{}) *gomock.Call
SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution
func (*MockHandlerMockRecorder) StartWorkflowExecution ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) StartWorkflowExecution(ctx, StartRequest interface{}) *gomock.Call
StartWorkflowExecution indicates an expected call of StartWorkflowExecution
func (*MockHandlerMockRecorder) TerminateWorkflowExecution ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) TerminateWorkflowExecution(ctx, TerminateRequest interface{}) *gomock.Call
TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution
func (*MockHandlerMockRecorder) UpdateDomain ¶ added in v0.13.0
func (mr *MockHandlerMockRecorder) 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 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) CountWorkflowExecutions ¶ added in v0.17.0
func (t ThriftHandler) CountWorkflowExecutions(ctx context.Context, request *shared.CountWorkflowExecutionsRequest) (response *shared.CountWorkflowExecutionsResponse, err error)
CountWorkflowExecutions forwards request to the underlying handler
func (ThriftHandler) DeprecateDomain ¶ added in v0.17.0
func (t ThriftHandler) DeprecateDomain(ctx context.Context, request *shared.DeprecateDomainRequest) (err error)
DeprecateDomain forwards request to the underlying handler
func (ThriftHandler) DescribeDomain ¶ added in v0.17.0
func (t ThriftHandler) DescribeDomain(ctx context.Context, request *shared.DescribeDomainRequest) (response *shared.DescribeDomainResponse, err error)
DescribeDomain forwards request to the underlying handler
func (ThriftHandler) DescribeTaskList ¶ added in v0.17.0
func (t ThriftHandler) DescribeTaskList(ctx context.Context, request *shared.DescribeTaskListRequest) (response *shared.DescribeTaskListResponse, err error)
DescribeTaskList forwards request to the underlying handler
func (ThriftHandler) DescribeWorkflowExecution ¶ added in v0.17.0
func (t ThriftHandler) DescribeWorkflowExecution(ctx context.Context, request *shared.DescribeWorkflowExecutionRequest) (response *shared.DescribeWorkflowExecutionResponse, err error)
DescribeWorkflowExecution forwards request to the underlying handler
func (ThriftHandler) GetClusterInfo ¶ added in v0.17.0
func (t ThriftHandler) GetClusterInfo(ctx context.Context) (response *shared.ClusterInfo, err error)
GetClusterInfo forwards request to the underlying handler
func (ThriftHandler) GetSearchAttributes ¶ added in v0.17.0
func (t ThriftHandler) GetSearchAttributes(ctx context.Context) (response *shared.GetSearchAttributesResponse, err error)
GetSearchAttributes forwards request to the underlying handler
func (ThriftHandler) GetWorkflowExecutionHistory ¶ added in v0.17.0
func (t ThriftHandler) GetWorkflowExecutionHistory(ctx context.Context, request *shared.GetWorkflowExecutionHistoryRequest) (response *shared.GetWorkflowExecutionHistoryResponse, err error)
GetWorkflowExecutionHistory 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) ListArchivedWorkflowExecutions ¶ added in v0.17.0
func (t ThriftHandler) ListArchivedWorkflowExecutions(ctx context.Context, request *shared.ListArchivedWorkflowExecutionsRequest) (response *shared.ListArchivedWorkflowExecutionsResponse, err error)
ListArchivedWorkflowExecutions forwards request to the underlying handler
func (ThriftHandler) ListClosedWorkflowExecutions ¶ added in v0.17.0
func (t ThriftHandler) ListClosedWorkflowExecutions(ctx context.Context, request *shared.ListClosedWorkflowExecutionsRequest) (response *shared.ListClosedWorkflowExecutionsResponse, err error)
ListClosedWorkflowExecutions forwards request to the underlying handler
func (ThriftHandler) ListDomains ¶ added in v0.17.0
func (t ThriftHandler) ListDomains(ctx context.Context, request *shared.ListDomainsRequest) (response *shared.ListDomainsResponse, err error)
ListDomains forwards request to the underlying handler
func (ThriftHandler) ListOpenWorkflowExecutions ¶ added in v0.17.0
func (t ThriftHandler) ListOpenWorkflowExecutions(ctx context.Context, request *shared.ListOpenWorkflowExecutionsRequest) (response *shared.ListOpenWorkflowExecutionsResponse, err error)
ListOpenWorkflowExecutions forwards request to the underlying handler
func (ThriftHandler) ListTaskListPartitions ¶ added in v0.17.0
func (t ThriftHandler) ListTaskListPartitions(ctx context.Context, request *shared.ListTaskListPartitionsRequest) (response *shared.ListTaskListPartitionsResponse, err error)
ListTaskListPartitions forwards request to the underlying handler
func (ThriftHandler) ListWorkflowExecutions ¶ added in v0.17.0
func (t ThriftHandler) ListWorkflowExecutions(ctx context.Context, request *shared.ListWorkflowExecutionsRequest) (response *shared.ListWorkflowExecutionsResponse, err error)
ListWorkflowExecutions forwards request to the underlying handler
func (ThriftHandler) PollForActivityTask ¶ added in v0.17.0
func (t ThriftHandler) PollForActivityTask(ctx context.Context, request *shared.PollForActivityTaskRequest) (response *shared.PollForActivityTaskResponse, err error)
PollForActivityTask forwards request to the underlying handler
func (ThriftHandler) PollForDecisionTask ¶ added in v0.17.0
func (t ThriftHandler) PollForDecisionTask(ctx context.Context, request *shared.PollForDecisionTaskRequest) (response *shared.PollForDecisionTaskResponse, err error)
PollForDecisionTask forwards request to the underlying handler
func (ThriftHandler) QueryWorkflow ¶ added in v0.17.0
func (t ThriftHandler) QueryWorkflow(ctx context.Context, request *shared.QueryWorkflowRequest) (response *shared.QueryWorkflowResponse, err error)
QueryWorkflow forwards request to the underlying handler
func (ThriftHandler) RecordActivityTaskHeartbeat ¶ added in v0.17.0
func (t ThriftHandler) RecordActivityTaskHeartbeat(ctx context.Context, request *shared.RecordActivityTaskHeartbeatRequest) (response *shared.RecordActivityTaskHeartbeatResponse, err error)
RecordActivityTaskHeartbeat forwards request to the underlying handler
func (ThriftHandler) RecordActivityTaskHeartbeatByID ¶ added in v0.17.0
func (t ThriftHandler) RecordActivityTaskHeartbeatByID(ctx context.Context, request *shared.RecordActivityTaskHeartbeatByIDRequest) (response *shared.RecordActivityTaskHeartbeatResponse, err error)
RecordActivityTaskHeartbeatByID forwards request to the underlying handler
func (ThriftHandler) RegisterDomain ¶ added in v0.17.0
func (t ThriftHandler) RegisterDomain(ctx context.Context, request *shared.RegisterDomainRequest) (err error)
RegisterDomain forwards request to the underlying handler
func (ThriftHandler) RequestCancelWorkflowExecution ¶ added in v0.17.0
func (t ThriftHandler) RequestCancelWorkflowExecution(ctx context.Context, request *shared.RequestCancelWorkflowExecutionRequest) (err error)
RequestCancelWorkflowExecution forwards request to the underlying handler
func (ThriftHandler) ResetStickyTaskList ¶ added in v0.17.0
func (t ThriftHandler) ResetStickyTaskList(ctx context.Context, request *shared.ResetStickyTaskListRequest) (response *shared.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 *shared.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 *shared.RespondActivityTaskCanceledRequest) (err error)
RespondActivityTaskCanceled forwards request to the underlying handler
func (ThriftHandler) RespondActivityTaskCanceledByID ¶ added in v0.17.0
func (t ThriftHandler) RespondActivityTaskCanceledByID(ctx context.Context, request *shared.RespondActivityTaskCanceledByIDRequest) (err error)
RespondActivityTaskCanceledByID forwards request to the underlying handler
func (ThriftHandler) RespondActivityTaskCompleted ¶ added in v0.17.0
func (t ThriftHandler) RespondActivityTaskCompleted(ctx context.Context, request *shared.RespondActivityTaskCompletedRequest) (err error)
RespondActivityTaskCompleted forwards request to the underlying handler
func (ThriftHandler) RespondActivityTaskCompletedByID ¶ added in v0.17.0
func (t ThriftHandler) RespondActivityTaskCompletedByID(ctx context.Context, request *shared.RespondActivityTaskCompletedByIDRequest) (err error)
RespondActivityTaskCompletedByID forwards request to the underlying handler
func (ThriftHandler) RespondActivityTaskFailed ¶ added in v0.17.0
func (t ThriftHandler) RespondActivityTaskFailed(ctx context.Context, request *shared.RespondActivityTaskFailedRequest) (err error)
RespondActivityTaskFailed forwards request to the underlying handler
func (ThriftHandler) RespondActivityTaskFailedByID ¶ added in v0.17.0
func (t ThriftHandler) RespondActivityTaskFailedByID(ctx context.Context, request *shared.RespondActivityTaskFailedByIDRequest) (err error)
RespondActivityTaskFailedByID forwards request to the underlying handler
func (ThriftHandler) RespondDecisionTaskCompleted ¶ added in v0.17.0
func (t ThriftHandler) RespondDecisionTaskCompleted(ctx context.Context, request *shared.RespondDecisionTaskCompletedRequest) (response *shared.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 *shared.RespondDecisionTaskFailedRequest) (err error)
RespondDecisionTaskFailed forwards request to the underlying handler
func (ThriftHandler) RespondQueryTaskCompleted ¶ added in v0.17.0
func (t ThriftHandler) RespondQueryTaskCompleted(ctx context.Context, request *shared.RespondQueryTaskCompletedRequest) (err error)
RespondQueryTaskCompleted forwards request to the underlying handler
func (ThriftHandler) ScanWorkflowExecutions ¶ added in v0.17.0
func (t ThriftHandler) ScanWorkflowExecutions(ctx context.Context, request *shared.ListWorkflowExecutionsRequest) (response *shared.ListWorkflowExecutionsResponse, err error)
ScanWorkflowExecutions forwards request to the underlying handler
func (ThriftHandler) SignalWithStartWorkflowExecution ¶ added in v0.17.0
func (t ThriftHandler) SignalWithStartWorkflowExecution(ctx context.Context, request *shared.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 *shared.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 *shared.StartWorkflowExecutionRequest) (response *shared.StartWorkflowExecutionResponse, err error)
StartWorkflowExecution forwards request to the underlying handler
func (ThriftHandler) TerminateWorkflowExecution ¶ added in v0.17.0
func (t ThriftHandler) TerminateWorkflowExecution(ctx context.Context, request *shared.TerminateWorkflowExecutionRequest) (err error)
TerminateWorkflowExecution forwards request to the underlying handler
func (ThriftHandler) UpdateDomain ¶ added in v0.17.0
func (t ThriftHandler) UpdateDomain(ctx context.Context, request *shared.UpdateDomainRequest) (response *shared.UpdateDomainResponse, err error)
UpdateDomain forwards request to the underlying handler
type WorkflowHandler ¶
WorkflowHandler - Thrift handler interface for workflow service
func NewWorkflowHandler ¶
func NewWorkflowHandler( resource resource.Resource, config *Config, replicationMessageSink messaging.Producer, versionChecker client.VersionChecker, ) *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) GetClusterInfo ¶ added in v0.11.0
func (wh *WorkflowHandler) GetClusterInfo( ctx context.Context, ) (resp *gen.ClusterInfo, err error)
GetClusterInfo return information about cadence deployment
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) ListTaskListPartitions ¶ added in v0.11.0
func (wh *WorkflowHandler) ListTaskListPartitions( ctx context.Context, request *gen.ListTaskListPartitionsRequest, ) (resp *gen.ListTaskListPartitionsResponse, retError error)
ListTaskListPartitions returns all the partition and host for a taskList
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) 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) 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.
func (*WorkflowHandler) UpdateHealthStatus ¶ added in v0.12.0
func (wh *WorkflowHandler) UpdateHealthStatus(status HealthStatus)
UpdateHealthStatus sets the health status for this rpc handler. This health status will be used within the rpc health check handler