frontend

package

Go to main page

Versions in this module

v0

v0.3.2

Sep 29, 2017

Changes in this version

type Config

+ HistoryMgrNumConns int

type WorkflowHandler

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

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

v0.3.1

Aug 15, 2017

v0.3.0

Aug 7, 2017

Changes in this version

+ type Config struct

+ DefaultHistoryMaxPageSize int32

+ DefaultVisibilityMaxPageSize int32

+ RPS int

+ func NewConfig() *Config

type WorkflowHandler

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

v0.2.0

Jun 30, 2017

Changes in this version

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

+ type Service struct

+ func (s *Service) Start()

+ func (s *Service) Stop()

+ type WorkflowHandler struct

+ func NewWorkflowHandler(sVice service.Service, metadataMgr persistence.MetadataManager, ...) (*WorkflowHandler, []thrift.TChanServer)

+ func (wh *WorkflowHandler) DeprecateDomain(ctx thrift.Context, deprecateRequest *gen.DeprecateDomainRequest) error

+ func (wh *WorkflowHandler) DescribeDomain(ctx thrift.Context, describeRequest *gen.DescribeDomainRequest) (*gen.DescribeDomainResponse, error)

+ func (wh *WorkflowHandler) GetWorkflowExecutionHistory(ctx thrift.Context, getRequest *gen.GetWorkflowExecutionHistoryRequest) (*gen.GetWorkflowExecutionHistoryResponse, error)

+ func (wh *WorkflowHandler) IsHealthy(ctx thrift.Context) (bool, error)

+ func (wh *WorkflowHandler) ListClosedWorkflowExecutions(ctx thrift.Context, listRequest *gen.ListClosedWorkflowExecutionsRequest) (*gen.ListClosedWorkflowExecutionsResponse, error)

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

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

+ func (wh *WorkflowHandler) PollForDecisionTask(ctx thrift.Context, pollRequest *gen.PollForDecisionTaskRequest) (*gen.PollForDecisionTaskResponse, error)

+ func (wh *WorkflowHandler) RecordActivityTaskHeartbeat(ctx thrift.Context, heartbeatRequest *gen.RecordActivityTaskHeartbeatRequest) (*gen.RecordActivityTaskHeartbeatResponse, error)

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

+ func (wh *WorkflowHandler) RequestCancelWorkflowExecution(ctx thrift.Context, cancelRequest *gen.RequestCancelWorkflowExecutionRequest) error

+ func (wh *WorkflowHandler) RespondActivityTaskCanceled(ctx thrift.Context, cancelRequest *gen.RespondActivityTaskCanceledRequest) error

+ func (wh *WorkflowHandler) RespondActivityTaskCompleted(ctx thrift.Context, completeRequest *gen.RespondActivityTaskCompletedRequest) error

+ func (wh *WorkflowHandler) RespondActivityTaskFailed(ctx thrift.Context, failedRequest *gen.RespondActivityTaskFailedRequest) error

+ func (wh *WorkflowHandler) RespondDecisionTaskCompleted(ctx thrift.Context, completeRequest *gen.RespondDecisionTaskCompletedRequest) error

+ func (wh *WorkflowHandler) SignalWorkflowExecution(ctx thrift.Context, signalRequest *gen.SignalWorkflowExecutionRequest) error

+ func (wh *WorkflowHandler) Start(thriftService []thrift.TChanServer) error

+ func (wh *WorkflowHandler) StartWorkflowExecution(ctx thrift.Context, startRequest *gen.StartWorkflowExecutionRequest) (*gen.StartWorkflowExecutionResponse, error)

+ func (wh *WorkflowHandler) Stop()

+ func (wh *WorkflowHandler) TerminateWorkflowExecution(ctx thrift.Context, terminateRequest *gen.TerminateWorkflowExecutionRequest) error

+ func (wh *WorkflowHandler) UpdateDomain(ctx thrift.Context, updateRequest *gen.UpdateDomainRequest) (*gen.UpdateDomainResponse, error)

v0.1.1-beta

Jun 7, 2017

v0.1.0-beta

Jun 6, 2017

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL