Documentation ¶
Index ¶
- type Client
- func (c *Client) Close()
- func (c *Client) GetSDKClient() sdkclient.Client
- func (c *Client) GetWorkflowHandle(workflowID string, runID string) WorkflowHandle
- func (c *Client) SignalWithStartWorkflow(workflowID string, signalName string, signalArg interface{}, ...) (WorkflowHandle, error)
- func (c *Client) StartWorkflow(options sdkclient.StartWorkflowOptions, workflowType string, ...) (WorkflowHandle, error)
- func (c *Client) WaitForAllWorkflowToComplete(namespace string) error
- type Options
- type WorkflowHandle
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is the exported module instance.
func (*Client) GetSDKClient ¶
func (*Client) GetWorkflowHandle ¶
func (c *Client) GetWorkflowHandle(workflowID string, runID string) WorkflowHandle
func (*Client) SignalWithStartWorkflow ¶
func (c *Client) SignalWithStartWorkflow(workflowID string, signalName string, signalArg interface{}, options sdkclient.StartWorkflowOptions, workflowType string, workflowArgs ...interface{}) (WorkflowHandle, error)
func (*Client) StartWorkflow ¶
func (c *Client) StartWorkflow(options sdkclient.StartWorkflowOptions, workflowType string, workflowArgs ...interface{}) (WorkflowHandle, error)
func (*Client) WaitForAllWorkflowToComplete ¶
type WorkflowHandle ¶
func (WorkflowHandle) Cancel ¶
func (r WorkflowHandle) Cancel() error
func (WorkflowHandle) Result ¶
func (r WorkflowHandle) Result() (interface{}, error)
func (WorkflowHandle) Signal ¶
func (r WorkflowHandle) Signal(name string, arg interface{}) error
func (WorkflowHandle) Terminate ¶
func (r WorkflowHandle) Terminate(reason string) error
Click to show internal directories.
Click to hide internal directories.