The highest tagged major version is v5.

workflow

package

v1.0.0-beta1 Latest Latest Go to latest Published: Jan 23, 2021 License: MIT Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/temporalio/roadrunner-temporal

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

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"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Plugin ¶

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

Plugin manages workflows and workers.

func (*Plugin) AddListener ¶

func (p *Plugin) AddListener(listener events.Listener)

AddListener adds event listeners to the service.

func (*Plugin) Init ¶

func (p *Plugin) Init(temporal temporal.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.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL