workflow

package
v1.0.0-RC.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 11, 2021 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

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

	// Main plugin name
	RootPluginName = "temporal"

	// RRMode sets as RR_MODE env variable to let pool know about the mode to run.
	RRMode = "workflow"
)
View Source 
const RR_CODEC = "RR_CODEC" //nolint

RR_CODEC env variable key

View Source 
const RR_MODE = "RR_MODE" //nolint

RR_MODE env variable key

Variables

This section is empty.

Functions

This section is empty.

Types

type Plugin 

type Plugin struct {
	// embed
	sync.Mutex
	// 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, cfg config.Configurer) 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() []rrWorker.BaseProcess

Workers returns list of available workflow workers.

func (*Plugin) WorkflowNames 

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

WorkflowNames returns list of all available workflows.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.