frontend

package
v1.2.7-prerelease1 Latest Latest
Warning

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

 Go to latest Published: Dec 8, 2023 License: MIT Imports: 56 Imported by: 7

Documentation

Overview

Package frontend is a generated GoMock package.

Package frontend is a generated GoMock package.

Index

Constants

View Source 
const (
	// DCRedirectionPolicyDefault means no redirection
	DCRedirectionPolicyDefault = ""
	// DCRedirectionPolicyNoop means no redirection
	DCRedirectionPolicyNoop = "noop"
	// DCRedirectionPolicySelectedAPIsForwarding means forwarding the following non-worker APIs based domain
	// 1. StartWorkflowExecution
	// 2. SignalWithStartWorkflowExecution
	// 3. SignalWorkflowExecution
	// 4. RequestCancelWorkflowExecution
	// 5. TerminateWorkflowExecution
	// 6. QueryWorkflowStrongConsistency
	// 7. ResetWorkflow
	// please also reference selectedAPIsForwardingRedirectionPolicyAPIAllowlist and DCRedirectionPolicySelectedAPIsForwardingV2
	DCRedirectionPolicySelectedAPIsForwarding = "selected-apis-forwarding"
	// DCRedirectionPolicySelectedAPIsForwardingV2 forwards everything in DCRedirectionPolicySelectedAPIsForwarding,
	// as well as activity completions (sync and async) and heartbeats.
	// This is done because activity results are generally deemed "useful" and relatively costly to re-do (when it is
	// even possible to redo), but activity workers themselves may be datacenter-specific.
	//
	// This will likely replace DCRedirectionPolicySelectedAPIsForwarding soon.
	//
	// 1-7. from DCRedirectionPolicySelectedAPIsForwarding
	// 8. RecordActivityTaskHeartbeat
	// 9. RecordActivityTaskHeartbeatByID
	// 10. RespondActivityTaskCanceled
	// 11. RespondActivityTaskCanceledByID
	// 12. RespondActivityTaskCompleted
	// 13. RespondActivityTaskCompletedByID
	// 14. RespondActivityTaskFailed
	// 15. RespondActivityTaskFailedByID
	// please also reference selectedAPIsForwardingRedirectionPolicyAPIAllowlistV2
	DCRedirectionPolicySelectedAPIsForwardingV2 = "selected-apis-forwarding-v2"
	// DCRedirectionPolicyAllDomainAPIsForwarding means forwarding all the worker and non-worker APIs based domain,
	// and falling back to DCRedirectionPolicySelectedAPIsForwarding when the current active cluster is not the
	// cluster migration target.
	DCRedirectionPolicyAllDomainAPIsForwarding = "all-domain-apis-forwarding"
	// DCRedirectionPolicyAllDomainAPIsForwardingV2 means forwarding all the worker and non-worker APIs based domain,
	// and falling back to DCRedirectionPolicySelectedAPIsForwardingV2 when the current active cluster is not the
	// cluster migration target.
	DCRedirectionPolicyAllDomainAPIsForwardingV2 = "all-domain-apis-forwarding-v2"
)

Variables

This section is empty.

Functions

func NewService 

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

NewService builds a new cadence-frontend service

Types

type AccessControlledWorkflowAdminHandler added in v0.23.1 

type AccessControlledWorkflowAdminHandler struct {
	AdminHandler
	// contains filtered or unexported fields
}

AccessControlledWorkflowAdminHandler frontend handler wrapper for authentication and authorization

func NewAccessControlledAdminHandlerImpl added in v0.23.1 

func NewAccessControlledAdminHandlerImpl(adminHandler AdminHandler, resource resource.Resource, authorizer authorization.Authorizer, cfg config.Authorization) *AccessControlledWorkflowAdminHandler

NewAccessControlledAdminHandlerImpl creates frontend handler with authentication support

func (*AccessControlledWorkflowAdminHandler) AddSearchAttribute added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) AddSearchAttribute(ctx context.Context, request *types.AddSearchAttributeRequest) error

func (*AccessControlledWorkflowAdminHandler) CloseShard added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) CloseShard(ctx context.Context, request *types.CloseShardRequest) error

func (*AccessControlledWorkflowAdminHandler) DeleteWorkflow added in v0.24.0 

func (a *AccessControlledWorkflowAdminHandler) DeleteWorkflow(ctx context.Context, request *types.AdminDeleteWorkflowRequest) (*types.AdminDeleteWorkflowResponse, error)

func (*AccessControlledWorkflowAdminHandler) DescribeCluster added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) DescribeCluster(ctx context.Context) (*types.DescribeClusterResponse, error)

func (*AccessControlledWorkflowAdminHandler) DescribeHistoryHost added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) DescribeHistoryHost(ctx context.Context, request *types.DescribeHistoryHostRequest) (*types.DescribeHistoryHostResponse, error)

func (*AccessControlledWorkflowAdminHandler) DescribeQueue added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) DescribeQueue(ctx context.Context, request *types.DescribeQueueRequest) (*types.DescribeQueueResponse, error)

func (*AccessControlledWorkflowAdminHandler) DescribeShardDistribution added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) DescribeShardDistribution(ctx context.Context, request *types.DescribeShardDistributionRequest) (*types.DescribeShardDistributionResponse, error)

func (*AccessControlledWorkflowAdminHandler) DescribeWorkflowExecution added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) DescribeWorkflowExecution(ctx context.Context, request *types.AdminDescribeWorkflowExecutionRequest) (*types.AdminDescribeWorkflowExecutionResponse, error)

func (*AccessControlledWorkflowAdminHandler) GetCrossClusterTasks added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) GetCrossClusterTasks(ctx context.Context, request *types.GetCrossClusterTasksRequest) (*types.GetCrossClusterTasksResponse, error)

func (*AccessControlledWorkflowAdminHandler) GetDLQReplicationMessages added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) GetDLQReplicationMessages(ctx context.Context, request *types.GetDLQReplicationMessagesRequest) (*types.GetDLQReplicationMessagesResponse, error)

func (*AccessControlledWorkflowAdminHandler) GetDomainReplicationMessages added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) GetDomainReplicationMessages(ctx context.Context, request *types.GetDomainReplicationMessagesRequest) (*types.GetDomainReplicationMessagesResponse, error)

func (*AccessControlledWorkflowAdminHandler) GetDynamicConfig added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) GetDynamicConfig(ctx context.Context, request *types.GetDynamicConfigRequest) (*types.GetDynamicConfigResponse, error)

func (*AccessControlledWorkflowAdminHandler) GetReplicationMessages added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) GetReplicationMessages(ctx context.Context, request *types.GetReplicationMessagesRequest) (*types.GetReplicationMessagesResponse, error)

func (*AccessControlledWorkflowAdminHandler) GetWorkflowExecutionRawHistoryV2 added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) GetWorkflowExecutionRawHistoryV2(ctx context.Context, request *types.GetWorkflowExecutionRawHistoryV2Request) (*types.GetWorkflowExecutionRawHistoryV2Response, error)

func (*AccessControlledWorkflowAdminHandler) ListDynamicConfig added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) ListDynamicConfig(ctx context.Context, request *types.ListDynamicConfigRequest) (*types.ListDynamicConfigResponse, error)

func (*AccessControlledWorkflowAdminHandler) MaintainCorruptWorkflow added in v0.24.0 

func (a *AccessControlledWorkflowAdminHandler) MaintainCorruptWorkflow(ctx context.Context, request *types.AdminMaintainWorkflowRequest) (*types.AdminMaintainWorkflowResponse, error)

func (*AccessControlledWorkflowAdminHandler) MergeDLQMessages added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) MergeDLQMessages(ctx context.Context, request *types.MergeDLQMessagesRequest) (*types.MergeDLQMessagesResponse, error)

func (*AccessControlledWorkflowAdminHandler) PurgeDLQMessages added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) PurgeDLQMessages(ctx context.Context, request *types.PurgeDLQMessagesRequest) error

func (*AccessControlledWorkflowAdminHandler) ReadDLQMessages added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) ReadDLQMessages(ctx context.Context, request *types.ReadDLQMessagesRequest) (*types.ReadDLQMessagesResponse, error)

func (*AccessControlledWorkflowAdminHandler) ReapplyEvents added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) ReapplyEvents(ctx context.Context, request *types.ReapplyEventsRequest) error

func (*AccessControlledWorkflowAdminHandler) RefreshWorkflowTasks added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) RefreshWorkflowTasks(ctx context.Context, request *types.RefreshWorkflowTasksRequest) error

func (*AccessControlledWorkflowAdminHandler) RemoveTask added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) RemoveTask(ctx context.Context, request *types.RemoveTaskRequest) error

func (*AccessControlledWorkflowAdminHandler) ResendReplicationTasks added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) ResendReplicationTasks(ctx context.Context, request *types.ResendReplicationTasksRequest) error

func (*AccessControlledWorkflowAdminHandler) ResetQueue added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) ResetQueue(ctx context.Context, request *types.ResetQueueRequest) error

func (*AccessControlledWorkflowAdminHandler) RestoreDynamicConfig added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) RestoreDynamicConfig(ctx context.Context, request *types.RestoreDynamicConfigRequest) error

func (*AccessControlledWorkflowAdminHandler) UpdateDynamicConfig added in v0.23.1 

func (a *AccessControlledWorkflowAdminHandler) UpdateDynamicConfig(ctx context.Context, request *types.UpdateDynamicConfigRequest) error

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, cfg config.Authorization) *AccessControlledWorkflowHandler

NewAccessControlledHandlerImpl creates frontend handler with authentication support

func (*AccessControlledWorkflowHandler) CountWorkflowExecutions added in v0.11.0 

func (a *AccessControlledWorkflowHandler) CountWorkflowExecutions(
	ctx context.Context,
	request *types.CountWorkflowExecutionsRequest,
) (*types.CountWorkflowExecutionsResponse, error)

CountWorkflowExecutions API call

func (*AccessControlledWorkflowHandler) DeprecateDomain added in v0.11.0 

func (a *AccessControlledWorkflowHandler) DeprecateDomain(
	ctx context.Context,
	request *types.DeprecateDomainRequest,
) error

DeprecateDomain API call

func (*AccessControlledWorkflowHandler) DescribeDomain added in v0.11.0 

func (a *AccessControlledWorkflowHandler) DescribeDomain(
	ctx context.Context,
	request *types.DescribeDomainRequest,
) (*types.DescribeDomainResponse, error)

DescribeDomain API call

func (*AccessControlledWorkflowHandler) DescribeTaskList added in v0.11.0 

func (a *AccessControlledWorkflowHandler) DescribeTaskList(
	ctx context.Context,
	request *types.DescribeTaskListRequest,
) (*types.DescribeTaskListResponse, error)

DescribeTaskList API call

func (*AccessControlledWorkflowHandler) DescribeWorkflowExecution added in v0.11.0 

func (a *AccessControlledWorkflowHandler) DescribeWorkflowExecution(
	ctx context.Context,
	request *types.DescribeWorkflowExecutionRequest,
) (*types.DescribeWorkflowExecutionResponse, error)

DescribeWorkflowExecution API call

func (*AccessControlledWorkflowHandler) GetClusterInfo added in v0.11.0 

func (a *AccessControlledWorkflowHandler) GetClusterInfo(
	ctx context.Context,
) (*types.ClusterInfo, error)

GetClusterInfo API call

func (*AccessControlledWorkflowHandler) GetSearchAttributes added in v0.11.0 

func (a *AccessControlledWorkflowHandler) GetSearchAttributes(
	ctx context.Context,
) (*types.GetSearchAttributesResponse, error)

GetSearchAttributes API call

func (*AccessControlledWorkflowHandler) GetTaskListsByDomain added in v0.23.1 

func (a *AccessControlledWorkflowHandler) GetTaskListsByDomain(
	ctx context.Context,
	request *types.GetTaskListsByDomainRequest,
) (*types.GetTaskListsByDomainResponse, error)

