frontend

package
v0.13.0 Latest Latest
Warning

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

 Go to latest Published: Jul 7, 2020 License: MIT Imports: 49 Imported by: 7

Documentation

Overview

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 APIs based domain
	// 1. StartWorkflowExecution
	// 2. SignalWithStartWorkflowExecution
	// 3. SignalWorkflowExecution
	// 4. RequestCancelWorkflowExecution
	// 5. TerminateWorkflowExecution
	// 6. QueryWorkflow
	// please also reference selectedAPIsForwardingRedirectionPolicyWhitelistedAPIs
	DCRedirectionPolicySelectedAPIsForwarding = "selected-apis-forwarding"
)

Variables

This section is empty.

Functions

func NewService 

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

NewService builds a new cadence-frontend service

Types

type AccessControlledWorkflowHandler added in v0.11.0 

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

AccessControlledWorkflowHandler frontend handler wrapper for authentication and authorization

func NewAccessControlledHandlerImpl added in v0.11.0 

func NewAccessControlledHandlerImpl(wfHandler Handler, authorizer authorization.Authorizer) *AccessControlledWorkflowHandler

NewAccessControlledHandlerImpl creates frontend handler with authentication support

func (*AccessControlledWorkflowHandler) CountWorkflowExecutions added in v0.11.0 

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

CountWorkflowExecutions API call

func (*AccessControlledWorkflowHandler) DeprecateDomain added in v0.11.0 

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

DeprecateDomain API call

func (*AccessControlledWorkflowHandler) DescribeDomain added in v0.11.0 

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

DescribeDomain API call

func (*AccessControlledWorkflowHandler) DescribeTaskList added in v0.11.0 

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

DescribeTaskList API call

func (*AccessControlledWorkflowHandler) DescribeWorkflowExecution added in v0.11.0 

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

DescribeWorkflowExecution API call

func (*AccessControlledWorkflowHandler) GetClusterInfo added in v0.11.0 

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

GetClusterInfo API call

func (*AccessControlledWorkflowHandler) GetConfig added in v0.13.0 

func (a *AccessControlledWorkflowHandler) GetConfig() *Config

GetConfig return config

func (*AccessControlledWorkflowHandler) GetResource added in v0.13.0 

func (a *AccessControlledWorkflowHandler) GetResource() resource.Resource

GetResource return resource

func (*AccessControlledWorkflowHandler) GetSearchAttributes added in v0.11.0 

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

GetSearchAttributes API call

func (*AccessControlledWorkflowHandler) GetWorkflowExecutionHistory added in v0.11.0 

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

GetWorkflowExecutionHistory API call

func (*AccessControlledWorkflowHandler) Health added in v0.11.0 

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

Health callback for for health check

func (*AccessControlledWorkflowHandler) ListArchivedWorkflowExecutions added in v0.11.0 

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

ListArchivedWorkflowExecutions API call

func (*AccessControlledWorkflowHandler) ListClosedWorkflowExecutions added in v0.11.0 

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

ListClosedWorkflowExecutions API call

func (*AccessControlledWorkflowHandler) ListDomains added in v0.11.0 

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

ListDomains API call

func (*AccessControlledWorkflowHandler) ListOpenWorkflowExecutions added in v0.11.0 

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

ListOpenWorkflowExecutions API call

func (*AccessControlledWorkflowHandler) ListTaskListPartitions added in v0.11.0 

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

ListTaskListPartitions API call

func (*AccessControlledWorkflowHandler) ListWorkflowExecutions added in v0.11.0 

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

ListWorkflowExecutions API call

func (*AccessControlledWorkflowHandler) PollForActivityTask added in v0.11.0 

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

PollForActivityTask API call

func (*AccessControlledWorkflowHandler) PollForDecisionTask added in v0.11.0 

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

PollForDecisionTask API call

func (*AccessControlledWorkflowHandler) QueryWorkflow added in v0.11.0 

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

QueryWorkflow API call

func (*AccessControlledWorkflowHandler) RecordActivityTaskHeartbeat added in v0.11.0 

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

RecordActivityTaskHeartbeat API call

func (*AccessControlledWorkflowHandler) RecordActivityTaskHeartbeatByID added in v0.11.0 

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

RecordActivityTaskHeartbeatByID API call

func (*AccessControlledWorkflowHandler) RegisterDomain added in v0.11.0 

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

RegisterDomain API call

func (*AccessControlledWorkflowHandler) RegisterHandler added in v0.11.0 

func (a *AccessControlledWorkflowHandler) RegisterHandler()

RegisterHandler register this handler, must be called before Start()

func (*AccessControlledWorkflowHandler) RequestCancelWorkflowExecution added in v0.11.0 

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

RequestCancelWorkflowExecution API call

func (*AccessControlledWorkflowHandler) ResetStickyTaskList added in v0.11.0 

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

ResetStickyTaskList API call

func (*AccessControlledWorkflowHandler) ResetWorkflowExecution added in v0.11.0 

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

ResetWorkflowExecution API call

func (*AccessControlledWorkflowHandler) RespondActivityTaskCanceled added in v0.11.0 

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

RespondActivityTaskCanceled API call

func (*AccessControlledWorkflowHandler) RespondActivityTaskCanceledByID added in v0.11.0 

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

RespondActivityTaskCanceledByID API call

func (*AccessControlledWorkflowHandler) RespondActivityTaskCompleted added in v0.11.0 

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

RespondActivityTaskCompleted API call

func (*AccessControlledWorkflowHandler) RespondActivityTaskCompletedByID added in v0.11.0 

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

RespondActivityTaskCompletedByID API call

func (*AccessControlledWorkflowHandler) RespondActivityTaskFailed added in v0.11.0 

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

RespondActivityTaskFailed API call

func (*AccessControlledWorkflowHandler) RespondActivityTaskFailedByID added in v0.11.0 

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

RespondActivityTaskFailedByID API call

func (*AccessControlledWorkflowHandler) RespondDecisionTaskCompleted added in v0.11.0 

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

RespondDecisionTaskCompleted API call

func (*AccessControlledWorkflowHandler) RespondDecisionTaskFailed added in v0.11.0 

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

RespondDecisionTaskFailed API call

func (*AccessControlledWorkflowHandler) RespondQueryTaskCompleted added in v0.11.0 

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

RespondQueryTaskCompleted API call

func (*AccessControlledWorkflowHandler) ScanWorkflowExecutions added in v0.11.0 

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

ScanWorkflowExecutions API call

func (*AccessControlledWorkflowHandler) SignalWithStartWorkflowExecution added in v0.11.0 

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

SignalWithStartWorkflowExecution API call

func (*AccessControlledWorkflowHandler) SignalWorkflowExecution added in v0.11.0 

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

SignalWorkflowExecution API call

func (*AccessControlledWorkflowHandler) Start added in v0.11.0 

func (a *AccessControlledWorkflowHandler) Start()

Start starts the handler

func (*AccessControlledWorkflowHandler) StartWorkflowExecution added in v0.11.0 

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

StartWorkflowExecution API call

func (*AccessControlledWorkflowHandler) Stop added in v0.11.0 

func (a *AccessControlledWorkflowHandler) Stop()

Stop stops the handler

func (*AccessControlledWorkflowHandler) TerminateWorkflowExecution added in v0.11.0 

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

TerminateWorkflowExecution API call

func (*AccessControlledWorkflowHandler) UpdateDomain added in v0.11.0 

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

UpdateDomain API call

func (*AccessControlledWorkflowHandler) UpdateHealthStatus added in v0.12.0 

func (a *AccessControlledWorkflowHandler) UpdateHealthStatus(status HealthStatus)

UpdateHealthStatus sets the health status for this rpc handler. This health status will be used within the rpc health check handler

type AdminHandler added in v0.3.12 

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

AdminHandler - Thrift handler interface for admin service

func NewAdminHandler added in v0.3.12 

func NewAdminHandler(
	resource resource.Resource,
	params *service.BootstrapParams,
	config *Config,
) *AdminHandler

NewAdminHandler creates a thrift handler for the cadence admin service

func (*AdminHandler) AddSearchAttribute added in v0.6.0 

func (adh *AdminHandler) AddSearchAttribute(
	ctx context.Context,
	request *admin.AddSearchAttributeRequest,
) (retError error)

AddSearchAttribute add search attribute to whitelist

func (*AdminHandler) CloseShard added in v0.9.0 

func (adh *AdminHandler) CloseShard(
	ctx context.Context,
	request *gen.CloseShardRequest,
) (retError error)

CloseShard returns information about the internal states of a history host

func (*AdminHandler) DescribeCluster added in v0.11.0 

