signalwithstartworkflow

Documentation

Index

• func ConvertToStartRequest(namespaceID namespace.ID, ...) *historyservice.StartWorkflowExecutionRequest
• func Invoke(ctx context.Context, ...) (_ *historyservice.SignalWithStartWorkflowExecutionResponse, retError error)
• func SignalWithStartWorkflow(ctx context.Context, shard shard.Context, namespaceEntry *namespace.Namespace, ...) (string, bool, error)

Functions

func ConvertToStartRequest

func ConvertToStartRequest(
	namespaceID namespace.ID,
	request *workflowservice.SignalWithStartWorkflowExecutionRequest,
	now time.Time,
) *historyservice.StartWorkflowExecutionRequest

func Invoke

func Invoke(
	ctx context.Context,
	signalWithStartRequest *historyservice.SignalWithStartWorkflowExecutionRequest,
	shard shard.Context,
	workflowConsistencyChecker api.WorkflowConsistencyChecker,
) (_ *historyservice.SignalWithStartWorkflowExecutionResponse, retError error)

func SignalWithStartWorkflow

func SignalWithStartWorkflow(
	ctx context.Context,
	shard shard.Context,
	namespaceEntry *namespace.Namespace,
	currentWorkflowLease api.WorkflowLease,
	startRequest *historyservice.StartWorkflowExecutionRequest,
	signalWithStartRequest *workflowservice.SignalWithStartWorkflowExecutionRequest,
) (string, bool, error)