frontend

package
v0.5.2 Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2019 License: MIT Imports: 39 Imported by: 7

Documentation

Index

Constants

View Source 
const (
	// DCRedirectionPolicyDefault means no redirection
	DCRedirectionPolicyDefault = ""
	// DCRedirectionPolicyNoop means no redirection
	DCRedirectionPolicyNoop = "noop"
	// DCRedirectionPolicyForwarding means forwarding from an DC to another DC
	DCRedirectionPolicyForwarding = "forwarding"
)

Variables

View Source 
var (
	// ErrInvalidDomainStatus is the error to indicate invalid domain status
	ErrInvalidDomainStatus = errors.New("invalid domain status attribute")
)

Functions

func NewService 

func NewService(params *service.BootstrapParams) common.Daemon

NewService builds a new cadence-frontend service

Types

type AdminHandler added in v0.3.12 

type AdminHandler struct {
	service.Service
	// contains filtered or unexported fields
}

AdminHandler - Thrift handler inteface for admin service

func NewAdminHandler added in v0.3.12 

func NewAdminHandler(
	sVice service.Service, numberOfHistoryShards int, metadataMgr persistence.MetadataManager,
	historyMgr persistence.HistoryManager, historyV2Mgr persistence.HistoryV2Manager) *AdminHandler

NewAdminHandler creates a thrift handler for the cadence admin service

func (*AdminHandler) DescribeHistoryHost added in v0.3.13 

func (adh *AdminHandler) DescribeHistoryHost(ctx context.Context, request *gen.DescribeHistoryHostRequest) (*gen.DescribeHistoryHostResponse, 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) (*admin.DescribeWorkflowExecutionResponse, error)

DescribeWorkflowExecution returns information about the specified workflow execution.

func (*AdminHandler) GetWorkflowExecutionRawHistory added in v0.5.0 

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

GetWorkflowExecutionRawHistory - retrieves the history of workflow execution

func (*AdminHandler) Start added in v0.3.12 

func (adh *AdminHandler) Start() error

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 {
	PersistenceMaxQPS          dynamicconfig.IntPropertyFn
	VisibilityMaxPageSize      dynamicconfig.IntPropertyFnWithDomainFilter
	EnableVisibilitySampling   dynamicconfig.BoolPropertyFn
	VisibilityListMaxQPS       dynamicconfig.IntPropertyFnWithDomainFilter
	EnableVisibilityToKafka    dynamicconfig.BoolPropertyFn
	EnableReadVisibilityFromES dynamicconfig.BoolPropertyFnWithDomainFilter
	HistoryMaxPageSize         dynamicconfig.IntPropertyFnWithDomainFilter
	RPS                        dynamicconfig.IntPropertyFn
	MaxIDLengthLimit           dynamicconfig.IntPropertyFn

	// Persistence settings
	HistoryMgrNumConns dynamicconfig.IntPropertyFn

	MaxDecisionStartToCloseTimeout dynamicconfig.IntPropertyFnWithDomainFilter

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

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

Config represents configuration for cadence-frontend service

func NewConfig added in v0.3.0 

func NewConfig(dc *dynamicconfig.Collection, enableVisibilityToKafka bool) *Config

NewConfig returns new service config with default values

type DCRedirectionHandlerImpl added in v0.5.2 

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

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

func NewDCRedirectionHandler added in v0.5.2 

func NewDCRedirectionHandler(currentClusteName string, redirectionPolicy DCRedirectionPolicy,
	sevice service.Service, frontendHandler *WorkflowHandler) *DCRedirectionHandlerImpl

NewDCRedirectionHandler creates a thrift handler for the cadence service, frontend and admin

func (*DCRedirectionHandlerImpl) DeprecateDomain added in v0.5.2 

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

DeprecateDomain API call

func (*DCRedirectionHandlerImpl) DescribeDomain added in v0.5.2 

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

DescribeDomain API call

func (*DCRedirectionHandlerImpl) DescribeTaskList added in v0.5.2 

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

DescribeTaskList API call

func (*DCRedirectionHandlerImpl) DescribeWorkflowExecution added in v0.5.2 

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

DescribeWorkflowExecution API call

func (*DCRedirectionHandlerImpl) GetWorkflowExecutionHistory added in v0.5.2 

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

GetWorkflowExecutionHistory API call

func (*DCRedirectionHandlerImpl) ListClosedWorkflowExecutions added in v0.5.2 

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

ListClosedWorkflowExecutions API call

func (*DCRedirectionHandlerImpl) ListDomains added in v0.5.2 

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

ListDomains API call

func (*DCRedirectionHandlerImpl) ListOpenWorkflowExecutions added in v0.5.2 

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

ListOpenWorkflowExecutions API call

func (*DCRedirectionHandlerImpl) PollForActivityTask added in v0.5.2 

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

PollForActivityTask API call

func (*DCRedirectionHandlerImpl) PollForDecisionTask added in v0.5.2 

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

PollForDecisionTask API call

func (*DCRedirectionHandlerImpl) QueryWorkflow added in v0.5.2 

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

QueryWorkflow API call

func (*DCRedirectionHandlerImpl) RecordActivityTaskHeartbeat added in v0.5.2 

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

RecordActivityTaskHeartbeat API call

func (*DCRedirectionHandlerImpl) RecordActivityTaskHeartbeatByID added in v0.5.2 

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

RecordActivityTaskHeartbeatByID API call

func (*DCRedirectionHandlerImpl) RegisterDomain added in v0.5.2 

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

RegisterDomain API call

func (*DCRedirectionHandlerImpl) RequestCancelWorkflowExecution added in v0.5.2 

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

RequestCancelWorkflowExecution API call

func (*DCRedirectionHandlerImpl) ResetStickyTaskList added in v0.5.2 

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

ResetStickyTaskList API call

func (*DCRedirectionHandlerImpl) ResetWorkflowExecution added in v0.5.2 

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

ResetWorkflowExecution API call

func (*DCRedirectionHandlerImpl) RespondActivityTaskCanceled added in v0.5.2 

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

RespondActivityTaskCanceled API call

func (*DCRedirectionHandlerImpl) RespondActivityTaskCanceledByID added in v0.5.2 

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

RespondActivityTaskCanceledByID API call

func (*DCRedirectionHandlerImpl) RespondActivityTaskCompleted added in v0.5.2 

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

RespondActivityTaskCompleted API call

func (*DCRedirectionHandlerImpl) RespondActivityTaskCompletedByID added in v0.5.2 

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

RespondActivityTaskCompletedByID API call

func (*DCRedirectionHandlerImpl) RespondActivityTaskFailed added in v0.5.2 

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

RespondActivityTaskFailed API call

func (*DCRedirectionHandlerImpl) RespondActivityTaskFailedByID added in v0.5.2 

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

RespondActivityTaskFailedByID API call

func (*DCRedirectionHandlerImpl) RespondDecisionTaskCompleted added in v0.5.2 

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

RespondDecisionTaskCompleted API call

func (*DCRedirectionHandlerImpl) RespondDecisionTaskFailed added in v0.5.2 

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

RespondDecisionTaskFailed API call

func (*DCRedirectionHandlerImpl) RespondQueryTaskCompleted added in v0.5.2 

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

RespondQueryTaskCompleted API call

func (*DCRedirectionHandlerImpl) SignalWithStartWorkflowExecution added in v0.5.2 

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

SignalWithStartWorkflowExecution API call

func (*DCRedirectionHandlerImpl) SignalWorkflowExecution added in v0.5.2 

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

SignalWorkflowExecution API call

func (*DCRedirectionHandlerImpl) Start added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) Start() error

