workflow

Documentation

Index

• func CancelWorkflow(c *cli.Context) error
• func CountWorkflow(c *cli.Context) error
• func DeleteWorkflow(c *cli.Context) error
• func DescribeWorkflow(c *cli.Context) error
• func ListWorkflow(c *cli.Context) error
• func NewWorkflowCommands() []*cli.Command
• func ParseFoldStatusList(flagValue string) ([]enumspb.WorkflowExecutionStatus, error)
• func QueryWorkflow(c *cli.Context) error
• func QueryWorkflowUsingStackTrace(c *cli.Context) error
• func ResetInBatch(c *cli.Context) error
• func ResetWorkflow(c *cli.Context) error
• func ShowHistory(c *cli.Context) error
• func SignalWorkflow(c *cli.Context) error
• func StartWorkflow(c *cli.Context, printProgress bool) error
• func StartWorkflowBaseArgs(c *cli.Context) (taskQueue string, workflowType string, et, rt, dt int, wid string)
• func TerminateWorkflow(c *cli.Context) error
• func TraceWorkflow(c *cli.Context) error
• func UnmarshalMemoFromCLI(c *cli.Context) (map[string]interface{}, error)
• func UnmarshalSearchAttrFromCLI(c *cli.Context) (map[string]interface{}, error)
• func UpdateWorkflow(c *cli.Context) error

Functions

func CancelWorkflow

func CancelWorkflow(c *cli.Context) error

CancelWorkflow cancels workflow executions based on filter parameters

func CountWorkflow

func CountWorkflow(c *cli.Context) error

CountWorkflow count number of workflows

func DeleteWorkflow

func DeleteWorkflow(c *cli.Context) error

DeleteWorkflow deletes workflow executions based on filter parameters

func DescribeWorkflow

func DescribeWorkflow(c *cli.Context) error

DescribeWorkflow show information about the specified workflow execution

func ListWorkflow

func ListWorkflow(c *cli.Context) error

ListWorkflow list workflow executions based on filters

func NewWorkflowCommands

func NewWorkflowCommands() []*cli.Command

func ParseFoldStatusList

func ParseFoldStatusList(flagValue string) ([]enumspb.WorkflowExecutionStatus, error)

func QueryWorkflow

func QueryWorkflow(c *cli.Context) error

QueryWorkflow query workflow execution

func QueryWorkflowUsingStackTrace

func QueryWorkflowUsingStackTrace(c *cli.Context) error

QueryWorkflowUsingStackTrace query workflow execution using __stack_trace as query type

func ResetInBatch

func ResetInBatch(c *cli.Context) error

ResetInBatch resets workflow in batch

func ResetWorkflow

func ResetWorkflow(c *cli.Context) error

ResetWorkflow reset workflow

func ShowHistory

func ShowHistory(c *cli.Context) error

ShowHistory shows the history of given workflow execution based on workflowID and runID.

func SignalWorkflow

func SignalWorkflow(c *cli.Context) error

SignalWorkflow signals workflow executions based on filter parameters

func StartWorkflow

func StartWorkflow(c *cli.Context, printProgress bool) error

StartWorkflow starts a new workflow execution and optionally prints progress

func StartWorkflowBaseArgs

func StartWorkflowBaseArgs(c *cli.Context) (
	taskQueue string,
	workflowType string,
	et, rt, dt int,
	wid string,
)

func TerminateWorkflow

func TerminateWorkflow(c *cli.Context) error

TerminateWorkflow terminates workflow executions based on filter parameters

func TraceWorkflow

func TraceWorkflow(c *cli.Context) error

func UnmarshalMemoFromCLI

func UnmarshalMemoFromCLI(c *cli.Context) (map[string]interface{}, error)

func UnmarshalSearchAttrFromCLI

func UnmarshalSearchAttrFromCLI(c *cli.Context) (map[string]interface{}, error)

func UpdateWorkflow

func UpdateWorkflow(c *cli.Context) error