startworkflow

Documentation

Index

• type Starter
  • func NewStarter(shardContext shard.Context, ...) (*Starter, error)
  • func (s *Starter) Invoke(ctx context.Context) (resp *historyservice.StartWorkflowExecutionResponse, retError error)

Types

type Starter

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

Starter starts a new workflow execution.

func NewStarter

func NewStarter(
	shardContext shard.Context,
	workflowConsistencyChecker api.WorkflowConsistencyChecker,
	tokenSerializer common.TaskTokenSerializer,
	visibilityManager manager.VisibilityManager,
	request *historyservice.StartWorkflowExecutionRequest,
) (*Starter, error)

NewStarter creates a new starter, fails if getting the active namespace fails.

func (*Starter) Invoke

func (s *Starter) Invoke(
	ctx context.Context,
) (resp *historyservice.StartWorkflowExecutionResponse, retError error)

Invoke starts a new workflow execution