sandboxrt

Documentation

Index

• func DefaultInitClient(*client.Options) error
• func MakeLocalActivityProxyFunc(c IPCClient, name string, fn interface{}) (interface{}, error)
• func NewActivityWorker(client client.Client, taskQueue string, ...) (worker.Worker, error)
• func NewClient(initClient func(*client.Options) error) (client.Client, error)
• func NewWorkflowWorker(client client.Client, taskQueue string, ...) (worker.Worker, error)
• func RegisterLocalActivityFunc(h IPCHost, name string, fn interface{}) error
• func Run(taskQueue string, initWorker func(*worker.Options, worker.Registry) error, ...) error
• func RunMain(taskQueue string, initWorker func(*worker.Options, worker.Registry) error, ...)
• type ActivityRegistration
• type IPCClient
• type IPCHost
• type IPCPipe
• type LocalRegistry
  • func (l *LocalRegistry) RegisterActivity(a interface{})
  • func (l *LocalRegistry) RegisterActivityWithOptions(a interface{}, options activity.RegisterOptions)
  • func (l *LocalRegistry) RegisterWorkflow(w interface{})
  • func (l *LocalRegistry) RegisterWorkflowWithOptions(w interface{}, options workflow.RegisterOptions)
• type WorkflowRegistration

Functions

func DefaultInitClient

func DefaultInitClient(*client.Options) error

func MakeLocalActivityProxyFunc

func MakeLocalActivityProxyFunc(c IPCClient, name string, fn interface{}) (interface{}, error)

func NewActivityWorker

func NewActivityWorker(
	client client.Client,
	taskQueue string,
	initWorker func(*worker.Options, worker.Registry) error,

	ipcHost IPCHost,
) (worker.Worker, error)

Returns nil with no error if no activities

func NewClient

func NewClient(initClient func(*client.Options) error) (client.Client, error)

func NewWorkflowWorker

func NewWorkflowWorker(
	client client.Client,
	taskQueue string,
	initWorker func(*worker.Options, worker.Registry) error,

	ipcClient IPCClient,
) (worker.Worker, error)

Returns nil with no error if no workflows

func RegisterLocalActivityFunc

func RegisterLocalActivityFunc(h IPCHost, name string, fn interface{}) error

func Run

func Run(
	taskQueue string,
	initWorker func(*worker.Options, worker.Registry) error,
	initClient func(*client.Options) error,
) error

func RunMain

func RunMain(
	taskQueue string,
	initWorker func(*worker.Options, worker.Registry) error,
	initClient func(*client.Options) error,
)

Types

type ActivityRegistration

type ActivityRegistration struct {
	Activity interface{}
	Options  activity.RegisterOptions
}

type IPCClient

type IPCClient interface {
	IPCPipe
	// If call returns an error, it is not an error from this function
	CallFunction(name string, args []interface{}) ([]interface{}, error)
}

type IPCHost

type IPCHost interface {
	IPCPipe
	RegisterFunction(name string, fn interface{}) error
	Serve(context.Context) error
}

type IPCPipe

type IPCPipe interface {
	Send([]byte) ([]byte, error)
	SetReceiveHandler(func([]byte) ([]byte, error))
}

type LocalRegistry

type LocalRegistry struct {
	Workflows  []*WorkflowRegistration
	Activities []*ActivityRegistration
}

func (*LocalRegistry) RegisterActivity

func (l *LocalRegistry) RegisterActivity(a interface{})

func (*LocalRegistry) RegisterActivityWithOptions

func (l *LocalRegistry) RegisterActivityWithOptions(a interface{}, options activity.RegisterOptions)

func (*LocalRegistry) RegisterWorkflow

func (l *LocalRegistry) RegisterWorkflow(w interface{})

func (*LocalRegistry) RegisterWorkflowWithOptions

func (l *LocalRegistry) RegisterWorkflowWithOptions(w interface{}, options workflow.RegisterOptions)

type WorkflowRegistration

type WorkflowRegistration struct {
	Workflow interface{}
	Options  workflow.RegisterOptions
}