func (adh *AdminHandler) DescribeCluster(
	ctx context.Context,
) (resp *admin.DescribeClusterResponse, retError error)

DescribeCluster return information about cadence deployment

func (*AdminHandler) DescribeHistoryHost added in v0.3.13 

func (adh *AdminHandler) DescribeHistoryHost(
	ctx context.Context,
	request *gen.DescribeHistoryHostRequest,
) (resp *gen.DescribeHistoryHostResponse, retError error)

DescribeHistoryHost returns information about the internal states of a history host

func (*AdminHandler) DescribeWorkflowExecution added in v0.3.13 

func (adh *AdminHandler) DescribeWorkflowExecution(
	ctx context.Context,
	request *admin.DescribeWorkflowExecutionRequest,
) (resp *admin.DescribeWorkflowExecutionResponse, retError error)

DescribeWorkflowExecution returns information about the specified workflow execution.

func (*AdminHandler) GetDLQReplicationMessages added in v0.12.0 

func (adh *AdminHandler) GetDLQReplicationMessages(
	ctx context.Context,
	request *replicator.GetDLQReplicationMessagesRequest,
) (resp *replicator.GetDLQReplicationMessagesResponse, err error)

GetDLQReplicationMessages returns new replication tasks based on the dlq info.

func (*AdminHandler) GetDomainReplicationMessages added in v0.11.0 

func (adh *AdminHandler) GetDomainReplicationMessages(
	ctx context.Context,
	request *replicator.GetDomainReplicationMessagesRequest,
) (resp *replicator.GetDomainReplicationMessagesResponse, err error)

GetDomainReplicationMessages returns new domain replication tasks since last retrieved task ID.

func (*AdminHandler) GetReplicationMessages added in v0.11.0 

func (adh *AdminHandler) GetReplicationMessages(
	ctx context.Context,
	request *replicator.GetReplicationMessagesRequest,
) (resp *replicator.GetReplicationMessagesResponse, err error)

GetReplicationMessages returns new replication tasks since the read level provided in the token.

func (*AdminHandler) GetWorkflowExecutionRawHistory added in v0.5.0 

func (adh *AdminHandler) GetWorkflowExecutionRawHistory(
	ctx context.Context,
	request *admin.GetWorkflowExecutionRawHistoryRequest,
) (resp *admin.GetWorkflowExecutionRawHistoryResponse, retError error)

GetWorkflowExecutionRawHistory - retrieves the history of workflow execution

func (*AdminHandler) GetWorkflowExecutionRawHistoryV2 added in v0.10.0 

func (adh *AdminHandler) GetWorkflowExecutionRawHistoryV2(
	ctx context.Context,
	request *admin.GetWorkflowExecutionRawHistoryV2Request,
) (resp *admin.GetWorkflowExecutionRawHistoryV2Response, retError error)

GetWorkflowExecutionRawHistoryV2 - retrieves the history of workflow execution

func (*AdminHandler) MergeDLQMessages added in v0.12.0 

func (adh *AdminHandler) MergeDLQMessages(
	ctx context.Context,
	request *replicator.MergeDLQMessagesRequest,
) (resp *replicator.MergeDLQMessagesResponse, err error)

MergeDLQMessages merges DLQ messages

func (*AdminHandler) PurgeDLQMessages added in v0.12.0 

func (adh *AdminHandler) PurgeDLQMessages(
	ctx context.Context,
	request *replicator.PurgeDLQMessagesRequest,
) (err error)

PurgeDLQMessages purge messages from DLQ

func (*AdminHandler) ReadDLQMessages added in v0.12.0 

func (adh *AdminHandler) ReadDLQMessages(
	ctx context.Context,
	request *replicator.ReadDLQMessagesRequest,
) (resp *replicator.ReadDLQMessagesResponse, err error)

ReadDLQMessages reads messages from DLQ

func (*AdminHandler) ReapplyEvents added in v0.11.0 

func (adh *AdminHandler) ReapplyEvents(
	ctx context.Context,
	request *gen.ReapplyEventsRequest,
) (err error)

ReapplyEvents applies stale events to the current workflow and the current run

func (*AdminHandler) RefreshWorkflowTasks added in v0.12.0 

func (adh *AdminHandler) RefreshWorkflowTasks(
	ctx context.Context,
	request *gen.RefreshWorkflowTasksRequest,
) (err error)

RefreshWorkflowTasks re-generates the workflow tasks

func (*AdminHandler) RegisterHandler added in v0.5.8 

func (adh *AdminHandler) RegisterHandler()

RegisterHandler register this handler, must be called before Start()

func (*AdminHandler) RemoveTask added in v0.9.0 

func (adh *AdminHandler) RemoveTask(
	ctx context.Context,
	request *gen.RemoveTaskRequest,
) (retError error)

RemoveTask returns information about the internal states of a history host

func (*AdminHandler) ResendReplicationTasks added in v0.12.0 

func (adh *AdminHandler) ResendReplicationTasks(
	ctx context.Context,
	request *admin.ResendReplicationTasksRequest,
) (err error)

ResendReplicationTasks requests replication task from remote cluster

func (*AdminHandler) Start added in v0.3.12 

func (adh *AdminHandler) Start()

Start starts the handler

func (*AdminHandler) Stop added in v0.3.12 

func (adh *AdminHandler) Stop()

Stop stops the handler

type Config added in v0.3.0 

type Config struct {
	NumHistoryShards                int
	PersistenceMaxQPS               dynamicconfig.IntPropertyFn
	PersistenceGlobalMaxQPS         dynamicconfig.IntPropertyFn
	VisibilityMaxPageSize           dynamicconfig.IntPropertyFnWithDomainFilter
	EnableVisibilitySampling        dynamicconfig.BoolPropertyFn
	EnableReadFromClosedExecutionV2 dynamicconfig.BoolPropertyFn
	VisibilityListMaxQPS            dynamicconfig.IntPropertyFnWithDomainFilter
	EnableReadVisibilityFromES      dynamicconfig.BoolPropertyFnWithDomainFilter
	ESVisibilityListMaxQPS          dynamicconfig.IntPropertyFnWithDomainFilter
	ESIndexMaxResultWindow          dynamicconfig.IntPropertyFn
	HistoryMaxPageSize              dynamicconfig.IntPropertyFnWithDomainFilter
	RPS                             dynamicconfig.IntPropertyFn
	MaxDomainRPSPerInstance         dynamicconfig.IntPropertyFnWithDomainFilter
	GlobalDomainRPS                 dynamicconfig.IntPropertyFnWithDomainFilter
	MaxIDLengthLimit                dynamicconfig.IntPropertyFn
	EnableClientVersionCheck        dynamicconfig.BoolPropertyFn
	MinRetentionDays                dynamicconfig.IntPropertyFn
	DisallowQuery                   dynamicconfig.BoolPropertyFnWithDomainFilter
	ShutdownDrainDuration           dynamicconfig.DurationPropertyFn

	// Persistence settings
	HistoryMgrNumConns dynamicconfig.IntPropertyFn

	MaxBadBinaries dynamicconfig.IntPropertyFnWithDomainFilter

	// security protection settings
	EnableAdminProtection         dynamicconfig.BoolPropertyFn
	AdminOperationToken           dynamicconfig.StringPropertyFn
	DisableListVisibilityByFilter dynamicconfig.BoolPropertyFnWithDomainFilter

	// size limit system protection
	BlobSizeLimitError dynamicconfig.IntPropertyFnWithDomainFilter
	BlobSizeLimitWarn  dynamicconfig.IntPropertyFnWithDomainFilter

	ThrottledLogRPS dynamicconfig.IntPropertyFn

	// Domain specific config
	EnableDomainNotActiveAutoForwarding dynamicconfig.BoolPropertyFnWithDomainFilter

	// ValidSearchAttributes is legal indexed keys that can be used in list APIs
	ValidSearchAttributes             dynamicconfig.MapPropertyFn
	SearchAttributesNumberOfKeysLimit dynamicconfig.IntPropertyFnWithDomainFilter
	SearchAttributesSizeOfValueLimit  dynamicconfig.IntPropertyFnWithDomainFilter
	SearchAttributesTotalSizeLimit    dynamicconfig.IntPropertyFnWithDomainFilter

	// VisibilityArchival system protection
	VisibilityArchivalQueryMaxPageSize dynamicconfig.IntPropertyFn

	SendRawWorkflowHistory dynamicconfig.BoolPropertyFnWithDomainFilter

	EnableRPCReplication         dynamicconfig.BoolPropertyFn
	EnableCleanupReplicationTask dynamicconfig.BoolPropertyFn
}

Config represents configuration for cadence-frontend service

