client

Documentation

Index

• type Client
  • func NewClient(options Options) (*Client, error)
  • 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
  • func (r WorkflowHandle) Cancel() error
  • func (r WorkflowHandle) Result() (interface{}, error)
  • func (r WorkflowHandle) Signal(name string, arg interface{}) error
  • func (r WorkflowHandle) Terminate(reason string) error

Types

type Client

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

Client is the exported module instance.

func NewClient

func NewClient(options Options) (*Client, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) GetSDKClient

func (c *Client) GetSDKClient() sdkclient.Client

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

func (c *Client) WaitForAllWorkflowToComplete(namespace string) error

type Options

type Options = sdkclient.Options

type WorkflowHandle

type WorkflowHandle struct {
	ID    string
	RunID string
	// contains filtered or unexported fields
}

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