workflow

package
v0.0.0-...-cfef285 Latest Latest
Warning

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

Go to latest
Published: Aug 11, 2023 License: AGPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CheckIPParam

type CheckIPParam struct {
	IPs []netip.Addr
}

CheckIPParam is a workflow parameter for the CheckIP workflow

type CheckIPResult

type CheckIPResult struct {
	IPs map[netip.Addr]net.HardwareAddr
}

CheckIPResult is a value returned by the CheckIP workflow

func CheckIP

func CheckIP(ctx workflow.Context, param CheckIPParam) (CheckIPResult, error)

CheckIP is a Temporal workflow for checking available IP addresses

type WorkerPool

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

WorkerPool contains a collection of Temporal Workers that can be added or removed in runtime, through master worker that is responsible for execution of special workflows AddWorker and RemoveWorker. WorkerPool allows to register specific Workflows and Activities for the added workers.

func NewWorkerPool

func NewWorkerPool(systemID string, client client.Client) (*WorkerPool, error)

NewWorkerPool returns WorkerPool that has a master worker listening to a Temporal Task Queue {systemID}

func (*WorkerPool) Configure

func (p *WorkerPool) Configure(ctx context.Context) error

Configure calls Configure workflow to be executed. This workflow will configure WorkerPool with a proper set of workers. E.g. it will call AddWorker and RemoveWorker workflows.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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