GetTaskListsByDomain API call

func (*AccessControlledWorkflowHandler) GetWorkflowExecutionHistory added in v0.11.0 

func (a *AccessControlledWorkflowHandler) GetWorkflowExecutionHistory(
	ctx context.Context,
	request *types.GetWorkflowExecutionHistoryRequest,
) (*types.GetWorkflowExecutionHistoryResponse, error)

GetWorkflowExecutionHistory API call

func (*AccessControlledWorkflowHandler) Health added in v0.11.0 

func (a *AccessControlledWorkflowHandler) Health(ctx context.Context) (*types.HealthStatus, error)

Health callback for for health check

func (*AccessControlledWorkflowHandler) ListArchivedWorkflowExecutions added in v0.11.0 

func (a *AccessControlledWorkflowHandler) ListArchivedWorkflowExecutions(
	ctx context.Context,
	request *types.ListArchivedWorkflowExecutionsRequest,
) (*types.ListArchivedWorkflowExecutionsResponse, error)

ListArchivedWorkflowExecutions API call

func (*AccessControlledWorkflowHandler) ListClosedWorkflowExecutions added in v0.11.0 

func (a *AccessControlledWorkflowHandler) ListClosedWorkflowExecutions(
	ctx context.Context,
	request *types.ListClosedWorkflowExecutionsRequest,
) (*types.ListClosedWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutions API call

func (*AccessControlledWorkflowHandler) ListDomains added in v0.11.0 

func (a *AccessControlledWorkflowHandler) ListDomains(
	ctx context.Context,
	request *types.ListDomainsRequest,
) (*types.ListDomainsResponse, error)

ListDomains API call

func (*AccessControlledWorkflowHandler) ListOpenWorkflowExecutions added in v0.11.0 

func (a *AccessControlledWorkflowHandler) ListOpenWorkflowExecutions(
	ctx context.Context,
	request *types.ListOpenWorkflowExecutionsRequest,
) (*types.ListOpenWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutions API call

func (*AccessControlledWorkflowHandler) ListTaskListPartitions added in v0.11.0 

func (a *AccessControlledWorkflowHandler) ListTaskListPartitions(
	ctx context.Context,
	request *types.ListTaskListPartitionsRequest,
) (*types.ListTaskListPartitionsResponse, error)

ListTaskListPartitions API call

func (*AccessControlledWorkflowHandler) ListWorkflowExecutions added in v0.11.0 

func (a *AccessControlledWorkflowHandler) ListWorkflowExecutions(
	ctx context.Context,
	request *types.ListWorkflowExecutionsRequest,
) (*types.ListWorkflowExecutionsResponse, error)

ListWorkflowExecutions API call

func (*AccessControlledWorkflowHandler) PollForActivityTask added in v0.11.0 

func (a *AccessControlledWorkflowHandler) PollForActivityTask(
	ctx context.Context,
	request *types.PollForActivityTaskRequest,
) (*types.PollForActivityTaskResponse, error)

PollForActivityTask API call

func (*AccessControlledWorkflowHandler) PollForDecisionTask added in v0.11.0 

func (a *AccessControlledWorkflowHandler) PollForDecisionTask(
	ctx context.Context,
	request *types.PollForDecisionTaskRequest,
) (*types.PollForDecisionTaskResponse, error)

PollForDecisionTask API call

func (*AccessControlledWorkflowHandler) QueryWorkflow added in v0.11.0 

func (a *AccessControlledWorkflowHandler) QueryWorkflow(
	ctx context.Context,
	request *types.QueryWorkflowRequest,
) (*types.QueryWorkflowResponse, error)

QueryWorkflow API call

func (*AccessControlledWorkflowHandler) RecordActivityTaskHeartbeat added in v0.11.0 

func (a *AccessControlledWorkflowHandler) RecordActivityTaskHeartbeat(
	ctx context.Context,
	request *types.RecordActivityTaskHeartbeatRequest,
) (*types.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeat API call

func (*AccessControlledWorkflowHandler) RecordActivityTaskHeartbeatByID added in v0.11.0 

func (a *AccessControlledWorkflowHandler) RecordActivityTaskHeartbeatByID(
	ctx context.Context,
	request *types.RecordActivityTaskHeartbeatByIDRequest,
) (*types.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeatByID API call

func (*AccessControlledWorkflowHandler) RefreshWorkflowTasks added in v0.24.0 

func (a *AccessControlledWorkflowHandler) RefreshWorkflowTasks(ctx context.Context, request *types.RefreshWorkflowTasksRequest) error

func (*AccessControlledWorkflowHandler) RegisterDomain added in v0.11.0 

func (a *AccessControlledWorkflowHandler) RegisterDomain(
	ctx context.Context,
	request *types.RegisterDomainRequest,
) error

RegisterDomain API call

func (*AccessControlledWorkflowHandler) RequestCancelWorkflowExecution added in v0.11.0 

func (a *AccessControlledWorkflowHandler) RequestCancelWorkflowExecution(
	ctx context.Context,
	request *types.RequestCancelWorkflowExecutionRequest,
) error

RequestCancelWorkflowExecution API call

func (*AccessControlledWorkflowHandler) ResetStickyTaskList added in v0.11.0 

func (a *AccessControlledWorkflowHandler) ResetStickyTaskList(
	ctx context.Context,
	request *types.ResetStickyTaskListRequest,
) (*types.ResetStickyTaskListResponse, error)

ResetStickyTaskList API call

func (*AccessControlledWorkflowHandler) ResetWorkflowExecution added in v0.11.0 

func (a *AccessControlledWorkflowHandler) ResetWorkflowExecution(
	ctx context.Context,
	request *types.ResetWorkflowExecutionRequest,
) (*types.ResetWorkflowExecutionResponse, error)

ResetWorkflowExecution API call

func (*AccessControlledWorkflowHandler) RespondActivityTaskCanceled added in v0.11.0 

func (a *AccessControlledWorkflowHandler) RespondActivityTaskCanceled(
	ctx context.Context,
	request *types.RespondActivityTaskCanceledRequest,
) error

RespondActivityTaskCanceled API call

func (*AccessControlledWorkflowHandler) RespondActivityTaskCanceledByID added in v0.11.0 

func (a *AccessControlledWorkflowHandler) RespondActivityTaskCanceledByID(
	ctx context.Context,
	request *types.RespondActivityTaskCanceledByIDRequest,
) error

RespondActivityTaskCanceledByID API call

func (*AccessControlledWorkflowHandler) RespondActivityTaskCompleted added in v0.11.0 

func (a *AccessControlledWorkflowHandler) RespondActivityTaskCompleted(
	ctx context.Context,
	request *types.RespondActivityTaskCompletedRequest,
) error

RespondActivityTaskCompleted API call

func (*AccessControlledWorkflowHandler) RespondActivityTaskCompletedByID added in v0.11.0 

func (a *AccessControlledWorkflowHandler) RespondActivityTaskCompletedByID(
	ctx context.Context,
	request *types.RespondActivityTaskCompletedByIDRequest,
) error

RespondActivityTaskCompletedByID API call

func (*AccessControlledWorkflowHandler) RespondActivityTaskFailed added in v0.11.0 

func (a *AccessControlledWorkflowHandler) RespondActivityTaskFailed(
	ctx context.Context,
	request *types.RespondActivityTaskFailedRequest,
) error

RespondActivityTaskFailed API call

func (*AccessControlledWorkflowHandler) RespondActivityTaskFailedByID added in v0.11.0 

func (a *AccessControlledWorkflowHandler) RespondActivityTaskFailedByID(
	ctx context.Context,
	request *types.RespondActivityTaskFailedByIDRequest,
) error

RespondActivityTaskFailedByID API call

func (*AccessControlledWorkflowHandler) RespondDecisionTaskCompleted added in v0.11.0 

func (a *AccessControlledWorkflowHandler) RespondDecisionTaskCompleted(
	ctx context.Context,
	request *types.RespondDecisionTaskCompletedRequest,
) (*types.RespondDecisionTaskCompletedResponse, error)

RespondDecisionTaskCompleted API call

func (*AccessControlledWorkflowHandler) RespondDecisionTaskFailed added in v0.11.0 

func (a *AccessControlledWorkflowHandler) RespondDecisionTaskFailed(
	ctx context.Context,
	request *types.RespondDecisionTaskFailedRequest,
) error

RespondDecisionTaskFailed API call

func (*AccessControlledWorkflowHandler) RespondQueryTaskCompleted added in v0.11.0 

func (a *AccessControlledWorkflowHandler) RespondQueryTaskCompleted(
	ctx context.Context,
	request *types.RespondQueryTaskCompletedRequest,
) error

RespondQueryTaskCompleted API call

func (*AccessControlledWorkflowHandler) RestartWorkflowExecution added in v0.25.0 

func (a *AccessControlledWorkflowHandler) RestartWorkflowExecution(ctx context.Context, request *types.RestartWorkflowExecutionRequest) (*types.RestartWorkflowExecutionResponse, error)

RestartWorkflowExecution API call

func (*AccessControlledWorkflowHandler) ScanWorkflowExecutions added in v0.11.0 

func (a *AccessControlledWorkflowHandler) ScanWorkflowExecutions(
	ctx context.Context,
	request *types.ListWorkflowExecutionsRequest,
) (*types.ListWorkflowExecutionsResponse, error)

ScanWorkflowExecutions API call

func (*AccessControlledWorkflowHandler) SignalWithStartWorkflowExecution added in v0.11.0 

func (a *AccessControlledWorkflowHandler) SignalWithStartWorkflowExecution(
	ctx context.Context,
	request *types.SignalWithStartWorkflowExecutionRequest,
) (*types.StartWorkflowExecutionResponse, error)

SignalWithStartWorkflowExecution API call

func (*AccessControlledWorkflowHandler) SignalWorkflowExecution added in v0.11.0 

func (a *AccessControlledWorkflowHandler) SignalWorkflowExecution(
	ctx context.Context,
	request *types.SignalWorkflowExecutionRequest,
) error

SignalWorkflowExecution API call

func (*AccessControlledWorkflowHandler) StartWorkflowExecution added in v0.11.0 

func (a *AccessControlledWorkflowHandler) StartWorkflowExecution(
	ctx context.Context,
	request *types.StartWorkflowExecutionRequest,
) (*types.StartWorkflowExecutionResponse, error)

StartWorkflowExecution API call

func (*AccessControlledWorkflowHandler) TerminateWorkflowExecution added in v0.11.0 

func (a *AccessControlledWorkflowHandler) TerminateWorkflowExecution(
	ctx context.Context,
	request *types.TerminateWorkflowExecutionRequest,
) error

TerminateWorkflowExecution API call

func (*AccessControlledWorkflowHandler) UpdateDomain added in v0.11.0 

func (a *AccessControlledWorkflowHandler) UpdateDomain(
	ctx context.Context,
	request *types.UpdateDomainRequest,
) (*types.UpdateDomainResponse, error)

UpdateDomain API call

type AdminHandler added in v0.3.12 

type AdminHandler interface {
	common.Daemon

	AddSearchAttribute(context.Context, *types.AddSearchAttributeRequest) error
	CloseShard(context.Context, *types.CloseShardRequest) error
	DescribeCluster(context.Context) (*types.DescribeClusterResponse, error)
	DescribeShardDistribution(context.Context, *types.DescribeShardDistributionRequest) (*types.DescribeShardDistributionResponse, error)
	DescribeHistoryHost(context.Context, *types.DescribeHistoryHostRequest) (*types.DescribeHistoryHostResponse, error)
	DescribeQueue(context.Context, *types.DescribeQueueRequest) (*types.DescribeQueueResponse, error)
	DescribeWorkflowExecution(context.Context, *types.AdminDescribeWorkflowExecutionRequest) (*types.AdminDescribeWorkflowExecutionResponse, error)
	GetDLQReplicationMessages(context.Context, *types.GetDLQReplicationMessagesRequest) (*types.GetDLQReplicationMessagesResponse, error)
	GetDomainReplicationMessages(context.Context, *types.GetDomainReplicationMessagesRequest) (*types.GetDomainReplicationMessagesResponse, error)
	GetReplicationMessages(context.Context, *types.GetReplicationMessagesRequest) (*types.GetReplicationMessagesResponse, error)
	GetWorkflowExecutionRawHistoryV2(context.Context, *types.GetWorkflowExecutionRawHistoryV2Request) (*types.GetWorkflowExecutionRawHistoryV2Response, error)
	CountDLQMessages(context.Context, *types.CountDLQMessagesRequest) (*types.CountDLQMessagesResponse, error)
	MergeDLQMessages(context.Context, *types.MergeDLQMessagesRequest) (*types.MergeDLQMessagesResponse, error)
	PurgeDLQMessages(context.Context, *types.PurgeDLQMessagesRequest) error
	ReadDLQMessages(context.Context, *types.ReadDLQMessagesRequest) (*types.ReadDLQMessagesResponse, error)
	ReapplyEvents(context.Context, *types.ReapplyEventsRequest) error
	RefreshWorkflowTasks(context.Context, *types.RefreshWorkflowTasksRequest) error
	RemoveTask(context.Context, *types.RemoveTaskRequest) error
	ResendReplicationTasks(context.Context, *types.ResendReplicationTasksRequest) error
	ResetQueue(context.Context, *types.ResetQueueRequest) error
	GetCrossClusterTasks(context.Context, *types.GetCrossClusterTasksRequest) (*types.GetCrossClusterTasksResponse, error)
	RespondCrossClusterTasksCompleted(context.Context, *types.RespondCrossClusterTasksCompletedRequest) (*types.RespondCrossClusterTasksCompletedResponse, error)
	GetDynamicConfig(context.Context, *types.GetDynamicConfigRequest) (*types.GetDynamicConfigResponse, error)
	UpdateDynamicConfig(context.Context, *types.UpdateDynamicConfigRequest) error
	RestoreDynamicConfig(context.Context, *types.RestoreDynamicConfigRequest) error
	ListDynamicConfig(context.Context, *types.ListDynamicConfigRequest) (*types.ListDynamicConfigResponse, error)
	DeleteWorkflow(context.Context, *types.AdminDeleteWorkflowRequest) (*types.AdminDeleteWorkflowResponse, error)
	MaintainCorruptWorkflow(context.Context, *types.AdminMaintainWorkflowRequest) (*types.AdminMaintainWorkflowResponse, error)
	GetGlobalIsolationGroups(ctx context.Context, request *types.GetGlobalIsolationGroupsRequest) (*types.GetGlobalIsolationGroupsResponse, error)
	UpdateGlobalIsolationGroups(ctx context.Context, request *types.UpdateGlobalIsolationGroupsRequest) (*types.UpdateGlobalIsolationGroupsResponse, error)
	GetDomainIsolationGroups(ctx context.Context, request *types.GetDomainIsolationGroupsRequest) (*types.GetDomainIsolationGroupsResponse, error)
	UpdateDomainIsolationGroups(ctx context.Context, request *types.UpdateDomainIsolationGroupsRequest) (*types.UpdateDomainIsolationGroupsResponse, error)
}

AdminHandler interface for admin service

func NewAdminHandler added in v0.3.12 

func NewAdminHandler(
	resource resource.Resource,
	params *resource.Params,
	config *Config,
	domainHandler domain.Handler,
) AdminHandler

NewAdminHandler creates a thrift service for the cadence 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) 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) error

CloseShard forwards request to the underlying handler

func (AdminThriftHandler) DeleteWorkflow added in v0.24.0 

func (t AdminThriftHandler) DeleteWorkflow(ctx context.Context, request *admin.AdminDeleteWorkflowRequest) (*admin.AdminDeleteWorkflowResponse, error)

DeleteWorkflow deletes dynamic config value from config store based on filter

func (AdminThriftHandler) DescribeCluster added in v0.17.0 

func (t AdminThriftHandler) DescribeCluster(ctx context.Context) (*admin.DescribeClusterResponse, 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) (*shared.DescribeHistoryHostResponse, 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) (*shared.DescribeQueueResponse, error)

DescribeQueue forwards request to the underlying handler

func (AdminThriftHandler) DescribeShardDistribution added in v0.22.0 

func (t AdminThriftHandler) DescribeShardDistribution(ctx context.Context, request *shared.DescribeShardDistributionRequest) (*shared.DescribeShardDistributionResponse, error)

DescribeShardDistribution forwards request to the underlying handler

func (AdminThriftHandler) DescribeWorkflowExecution added in v0.17.0 

func (t AdminThriftHandler) DescribeWorkflowExecution(ctx context.Context, request *admin.DescribeWorkflowExecutionRequest) (*admin.DescribeWorkflowExecutionResponse, error)

DescribeWorkflowExecution forwards request to the underlying handler

func (AdminThriftHandler) GetCrossClusterTasks added in v0.22.0 

func (t AdminThriftHandler) GetCrossClusterTasks(ctx context.Context, request *shared.GetCrossClusterTasksRequest) (*shared.GetCrossClusterTasksResponse, error)

GetCrossClusterTasks fetches cross cluster tasks

func (AdminThriftHandler) GetDLQReplicationMessages added in v0.17.0 

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

GetDLQReplicationMessages forwards request to the underlying handler

func (AdminThriftHandler) GetDomainIsolationGroups added in v1.2.1 

func (t AdminThriftHandler) GetDomainIsolationGroups(ctx context.Context, request *admin.GetDomainIsolationGroupsRequest) (*admin.GetDomainIsolationGroupsResponse, error)

func (AdminThriftHandler) GetDomainReplicationMessages added in v0.17.0 

func (t AdminThriftHandler) GetDomainReplicationMessages(ctx context.Context, request *replicator.GetDomainReplicationMessagesRequest) (*replicator.GetDomainReplicationMessagesResponse, error)

GetDomainReplicationMessages forwards request to the underlying handler

func (AdminThriftHandler) GetDynamicConfig added in v0.23.1 

func (t AdminThriftHandler) GetDynamicConfig(ctx context.Context, request *admin.GetDynamicConfigRequest) (*admin.GetDynamicConfigResponse, error)

GetDynamicConfig fetches dynamic config value

func (AdminThriftHandler) GetGlobalIsolationGroups added in v1.2.1 

func (t AdminThriftHandler) GetGlobalIsolationGroups(ctx context.Context, request *admin.GetGlobalIsolationGroupsRequest) (*admin.GetGlobalIsolationGroupsResponse, error)

func (AdminThriftHandler) GetReplicationMessages added in v0.17.0 

func (t AdminThriftHandler) GetReplicationMessages(ctx context.Context, request *replicator.GetReplicationMessagesRequest) (*replicator.GetReplicationMessagesResponse, 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) (*admin.GetWorkflowExecutionRawHistoryV2Response, error)

GetWorkflowExecutionRawHistoryV2 forwards request to the underlying handler

func (AdminThriftHandler) ListDynamicConfig added in v0.23.1 

func (t AdminThriftHandler) ListDynamicConfig(ctx context.Context, request *admin.ListDynamicConfigRequest) (*admin.ListDynamicConfigResponse, error)

ListDynamicConfig fetches all values associated to specified dc parameters or all otherwise

func (AdminThriftHandler) MaintainCorruptWorkflow added in v0.24.0 

func (t AdminThriftHandler) MaintainCorruptWorkflow(ctx context.Context, request *admin.AdminMaintainWorkflowRequest) (*admin.AdminMaintainWorkflowResponse, error)

MaintainCorruptWorkflow deletes dynamic config value from config store based on filter

func (AdminThriftHandler) MergeDLQMessages added in v0.17.0 

func (t AdminThriftHandler) MergeDLQMessages(ctx context.Context, request *replicator.MergeDLQMessagesRequest) (*replicator.MergeDLQMessagesResponse, 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) 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) (*replicator.ReadDLQMessagesResponse, 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) 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) 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) 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) 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) error

