temporal

Documentation

Index

• Constants
• func New(address string) *worker
• type Client
  • func NewClient(address string) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) CreateWorker(taskQue string)
  • func (c *Client) RegisterActivity(activity interface{})
  • func (c *Client) RegisterWorkflow(workflow interface{})
  • func (c *Client) StartWorker() error
• type Worker
  • func NewDeployWorker(address string) (Worker, error)

Constants

const (
	ClimonDeployTaskQueue = "CLIMON_DEPLOY_TASK_QUEUE"
)

Functions

func New

func New(address string) *worker

Types

type Client

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

func NewClient

func NewClient(address string) (*Client, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) CreateWorker

func (c *Client) CreateWorker(taskQue string)

func (*Client) RegisterActivity

func (c *Client) RegisterActivity(activity interface{})

func (*Client) RegisterWorkflow

func (c *Client) RegisterWorkflow(workflow interface{})

func (*Client) StartWorker

func (c *Client) StartWorker() error

type Worker

type Worker interface {
	Start() error
	Stop() error
}

func NewDeployWorker

func NewDeployWorker(address string) (Worker, error)