The highest tagged major version is v5.

workflow

package

v1.0.17 Latest Latest Go to latest Published: Dec 14, 2021 License: MIT Imports: 23 Imported by: 0

Details

View Source

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

View Source

const RR_CODEC = "RR_CODEC" //nolint:revive,stylecheck

RR_CODEC env variable key

View Source

const RR_MODE = "RR_MODE" //nolint:revive,stylecheck

RR_MODE env variable key

This section is empty.

This section is empty.

type Plugin struct {
	// embed
	sync.Mutex
	// contains filtered or unexported fields
}

Plugin manages workflows and workers.

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

Init workflow plugin.

func (p *Plugin) Name() string

Name of the service.

func (p *Plugin) Reset() error

Reset resets underlying workflow pool with new copy.

func (p *Plugin) Serve() chan error

Serve starts workflow service.

func (p *Plugin) Stop() error

Stop workflow service.

func (p *Plugin) Workers() []*process.State

Workers returns list of available workflow workers.

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

WorkflowNames returns list of all available workflows.