ResetQueue forwards request to the underlying handler

func (AdminThriftHandler) RespondCrossClusterTasksCompleted added in v0.24.0 

func (t AdminThriftHandler) RespondCrossClusterTasksCompleted(ctx context.Context, request *shared.RespondCrossClusterTasksCompletedRequest) (*shared.RespondCrossClusterTasksCompletedResponse, error)

RespondCrossClusterTasksCompleted responds the result of processing cross cluster tasks

func (AdminThriftHandler) RestoreDynamicConfig added in v0.23.1 

func (t AdminThriftHandler) RestoreDynamicConfig(ctx context.Context, request *admin.RestoreDynamicConfigRequest) error

RestoreDynamicConfig deletes dynamic config value from config store based on filter

func (AdminThriftHandler) UpdateDomainIsolationGroups added in v1.2.1 

func (t AdminThriftHandler) UpdateDomainIsolationGroups(ctx context.Context, request *admin.UpdateDomainIsolationGroupsRequest) (*admin.UpdateDomainIsolationGroupsResponse, error)

func (AdminThriftHandler) UpdateDynamicConfig added in v0.23.1 

func (t AdminThriftHandler) UpdateDynamicConfig(ctx context.Context, request *admin.UpdateDynamicConfigRequest) error

UpdateDynamicConfig updates dynamic config value

func (AdminThriftHandler) UpdateGlobalIsolationGroups added in v1.2.1 

func (t AdminThriftHandler) UpdateGlobalIsolationGroups(ctx context.Context, request *admin.UpdateGlobalIsolationGroupsRequest) (*admin.UpdateGlobalIsolationGroupsResponse, error)

type ClusterRedirectionHandlerImpl added in v0.24.0 

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

ClusterRedirectionHandlerImpl is simple wrapper over frontend service, doing redirection based on policy for global domains not being active in current cluster

func NewClusterRedirectionHandler added in v0.24.0 

func NewClusterRedirectionHandler(
	wfHandler Handler,
	resource resource.Resource,
	config *Config,
	policy config.ClusterRedirectionPolicy,
) *ClusterRedirectionHandlerImpl

NewClusterRedirectionHandler creates a frontend handler to handle cluster redirection for global domains not being active in current cluster

func (*ClusterRedirectionHandlerImpl) CountWorkflowExecutions added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) CountWorkflowExecutions(
	ctx context.Context,
	request *types.CountWorkflowExecutionsRequest,
) (resp *types.CountWorkflowExecutionsResponse, retError error)

CountWorkflowExecutions API call

func (*ClusterRedirectionHandlerImpl) DeprecateDomain added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) DeprecateDomain(
	ctx context.Context,
	request *types.DeprecateDomainRequest,
) (retError error)

DeprecateDomain API call

func (*ClusterRedirectionHandlerImpl) DescribeDomain added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) DescribeDomain(
	ctx context.Context,
	request *types.DescribeDomainRequest,
) (resp *types.DescribeDomainResponse, retError error)

DescribeDomain API call

func (*ClusterRedirectionHandlerImpl) DescribeTaskList added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) DescribeTaskList(
	ctx context.Context,
	request *types.DescribeTaskListRequest,
) (resp *types.DescribeTaskListResponse, retError error)

DescribeTaskList API call

func (*ClusterRedirectionHandlerImpl) DescribeWorkflowExecution added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) DescribeWorkflowExecution(
	ctx context.Context,
	request *types.DescribeWorkflowExecutionRequest,
) (resp *types.DescribeWorkflowExecutionResponse, retError error)

DescribeWorkflowExecution API call

func (*ClusterRedirectionHandlerImpl) GetClusterInfo added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) GetClusterInfo(
	ctx context.Context,
) (*types.ClusterInfo, error)

GetClusterInfo API call

func (*ClusterRedirectionHandlerImpl) GetSearchAttributes added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) GetSearchAttributes(
	ctx context.Context,
) (resp *types.GetSearchAttributesResponse, retError error)

GetSearchAttributes API call

