callable

package
v1.43.0 Latest Latest
Warning

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

Go to latest
Published: Sep 4, 2025 License: GPL-3.0 Imports: 23 Imported by: 0

Documentation

Overview

Package callable provides utility functions for workflow callable operations, including timeout handling and trigger expression parsing.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AcquireTimeout added in v0.26.80

func AcquireTimeout(defaultTimeout time.Duration, varStack map[string]string, callName string, envId string) time.Duration

Types

type Call

type Call struct {
	Func     string
	Return   string
	VarStack map[string]string
	Traits   task.Traits
	// contains filtered or unexported fields
}

func NewCall

func NewCall(funcCall string, returnVar string, parent ParentRole) (call *Call)

func (*Call) Await added in v0.20.81

func (c *Call) Await() error

func (*Call) Call

func (c *Call) Call() error

func (*Call) Cancel added in v1.16.1

func (c *Call) Cancel() bool

func (*Call) GetName

func (c *Call) GetName() string

func (*Call) GetParentRole

func (c *Call) GetParentRole() interface{}

func (*Call) GetParentRolePath

func (c *Call) GetParentRolePath() string

func (*Call) GetTraits

func (c *Call) GetTraits() task.Traits

func (*Call) Start added in v0.20.81

func (c *Call) Start()

type Calls

type Calls []*Call

func (Calls) AwaitAll added in v0.20.81

func (s Calls) AwaitAll() map[*Call]error

func (Calls) CallAll

func (s Calls) CallAll() map[*Call]error

func (Calls) StartAll added in v0.20.81

func (s Calls) StartAll()

type CallsMap added in v0.28.0

type CallsMap map[HookWeight]Calls

func (CallsMap) GetWeights added in v0.28.0

func (m CallsMap) GetWeights() []HookWeight

type Hook

type Hook interface {
	GetParentRole() interface{}
	GetParentRolePath() string
	GetName() string
	GetTraits() task.Traits
}

type HookWeight added in v0.28.0

type HookWeight int

func ParseTriggerExpression added in v0.28.0

func ParseTriggerExpression(triggerExpr string) (triggerName string, triggerWeight HookWeight)

type Hooks

type Hooks []Hook

func (Hooks) FilterCalls

func (s Hooks) FilterCalls() (calls Calls)

func (Hooks) FilterTasks

func (s Hooks) FilterTasks() (tasks task.Tasks)

type HooksMap added in v0.28.0

type HooksMap map[HookWeight]Hooks

func (HooksMap) GetWeights added in v0.28.0

func (m HooksMap) GetWeights() []HookWeight

type ParentRole

type ParentRole interface {
	GetPath() string
	GetTaskTraits() task.Traits
	GetEnvironmentId() uid.ID
	ConsolidatedVarStack() (varStack map[string]string, err error)
	SendEvent(event.Event)
	SetRuntimeVar(key string, value string)
	SetRuntimeVars(kv map[string]string)
	DeleteRuntimeVar(key string)
	DeleteRuntimeVars(keys []string)
	SetGlobalRuntimeVar(key string, value string)
	SetGlobalRuntimeVars(kv map[string]string)
	DeleteGlobalRuntimeVar(key string)
	DeleteGlobalRuntimeVars(keys []string)
	GetCurrentRunNumber() uint32
}

Jump to

Keyboard shortcuts

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