workflow

Documentation

Index

• Constants
• type Plugin
  • func (p *Plugin) Init(temporal client.Temporal, server server.Server, log logger.Logger) error
  • func (p *Plugin) Name() string
  • func (p *Plugin) Reset() error
  • func (p *Plugin) Serve() chan error
  • func (p *Plugin) Stop() error
  • func (p *Plugin) Workers() []worker.BaseProcess
  • func (p *Plugin) WorkflowNames() []string
• type PoolEvent

Constants

const (
	// PluginName defines public service name.
	PluginName = "workflows"

	// RRMode sets as RR_MODE env variable to let worker know about the mode to run.
	RRMode = "temporal/workflow"
)

const RR_CODEC = "RR_CODEC" //nolint

RR_CODEC env variable key

const RR_MODE = "RR_MODE" //nolint

RR_MODE env variable key

Types

type Plugin

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

Plugin manages workflows and workers.

func (*Plugin) Init

func (p *Plugin) Init(temporal client.Temporal, server server.Server, log logger.Logger) error

Init workflow plugin.

func (*Plugin) Name

func (p *Plugin) Name() string

Name of the service.

func (*Plugin) Reset

func (p *Plugin) Reset() error

Reset resets underlying workflow pool with new copy.

func (*Plugin) Serve

func (p *Plugin) Serve() chan error

Serve starts workflow service.

func (*Plugin) Stop

func (p *Plugin) Stop() error

Stop workflow service.

func (*Plugin) Workers

func (p *Plugin) Workers() []worker.BaseProcess

Workers returns list of available workflow workers.

func (*Plugin) WorkflowNames

func (p *Plugin) WorkflowNames() []string

WorkflowNames returns list of all available workflows.

type PoolEvent

type PoolEvent struct {
	Event   int
	Context interface{}
	Caused  error
}

PoolEvent triggered on workflow pool worker events.