func (*ClusterRedirectionHandlerImpl) GetTaskListsByDomain added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) GetTaskListsByDomain(
	ctx context.Context,
	request *types.GetTaskListsByDomainRequest,
) (resp *types.GetTaskListsByDomainResponse, retError error)

GetTaskListsByDomain API call

func (*ClusterRedirectionHandlerImpl) GetWorkflowExecutionHistory added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) GetWorkflowExecutionHistory(
	ctx context.Context,
	request *types.GetWorkflowExecutionHistoryRequest,
) (resp *types.GetWorkflowExecutionHistoryResponse, retError error)

GetWorkflowExecutionHistory API call

func (*ClusterRedirectionHandlerImpl) Health added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) Health(ctx context.Context) (*types.HealthStatus, error)

Health is for health check

func (*ClusterRedirectionHandlerImpl) ListArchivedWorkflowExecutions added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) ListArchivedWorkflowExecutions(
	ctx context.Context,
	request *types.ListArchivedWorkflowExecutionsRequest,
) (resp *types.ListArchivedWorkflowExecutionsResponse, retError error)

ListArchivedWorkflowExecutions API call

func (*ClusterRedirectionHandlerImpl) ListClosedWorkflowExecutions added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) ListClosedWorkflowExecutions(
	ctx context.Context,
	request *types.ListClosedWorkflowExecutionsRequest,
) (resp *types.ListClosedWorkflowExecutionsResponse, retError error)

ListClosedWorkflowExecutions API call

func (*ClusterRedirectionHandlerImpl) ListDomains added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) ListDomains(
	ctx context.Context,
	request *types.ListDomainsRequest,
) (resp *types.ListDomainsResponse, retError error)

ListDomains API call

func (*ClusterRedirectionHandlerImpl) ListOpenWorkflowExecutions added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) ListOpenWorkflowExecutions(
	ctx context.Context,
	request *types.ListOpenWorkflowExecutionsRequest,
) (resp *types.ListOpenWorkflowExecutionsResponse, retError error)

ListOpenWorkflowExecutions API call

func (*ClusterRedirectionHandlerImpl) ListTaskListPartitions added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) ListTaskListPartitions(
	ctx context.Context,
	request *types.ListTaskListPartitionsRequest,
) (resp *types.ListTaskListPartitionsResponse, retError error)

ListTaskListPartitions API call

func (*ClusterRedirectionHandlerImpl) ListWorkflowExecutions added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) ListWorkflowExecutions(
	ctx context.Context,
	request *types.ListWorkflowExecutionsRequest,
) (resp *types.ListWorkflowExecutionsResponse, retError error)

ListWorkflowExecutions API call

func (*ClusterRedirectionHandlerImpl) PollForActivityTask added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) PollForActivityTask(
	ctx context.Context,
	request *types.PollForActivityTaskRequest,
) (resp *types.PollForActivityTaskResponse, retError error)

PollForActivityTask API call

func (*ClusterRedirectionHandlerImpl) PollForDecisionTask added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) PollForDecisionTask(
	ctx context.Context,
	request *types.PollForDecisionTaskRequest,
) (resp *types.PollForDecisionTaskResponse, retError error)

PollForDecisionTask API call

func (*ClusterRedirectionHandlerImpl) QueryWorkflow added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) QueryWorkflow(
	ctx context.Context,
	request *types.QueryWorkflowRequest,
) (resp *types.QueryWorkflowResponse, retError error)

QueryWorkflow API call

func (*ClusterRedirectionHandlerImpl) RecordActivityTaskHeartbeat added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) RecordActivityTaskHeartbeat(
	ctx context.Context,
	request *types.RecordActivityTaskHeartbeatRequest,
) (resp *types.RecordActivityTaskHeartbeatResponse, retError error)

RecordActivityTaskHeartbeat API call

func (*ClusterRedirectionHandlerImpl) RecordActivityTaskHeartbeatByID added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) RecordActivityTaskHeartbeatByID(
	ctx context.Context,
	request *types.RecordActivityTaskHeartbeatByIDRequest,
) (resp *types.RecordActivityTaskHeartbeatResponse, retError error)

RecordActivityTaskHeartbeatByID API call

func (*ClusterRedirectionHandlerImpl) RefreshWorkflowTasks added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) RefreshWorkflowTasks(
	ctx context.Context,
	request *types.RefreshWorkflowTasksRequest,
) (retError error)

RefreshWorkflowTasks API call

func (*ClusterRedirectionHandlerImpl) RegisterDomain added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) RegisterDomain(
	ctx context.Context,
	request *types.RegisterDomainRequest,
) (retError error)

RegisterDomain API call

func (*ClusterRedirectionHandlerImpl) RequestCancelWorkflowExecution added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) RequestCancelWorkflowExecution(
	ctx context.Context,
	request *types.RequestCancelWorkflowExecutionRequest,
) (retError error)

RequestCancelWorkflowExecution API call

func (*ClusterRedirectionHandlerImpl) ResetStickyTaskList added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) ResetStickyTaskList(
	ctx context.Context,
	request *types.ResetStickyTaskListRequest,
) (resp *types.ResetStickyTaskListResponse, retError error)

ResetStickyTaskList API call

func (*ClusterRedirectionHandlerImpl) ResetWorkflowExecution added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) ResetWorkflowExecution(
	ctx context.Context,
	request *types.ResetWorkflowExecutionRequest,
) (resp *types.ResetWorkflowExecutionResponse, retError error)

ResetWorkflowExecution API call

func (*ClusterRedirectionHandlerImpl) RespondActivityTaskCanceled added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) RespondActivityTaskCanceled(
	ctx context.Context,
	request *types.RespondActivityTaskCanceledRequest,
) (retError error)

RespondActivityTaskCanceled API call

func (*ClusterRedirectionHandlerImpl) RespondActivityTaskCanceledByID added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) RespondActivityTaskCanceledByID(
	ctx context.Context,
	request *types.RespondActivityTaskCanceledByIDRequest,
) (retError error)

RespondActivityTaskCanceledByID API call

func (*ClusterRedirectionHandlerImpl) RespondActivityTaskCompleted added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) RespondActivityTaskCompleted(
	ctx context.Context,
	request *types.RespondActivityTaskCompletedRequest,
) (retError error)

RespondActivityTaskCompleted API call

func (*ClusterRedirectionHandlerImpl) RespondActivityTaskCompletedByID added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) RespondActivityTaskCompletedByID(
	ctx context.Context,
	request *types.RespondActivityTaskCompletedByIDRequest,
) (retError error)

RespondActivityTaskCompletedByID API call

func (*ClusterRedirectionHandlerImpl) RespondActivityTaskFailed added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) RespondActivityTaskFailed(
	ctx context.Context,
	request *types.RespondActivityTaskFailedRequest,
) (retError error)

RespondActivityTaskFailed API call

func (*ClusterRedirectionHandlerImpl) RespondActivityTaskFailedByID added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) RespondActivityTaskFailedByID(
	ctx context.Context,
	request *types.RespondActivityTaskFailedByIDRequest,
) (retError error)

RespondActivityTaskFailedByID API call

func (*ClusterRedirectionHandlerImpl) RespondDecisionTaskCompleted added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) RespondDecisionTaskCompleted(
	ctx context.Context,
	request *types.RespondDecisionTaskCompletedRequest,
) (resp *types.RespondDecisionTaskCompletedResponse, retError error)

RespondDecisionTaskCompleted API call

func (*ClusterRedirectionHandlerImpl) RespondDecisionTaskFailed added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) RespondDecisionTaskFailed(
	ctx context.Context,
	request *types.RespondDecisionTaskFailedRequest,
) (retError error)

RespondDecisionTaskFailed API call

func (*ClusterRedirectionHandlerImpl) RespondQueryTaskCompleted added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) RespondQueryTaskCompleted(
	ctx context.Context,
	request *types.RespondQueryTaskCompletedRequest,
) (retError error)

RespondQueryTaskCompleted API call

func (*ClusterRedirectionHandlerImpl) RestartWorkflowExecution added in v0.25.0 

func (handler *ClusterRedirectionHandlerImpl) RestartWorkflowExecution(ctx context.Context, request *types.RestartWorkflowExecutionRequest) (resp *types.RestartWorkflowExecutionResponse, retError error)

func (*ClusterRedirectionHandlerImpl) ScanWorkflowExecutions added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) ScanWorkflowExecutions(
	ctx context.Context,
	request *types.ListWorkflowExecutionsRequest,
) (resp *types.ListWorkflowExecutionsResponse, retError error)

ScanWorkflowExecutions API call

func (*ClusterRedirectionHandlerImpl) SignalWithStartWorkflowExecution added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) SignalWithStartWorkflowExecution(
	ctx context.Context,
	request *types.SignalWithStartWorkflowExecutionRequest,
) (resp *types.StartWorkflowExecutionResponse, retError error)

SignalWithStartWorkflowExecution API call

func (*ClusterRedirectionHandlerImpl) SignalWorkflowExecution added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) SignalWorkflowExecution(
	ctx context.Context,
	request *types.SignalWorkflowExecutionRequest,
) (retError error)

SignalWorkflowExecution API call

func (*ClusterRedirectionHandlerImpl) StartWorkflowExecution added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) StartWorkflowExecution(
	ctx context.Context,
	request *types.StartWorkflowExecutionRequest,
) (resp *types.StartWorkflowExecutionResponse, retError error)

StartWorkflowExecution API call

func (*ClusterRedirectionHandlerImpl) TerminateWorkflowExecution added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) TerminateWorkflowExecution(
	ctx context.Context,
	request *types.TerminateWorkflowExecutionRequest,
) (retError error)

TerminateWorkflowExecution API call

func (*ClusterRedirectionHandlerImpl) UpdateDomain added in v0.24.0 

func (handler *ClusterRedirectionHandlerImpl) UpdateDomain(
	ctx context.Context,
	request *types.UpdateDomainRequest,
) (resp *types.UpdateDomainResponse, retError error)

UpdateDomain API call

type ClusterRedirectionPolicy added in v0.24.0 

type ClusterRedirectionPolicy 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
}

ClusterRedirectionPolicy 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.ClusterRedirectionPolicy) ClusterRedirectionPolicy

RedirectionPolicyGenerator generate corresponding redirection policy

type Config added in v0.3.0 