func NewConfig added in v0.3.0 

func NewConfig(dc *dynamicconfig.Collection, numHistoryShards int, enableReadFromES bool) *Config

NewConfig returns new service config with default values

type DCRedirectionHandlerImpl added in v0.5.2 

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

DCRedirectionHandlerImpl is simple wrapper over frontend service, doing redirection based on policy

func NewDCRedirectionHandler added in v0.5.2 

func NewDCRedirectionHandler(
	wfHandler Handler,
	policy config.DCRedirectionPolicy,
) *DCRedirectionHandlerImpl

NewDCRedirectionHandler creates a thrift handler for the cadence service, frontend

func (*DCRedirectionHandlerImpl) CountWorkflowExecutions added in v0.5.8 

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

CountWorkflowExecutions API call

func (*DCRedirectionHandlerImpl) DeprecateDomain added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) DeprecateDomain(
	ctx context.Context,
	request *shared.DeprecateDomainRequest,
) (retError error)

DeprecateDomain API call

func (*DCRedirectionHandlerImpl) DescribeDomain added in v0.5.2 

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

DescribeDomain API call

func (*DCRedirectionHandlerImpl) DescribeTaskList added in v0.5.2 

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

DescribeTaskList API call

func (*DCRedirectionHandlerImpl) DescribeWorkflowExecution added in v0.5.2 

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

DescribeWorkflowExecution API call

func (*DCRedirectionHandlerImpl) GetClusterInfo added in v0.11.0 

func (handler *DCRedirectionHandlerImpl) GetClusterInfo(
	ctx context.Context,
) (*shared.ClusterInfo, error)

GetClusterInfo API call

func (*DCRedirectionHandlerImpl) GetConfig added in v0.13.0 

func (handler *DCRedirectionHandlerImpl) GetConfig() *Config

GetConfig return config

func (*DCRedirectionHandlerImpl) GetResource added in v0.13.0 

func (handler *DCRedirectionHandlerImpl) GetResource() resource.Resource

GetResource return resource

func (*DCRedirectionHandlerImpl) GetSearchAttributes added in v0.5.9 

func (handler *DCRedirectionHandlerImpl) GetSearchAttributes(
	ctx context.Context,
) (resp *shared.GetSearchAttributesResponse, retError error)

GetSearchAttributes API call

func (*DCRedirectionHandlerImpl) GetWorkflowExecutionHistory added in v0.5.2 

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

GetWorkflowExecutionHistory API call

func (*DCRedirectionHandlerImpl) Health added in v0.5.8 

func (handler *DCRedirectionHandlerImpl) Health(ctx context.Context) (*health.HealthStatus, error)

Health is for health check

func (*DCRedirectionHandlerImpl) ListArchivedWorkflowExecutions added in v0.9.0 

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

ListArchivedWorkflowExecutions API call

func (*DCRedirectionHandlerImpl) ListClosedWorkflowExecutions added in v0.5.2 

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

ListClosedWorkflowExecutions API call

func (*DCRedirectionHandlerImpl) ListDomains added in v0.5.2 

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

ListDomains API call

func (*DCRedirectionHandlerImpl) ListOpenWorkflowExecutions added in v0.5.2 

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

ListOpenWorkflowExecutions API call

func (*DCRedirectionHandlerImpl) ListTaskListPartitions added in v0.11.0 

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

ListTaskListPartitions API call

func (*DCRedirectionHandlerImpl) ListWorkflowExecutions added in v0.5.7 

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

ListWorkflowExecutions API call

func (*DCRedirectionHandlerImpl) PollForActivityTask added in v0.5.2 

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

PollForActivityTask API call

func (*DCRedirectionHandlerImpl) PollForDecisionTask added in v0.5.2 

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

PollForDecisionTask API call

func (*DCRedirectionHandlerImpl) QueryWorkflow added in v0.5.2 

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

QueryWorkflow API call

func (*DCRedirectionHandlerImpl) RecordActivityTaskHeartbeat added in v0.5.2 

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

RecordActivityTaskHeartbeat API call

func (*DCRedirectionHandlerImpl) RecordActivityTaskHeartbeatByID added in v0.5.2 

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

RecordActivityTaskHeartbeatByID API call

func (*DCRedirectionHandlerImpl) RegisterDomain added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) RegisterDomain(
	ctx context.Context,
	request *shared.RegisterDomainRequest,
) (retError error)

RegisterDomain API call

func (*DCRedirectionHandlerImpl) RegisterHandler added in v0.5.8 

func (handler *DCRedirectionHandlerImpl) RegisterHandler()

RegisterHandler register this handler, must be called before Start()

func (*DCRedirectionHandlerImpl) RequestCancelWorkflowExecution added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) RequestCancelWorkflowExecution(
	ctx context.Context,
	request *shared.RequestCancelWorkflowExecutionRequest,
) (retError error)

RequestCancelWorkflowExecution API call

func (*DCRedirectionHandlerImpl) ResetStickyTaskList added in v0.5.2 

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

ResetStickyTaskList API call

func (*DCRedirectionHandlerImpl) ResetWorkflowExecution added in v0.5.2 

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

ResetWorkflowExecution API call

func (*DCRedirectionHandlerImpl) RespondActivityTaskCanceled added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) RespondActivityTaskCanceled(
	ctx context.Context,
	request *shared.RespondActivityTaskCanceledRequest,
) (retError error)

RespondActivityTaskCanceled API call

func (*DCRedirectionHandlerImpl) RespondActivityTaskCanceledByID added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) RespondActivityTaskCanceledByID(
	ctx context.Context,
	request *shared.RespondActivityTaskCanceledByIDRequest,
) (retError error)

RespondActivityTaskCanceledByID API call

func (*DCRedirectionHandlerImpl) RespondActivityTaskCompleted added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) RespondActivityTaskCompleted(
	ctx context.Context,
	request *shared.RespondActivityTaskCompletedRequest,
) (retError error)

RespondActivityTaskCompleted API call

func (*DCRedirectionHandlerImpl) RespondActivityTaskCompletedByID added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) RespondActivityTaskCompletedByID(
	ctx context.Context,
	request *shared.RespondActivityTaskCompletedByIDRequest,
) (retError error)

RespondActivityTaskCompletedByID API call

func (*DCRedirectionHandlerImpl) RespondActivityTaskFailed added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) RespondActivityTaskFailed(
	ctx context.Context,
	request *shared.RespondActivityTaskFailedRequest,
) (retError error)

RespondActivityTaskFailed API call

func (*DCRedirectionHandlerImpl) RespondActivityTaskFailedByID added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) RespondActivityTaskFailedByID(
	ctx context.Context,
	request *shared.RespondActivityTaskFailedByIDRequest,
) (retError error)

RespondActivityTaskFailedByID API call

func (*DCRedirectionHandlerImpl) RespondDecisionTaskCompleted added in v0.5.2 

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

RespondDecisionTaskCompleted API call

func (*DCRedirectionHandlerImpl) RespondDecisionTaskFailed added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) RespondDecisionTaskFailed(
	ctx context.Context,
	request *shared.RespondDecisionTaskFailedRequest,
) (retError error)

RespondDecisionTaskFailed API call

func (*DCRedirectionHandlerImpl) RespondQueryTaskCompleted added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) RespondQueryTaskCompleted(
	ctx context.Context,
	request *shared.RespondQueryTaskCompletedRequest,
) (retError error)

RespondQueryTaskCompleted API call

func (*DCRedirectionHandlerImpl) ScanWorkflowExecutions added in v0.5.8 

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

ScanWorkflowExecutions API call

func (*DCRedirectionHandlerImpl) SignalWithStartWorkflowExecution added in v0.5.2 

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

SignalWithStartWorkflowExecution API call

func (*DCRedirectionHandlerImpl) SignalWorkflowExecution added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) SignalWorkflowExecution(
	ctx context.Context,
	request *shared.SignalWorkflowExecutionRequest,
) (retError error)

SignalWorkflowExecution API call

func (*DCRedirectionHandlerImpl) Start added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) Start()

Start starts the handler

func (*DCRedirectionHandlerImpl) StartWorkflowExecution added in v0.5.2 

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

StartWorkflowExecution API call

func (*DCRedirectionHandlerImpl) Stop added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) Stop()

Stop stops the handler

func (*DCRedirectionHandlerImpl) TerminateWorkflowExecution added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) TerminateWorkflowExecution(
	ctx context.Context,
	request *shared.TerminateWorkflowExecutionRequest,
) (retError error)

TerminateWorkflowExecution API call

func (*DCRedirectionHandlerImpl) UpdateDomain added in v0.5.2 

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

UpdateDomain API call

