workflow

Documentation

Index

• type CheckIPParam
• type CheckIPResult
  • func CheckIP(ctx workflow.Context, param CheckIPParam) (CheckIPResult, error)
• type WorkerPool
  • func NewWorkerPool(systemID string, client client.Client) (*WorkerPool, error)
  • func (p *WorkerPool) Configure(ctx context.Context) error

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.