type Config struct {
	NumHistoryShards         int
	IsAdvancedVisConfigExist bool

	PersistenceMaxQPS               dynamicconfig.IntPropertyFn
	PersistenceGlobalMaxQPS         dynamicconfig.IntPropertyFn
	VisibilityMaxPageSize           dynamicconfig.IntPropertyFnWithDomainFilter
	EnableVisibilitySampling        dynamicconfig.BoolPropertyFn
	EnableReadFromClosedExecutionV2 dynamicconfig.BoolPropertyFn
	// deprecated: never used for ratelimiting, only sampling-based failure injection, and only on database-based visibility
	VisibilityListMaxQPS            dynamicconfig.IntPropertyFnWithDomainFilter
	EnableReadVisibilityFromES      dynamicconfig.BoolPropertyFnWithDomainFilter
	EnableReadVisibilityFromPinot   dynamicconfig.BoolPropertyFnWithDomainFilter
	EnableLogCustomerQueryParameter dynamicconfig.BoolPropertyFnWithDomainFilter
	// deprecated: never read from
	ESVisibilityListMaxQPS            dynamicconfig.IntPropertyFnWithDomainFilter
	ESIndexMaxResultWindow            dynamicconfig.IntPropertyFn
	HistoryMaxPageSize                dynamicconfig.IntPropertyFnWithDomainFilter
	UserRPS                           dynamicconfig.IntPropertyFn
	WorkerRPS                         dynamicconfig.IntPropertyFn
	VisibilityRPS                     dynamicconfig.IntPropertyFn
	MaxDomainUserRPSPerInstance       dynamicconfig.IntPropertyFnWithDomainFilter
	MaxDomainWorkerRPSPerInstance     dynamicconfig.IntPropertyFnWithDomainFilter
	MaxDomainVisibilityRPSPerInstance dynamicconfig.IntPropertyFnWithDomainFilter
	GlobalDomainUserRPS               dynamicconfig.IntPropertyFnWithDomainFilter
	GlobalDomainWorkerRPS             dynamicconfig.IntPropertyFnWithDomainFilter
	GlobalDomainVisibilityRPS         dynamicconfig.IntPropertyFnWithDomainFilter
	EnableClientVersionCheck          dynamicconfig.BoolPropertyFn
	EnableQueryAttributeValidation    dynamicconfig.BoolPropertyFn
	DisallowQuery                     dynamicconfig.BoolPropertyFnWithDomainFilter
	ShutdownDrainDuration             dynamicconfig.DurationPropertyFn
	Lockdown                          dynamicconfig.BoolPropertyFnWithDomainFilter

	// isolation configuration
	EnableTasklistIsolation dynamicconfig.BoolPropertyFnWithDomainFilter

	// id length limits
	MaxIDLengthWarnLimit  dynamicconfig.IntPropertyFn
	DomainNameMaxLength   dynamicconfig.IntPropertyFnWithDomainFilter
	IdentityMaxLength     dynamicconfig.IntPropertyFnWithDomainFilter
	WorkflowIDMaxLength   dynamicconfig.IntPropertyFnWithDomainFilter
	SignalNameMaxLength   dynamicconfig.IntPropertyFnWithDomainFilter
	WorkflowTypeMaxLength dynamicconfig.IntPropertyFnWithDomainFilter
	RequestIDMaxLength    dynamicconfig.IntPropertyFnWithDomainFilter
	TaskListNameMaxLength dynamicconfig.IntPropertyFnWithDomainFilter

	// 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

	// max number of decisions per RespondDecisionTaskCompleted request (unlimited by default)
	DecisionResultCountLimit dynamicconfig.IntPropertyFnWithDomainFilter

	// Emit signal related metrics with signal name tag. Be aware of cardinality.
	EmitSignalNameMetricsTag dynamicconfig.BoolPropertyFnWithDomainFilter

	// HostName for machine running the service
	HostName string
	// 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, isAdvancedVisConfigExist bool, hostName string) *Config

NewConfig returns new service config with default values

type Handler added in v0.13.0 

type Handler interface {
	Health(context.Context) (*types.HealthStatus, error)
	CountWorkflowExecutions(context.Context, *types.CountWorkflowExecutionsRequest) (*types.CountWorkflowExecutionsResponse, error)
	DeprecateDomain(context.Context, *types.DeprecateDomainRequest) error
	DescribeDomain(context.Context, *types.DescribeDomainRequest) (*types.DescribeDomainResponse, error)
	DescribeTaskList(context.Context, *types.DescribeTaskListRequest) (*types.DescribeTaskListResponse, error)
	DescribeWorkflowExecution(context.Context, *types.DescribeWorkflowExecutionRequest) (*types.DescribeWorkflowExecutionResponse, error)
	GetClusterInfo(context.Context) (*types.ClusterInfo, error)
	GetSearchAttributes(context.Context) (*types.GetSearchAttributesResponse, error)
	GetWorkflowExecutionHistory(context.Context, *types.GetWorkflowExecutionHistoryRequest) (*types.GetWorkflowExecutionHistoryResponse, error)
	ListArchivedWorkflowExecutions(context.Context, *types.ListArchivedWorkflowExecutionsRequest) (*types.ListArchivedWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutions(context.Context, *types.ListClosedWorkflowExecutionsRequest) (*types.ListClosedWorkflowExecutionsResponse, error)
	ListDomains(context.Context, *types.ListDomainsRequest) (*types.ListDomainsResponse, error)
	ListOpenWorkflowExecutions(context.Context, *types.ListOpenWorkflowExecutionsRequest) (*types.ListOpenWorkflowExecutionsResponse, error)
	ListTaskListPartitions(context.Context, *types.ListTaskListPartitionsRequest) (*types.ListTaskListPartitionsResponse, error)
	GetTaskListsByDomain(context.Context, *types.GetTaskListsByDomainRequest) (*types.GetTaskListsByDomainResponse, error)
	RefreshWorkflowTasks(context.Context, *types.RefreshWorkflowTasksRequest) error
	ListWorkflowExecutions(context.Context, *types.ListWorkflowExecutionsRequest) (*types.ListWorkflowExecutionsResponse, error)
	PollForActivityTask(context.Context, *types.PollForActivityTaskRequest) (*types.PollForActivityTaskResponse, error)
	PollForDecisionTask(context.Context, *types.PollForDecisionTaskRequest) (*types.PollForDecisionTaskResponse, error)
	QueryWorkflow(context.Context, *types.QueryWorkflowRequest) (*types.QueryWorkflowResponse, error)
	RecordActivityTaskHeartbeat(context.Context, *types.RecordActivityTaskHeartbeatRequest) (*types.RecordActivityTaskHeartbeatResponse, error)
	RecordActivityTaskHeartbeatByID(context.Context, *types.RecordActivityTaskHeartbeatByIDRequest) (*types.RecordActivityTaskHeartbeatResponse, error)
	RegisterDomain(context.Context, *types.RegisterDomainRequest) error
	RequestCancelWorkflowExecution(context.Context, *types.RequestCancelWorkflowExecutionRequest) error
	ResetStickyTaskList(context.Context, *types.ResetStickyTaskListRequest) (*types.ResetStickyTaskListResponse, error)
	ResetWorkflowExecution(context.Context, *types.ResetWorkflowExecutionRequest) (*types.ResetWorkflowExecutionResponse, error)
	RespondActivityTaskCanceled(context.Context, *types.RespondActivityTaskCanceledRequest) error
	RespondActivityTaskCanceledByID(context.Context, *types.RespondActivityTaskCanceledByIDRequest) error
	RespondActivityTaskCompleted(context.Context, *types.RespondActivityTaskCompletedRequest) error
	RespondActivityTaskCompletedByID(context.Context, *types.RespondActivityTaskCompletedByIDRequest) error
	RespondActivityTaskFailed(context.Context, *types.RespondActivityTaskFailedRequest) error
	RespondActivityTaskFailedByID(context.Context, *types.RespondActivityTaskFailedByIDRequest) error
	RespondDecisionTaskCompleted(context.Context, *types.RespondDecisionTaskCompletedRequest) (*types.RespondDecisionTaskCompletedResponse, error)
	RespondDecisionTaskFailed(context.Context, *types.RespondDecisionTaskFailedRequest) error
	RespondQueryTaskCompleted(context.Context, *types.RespondQueryTaskCompletedRequest) error
	RestartWorkflowExecution(context.Context, *types.RestartWorkflowExecutionRequest) (*types.RestartWorkflowExecutionResponse, error)
	ScanWorkflowExecutions(context.Context, *types.ListWorkflowExecutionsRequest) (*types.ListWorkflowExecutionsResponse, error)
	SignalWithStartWorkflowExecution(context.Context, *types.SignalWithStartWorkflowExecutionRequest) (*types.StartWorkflowExecutionResponse, error)
	SignalWorkflowExecution(context.Context, *types.SignalWorkflowExecutionRequest) error
	StartWorkflowExecution(context.Context, *types.StartWorkflowExecutionRequest) (*types.StartWorkflowExecutionResponse, error)
	TerminateWorkflowExecution(context.Context, *types.TerminateWorkflowExecutionRequest) error
	UpdateDomain(context.Context, *types.UpdateDomainRequest) (*types.UpdateDomainResponse, error)
}

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 *types.AddSearchAttributeRequest) error

AddSearchAttribute mocks base method.

func (*MockAdminHandler) CloseShard added in v0.17.0 

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

CloseShard mocks base method.

func (*MockAdminHandler) CountDLQMessages added in v0.25.0 

func (m *MockAdminHandler) CountDLQMessages(arg0 context.Context, arg1 *types.CountDLQMessagesRequest) (*types.CountDLQMessagesResponse, error)

CountDLQMessages mocks base method.

func (*MockAdminHandler) DeleteWorkflow added in v0.24.0 

func (m *MockAdminHandler) DeleteWorkflow(arg0 context.Context, arg1 *types.AdminDeleteWorkflowRequest) (*types.AdminDeleteWorkflowResponse, error)

DeleteWorkflow mocks base method.

func (*MockAdminHandler) DescribeCluster added in v0.17.0 

func (m *MockAdminHandler) DescribeCluster(arg0 context.Context) (*types.DescribeClusterResponse, error)

DescribeCluster mocks base method.

func (*MockAdminHandler) DescribeHistoryHost added in v0.17.0 

func (m *MockAdminHandler) DescribeHistoryHost(arg0 context.Context, arg1 *types.DescribeHistoryHostRequest) (*types.DescribeHistoryHostResponse, error)

DescribeHistoryHost mocks base method.

func (*MockAdminHandler) DescribeQueue added in v0.17.0 

func (m *MockAdminHandler) DescribeQueue(arg0 context.Context, arg1 *types.DescribeQueueRequest) (*types.DescribeQueueResponse, error)

DescribeQueue mocks base method.

func (*MockAdminHandler) DescribeShardDistribution added in v0.22.0 

func (m *MockAdminHandler) DescribeShardDistribution(arg0 context.Context, arg1 *types.DescribeShardDistributionRequest) (*types.DescribeShardDistributionResponse, error)

DescribeShardDistribution mocks base method.

func (*MockAdminHandler) DescribeWorkflowExecution added in v0.17.0 

func (m *MockAdminHandler) DescribeWorkflowExecution(arg0 context.Context, arg1 *types.AdminDescribeWorkflowExecutionRequest) (*types.AdminDescribeWorkflowExecutionResponse, 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) GetCrossClusterTasks added in v0.23.1 

func (m *MockAdminHandler) GetCrossClusterTasks(arg0 context.Context, arg1 *types.GetCrossClusterTasksRequest) (*types.GetCrossClusterTasksResponse, error)

GetCrossClusterTasks mocks base method.

func (*MockAdminHandler) GetDLQReplicationMessages added in v0.17.0 

func (m *MockAdminHandler) GetDLQReplicationMessages(arg0 context.Context, arg1 *types.GetDLQReplicationMessagesRequest) (*types.GetDLQReplicationMessagesResponse, error)

GetDLQReplicationMessages mocks base method.

func (*MockAdminHandler) GetDomainIsolationGroups added in v1.2.1 

func (m *MockAdminHandler) GetDomainIsolationGroups(ctx context.Context, request *types.GetDomainIsolationGroupsRequest) (*types.GetDomainIsolationGroupsResponse, error)

GetDomainIsolationGroups mocks base method.

func (*MockAdminHandler) GetDomainReplicationMessages added in v0.17.0 

func (m *MockAdminHandler) GetDomainReplicationMessages(arg0 context.Context, arg1 *types.GetDomainReplicationMessagesRequest) (*types.GetDomainReplicationMessagesResponse, error)

GetDomainReplicationMessages mocks base method.

func (*MockAdminHandler) GetDynamicConfig added in v0.23.1 

func (m *MockAdminHandler) GetDynamicConfig(arg0 context.Context, arg1 *types.GetDynamicConfigRequest) (*types.GetDynamicConfigResponse, error)

GetDynamicConfig mocks base method.

func (*MockAdminHandler) GetGlobalIsolationGroups added in v1.2.1 

func (m *MockAdminHandler) GetGlobalIsolationGroups(ctx context.Context, request *types.GetGlobalIsolationGroupsRequest) (*types.GetGlobalIsolationGroupsResponse, error)

GetGlobalIsolationGroups mocks base method.

func (*MockAdminHandler) GetReplicationMessages added in v0.17.0 

func (m *MockAdminHandler) GetReplicationMessages(arg0 context.Context, arg1 *types.GetReplicationMessagesRequest) (*types.GetReplicationMessagesResponse, error)

GetReplicationMessages mocks base method.

func (*MockAdminHandler) GetWorkflowExecutionRawHistoryV2 added in v0.17.0 

func (m *MockAdminHandler) GetWorkflowExecutionRawHistoryV2(arg0 context.Context, arg1 *types.GetWorkflowExecutionRawHistoryV2Request) (*types.GetWorkflowExecutionRawHistoryV2Response, error)

GetWorkflowExecutionRawHistoryV2 mocks base method.

func (*MockAdminHandler) ListDynamicConfig added in v0.23.1 

func (m *MockAdminHandler) ListDynamicConfig(arg0 context.Context, arg1 *types.ListDynamicConfigRequest) (*types.ListDynamicConfigResponse, error)

ListDynamicConfig mocks base method.

func (*MockAdminHandler) MaintainCorruptWorkflow added in v0.24.0 

func (m *MockAdminHandler) MaintainCorruptWorkflow(arg0 context.Context, arg1 *types.AdminMaintainWorkflowRequest) (*types.AdminMaintainWorkflowResponse, error)

MaintainCorruptWorkflow mocks base method.

func (*MockAdminHandler) MergeDLQMessages added in v0.17.0 

func (m *MockAdminHandler) MergeDLQMessages(arg0 context.Context, arg1 *types.MergeDLQMessagesRequest) (*types.MergeDLQMessagesResponse, error)

MergeDLQMessages mocks base method.

func (*MockAdminHandler) PurgeDLQMessages added in v0.17.0 

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

PurgeDLQMessages mocks base method.

func (*MockAdminHandler) ReadDLQMessages added in v0.17.0 

func (m *MockAdminHandler) ReadDLQMessages(arg0 context.Context, arg1 *types.ReadDLQMessagesRequest) (*types.ReadDLQMessagesResponse, error)

ReadDLQMessages mocks base method.

func (*MockAdminHandler) ReapplyEvents added in v0.17.0 

func (m *MockAdminHandler) ReapplyEvents(arg0 context.Context, arg1 *types.ReapplyEventsRequest) error

ReapplyEvents mocks base method.

func (*MockAdminHandler) RefreshWorkflowTasks added in v0.17.0 

func (m *MockAdminHandler) RefreshWorkflowTasks(arg0 context.Context, arg1 *types.RefreshWorkflowTasksRequest) error

RefreshWorkflowTasks mocks base method.

func (*MockAdminHandler) RemoveTask added in v0.17.0 

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

RemoveTask mocks base method.

func (*MockAdminHandler) ResendReplicationTasks added in v0.17.0 

func (m *MockAdminHandler) ResendReplicationTasks(arg0 context.Context, arg1 *types.ResendReplicationTasksRequest) error

ResendReplicationTasks mocks base method.

func (*MockAdminHandler) ResetQueue added in v0.17.0 

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

ResetQueue mocks base method.

func (*MockAdminHandler) RespondCrossClusterTasksCompleted added in v0.24.0 

func (m *MockAdminHandler) RespondCrossClusterTasksCompleted(arg0 context.Context, arg1 *types.RespondCrossClusterTasksCompletedRequest) (*types.RespondCrossClusterTasksCompletedResponse, error)

RespondCrossClusterTasksCompleted mocks base method.

func (*MockAdminHandler) RestoreDynamicConfig added in v0.23.1 

func (m *MockAdminHandler) RestoreDynamicConfig(arg0 context.Context, arg1 *types.RestoreDynamicConfigRequest) error

RestoreDynamicConfig mocks base method.

func (*MockAdminHandler) Start added in v0.23.1 

func (m *MockAdminHandler) Start()

Start mocks base method.

func (*MockAdminHandler) Stop added in v0.23.1 

func (m *MockAdminHandler) Stop()

Stop mocks base method.

func (*MockAdminHandler) UpdateDomainIsolationGroups added in v1.2.1 

func (m *MockAdminHandler) UpdateDomainIsolationGroups(ctx context.Context, request *types.UpdateDomainIsolationGroupsRequest) (*types.UpdateDomainIsolationGroupsResponse, error)

UpdateDomainIsolationGroups mocks base method.

func (*MockAdminHandler) UpdateDynamicConfig added in v0.23.1 

func (m *MockAdminHandler) UpdateDynamicConfig(arg0 context.Context, arg1 *types.UpdateDynamicConfigRequest) error

UpdateDynamicConfig mocks base method.

func (*MockAdminHandler) UpdateGlobalIsolationGroups added in v1.2.1 

func (m *MockAdminHandler) UpdateGlobalIsolationGroups(ctx context.Context, request *types.UpdateGlobalIsolationGroupsRequest) (*types.UpdateGlobalIsolationGroupsResponse, error)

UpdateGlobalIsolationGroups 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) CountDLQMessages added in v0.25.0 

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