func (*DCRedirectionHandlerImpl) UpdateHealthStatus added in v0.12.0 

func (handler *DCRedirectionHandlerImpl) UpdateHealthStatus(status HealthStatus)

UpdateHealthStatus sets the health status for this rpc handler. This health status will be used within the rpc health check handler

type DCRedirectionPolicy added in v0.5.2 

type DCRedirectionPolicy interface {
	WithDomainIDRedirect(ctx context.Context, domainID string, apiName string, call func(string) error) error
	WithDomainNameRedirect(ctx context.Context, domainName string, apiName string, call func(string) error) error
}

DCRedirectionPolicy is a DC redirection policy interface

func RedirectionPolicyGenerator added in v0.5.2 

func RedirectionPolicyGenerator(clusterMetadata cluster.Metadata, config *Config,
	domainCache cache.DomainCache, policy config.DCRedirectionPolicy) DCRedirectionPolicy

RedirectionPolicyGenerator generate corresponding redirection policy

type Handler added in v0.13.0 

type Handler interface {
	workflowserviceserver.Interface
	common.Daemon

	GetResource() resource.Resource
	GetConfig() *Config
	// RegisterHandler register this handler, must be called before Start()
	RegisterHandler()
	// Health is the health check method for this rpc handler
	Health(ctx context.Context) (*health.HealthStatus, error)
	// UpdateHealthStatus sets the health status for this rpc handler.
	// This health status will be used within the rpc health check handler
	UpdateHealthStatus(status HealthStatus)
}

Handler is interface wrapping frontend handler

func NewWorkflowHandler 

func NewWorkflowHandler(
	resource resource.Resource,
	config *Config,
	replicationMessageSink messaging.Producer,
) Handler

NewWorkflowHandler creates a thrift handler for the cadence service

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
	// 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 MockDCRedirectionPolicy added in v0.5.9 

type MockDCRedirectionPolicy struct {
	mock.Mock
}

MockDCRedirectionPolicy is an autogenerated mock type for the DCRedirectionPolicy type

func (*MockDCRedirectionPolicy) WithDomainIDRedirect added in v0.5.9 

func (_m *MockDCRedirectionPolicy) WithDomainIDRedirect(ctx context.Context, domainID string, apiName string, call func(string) error) error

WithDomainIDRedirect provides a mock function with given fields: domainID, apiName, call

func (*MockDCRedirectionPolicy) WithDomainNameRedirect added in v0.5.9 

func (_m *MockDCRedirectionPolicy) WithDomainNameRedirect(ctx context.Context, domainName string, apiName string, call func(string) error) error

WithDomainNameRedirect provides a mock function with given fields: domainName, apiName, call

type MockHandler added in v0.13.0 

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

MockHandler is a mock of Handler interface

func NewMockHandler added in v0.13.0 

func NewMockHandler(ctrl *gomock.Controller) *MockHandler

NewMockHandler creates a new mock instance

func (*MockHandler) CountWorkflowExecutions added in v0.13.0 

func (m *MockHandler) CountWorkflowExecutions(ctx context.Context, CountRequest *shared.CountWorkflowExecutionsRequest) (*shared.CountWorkflowExecutionsResponse, error)

CountWorkflowExecutions mocks base method

func (*MockHandler) DeprecateDomain added in v0.13.0 

func (m *MockHandler) DeprecateDomain(ctx context.Context, DeprecateRequest *shared.DeprecateDomainRequest) error

DeprecateDomain mocks base method

func (*MockHandler) DescribeDomain added in v0.13.0 

func (m *MockHandler) DescribeDomain(ctx context.Context, DescribeRequest *shared.DescribeDomainRequest) (*shared.DescribeDomainResponse, error)

DescribeDomain mocks base method

func (*MockHandler) DescribeTaskList added in v0.13.0 

func (m *MockHandler) DescribeTaskList(ctx context.Context, Request *shared.DescribeTaskListRequest) (*shared.DescribeTaskListResponse, error)

DescribeTaskList mocks base method

func (*MockHandler) DescribeWorkflowExecution added in v0.13.0 

func (m *MockHandler) DescribeWorkflowExecution(ctx context.Context, DescribeRequest *shared.DescribeWorkflowExecutionRequest) (*shared.DescribeWorkflowExecutionResponse, error)

DescribeWorkflowExecution mocks base method

func (*MockHandler) EXPECT added in v0.13.0 

func (m *MockHandler) EXPECT() *MockHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockHandler) GetClusterInfo added in v0.13.0 

func (m *MockHandler) GetClusterInfo(ctx context.Context) (*shared.ClusterInfo, error)

GetClusterInfo mocks base method

func (*MockHandler) GetConfig added in v0.13.0 

func (m *MockHandler) GetConfig() *Config

GetConfig mocks base method

func (*MockHandler) GetResource added in v0.13.0 

func (m *MockHandler) GetResource() resource.Resource

GetResource mocks base method

func (*MockHandler) GetSearchAttributes added in v0.13.0 

func (m *MockHandler) GetSearchAttributes(ctx context.Context) (*shared.GetSearchAttributesResponse, error)

GetSearchAttributes mocks base method

func (*MockHandler) GetWorkflowExecutionHistory added in v0.13.0 

func (m *MockHandler) GetWorkflowExecutionHistory(ctx context.Context, GetRequest *shared.GetWorkflowExecutionHistoryRequest) (*shared.GetWorkflowExecutionHistoryResponse, error)

GetWorkflowExecutionHistory mocks base method

func (*MockHandler) Health added in v0.13.0 

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

Health mocks base method

func (*MockHandler) ListArchivedWorkflowExecutions added in v0.13.0 

func (m *MockHandler) ListArchivedWorkflowExecutions(ctx context.Context, ListRequest *shared.ListArchivedWorkflowExecutionsRequest) (*shared.ListArchivedWorkflowExecutionsResponse, error)

ListArchivedWorkflowExecutions mocks base method

func (*MockHandler) ListClosedWorkflowExecutions added in v0.13.0 