Start starts the handler

func (*DCRedirectionHandlerImpl) StartWorkflowExecution added in v0.5.2 

func (handler *DCRedirectionHandlerImpl) StartWorkflowExecution(
	ctx context.Context,
	request *shared.StartWorkflowExecutionRequest,
) (*shared.StartWorkflowExecutionResponse, 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,
) error

TerminateWorkflowExecution API call

func (*DCRedirectionHandlerImpl) UpdateDomain added in v0.5.2 

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

UpdateDomain API call

type DCRedirectionPolicy added in v0.5.2 

type DCRedirectionPolicy interface {
	GetTargetDatacenterByName(domainName string) (string, error)
	GetTargetDatacenterByID(domainName string) (string, error)
}

DCRedirectionPolicy is DC redirection policy interface

func RedirectionPolicyGenerator added in v0.5.2 

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

RedirectionPolicyGenerator generate corresponding redirection policy

type DomainReplicator added in v0.3.7 

type DomainReplicator interface {
	HandleTransmissionTask(domainOperation replicator.DomainOperation, info *persistence.DomainInfo,
		config *persistence.DomainConfig, replicationConfig *persistence.DomainReplicationConfig,
		configVersion int64, failoverVersion int64, isGlobalDomainEnabled bool) error
}

DomainReplicator is the interface which can replicate the domain

func NewDomainReplicator added in v0.3.7 

func NewDomainReplicator(kafka messaging.Producer, logger bark.Logger) DomainReplicator

NewDomainReplicator create a new instance odf domain replicator

type ForwardingDCRedirectionPolicy added in v0.5.2 

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

ForwardingDCRedirectionPolicy is DC redirection policy which forwards API calls if domain is effective global, fromDC is current cluster, fromDC is not in replication config and toDC is in replication config,

func NewForwardingDCRedirectionPolicy added in v0.5.2 

func NewForwardingDCRedirectionPolicy(fromDC string, toDC string, domainCache cache.DomainCache) *ForwardingDCRedirectionPolicy

NewForwardingDCRedirectionPolicy creates a datacenter redirection policy forwarding API calls

func (*ForwardingDCRedirectionPolicy) GetTargetDatacenterByID added in v0.5.2 

func (policy *ForwardingDCRedirectionPolicy) GetTargetDatacenterByID(domainID string) (string, error)

GetTargetDatacenterByID get target cluster name by domain ID

func (*ForwardingDCRedirectionPolicy) GetTargetDatacenterByName added in v0.5.2 

func (policy *ForwardingDCRedirectionPolicy) GetTargetDatacenterByName(domainName string) (string, error)