CountDLQMessages indicates an expected call of CountDLQMessages.

func (*MockAdminHandlerMockRecorder) DeleteWorkflow added in v0.25.0 

func (mr *MockAdminHandlerMockRecorder) DeleteWorkflow(arg0, arg1 interface{}) *gomock.Call

DeleteWorkflow indicates an expected call of DeleteWorkflow.

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) DescribeShardDistribution added in v0.23.1 

func (mr *MockAdminHandlerMockRecorder) DescribeShardDistribution(arg0, arg1 interface{}) *gomock.Call

DescribeShardDistribution indicates an expected call of DescribeShardDistribution.

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) GetCrossClusterTasks added in v0.23.1 

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

GetCrossClusterTasks indicates an expected call of GetCrossClusterTasks.

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) GetDomainIsolationGroups added in v1.2.1 

func (mr *MockAdminHandlerMockRecorder) GetDomainIsolationGroups(ctx, request interface{}) *gomock.Call

GetDomainIsolationGroups indicates an expected call of GetDomainIsolationGroups.

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) GetDynamicConfig added in v0.23.1 

func (mr *MockAdminHandlerMockRecorder) GetDynamicConfig(arg0, arg1 interface{}) *gomock.Call

GetDynamicConfig indicates an expected call of GetDynamicConfig.

func (*MockAdminHandlerMockRecorder) GetGlobalIsolationGroups added in v1.2.1 

func (mr *MockAdminHandlerMockRecorder) GetGlobalIsolationGroups(ctx, request interface{}) *gomock.Call

GetGlobalIsolationGroups indicates an expected call of GetGlobalIsolationGroups.

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) ListDynamicConfig added in v0.23.1 

func (mr *MockAdminHandlerMockRecorder) ListDynamicConfig(arg0, arg1 interface{}) *gomock.Call

ListDynamicConfig indicates an expected call of ListDynamicConfig.

func (*MockAdminHandlerMockRecorder) MaintainCorruptWorkflow added in v0.25.0 

func (mr *MockAdminHandlerMockRecorder) MaintainCorruptWorkflow(arg0, arg1 interface{}) *gomock.Call

MaintainCorruptWorkflow indicates an expected call of MaintainCorruptWorkflow.

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.

func (*MockAdminHandlerMockRecorder) RespondCrossClusterTasksCompleted added in v0.24.0 

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

RespondCrossClusterTasksCompleted indicates an expected call of RespondCrossClusterTasksCompleted.

func (*MockAdminHandlerMockRecorder) RestoreDynamicConfig added in v0.23.1 

func (mr *MockAdminHandlerMockRecorder) RestoreDynamicConfig(arg0, arg1 interface{}) *gomock.Call

RestoreDynamicConfig indicates an expected call of RestoreDynamicConfig.

func (*MockAdminHandlerMockRecorder) Start added in v0.23.1 

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

Start indicates an expected call of Start.

func (*MockAdminHandlerMockRecorder) Stop added in v0.23.1 

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

Stop indicates an expected call of Stop.

func (*MockAdminHandlerMockRecorder) UpdateDomainIsolationGroups added in v1.2.1 

func (mr *MockAdminHandlerMockRecorder) UpdateDomainIsolationGroups(ctx, request interface{}) *gomock.Call

UpdateDomainIsolationGroups indicates an expected call of UpdateDomainIsolationGroups.

func (*MockAdminHandlerMockRecorder) UpdateDynamicConfig added in v0.23.1 

func (mr *MockAdminHandlerMockRecorder) UpdateDynamicConfig(arg0, arg1 interface{}) *gomock.Call

UpdateDynamicConfig indicates an expected call of UpdateDynamicConfig.

func (*MockAdminHandlerMockRecorder) UpdateGlobalIsolationGroups added in v1.2.1 

func (mr *MockAdminHandlerMockRecorder) UpdateGlobalIsolationGroups(ctx, request interface{}) *gomock.Call

UpdateGlobalIsolationGroups indicates an expected call of UpdateGlobalIsolationGroups.

type MockClusterRedirectionPolicy added in v0.24.0 

type MockClusterRedirectionPolicy struct {
	mock.Mock
}

MockClusterRedirectionPolicy is an autogenerated mock type for the ClusterRedirectionPolicy type

func (*MockClusterRedirectionPolicy) WithDomainIDRedirect added in v0.24.0 

func (_m *MockClusterRedirectionPolicy) 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 (*MockClusterRedirectionPolicy) WithDomainNameRedirect added in v0.24.0 

func (_m *MockClusterRedirectionPolicy) 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(arg0 context.Context, arg1 *types.CountWorkflowExecutionsRequest) (*types.CountWorkflowExecutionsResponse, error)

CountWorkflowExecutions mocks base method.

func (*MockHandler) DeprecateDomain added in v0.13.0 

func (m *MockHandler) DeprecateDomain(arg0 context.Context, arg1 *types.DeprecateDomainRequest) error

DeprecateDomain mocks base method.

func (*MockHandler) DescribeDomain added in v0.13.0 

func (m *MockHandler) DescribeDomain(arg0 context.Context, arg1 *types.DescribeDomainRequest) (*types.DescribeDomainResponse, error)

DescribeDomain mocks base method.

func (*MockHandler) DescribeTaskList added in v0.13.0 

func (m *MockHandler) DescribeTaskList(arg0 context.Context, arg1 *types.DescribeTaskListRequest) (*types.DescribeTaskListResponse, error)

DescribeTaskList mocks base method.

func (*MockHandler) DescribeWorkflowExecution added in v0.13.0 