func (m *MockHandler) ListClosedWorkflowExecutions(ctx context.Context, ListRequest *shared.ListClosedWorkflowExecutionsRequest) (*shared.ListClosedWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutions mocks base method

func (*MockHandler) ListDomains added in v0.13.0 

func (m *MockHandler) ListDomains(ctx context.Context, ListRequest *shared.ListDomainsRequest) (*shared.ListDomainsResponse, error)

ListDomains mocks base method

func (*MockHandler) ListOpenWorkflowExecutions added in v0.13.0 

func (m *MockHandler) ListOpenWorkflowExecutions(ctx context.Context, ListRequest *shared.ListOpenWorkflowExecutionsRequest) (*shared.ListOpenWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutions mocks base method

func (*MockHandler) ListTaskListPartitions added in v0.13.0 

func (m *MockHandler) ListTaskListPartitions(ctx context.Context, Request *shared.ListTaskListPartitionsRequest) (*shared.ListTaskListPartitionsResponse, error)

ListTaskListPartitions mocks base method

func (*MockHandler) ListWorkflowExecutions added in v0.13.0 

func (m *MockHandler) ListWorkflowExecutions(ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, error)

ListWorkflowExecutions mocks base method

func (*MockHandler) PollForActivityTask added in v0.13.0 

func (m *MockHandler) PollForActivityTask(ctx context.Context, PollRequest *shared.PollForActivityTaskRequest) (*shared.PollForActivityTaskResponse, error)

PollForActivityTask mocks base method

func (*MockHandler) PollForDecisionTask added in v0.13.0 

func (m *MockHandler) PollForDecisionTask(ctx context.Context, PollRequest *shared.PollForDecisionTaskRequest) (*shared.PollForDecisionTaskResponse, error)

PollForDecisionTask mocks base method

func (*MockHandler) QueryWorkflow added in v0.13.0 

func (m *MockHandler) QueryWorkflow(ctx context.Context, QueryRequest *shared.QueryWorkflowRequest) (*shared.QueryWorkflowResponse, error)

QueryWorkflow mocks base method

func (*MockHandler) RecordActivityTaskHeartbeat added in v0.13.0 

func (m *MockHandler) RecordActivityTaskHeartbeat(ctx context.Context, HeartbeatRequest *shared.RecordActivityTaskHeartbeatRequest) (*shared.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeat mocks base method

func (*MockHandler) RecordActivityTaskHeartbeatByID added in v0.13.0 

func (m *MockHandler) RecordActivityTaskHeartbeatByID(ctx context.Context, HeartbeatRequest *shared.RecordActivityTaskHeartbeatByIDRequest) (*shared.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeatByID mocks base method

func (*MockHandler) RegisterDomain added in v0.13.0 

func (m *MockHandler) RegisterDomain(ctx context.Context, RegisterRequest *shared.RegisterDomainRequest) error

RegisterDomain mocks base method

func (*MockHandler) RegisterHandler added in v0.13.0 

func (m *MockHandler) RegisterHandler()

RegisterHandler mocks base method

func (*MockHandler) RequestCancelWorkflowExecution added in v0.13.0 

func (m *MockHandler) RequestCancelWorkflowExecution(ctx context.Context, CancelRequest *shared.RequestCancelWorkflowExecutionRequest) error

RequestCancelWorkflowExecution mocks base method

func (*MockHandler) ResetStickyTaskList added in v0.13.0 

func (m *MockHandler) ResetStickyTaskList(ctx context.Context, ResetRequest *shared.ResetStickyTaskListRequest) (*shared.ResetStickyTaskListResponse, error)

ResetStickyTaskList mocks base method

func (*MockHandler) ResetWorkflowExecution added in v0.13.0 

func (m *MockHandler) ResetWorkflowExecution(ctx context.Context, ResetRequest *shared.ResetWorkflowExecutionRequest) (*shared.ResetWorkflowExecutionResponse, error)

ResetWorkflowExecution mocks base method

func (*MockHandler) RespondActivityTaskCanceled added in v0.13.0 

func (m *MockHandler) RespondActivityTaskCanceled(ctx context.Context, CanceledRequest *shared.RespondActivityTaskCanceledRequest) error

RespondActivityTaskCanceled mocks base method

func (*MockHandler) RespondActivityTaskCanceledByID added in v0.13.0 

func (m *MockHandler) RespondActivityTaskCanceledByID(ctx context.Context, CanceledRequest *shared.RespondActivityTaskCanceledByIDRequest) error

RespondActivityTaskCanceledByID mocks base method

func (*MockHandler) RespondActivityTaskCompleted added in v0.13.0 

func (m *MockHandler) RespondActivityTaskCompleted(ctx context.Context, CompleteRequest *shared.RespondActivityTaskCompletedRequest) error

RespondActivityTaskCompleted mocks base method

func (*MockHandler) RespondActivityTaskCompletedByID added in v0.13.0 

func (m *MockHandler) RespondActivityTaskCompletedByID(ctx context.Context, CompleteRequest *shared.RespondActivityTaskCompletedByIDRequest) error

RespondActivityTaskCompletedByID mocks base method

func (*MockHandler) RespondActivityTaskFailed added in v0.13.0 

func (m *MockHandler) RespondActivityTaskFailed(ctx context.Context, FailRequest *shared.RespondActivityTaskFailedRequest) error

RespondActivityTaskFailed mocks base method

func (*MockHandler) RespondActivityTaskFailedByID added in v0.13.0 

func (m *MockHandler) RespondActivityTaskFailedByID(ctx context.Context, FailRequest *shared.RespondActivityTaskFailedByIDRequest) error

RespondActivityTaskFailedByID mocks base method

func (*MockHandler) RespondDecisionTaskCompleted added in v0.13.0 

func (m *MockHandler) RespondDecisionTaskCompleted(ctx context.Context, CompleteRequest *shared.RespondDecisionTaskCompletedRequest) (*shared.RespondDecisionTaskCompletedResponse, error)

RespondDecisionTaskCompleted mocks base method

func (*MockHandler) RespondDecisionTaskFailed added in v0.13.0 

func (m *MockHandler) RespondDecisionTaskFailed(ctx context.Context, FailedRequest *shared.RespondDecisionTaskFailedRequest) error

RespondDecisionTaskFailed mocks base method

func (*MockHandler) RespondQueryTaskCompleted added in v0.13.0 

func (m *MockHandler) RespondQueryTaskCompleted(ctx context.Context, CompleteRequest *shared.RespondQueryTaskCompletedRequest) error

RespondQueryTaskCompleted mocks base method

func (*MockHandler) ScanWorkflowExecutions added in v0.13.0 

func (m *MockHandler) ScanWorkflowExecutions(ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, error)

ScanWorkflowExecutions mocks base method

func (*MockHandler) SignalWithStartWorkflowExecution added in v0.13.0 

func (m *MockHandler) SignalWithStartWorkflowExecution(ctx context.Context, SignalWithStartRequest *shared.SignalWithStartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)

SignalWithStartWorkflowExecution mocks base method

func (*MockHandler) SignalWorkflowExecution added in v0.13.0 

func (m *MockHandler) SignalWorkflowExecution(ctx context.Context, SignalRequest *shared.SignalWorkflowExecutionRequest) error

SignalWorkflowExecution mocks base method

func (*MockHandler) Start added in v0.13.0 

func (m *MockHandler) Start()

Start mocks base method

func (*MockHandler) StartWorkflowExecution added in v0.13.0 

func (m *MockHandler) StartWorkflowExecution(ctx context.Context, StartRequest *shared.StartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)

StartWorkflowExecution mocks base method

func (*MockHandler) Stop added in v0.13.0 

func (m *MockHandler) Stop()

Stop mocks base method

func (*MockHandler) TerminateWorkflowExecution added in v0.13.0 

func (m *MockHandler) TerminateWorkflowExecution(ctx context.Context, TerminateRequest *shared.TerminateWorkflowExecutionRequest) error

TerminateWorkflowExecution mocks base method

func (*MockHandler) UpdateDomain added in v0.13.0 

func (m *MockHandler) UpdateDomain(ctx context.Context, UpdateRequest *shared.UpdateDomainRequest) (*shared.UpdateDomainResponse, error)

UpdateDomain mocks base method

func (*MockHandler) UpdateHealthStatus added in v0.13.0 

func (m *MockHandler) UpdateHealthStatus(status HealthStatus)

UpdateHealthStatus mocks base method

type MockHandlerMockRecorder added in v0.13.0 

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

MockHandlerMockRecorder is the mock recorder for MockHandler

func (*MockHandlerMockRecorder) CountWorkflowExecutions added in v0.13.0 

func (mr *MockHandlerMockRecorder) CountWorkflowExecutions(ctx, CountRequest interface{}) *gomock.Call

CountWorkflowExecutions indicates an expected call of CountWorkflowExecutions

func (*MockHandlerMockRecorder) DeprecateDomain added in v0.13.0 

func (mr *MockHandlerMockRecorder) DeprecateDomain(ctx, DeprecateRequest interface{}) *gomock.Call

DeprecateDomain indicates an expected call of DeprecateDomain

func (*MockHandlerMockRecorder) DescribeDomain added in v0.13.0 

func (mr *MockHandlerMockRecorder) DescribeDomain(ctx, DescribeRequest interface{}) *gomock.Call

DescribeDomain indicates an expected call of DescribeDomain

func (*MockHandlerMockRecorder) DescribeTaskList added in v0.13.0 

func (mr *MockHandlerMockRecorder) DescribeTaskList(ctx, Request interface{}) *gomock.Call

DescribeTaskList indicates an expected call of DescribeTaskList

func (*MockHandlerMockRecorder) DescribeWorkflowExecution added in v0.13.0 

func (mr *MockHandlerMockRecorder) DescribeWorkflowExecution(ctx, DescribeRequest interface{}) *gomock.Call

DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution

func (*MockHandlerMockRecorder) GetClusterInfo added in v0.13.0 

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

GetClusterInfo indicates an expected call of GetClusterInfo

func (*MockHandlerMockRecorder) GetConfig added in v0.13.0 

func (mr *MockHandlerMockRecorder) GetConfig() *gomock.Call

GetConfig indicates an expected call of GetConfig

func (*MockHandlerMockRecorder) GetResource added in v0.13.0 

func (mr *MockHandlerMockRecorder) GetResource() *gomock.Call

GetResource indicates an expected call of GetResource

func (*MockHandlerMockRecorder) GetSearchAttributes added in v0.13.0 

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

GetSearchAttributes indicates an expected call of GetSearchAttributes

func (*MockHandlerMockRecorder) GetWorkflowExecutionHistory added in v0.13.0 

func (mr *MockHandlerMockRecorder) GetWorkflowExecutionHistory(ctx, GetRequest interface{}) *gomock.Call

GetWorkflowExecutionHistory indicates an expected call of GetWorkflowExecutionHistory

func (*MockHandlerMockRecorder) Health added in v0.13.0 

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

Health indicates an expected call of Health

func (*MockHandlerMockRecorder) ListArchivedWorkflowExecutions added in v0.13.0 

func (mr *MockHandlerMockRecorder) ListArchivedWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call

ListArchivedWorkflowExecutions indicates an expected call of ListArchivedWorkflowExecutions

func (*MockHandlerMockRecorder) ListClosedWorkflowExecutions added in v0.13.0 

func (mr *MockHandlerMockRecorder) ListClosedWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call

ListClosedWorkflowExecutions indicates an expected call of ListClosedWorkflowExecutions

func (*MockHandlerMockRecorder) ListDomains added in v0.13.0 

func (mr *MockHandlerMockRecorder) ListDomains(ctx, ListRequest interface{}) *gomock.Call

ListDomains indicates an expected call of ListDomains

func (*MockHandlerMockRecorder) ListOpenWorkflowExecutions added in v0.13.0 

func (mr *MockHandlerMockRecorder) ListOpenWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call

ListOpenWorkflowExecutions indicates an expected call of ListOpenWorkflowExecutions

func (*MockHandlerMockRecorder) ListTaskListPartitions added in v0.13.0 

func (mr *MockHandlerMockRecorder) ListTaskListPartitions(ctx, Request interface{}) *gomock.Call

ListTaskListPartitions indicates an expected call of ListTaskListPartitions

func (*MockHandlerMockRecorder) ListWorkflowExecutions added in v0.13.0 

func (mr *MockHandlerMockRecorder) ListWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call

ListWorkflowExecutions indicates an expected call of ListWorkflowExecutions

func (*MockHandlerMockRecorder) PollForActivityTask added in v0.13.0 

func (mr *MockHandlerMockRecorder) PollForActivityTask(ctx, PollRequest interface{}) *gomock.Call

PollForActivityTask indicates an expected call of PollForActivityTask

func (*MockHandlerMockRecorder) PollForDecisionTask added in v0.13.0 

func (mr *MockHandlerMockRecorder) PollForDecisionTask(ctx, PollRequest interface{}) *gomock.Call

PollForDecisionTask indicates an expected call of PollForDecisionTask

func (*MockHandlerMockRecorder) QueryWorkflow added in v0.13.0 

func (mr *MockHandlerMockRecorder) QueryWorkflow(ctx, QueryRequest interface{}) *gomock.Call

QueryWorkflow indicates an expected call of QueryWorkflow

func (*MockHandlerMockRecorder) RecordActivityTaskHeartbeat added in v0.13.0 

func (mr *MockHandlerMockRecorder) RecordActivityTaskHeartbeat(ctx, HeartbeatRequest interface{}) *gomock.Call

RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat

func (*MockHandlerMockRecorder) RecordActivityTaskHeartbeatByID added in v0.13.0 

func (mr *MockHandlerMockRecorder) RecordActivityTaskHeartbeatByID(ctx, HeartbeatRequest interface{}) *gomock.Call

RecordActivityTaskHeartbeatByID indicates an expected call of RecordActivityTaskHeartbeatByID

func (*MockHandlerMockRecorder) RegisterDomain added in v0.13.0 

func (mr *MockHandlerMockRecorder) RegisterDomain(ctx, RegisterRequest interface{}) *gomock.Call

RegisterDomain indicates an expected call of RegisterDomain

func (*MockHandlerMockRecorder) RegisterHandler added in v0.13.0 

func (mr *MockHandlerMockRecorder) RegisterHandler() *gomock.Call

RegisterHandler indicates an expected call of RegisterHandler

func (*MockHandlerMockRecorder) RequestCancelWorkflowExecution added in v0.13.0 

func (mr *MockHandlerMockRecorder) RequestCancelWorkflowExecution(ctx, CancelRequest interface{}) *gomock.Call

RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution

func (*MockHandlerMockRecorder) ResetStickyTaskList added in v0.13.0 

func (mr *MockHandlerMockRecorder) ResetStickyTaskList(ctx, ResetRequest interface{}) *gomock.Call

ResetStickyTaskList indicates an expected call of ResetStickyTaskList

func (*MockHandlerMockRecorder) ResetWorkflowExecution added in v0.13.0 

func (mr *MockHandlerMockRecorder) ResetWorkflowExecution(ctx, ResetRequest interface{}) *gomock.Call

ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution

func (*MockHandlerMockRecorder) RespondActivityTaskCanceled added in v0.13.0 

func (mr *MockHandlerMockRecorder) RespondActivityTaskCanceled(ctx, CanceledRequest interface{}) *gomock.Call

RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled

func (*MockHandlerMockRecorder) RespondActivityTaskCanceledByID added in v0.13.0 

func (mr *MockHandlerMockRecorder) RespondActivityTaskCanceledByID(ctx, CanceledRequest interface{}) *gomock.Call

RespondActivityTaskCanceledByID indicates an expected call of RespondActivityTaskCanceledByID

func (*MockHandlerMockRecorder) RespondActivityTaskCompleted added in v0.13.0 

func (mr *MockHandlerMockRecorder) RespondActivityTaskCompleted(ctx, CompleteRequest interface{}) *gomock.Call

RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted

func (*MockHandlerMockRecorder) RespondActivityTaskCompletedByID added in v0.13.0 

func (mr *MockHandlerMockRecorder) RespondActivityTaskCompletedByID(ctx, CompleteRequest interface{}) *gomock.Call

RespondActivityTaskCompletedByID indicates an expected call of RespondActivityTaskCompletedByID

func (*MockHandlerMockRecorder) RespondActivityTaskFailed added in v0.13.0 

func (mr *MockHandlerMockRecorder) RespondActivityTaskFailed(ctx, FailRequest interface{}) *gomock.Call

RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed

func (*MockHandlerMockRecorder) RespondActivityTaskFailedByID added in v0.13.0 

func (mr *MockHandlerMockRecorder) RespondActivityTaskFailedByID(ctx, FailRequest interface{}) *gomock.Call

RespondActivityTaskFailedByID indicates an expected call of RespondActivityTaskFailedByID

func (*MockHandlerMockRecorder) RespondDecisionTaskCompleted added in v0.13.0 

func (mr *MockHandlerMockRecorder) RespondDecisionTaskCompleted(ctx, CompleteRequest interface{}) *gomock.Call

RespondDecisionTaskCompleted indicates an expected call of RespondDecisionTaskCompleted

func (*MockHandlerMockRecorder) RespondDecisionTaskFailed added in v0.13.0 

func (mr *MockHandlerMockRecorder) RespondDecisionTaskFailed(ctx, FailedRequest interface{}) *gomock.Call

RespondDecisionTaskFailed indicates an expected call of RespondDecisionTaskFailed

func (*MockHandlerMockRecorder) RespondQueryTaskCompleted added in v0.13.0 

func (mr *MockHandlerMockRecorder) RespondQueryTaskCompleted(ctx, CompleteRequest interface{}) *gomock.Call

RespondQueryTaskCompleted indicates an expected call of RespondQueryTaskCompleted

func (*MockHandlerMockRecorder) ScanWorkflowExecutions added in v0.13.0 

func (mr *MockHandlerMockRecorder) ScanWorkflowExecutions(ctx, ListRequest interface{}) *gomock.Call

ScanWorkflowExecutions indicates an expected call of ScanWorkflowExecutions

func (*MockHandlerMockRecorder) SignalWithStartWorkflowExecution added in v0.13.0 

func (mr *MockHandlerMockRecorder) SignalWithStartWorkflowExecution(ctx, SignalWithStartRequest interface{}) *gomock.Call

SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution

func (*MockHandlerMockRecorder) SignalWorkflowExecution added in v0.13.0 

func (mr *MockHandlerMockRecorder) SignalWorkflowExecution(ctx, SignalRequest interface{}) *gomock.Call

SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution

func (*MockHandlerMockRecorder) Start added in v0.13.0 

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

Start indicates an expected call of Start

func (*MockHandlerMockRecorder) StartWorkflowExecution added in v0.13.0 

func (mr *MockHandlerMockRecorder) StartWorkflowExecution(ctx, StartRequest interface{}) *gomock.Call

StartWorkflowExecution indicates an expected call of StartWorkflowExecution

func (*MockHandlerMockRecorder) Stop added in v0.13.0 

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

Stop indicates an expected call of Stop

func (*MockHandlerMockRecorder) TerminateWorkflowExecution added in v0.13.0 

func (mr *MockHandlerMockRecorder) TerminateWorkflowExecution(ctx, TerminateRequest interface{}) *gomock.Call

TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution

func (*MockHandlerMockRecorder) UpdateDomain added in v0.13.0 

func (mr *MockHandlerMockRecorder) UpdateDomain(ctx, UpdateRequest interface{}) *gomock.Call

UpdateDomain indicates an expected call of UpdateDomain

func (*MockHandlerMockRecorder) UpdateHealthStatus added in v0.13.0 

func (mr *MockHandlerMockRecorder) UpdateHealthStatus(status interface{}) *gomock.Call

UpdateHealthStatus indicates an expected call of UpdateHealthStatus

type NoopRedirectionPolicy added in v0.5.2 

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

NoopRedirectionPolicy is DC redirection policy which does nothing

func NewNoopRedirectionPolicy added in v0.5.2 

func NewNoopRedirectionPolicy(currentClusterName string) *NoopRedirectionPolicy

NewNoopRedirectionPolicy is DC redirection policy which does nothing

func (*NoopRedirectionPolicy) WithDomainIDRedirect added in v0.5.9 

func (policy *NoopRedirectionPolicy) WithDomainIDRedirect(ctx context.Context, domainID string, apiName string, call func(string) error) error

WithDomainIDRedirect redirect the API call based on domain ID

func (*NoopRedirectionPolicy) WithDomainNameRedirect added in v0.5.9 

func (policy *NoopRedirectionPolicy) WithDomainNameRedirect(ctx context.Context, domainName string, apiName string, call func(string) error) error

WithDomainNameRedirect redirect the API call based on domain name

type SelectedAPIsForwardingRedirectionPolicy added in v0.5.9 

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

SelectedAPIsForwardingRedirectionPolicy is a DC redirection policy which (based on domain) forwards selected APIs calls to active cluster

func NewSelectedAPIsForwardingPolicy added in v0.5.9 

func NewSelectedAPIsForwardingPolicy(currentClusterName string, config *Config, domainCache cache.DomainCache) *SelectedAPIsForwardingRedirectionPolicy

NewSelectedAPIsForwardingPolicy creates a forwarding policy for selected APIs based on domain

func (*SelectedAPIsForwardingRedirectionPolicy) WithDomainIDRedirect added in v0.5.9 

func (policy *SelectedAPIsForwardingRedirectionPolicy) WithDomainIDRedirect(ctx context.Context, domainID string, apiName string, call func(string) error) error

WithDomainIDRedirect redirect the API call based on domain ID

func (*SelectedAPIsForwardingRedirectionPolicy) WithDomainNameRedirect added in v0.5.9 

func (policy *SelectedAPIsForwardingRedirectionPolicy) WithDomainNameRedirect(ctx context.Context, domainName string, apiName string, call func(string) error) error

WithDomainNameRedirect redirect the API call based on domain name

type Service 

type Service struct {
	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 WorkflowHandler 

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

WorkflowHandler - Thrift handler interface for workflow service

func (*WorkflowHandler) CountWorkflowExecutions added in v0.5.8 

func (wh *WorkflowHandler) CountWorkflowExecutions(
	ctx context.Context,
	countRequest *gen.CountWorkflowExecutionsRequest,
) (resp *gen.CountWorkflowExecutionsResponse, retError error)

CountWorkflowExecutions - count number of workflow executions in a domain

func (*WorkflowHandler) DeprecateDomain 

func (wh *WorkflowHandler) DeprecateDomain(ctx context.Context, deprecateRequest *gen.DeprecateDomainRequest) (retError error)

DeprecateDomain us used to update status of a registered domain to DEPRECATED. Once the domain is deprecated it cannot be used to start new workflow executions. Existing workflow executions will continue to run on deprecated domains.

func (*WorkflowHandler) DescribeDomain 

func (wh *WorkflowHandler) DescribeDomain(
	ctx context.Context,
	describeRequest *gen.DescribeDomainRequest,
) (response *gen.DescribeDomainResponse, retError error)

DescribeDomain returns the information and configuration for a registered domain.

func (*WorkflowHandler) DescribeTaskList added in v0.3.5 

func (wh *WorkflowHandler) DescribeTaskList(
	ctx context.Context,
	request *gen.DescribeTaskListRequest,
) (resp *gen.DescribeTaskListResponse, retError error)

DescribeTaskList returns information about the target tasklist, right now this API returns the pollers which polled this tasklist in last few minutes. If includeTaskListStatus field is true, it will also return status of tasklist's ackManager (readLevel, ackLevel, backlogCountHint and taskIDBlock).

func (*WorkflowHandler) DescribeWorkflowExecution added in v0.3.3 

func (wh *WorkflowHandler) DescribeWorkflowExecution(
	ctx context.Context,
	request *gen.DescribeWorkflowExecutionRequest,
) (resp *gen.DescribeWorkflowExecutionResponse, retError error)

DescribeWorkflowExecution returns information about the specified workflow execution.

func (*WorkflowHandler) GetClusterInfo added in v0.11.0 

func (wh *WorkflowHandler) GetClusterInfo(
	ctx context.Context,
) (resp *gen.ClusterInfo, err error)

GetClusterInfo return information about cadence deployment

func (*WorkflowHandler) GetConfig added in v0.13.0 

func (wh *WorkflowHandler) GetConfig() *Config

GetConfig return config

func (*WorkflowHandler) GetResource added in v0.13.0 

func (wh *WorkflowHandler) GetResource() resource.Resource

GetResource return resource

func (*WorkflowHandler) GetSearchAttributes added in v0.5.9 

func (wh *WorkflowHandler) GetSearchAttributes(ctx context.Context) (resp *gen.GetSearchAttributesResponse, retError error)

GetSearchAttributes return valid indexed keys

func (*WorkflowHandler) GetWorkflowExecutionHistory 

func (wh *WorkflowHandler) GetWorkflowExecutionHistory(
	ctx context.Context,
	getRequest *gen.GetWorkflowExecutionHistoryRequest,
) (resp *gen.GetWorkflowExecutionHistoryResponse, retError error)

GetWorkflowExecutionHistory - retrieves the history of workflow execution

func (*WorkflowHandler) Health added in v0.3.0 

func (wh *WorkflowHandler) Health(ctx context.Context) (*health.HealthStatus, error)

Health is for health check

func (*WorkflowHandler) ListArchivedWorkflowExecutions added in v0.9.0 

func (wh *WorkflowHandler) ListArchivedWorkflowExecutions(
	ctx context.Context,
	listRequest *gen.ListArchivedWorkflowExecutionsRequest,
) (resp *gen.ListArchivedWorkflowExecutionsResponse, retError error)

ListArchivedWorkflowExecutions - retrieves archived info for closed workflow executions in a domain

func (*WorkflowHandler) ListClosedWorkflowExecutions 

func (wh *WorkflowHandler) ListClosedWorkflowExecutions(
	ctx context.Context,
	listRequest *gen.ListClosedWorkflowExecutionsRequest,
) (resp *gen.ListClosedWorkflowExecutionsResponse, retError error)

ListClosedWorkflowExecutions - retrieves info for closed workflow executions in a domain

func (*WorkflowHandler) ListDomains added in v0.3.14 

func (wh *WorkflowHandler) ListDomains(
	ctx context.Context,
	listRequest *gen.ListDomainsRequest,
) (response *gen.ListDomainsResponse, retError error)

ListDomains returns the information and configuration for a registered domain.

func (*WorkflowHandler) ListOpenWorkflowExecutions 

func (wh *WorkflowHandler) ListOpenWorkflowExecutions(
	ctx context.Context,
	listRequest *gen.ListOpenWorkflowExecutionsRequest,
) (resp *gen.ListOpenWorkflowExecutionsResponse, retError error)

ListOpenWorkflowExecutions - retrieves info for open workflow executions in a domain

func (*WorkflowHandler) ListTaskListPartitions added in v0.11.0 

func (wh *WorkflowHandler) ListTaskListPartitions(
	ctx context.Context,
	request *gen.ListTaskListPartitionsRequest,
) (resp *gen.ListTaskListPartitionsResponse, retError error)

ListTaskListPartitions returns all the partition and host for a taskList

func (*WorkflowHandler) ListWorkflowExecutions added in v0.5.7 

func (wh *WorkflowHandler) ListWorkflowExecutions(
	ctx context.Context,
	listRequest *gen.ListWorkflowExecutionsRequest,
) (resp *gen.ListWorkflowExecutionsResponse, retError error)

ListWorkflowExecutions - retrieves info for workflow executions in a domain

func (*WorkflowHandler) PollForActivityTask 

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

PollForActivityTask - Poll for an activity task.

func (*WorkflowHandler) PollForDecisionTask 

func (wh *WorkflowHandler) PollForDecisionTask(
	ctx context.Context,
	pollRequest *gen.PollForDecisionTaskRequest,
) (resp *gen.PollForDecisionTaskResponse, retError error)

PollForDecisionTask - Poll for a decision task.

func (*WorkflowHandler) QueryWorkflow added in v0.3.2 

func (wh *WorkflowHandler) QueryWorkflow(
	ctx context.Context,
	queryRequest *gen.QueryWorkflowRequest,
) (resp *gen.QueryWorkflowResponse, retError error)

QueryWorkflow returns query result for a specified workflow execution

func (*WorkflowHandler) RecordActivityTaskHeartbeat 

func (wh *WorkflowHandler) RecordActivityTaskHeartbeat(
	ctx context.Context,
	heartbeatRequest *gen.RecordActivityTaskHeartbeatRequest,
) (resp *gen.RecordActivityTaskHeartbeatResponse, retError error)

RecordActivityTaskHeartbeat - Record Activity Task Heart beat.

func (*WorkflowHandler) RecordActivityTaskHeartbeatByID added in v0.3.7 

func (wh *WorkflowHandler) RecordActivityTaskHeartbeatByID(
	ctx context.Context,
	heartbeatRequest *gen.RecordActivityTaskHeartbeatByIDRequest,
) (resp *gen.RecordActivityTaskHeartbeatResponse, retError error)

RecordActivityTaskHeartbeatByID - Record Activity Task Heart beat.

func (*WorkflowHandler) RegisterDomain 

func (wh *WorkflowHandler) RegisterDomain(ctx context.Context, registerRequest *gen.RegisterDomainRequest) (retError error)

RegisterDomain creates a new domain which can be used as a container for all resources. Domain is a top level entity within Cadence, used as a container for all resources like workflow executions, tasklists, etc. Domain acts as a sandbox and provides isolation for all resources within the domain. All resources belongs to exactly one domain.

func (*WorkflowHandler) RegisterHandler added in v0.5.8 

func (wh *WorkflowHandler) RegisterHandler()

RegisterHandler register this handler, must be called before Start() if DCRedirectionHandler is also used, use RegisterHandler in DCRedirectionHandler instead

func (*WorkflowHandler) RequestCancelWorkflowExecution 

func (wh *WorkflowHandler) RequestCancelWorkflowExecution(
	ctx context.Context,
	cancelRequest *gen.RequestCancelWorkflowExecutionRequest,
) (retError error)

RequestCancelWorkflowExecution - requests to cancel a workflow execution

func (*WorkflowHandler) ResetStickyTaskList added in v0.3.12 

func (wh *WorkflowHandler) ResetStickyTaskList(
	ctx context.Context,
	resetRequest *gen.ResetStickyTaskListRequest,
) (resp *gen.ResetStickyTaskListResponse, retError error)

ResetStickyTaskList reset the volatile information in mutable state of a given workflow.

func (*WorkflowHandler) ResetWorkflowExecution added in v0.5.2 

func (wh *WorkflowHandler) ResetWorkflowExecution(
	ctx context.Context,
	resetRequest *gen.ResetWorkflowExecutionRequest,
) (resp *gen.ResetWorkflowExecutionResponse, retError error)

ResetWorkflowExecution reset an existing workflow execution to the nextFirstEventID in the history and immediately terminating the current execution instance.

func (*WorkflowHandler) RespondActivityTaskCanceled 

func (wh *WorkflowHandler) RespondActivityTaskCanceled(
	ctx context.Context,
	cancelRequest *gen.RespondActivityTaskCanceledRequest,
) (retError error)

RespondActivityTaskCanceled - called to cancel an activity task

func (*WorkflowHandler) RespondActivityTaskCanceledByID added in v0.3.3 

func (wh *WorkflowHandler) RespondActivityTaskCanceledByID(
	ctx context.Context,
	cancelRequest *gen.RespondActivityTaskCanceledByIDRequest,
) (retError error)

RespondActivityTaskCanceledByID - called to cancel an activity task

func (*WorkflowHandler) RespondActivityTaskCompleted 

func (wh *WorkflowHandler) RespondActivityTaskCompleted(
	ctx context.Context,
	completeRequest *gen.RespondActivityTaskCompletedRequest,
) (retError error)

RespondActivityTaskCompleted - response to an activity task

func (*WorkflowHandler) RespondActivityTaskCompletedByID added in v0.3.3 

func (wh *WorkflowHandler) RespondActivityTaskCompletedByID(
	ctx context.Context,
	completeRequest *gen.RespondActivityTaskCompletedByIDRequest,
) (retError error)

RespondActivityTaskCompletedByID - response to an activity task

func (*WorkflowHandler) RespondActivityTaskFailed 

func (wh *WorkflowHandler) RespondActivityTaskFailed(
	ctx context.Context,
	failedRequest *gen.RespondActivityTaskFailedRequest,
) (retError error)

RespondActivityTaskFailed - response to an activity task failure

func (*WorkflowHandler) RespondActivityTaskFailedByID added in v0.3.3 

func (wh *WorkflowHandler) RespondActivityTaskFailedByID(
	ctx context.Context,
	failedRequest *gen.RespondActivityTaskFailedByIDRequest,
) (retError error)

RespondActivityTaskFailedByID - response to an activity task failure

func (*WorkflowHandler) RespondDecisionTaskCompleted 

func (wh *WorkflowHandler) RespondDecisionTaskCompleted(
	ctx context.Context,
	completeRequest *gen.RespondDecisionTaskCompletedRequest,
) (resp *gen.RespondDecisionTaskCompletedResponse, retError error)

RespondDecisionTaskCompleted - response to a decision task

func (*WorkflowHandler) RespondDecisionTaskFailed added in v0.3.3 

func (wh *WorkflowHandler) RespondDecisionTaskFailed(
	ctx context.Context,
	failedRequest *gen.RespondDecisionTaskFailedRequest,
) (retError error)

RespondDecisionTaskFailed - failed response to a decision task

func (*WorkflowHandler) RespondQueryTaskCompleted added in v0.3.2 

func (wh *WorkflowHandler) RespondQueryTaskCompleted(
	ctx context.Context,
	completeRequest *gen.RespondQueryTaskCompletedRequest,
) (retError error)

RespondQueryTaskCompleted - response to a query task

func (*WorkflowHandler) ScanWorkflowExecutions added in v0.5.8 

func (wh *WorkflowHandler) ScanWorkflowExecutions(
	ctx context.Context,
	listRequest *gen.ListWorkflowExecutionsRequest,
) (resp *gen.ListWorkflowExecutionsResponse, retError error)

ScanWorkflowExecutions - retrieves info for large amount of workflow executions in a domain without order

func (*WorkflowHandler) SignalWithStartWorkflowExecution added in v0.3.11 

func (wh *WorkflowHandler) SignalWithStartWorkflowExecution(
	ctx context.Context,
	signalWithStartRequest *gen.SignalWithStartWorkflowExecutionRequest,
) (resp *gen.StartWorkflowExecutionResponse, retError error)

SignalWithStartWorkflowExecution is used to ensure sending a signal event to a workflow execution. If workflow is running, this results in WorkflowExecutionSignaled event recorded in the history and a decision task being created for the execution. If workflow is not running or not found, this results in WorkflowExecutionStarted and WorkflowExecutionSignaled event recorded in history, and a decision task being created for the execution

func (*WorkflowHandler) SignalWorkflowExecution 

func (wh *WorkflowHandler) SignalWorkflowExecution(
	ctx context.Context,
	signalRequest *gen.SignalWorkflowExecutionRequest,
) (retError error)

SignalWorkflowExecution is used to send a signal event to running workflow execution. This results in WorkflowExecutionSignaled event recorded in the history and a decision task being created for the execution.

func (*WorkflowHandler) Start 

func (wh *WorkflowHandler) Start()

Start starts the handler

func (*WorkflowHandler) StartWorkflowExecution 

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

StartWorkflowExecution - Creates a new workflow execution

func (*WorkflowHandler) Stop 

func (wh *WorkflowHandler) Stop()

Stop stops the handler

func (*WorkflowHandler) TerminateWorkflowExecution 

func (wh *WorkflowHandler) TerminateWorkflowExecution(
	ctx context.Context,
	terminateRequest *gen.TerminateWorkflowExecutionRequest,
) (retError error)

TerminateWorkflowExecution terminates an existing workflow execution by recording WorkflowExecutionTerminated event in the history and immediately terminating the execution instance.

func (*WorkflowHandler) UpdateDomain 

func (wh *WorkflowHandler) UpdateDomain(
	ctx context.Context,
	updateRequest *gen.UpdateDomainRequest,
) (resp *gen.UpdateDomainResponse, retError error)

UpdateDomain is used to update the information and configuration for a registered domain.

func (*WorkflowHandler) UpdateHealthStatus added in v0.12.0 

func (wh *WorkflowHandler) UpdateHealthStatus(status HealthStatus)

UpdateHealthStatus sets the health status for this rpc handler. This health status will be used within the rpc health check handler

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.