GetTargetDatacenterByName get target cluster name by domain Name

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(currentClusteName string) *NoopRedirectionPolicy

NewNoopRedirectionPolicy is DC redirection policy which does nothing

func (*NoopRedirectionPolicy) GetTargetDatacenterByID added in v0.5.2 

func (policy *NoopRedirectionPolicy) GetTargetDatacenterByID(domainID string) (string, error)

GetTargetDatacenterByID get target cluster name by domain ID

func (*NoopRedirectionPolicy) GetTargetDatacenterByName added in v0.5.2 

func (policy *NoopRedirectionPolicy) GetTargetDatacenterByName(domainName string) (string, error)

GetTargetDatacenterByName get target cluster name by domain Name

type Service 

type Service struct {
	// 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 {
	service.Service
	// contains filtered or unexported fields
}

WorkflowHandler - Thrift handler interface for workflow service

func NewWorkflowHandler 

func NewWorkflowHandler(sVice service.Service, config *Config, metadataMgr persistence.MetadataManager,
	historyMgr persistence.HistoryManager, historyV2Mgr persistence.HistoryV2Manager,
	visibilityMgr persistence.VisibilityManager, kafkaProducer messaging.Producer,
	blobstoreClient blobstore.Client) *WorkflowHandler

NewWorkflowHandler creates a thrift handler for the cadence service

func (*WorkflowHandler) DeprecateDomain 

func (wh *WorkflowHandler) DeprecateDomain(ctx context.Context, deprecateRequest *gen.DeprecateDomainRequest) 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) (*gen.DescribeDomainResponse, 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) (*gen.DescribeTaskListResponse, error)

DescribeTaskList returns information about the target tasklist, right now this API returns the pollers which polled this tasklist in last few minutes.

func (*WorkflowHandler) DescribeWorkflowExecution added in v0.3.3 

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

DescribeWorkflowExecution returns information about the specified workflow execution.

func (*WorkflowHandler) GetWorkflowExecutionHistory 

func (wh *WorkflowHandler) GetWorkflowExecutionHistory(
	ctx context.Context,
	getRequest *gen.GetWorkflowExecutionHistoryRequest) (*gen.GetWorkflowExecutionHistoryResponse, 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) ListClosedWorkflowExecutions 

func (wh *WorkflowHandler) ListClosedWorkflowExecutions(ctx context.Context,
	listRequest *gen.ListClosedWorkflowExecutionsRequest) (*gen.ListClosedWorkflowExecutionsResponse, 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) (*gen.ListDomainsResponse, error)

ListDomains returns the information and configuration for a registered domain.

func (*WorkflowHandler) ListOpenWorkflowExecutions 

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

ListOpenWorkflowExecutions - retrieves info for open workflow executions in a domain

func (*WorkflowHandler) PollForActivityTask 

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

PollForActivityTask - Poll for an activity task.

func (*WorkflowHandler) PollForDecisionTask 

func (wh *WorkflowHandler) PollForDecisionTask(
	ctx context.Context,
	pollRequest *gen.PollForDecisionTaskRequest) (*gen.PollForDecisionTaskResponse, 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) (*gen.QueryWorkflowResponse, 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, err 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, err error)

RecordActivityTaskHeartbeatByID - Record Activity Task Heart beat.

func (*WorkflowHandler) RegisterDomain 

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

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

func (*WorkflowHandler) RequestCancelWorkflowExecution 

func (wh *WorkflowHandler) RequestCancelWorkflowExecution(
	ctx context.Context,
	cancelRequest *gen.RequestCancelWorkflowExecutionRequest) 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) (*gen.ResetStickyTaskListResponse, 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) (*gen.ResetWorkflowExecutionResponse, 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) 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) error

RespondActivityTaskCanceledByID - called to cancel an activity task

func (*WorkflowHandler) RespondActivityTaskCompleted 

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

RespondActivityTaskCompletedByID - response to an activity task

func (*WorkflowHandler) RespondActivityTaskFailed 

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

RespondActivityTaskFailedByID - response to an activity task failure

func (*WorkflowHandler) RespondDecisionTaskCompleted 

func (wh *WorkflowHandler) RespondDecisionTaskCompleted(
	ctx context.Context,
	completeRequest *gen.RespondDecisionTaskCompletedRequest) (*gen.RespondDecisionTaskCompletedResponse, 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) 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) error

RespondQueryTaskCompleted - response to a query task

func (*WorkflowHandler) SignalWithStartWorkflowExecution added in v0.3.11 

func (wh *WorkflowHandler) SignalWithStartWorkflowExecution(ctx context.Context,
	signalWithStartRequest *gen.SignalWithStartWorkflowExecutionRequest) (*gen.StartWorkflowExecutionResponse, 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) 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() error

Start starts the handler

func (*WorkflowHandler) StartWorkflowExecution 

func (wh *WorkflowHandler) StartWorkflowExecution(
	ctx context.Context,
	startRequest *gen.StartWorkflowExecutionRequest) (*gen.StartWorkflowExecutionResponse, 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) 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) (*gen.UpdateDomainResponse, error)

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

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.