func (m *MockHandler) DescribeWorkflowExecution(arg0 context.Context, arg1 *types.DescribeWorkflowExecutionRequest) (*types.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(arg0 context.Context) (*types.ClusterInfo, error)

GetClusterInfo mocks base method.

func (*MockHandler) GetSearchAttributes added in v0.13.0 

func (m *MockHandler) GetSearchAttributes(arg0 context.Context) (*types.GetSearchAttributesResponse, error)

GetSearchAttributes mocks base method.

func (*MockHandler) GetTaskListsByDomain added in v0.23.1 

func (m *MockHandler) GetTaskListsByDomain(arg0 context.Context, arg1 *types.GetTaskListsByDomainRequest) (*types.GetTaskListsByDomainResponse, error)

GetTaskListsByDomain mocks base method.

func (*MockHandler) GetWorkflowExecutionHistory added in v0.13.0 

func (m *MockHandler) GetWorkflowExecutionHistory(arg0 context.Context, arg1 *types.GetWorkflowExecutionHistoryRequest) (*types.GetWorkflowExecutionHistoryResponse, error)

GetWorkflowExecutionHistory mocks base method.

func (*MockHandler) Health added in v0.13.0 

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

Health mocks base method.

func (*MockHandler) ListArchivedWorkflowExecutions added in v0.13.0 

func (m *MockHandler) ListArchivedWorkflowExecutions(arg0 context.Context, arg1 *types.ListArchivedWorkflowExecutionsRequest) (*types.ListArchivedWorkflowExecutionsResponse, error)

ListArchivedWorkflowExecutions mocks base method.

func (*MockHandler) ListClosedWorkflowExecutions added in v0.13.0 

func (m *MockHandler) ListClosedWorkflowExecutions(arg0 context.Context, arg1 *types.ListClosedWorkflowExecutionsRequest) (*types.ListClosedWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutions mocks base method.

func (*MockHandler) ListDomains added in v0.13.0 

func (m *MockHandler) ListDomains(arg0 context.Context, arg1 *types.ListDomainsRequest) (*types.ListDomainsResponse, error)

ListDomains mocks base method.

func (*MockHandler) ListOpenWorkflowExecutions added in v0.13.0 

func (m *MockHandler) ListOpenWorkflowExecutions(arg0 context.Context, arg1 *types.ListOpenWorkflowExecutionsRequest) (*types.ListOpenWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutions mocks base method.

func (*MockHandler) ListTaskListPartitions added in v0.13.0 

func (m *MockHandler) ListTaskListPartitions(arg0 context.Context, arg1 *types.ListTaskListPartitionsRequest) (*types.ListTaskListPartitionsResponse, error)

ListTaskListPartitions mocks base method.

func (*MockHandler) ListWorkflowExecutions added in v0.13.0 

func (m *MockHandler) ListWorkflowExecutions(arg0 context.Context, arg1 *types.ListWorkflowExecutionsRequest) (*types.ListWorkflowExecutionsResponse, error)

ListWorkflowExecutions mocks base method.

func (*MockHandler) PollForActivityTask added in v0.13.0 

func (m *MockHandler) PollForActivityTask(arg0 context.Context, arg1 *types.PollForActivityTaskRequest) (*types.PollForActivityTaskResponse, error)

PollForActivityTask mocks base method.

func (*MockHandler) PollForDecisionTask added in v0.13.0 

func (m *MockHandler) PollForDecisionTask(arg0 context.Context, arg1 *types.PollForDecisionTaskRequest) (*types.PollForDecisionTaskResponse, error)

PollForDecisionTask mocks base method.

func (*MockHandler) QueryWorkflow added in v0.13.0 

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

QueryWorkflow mocks base method.

func (*MockHandler) RecordActivityTaskHeartbeat added in v0.13.0 

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

RecordActivityTaskHeartbeat mocks base method.

func (*MockHandler) RecordActivityTaskHeartbeatByID added in v0.13.0 

func (m *MockHandler) RecordActivityTaskHeartbeatByID(arg0 context.Context, arg1 *types.RecordActivityTaskHeartbeatByIDRequest) (*types.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeatByID mocks base method.

func (*MockHandler) RefreshWorkflowTasks added in v0.24.0 

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

RefreshWorkflowTasks mocks base method.

func (*MockHandler) RegisterDomain added in v0.13.0 

func (m *MockHandler) RegisterDomain(arg0 context.Context, arg1 *types.RegisterDomainRequest) error

RegisterDomain mocks base method.

func (*MockHandler) RequestCancelWorkflowExecution added in v0.13.0 

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

RequestCancelWorkflowExecution mocks base method.

func (*MockHandler) ResetStickyTaskList added in v0.13.0 

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

ResetStickyTaskList mocks base method.

func (*MockHandler) ResetWorkflowExecution added in v0.13.0 

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

ResetWorkflowExecution mocks base method.

func (*MockHandler) RespondActivityTaskCanceled added in v0.13.0 

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

RespondActivityTaskCanceled mocks base method.

func (*MockHandler) RespondActivityTaskCanceledByID added in v0.13.0 

func (m *MockHandler) RespondActivityTaskCanceledByID(arg0 context.Context, arg1 *types.RespondActivityTaskCanceledByIDRequest) error

RespondActivityTaskCanceledByID mocks base method.

func (*MockHandler) RespondActivityTaskCompleted added in v0.13.0 

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

RespondActivityTaskCompleted mocks base method.

func (*MockHandler) RespondActivityTaskCompletedByID added in v0.13.0 

func (m *MockHandler) RespondActivityTaskCompletedByID(arg0 context.Context, arg1 *types.RespondActivityTaskCompletedByIDRequest) error

RespondActivityTaskCompletedByID mocks base method.

func (*MockHandler) RespondActivityTaskFailed added in v0.13.0 

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

RespondActivityTaskFailed mocks base method.

func (*MockHandler) RespondActivityTaskFailedByID added in v0.13.0 

func (m *MockHandler) RespondActivityTaskFailedByID(arg0 context.Context, arg1 *types.RespondActivityTaskFailedByIDRequest) error

RespondActivityTaskFailedByID mocks base method.

func (*MockHandler) RespondDecisionTaskCompleted added in v0.13.0 

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

RespondDecisionTaskCompleted mocks base method.

func (*MockHandler) RespondDecisionTaskFailed added in v0.13.0 

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

RespondDecisionTaskFailed mocks base method.

func (*MockHandler) RespondQueryTaskCompleted added in v0.13.0 

func (m *MockHandler) RespondQueryTaskCompleted(arg0 context.Context, arg1 *types.RespondQueryTaskCompletedRequest) error

RespondQueryTaskCompleted mocks base method.

func (*MockHandler) RestartWorkflowExecution added in v0.25.0 

func (m *MockHandler) RestartWorkflowExecution(arg0 context.Context, arg1 *types.RestartWorkflowExecutionRequest) (*types.RestartWorkflowExecutionResponse, error)

RestartWorkflowExecution mocks base method.

func (*MockHandler) ScanWorkflowExecutions added in v0.13.0 

func (m *MockHandler) ScanWorkflowExecutions(arg0 context.Context, arg1 *types.ListWorkflowExecutionsRequest) (*types.ListWorkflowExecutionsResponse, error)

ScanWorkflowExecutions mocks base method.

func (*MockHandler) SignalWithStartWorkflowExecution added in v0.13.0 

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

SignalWithStartWorkflowExecution mocks base method.

func (*MockHandler) SignalWorkflowExecution added in v0.13.0 

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

SignalWorkflowExecution mocks base method.

func (*MockHandler) StartWorkflowExecution added in v0.13.0 

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

StartWorkflowExecution mocks base method.

func (*MockHandler) TerminateWorkflowExecution added in v0.13.0 

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

TerminateWorkflowExecution mocks base method.

func (*MockHandler) UpdateDomain added in v0.13.0 

func (m *MockHandler) UpdateDomain(arg0 context.Context, arg1 *types.UpdateDomainRequest) (*types.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(arg0, arg1 interface{}) *gomock.Call

CountWorkflowExecutions indicates an expected call of CountWorkflowExecutions.

func (*MockHandlerMockRecorder) DeprecateDomain added in v0.13.0 

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

DeprecateDomain indicates an expected call of DeprecateDomain.

func (*MockHandlerMockRecorder) DescribeDomain added in v0.13.0 

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

DescribeDomain indicates an expected call of DescribeDomain.

func (*MockHandlerMockRecorder) DescribeTaskList added in v0.13.0 

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

DescribeTaskList indicates an expected call of DescribeTaskList.

func (*MockHandlerMockRecorder) DescribeWorkflowExecution added in v0.13.0 

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

DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.

func (*MockHandlerMockRecorder) GetClusterInfo added in v0.13.0 

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

GetClusterInfo indicates an expected call of GetClusterInfo.

func (*MockHandlerMockRecorder) GetSearchAttributes added in v0.13.0 

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

GetSearchAttributes indicates an expected call of GetSearchAttributes.

func (*MockHandlerMockRecorder) GetTaskListsByDomain added in v0.23.1 

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

GetTaskListsByDomain indicates an expected call of GetTaskListsByDomain.

func (*MockHandlerMockRecorder) GetWorkflowExecutionHistory added in v0.13.0 

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

GetWorkflowExecutionHistory indicates an expected call of GetWorkflowExecutionHistory.

func (*MockHandlerMockRecorder) Health added in v0.13.0 

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

Health indicates an expected call of Health.

func (*MockHandlerMockRecorder) ListArchivedWorkflowExecutions added in v0.13.0 

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

ListArchivedWorkflowExecutions indicates an expected call of ListArchivedWorkflowExecutions.

func (*MockHandlerMockRecorder) ListClosedWorkflowExecutions added in v0.13.0 

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

ListClosedWorkflowExecutions indicates an expected call of ListClosedWorkflowExecutions.

func (*MockHandlerMockRecorder) ListDomains added in v0.13.0 

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

ListDomains indicates an expected call of ListDomains.

func (*MockHandlerMockRecorder) ListOpenWorkflowExecutions added in v0.13.0 

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

ListOpenWorkflowExecutions indicates an expected call of ListOpenWorkflowExecutions.

func (*MockHandlerMockRecorder) ListTaskListPartitions added in v0.13.0 

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

ListTaskListPartitions indicates an expected call of ListTaskListPartitions.

func (*MockHandlerMockRecorder) ListWorkflowExecutions added in v0.13.0 

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

ListWorkflowExecutions indicates an expected call of ListWorkflowExecutions.

func (*MockHandlerMockRecorder) PollForActivityTask added in v0.13.0 

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

PollForActivityTask indicates an expected call of PollForActivityTask.

func (*MockHandlerMockRecorder) PollForDecisionTask added in v0.13.0 

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

PollForDecisionTask indicates an expected call of PollForDecisionTask.

func (*MockHandlerMockRecorder) QueryWorkflow added in v0.13.0 

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

QueryWorkflow indicates an expected call of QueryWorkflow.

func (*MockHandlerMockRecorder) RecordActivityTaskHeartbeat added in v0.13.0 

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

RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat.

func (*MockHandlerMockRecorder) RecordActivityTaskHeartbeatByID added in v0.13.0 

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

RecordActivityTaskHeartbeatByID indicates an expected call of RecordActivityTaskHeartbeatByID.

func (*MockHandlerMockRecorder) RefreshWorkflowTasks added in v0.24.0 

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

RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks.

func (*MockHandlerMockRecorder) RegisterDomain added in v0.13.0 

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

RegisterDomain indicates an expected call of RegisterDomain.

func (*MockHandlerMockRecorder) RequestCancelWorkflowExecution added in v0.13.0 

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

RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution.

func (*MockHandlerMockRecorder) ResetStickyTaskList added in v0.13.0 

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

ResetStickyTaskList indicates an expected call of ResetStickyTaskList.

func (*MockHandlerMockRecorder) ResetWorkflowExecution added in v0.13.0 

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

ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.

func (*MockHandlerMockRecorder) RespondActivityTaskCanceled added in v0.13.0 

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

RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled.

func (*MockHandlerMockRecorder) RespondActivityTaskCanceledByID added in v0.13.0 

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

RespondActivityTaskCanceledByID indicates an expected call of RespondActivityTaskCanceledByID.

func (*MockHandlerMockRecorder) RespondActivityTaskCompleted added in v0.13.0 

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

RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted.

func (*MockHandlerMockRecorder) RespondActivityTaskCompletedByID added in v0.13.0 

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

RespondActivityTaskCompletedByID indicates an expected call of RespondActivityTaskCompletedByID.

func (*MockHandlerMockRecorder) RespondActivityTaskFailed added in v0.13.0 

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

RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed.

func (*MockHandlerMockRecorder) RespondActivityTaskFailedByID added in v0.13.0 

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

RespondActivityTaskFailedByID indicates an expected call of RespondActivityTaskFailedByID.

func (*MockHandlerMockRecorder) RespondDecisionTaskCompleted added in v0.13.0 

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

RespondDecisionTaskCompleted indicates an expected call of RespondDecisionTaskCompleted.

func (*MockHandlerMockRecorder) RespondDecisionTaskFailed added in v0.13.0 

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

RespondDecisionTaskFailed indicates an expected call of RespondDecisionTaskFailed.

func (*MockHandlerMockRecorder) RespondQueryTaskCompleted added in v0.13.0 

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

RespondQueryTaskCompleted indicates an expected call of RespondQueryTaskCompleted.

func (*MockHandlerMockRecorder) RestartWorkflowExecution added in v0.25.0 

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

RestartWorkflowExecution indicates an expected call of RestartWorkflowExecution.

func (*MockHandlerMockRecorder) ScanWorkflowExecutions added in v0.13.0 

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

ScanWorkflowExecutions indicates an expected call of ScanWorkflowExecutions.

func (*MockHandlerMockRecorder) SignalWithStartWorkflowExecution added in v0.13.0 

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

SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution.

func (*MockHandlerMockRecorder) SignalWorkflowExecution added in v0.13.0 

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

SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution.

func (*MockHandlerMockRecorder) StartWorkflowExecution added in v0.13.0 

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

StartWorkflowExecution indicates an expected call of StartWorkflowExecution.

func (*MockHandlerMockRecorder) TerminateWorkflowExecution added in v0.13.0 

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

TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution.

func (*MockHandlerMockRecorder) UpdateDomain added in v0.13.0 

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

UpdateDomain indicates an expected call of UpdateDomain.

type Service 

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

Service represents the cadence-frontend service

func (*Service) Start 

func (s *Service) Start()

Start starts the service

func (*Service) Stop 

func (s *Service) Stop()

Stop stops the service

type ThriftHandler added in v0.17.0 

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

ThriftHandler wrap underlying handler and handles Thrift related type conversions

func NewThriftHandler added in v0.17.0 

func NewThriftHandler(h Handler) ThriftHandler

NewThriftHandler creates Thrift handler on top of underlying handler

func (ThriftHandler) CountWorkflowExecutions added in v0.17.0 

func (t ThriftHandler) CountWorkflowExecutions(ctx context.Context, request *shared.CountWorkflowExecutionsRequest) (*shared.CountWorkflowExecutionsResponse, 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) 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) (*shared.DescribeDomainResponse, 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) (*shared.DescribeTaskListResponse, 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) (*shared.DescribeWorkflowExecutionResponse, error)

DescribeWorkflowExecution forwards request to the underlying handler

func (ThriftHandler) GetClusterInfo added in v0.17.0 

func (t ThriftHandler) GetClusterInfo(ctx context.Context) (*shared.ClusterInfo, error)

GetClusterInfo forwards request to the underlying handler

func (ThriftHandler) GetSearchAttributes added in v0.17.0 

func (t ThriftHandler) GetSearchAttributes(ctx context.Context) (*shared.GetSearchAttributesResponse, error)

GetSearchAttributes forwards request to the underlying handler

func (ThriftHandler) GetTaskListsByDomain added in v0.23.1 

func (t ThriftHandler) GetTaskListsByDomain(ctx context.Context, request *shared.GetTaskListsByDomainRequest) (*shared.GetTaskListsByDomainResponse, error)

GetTaskListsByDomain forwards request to the underlying handler

func (ThriftHandler) GetWorkflowExecutionHistory added in v0.17.0 

func (t ThriftHandler) GetWorkflowExecutionHistory(ctx context.Context, request *shared.GetWorkflowExecutionHistoryRequest) (*shared.GetWorkflowExecutionHistoryResponse, error)

GetWorkflowExecutionHistory forwards request to the underlying handler

func (ThriftHandler) Health added in v0.17.0 

func (t ThriftHandler) Health(ctx context.Context) (*health.HealthStatus, 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) (*shared.ListArchivedWorkflowExecutionsResponse, 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) (*shared.ListClosedWorkflowExecutionsResponse, 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) (*shared.ListDomainsResponse, 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) (*shared.ListOpenWorkflowExecutionsResponse, 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) (*shared.ListTaskListPartitionsResponse, 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) (*shared.ListWorkflowExecutionsResponse, 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) (*shared.PollForActivityTaskResponse, 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) (*shared.PollForDecisionTaskResponse, 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) (*shared.QueryWorkflowResponse, 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) (*shared.RecordActivityTaskHeartbeatResponse, 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) (*shared.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeatByID forwards request to the underlying handler

func (ThriftHandler) RefreshWorkflowTasks added in v0.24.0 

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

RefreshWorkflowTasks forwards request to the underlying handler

func (ThriftHandler) RegisterDomain added in v0.17.0 

func (t ThriftHandler) RegisterDomain(ctx context.Context, request *shared.RegisterDomainRequest) 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) 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) (*shared.ResetStickyTaskListResponse, 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) (*shared.ResetWorkflowExecutionResponse, 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) 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) 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) 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) 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) 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) 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) (*shared.RespondDecisionTaskCompletedResponse, 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) 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) error

RespondQueryTaskCompleted forwards request to the underlying handler

func (ThriftHandler) RestartWorkflowExecution added in v0.25.0 

func (t ThriftHandler) RestartWorkflowExecution(ctx context.Context, request *shared.RestartWorkflowExecutionRequest) (*shared.RestartWorkflowExecutionResponse, error)

func (ThriftHandler) ScanWorkflowExecutions added in v0.17.0 

func (t ThriftHandler) ScanWorkflowExecutions(ctx context.Context, request *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, 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) (*shared.StartWorkflowExecutionResponse, 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) 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) (*shared.StartWorkflowExecutionResponse, 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) 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) (*shared.UpdateDomainResponse, error)

UpdateDomain forwards request to the underlying handler

type WorkflowHandler 

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

WorkflowHandler - Thrift handler interface for workflow service

func NewWorkflowHandler 

func NewWorkflowHandler(
	resource resource.Resource,
	config *Config,
	versionChecker client.VersionChecker,
	domainHandler domain.Handler,
) *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 *types.CountWorkflowExecutionsRequest,
) (resp *types.CountWorkflowExecutionsResponse, retError error)

CountWorkflowExecutions - count number of workflow executions in a domain

func (*WorkflowHandler) DeprecateDomain 

func (wh *WorkflowHandler) DeprecateDomain(ctx context.Context, deprecateRequest *types.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 *types.DescribeDomainRequest,
) (response *types.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 *types.DescribeTaskListRequest,
) (resp *types.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 *types.DescribeWorkflowExecutionRequest,
) (resp *types.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 *types.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 *types.GetSearchAttributesResponse, retError error)

GetSearchAttributes return valid indexed keys

func (*WorkflowHandler) GetTaskListsByDomain added in v0.23.1 

func (wh *WorkflowHandler) GetTaskListsByDomain(
	ctx context.Context,
	request *types.GetTaskListsByDomainRequest,
) (resp *types.GetTaskListsByDomainResponse, retError error)

GetTaskListsByDomain returns all the partition and host for a taskList

func (*WorkflowHandler) GetWorkflowExecutionHistory 

func (wh *WorkflowHandler) GetWorkflowExecutionHistory(
	ctx context.Context,
	getRequest *types.GetWorkflowExecutionHistoryRequest,
) (resp *types.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) (*types.HealthStatus, error)

Health is for health check

func (*WorkflowHandler) ListArchivedWorkflowExecutions added in v0.9.0 

func (wh *WorkflowHandler) ListArchivedWorkflowExecutions(
	ctx context.Context,
	listRequest *types.ListArchivedWorkflowExecutionsRequest,
) (resp *types.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 *types.ListClosedWorkflowExecutionsRequest,
) (resp *types.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 *types.ListDomainsRequest,
) (response *types.ListDomainsResponse, retError error)

ListDomains returns the information and configuration for a registered domain.

func (*WorkflowHandler) ListOpenWorkflowExecutions 

func (wh *WorkflowHandler) ListOpenWorkflowExecutions(
	ctx context.Context,
	listRequest *types.ListOpenWorkflowExecutionsRequest,
) (resp *types.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 *types.ListTaskListPartitionsRequest,
) (resp *types.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 *types.ListWorkflowExecutionsRequest,
) (resp *types.ListWorkflowExecutionsResponse, retError error)

ListWorkflowExecutions - retrieves info for workflow executions in a domain

func (*WorkflowHandler) PollForActivityTask 

func (wh *WorkflowHandler) PollForActivityTask(
	ctx context.Context,
	pollRequest *types.PollForActivityTaskRequest,
) (resp *types.PollForActivityTaskResponse, retError error)

PollForActivityTask - Poll for an activity task.

func (*WorkflowHandler) PollForDecisionTask 

func (wh *WorkflowHandler) PollForDecisionTask(
	ctx context.Context,
	pollRequest *types.PollForDecisionTaskRequest,
) (resp *types.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 *types.QueryWorkflowRequest,
) (resp *types.QueryWorkflowResponse, retError error)

QueryWorkflow returns query result for a specified workflow execution

func (*WorkflowHandler) RecordActivityTaskHeartbeat 

func (wh *WorkflowHandler) RecordActivityTaskHeartbeat(
	ctx context.Context,
	heartbeatRequest *types.RecordActivityTaskHeartbeatRequest,
) (resp *types.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 *types.RecordActivityTaskHeartbeatByIDRequest,
) (resp *types.RecordActivityTaskHeartbeatResponse, retError error)

RecordActivityTaskHeartbeatByID - Record Activity Task Heart beat.

func (*WorkflowHandler) RefreshWorkflowTasks added in v0.24.0 

func (wh *WorkflowHandler) RefreshWorkflowTasks(
	ctx context.Context,
	request *types.RefreshWorkflowTasksRequest,
) (err error)

RefreshWorkflowTasks re-generates the workflow tasks

func (*WorkflowHandler) RegisterDomain 

func (wh *WorkflowHandler) RegisterDomain(ctx context.Context, registerRequest *types.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 *types.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 *types.ResetStickyTaskListRequest,
) (resp *types.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 *types.ResetWorkflowExecutionRequest,
) (resp *types.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 *types.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 *types.RespondActivityTaskCanceledByIDRequest,
) (retError error)

RespondActivityTaskCanceledByID - called to cancel an activity task

func (*WorkflowHandler) RespondActivityTaskCompleted 

func (wh *WorkflowHandler) RespondActivityTaskCompleted(
	ctx context.Context,
	completeRequest *types.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 *types.RespondActivityTaskCompletedByIDRequest,
) (retError error)

RespondActivityTaskCompletedByID - response to an activity task

func (*WorkflowHandler) RespondActivityTaskFailed 

func (wh *WorkflowHandler) RespondActivityTaskFailed(
	ctx context.Context,
	failedRequest *types.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 *types.RespondActivityTaskFailedByIDRequest,
) (retError error)

RespondActivityTaskFailedByID - response to an activity task failure

func (*WorkflowHandler) RespondDecisionTaskCompleted 

func (wh *WorkflowHandler) RespondDecisionTaskCompleted(
	ctx context.Context,
	completeRequest *types.RespondDecisionTaskCompletedRequest,
) (resp *types.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 *types.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 *types.RespondQueryTaskCompletedRequest,
) (retError error)

RespondQueryTaskCompleted - response to a query task

func (*WorkflowHandler) RestartWorkflowExecution added in v0.25.0 

func (wh *WorkflowHandler) RestartWorkflowExecution(ctx context.Context, request *types.RestartWorkflowExecutionRequest) (resp *types.RestartWorkflowExecutionResponse, retError error)

RestartWorkflowExecution - retrieves info for an existing workflow then restarts it

func (*WorkflowHandler) ScanWorkflowExecutions added in v0.5.8 

func (wh *WorkflowHandler) ScanWorkflowExecutions(
	ctx context.Context,
	listRequest *types.ListWorkflowExecutionsRequest,
) (resp *types.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 *types.SignalWithStartWorkflowExecutionRequest,
) (resp *types.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 *types.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) Start 

func (wh *WorkflowHandler) Start()

Start starts the handler

func (*WorkflowHandler) StartWorkflowExecution 

func (wh *WorkflowHandler) StartWorkflowExecution(
	ctx context.Context,
	startRequest *types.StartWorkflowExecutionRequest,
) (resp *types.StartWorkflowExecutionResponse, retError error)

StartWorkflowExecution - Creates a new workflow execution

func (*WorkflowHandler) Stop 

func (wh *WorkflowHandler) Stop()

Stop stops the handler

func (*WorkflowHandler) TerminateWorkflowExecution 

func (wh *WorkflowHandler) TerminateWorkflowExecution(
	ctx context.Context,
	terminateRequest *types.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 *types.UpdateDomainRequest,
) (resp *types.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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.