units

package
v1.2.11 Latest Latest
Warning

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

 Go to latest Published: Aug 28, 2026 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuiltinNames added in v1.2.8 

func BuiltinNames() []string

func BuiltinRegistrations added in v1.2.8 

func BuiltinRegistrations() []workerunit.Registration

BuiltinRegistrations returns a copy of the standard unit catalog. Callers can select a subset without mutating package-level state.

func RegisterBuiltins added in v1.2.8 

func RegisterBuiltins(reg *workerunit.Registry) error

RegisterBuiltins atomically installs the standard unit catalog into reg.

Types

type AdjustDateUnit added in v1.2.8 

type AdjustDateUnit struct {
	unit.Unit
}

AdjustDateUnit applies calendar-aware or duration-aware arithmetic to a date.

func NewAdjustDateUnit added in v1.2.8 

func NewAdjustDateUnit() AdjustDateUnit

func (*AdjustDateUnit) Execute added in v1.2.8 

func (u *AdjustDateUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*AdjustDateUnit) GetUnitMeta added in v1.2.8 

func (u *AdjustDateUnit) GetUnitMeta() *unit.Unit

func (*AdjustDateUnit) GetUnitName added in v1.2.8 

func (u *AdjustDateUnit) GetUnitName() string

type AskForInputUnit added in v1.2.8 

type AskForInputUnit struct {
	unit.Unit
}

AskForInputUnit returns a value collected by the workflow run form.

func NewAskForInputUnit added in v1.2.8 

func NewAskForInputUnit() AskForInputUnit

func (*AskForInputUnit) Execute added in v1.2.8 

func (u *AskForInputUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*AskForInputUnit) GetUnitMeta added in v1.2.8 

func (u *AskForInputUnit) GetUnitMeta() *unit.Unit

func (*AskForInputUnit) GetUnitName added in v1.2.8 

func (u *AskForInputUnit) GetUnitName() string

type BranchJoinUnit added in v1.2.8 

type BranchJoinUnit struct {
	unit.Unit
	BranchOrder  []string          `json:"branch_order,omitempty"`
	BranchLabels map[string]string `json:"branch_labels,omitempty"`
}

BranchJoinUnit is an internal control-flow unit used by structured branches. Inputs are keyed by branch name; the first non-nil value in BranchOrder wins.

func (*BranchJoinUnit) Execute added in v1.2.8 

func (u *BranchJoinUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*BranchJoinUnit) GetUnitMeta added in v1.2.8 

func (u *BranchJoinUnit) GetUnitMeta() *unit.Unit

func (*BranchJoinUnit) GetUnitName added in v1.2.8 

func (u *BranchJoinUnit) GetUnitName() string

type BreakUnit added in v0.8.3 

type BreakUnit struct {
	unit.Unit
}

func (*BreakUnit) Execute added in v0.8.3 

func (u *BreakUnit) Execute(ctx context.Context, state unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*BreakUnit) GetUnitMeta added in v0.8.3 

func (u *BreakUnit) GetUnitMeta() *unit.Unit

func (*BreakUnit) GetUnitName added in v0.8.3 

func (u *BreakUnit) GetUnitName() string

type CalculateUnit added in v1.2.8 

type CalculateUnit struct {
	unit.Unit
}

CalculateUnit performs one selected arithmetic operation on two numbers.

func NewCalculateUnit added in v1.2.8 

func NewCalculateUnit() CalculateUnit

func (*CalculateUnit) Execute added in v1.2.8 

func (u *CalculateUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*CalculateUnit) GetUnitMeta added in v1.2.8 

func (u *CalculateUnit) GetUnitMeta() *unit.Unit

func (*CalculateUnit) GetUnitName added in v1.2.8 

func (u *CalculateUnit) GetUnitName() string

type ChangeCaseUnit added in v1.2.8 

type ChangeCaseUnit struct {
	unit.Unit
}

ChangeCaseUnit applies one selected Unicode-aware case transformation.

func NewChangeCaseUnit added in v1.2.8 

func NewChangeCaseUnit() ChangeCaseUnit

func (*ChangeCaseUnit) Execute added in v1.2.8 

func (u *ChangeCaseUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*ChangeCaseUnit) GetUnitMeta added in v1.2.8 

func (u *ChangeCaseUnit) GetUnitMeta() *unit.Unit

func (*ChangeCaseUnit) GetUnitName added in v1.2.8 

func (u *ChangeCaseUnit) GetUnitName() string

type ChooseFromMenuUnit added in v1.2.8 

type ChooseFromMenuUnit struct {
	unit.Unit
}

ChooseFromMenuUnit returns one validated item from a configured menu.

func NewChooseFromMenuUnit added in v1.2.8 

func NewChooseFromMenuUnit() ChooseFromMenuUnit

func (*ChooseFromMenuUnit) Execute added in v1.2.8 

func (u *ChooseFromMenuUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*ChooseFromMenuUnit) GetUnitMeta added in v1.2.8 

func (u *ChooseFromMenuUnit) GetUnitMeta() *unit.Unit

func (*ChooseFromMenuUnit) GetUnitName added in v1.2.8 

func (u *ChooseFromMenuUnit) GetUnitName() string

type CombineTextUnit added in v1.2.8 

type CombineTextUnit struct {
	unit.Unit
}

CombineTextUnit joins an incoming list into one text value.

func NewCombineTextUnit added in v1.2.8 

func NewCombineTextUnit() CombineTextUnit

func (*CombineTextUnit) Execute added in v1.2.8 

func (u *CombineTextUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*CombineTextUnit) GetUnitMeta added in v1.2.8 

func (u *CombineTextUnit) GetUnitMeta() *unit.Unit

func (*CombineTextUnit) GetUnitName added in v1.2.8 

func (u *CombineTextUnit) GetUnitName() string

type ContinueUnit added in v0.8.3 

type ContinueUnit struct {
	unit.Unit
}

func (*ContinueUnit) Execute added in v0.8.3 

func (u *ContinueUnit) Execute(ctx context.Context, state unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*ContinueUnit) GetUnitMeta added in v0.8.3 

func (u *ContinueUnit) GetUnitMeta() *unit.Unit

func (*ContinueUnit) GetUnitName added in v0.8.3 

func (u *ContinueUnit) GetUnitName() string

type CountUnit added in v1.2.8 

type CountUnit struct {
	unit.Unit
}

CountUnit counts a selected aspect of the incoming value.

func NewCountUnit added in v1.2.8 

func NewCountUnit() CountUnit

func (*CountUnit) Execute added in v1.2.8 

func (u *CountUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*CountUnit) GetUnitMeta added in v1.2.8 

func (u *CountUnit) GetUnitMeta() *unit.Unit

func (*CountUnit) GetUnitName added in v1.2.8 

func (u *CountUnit) GetUnitName() string

type DateUnit added in v1.2.8 

type DateUnit struct {
	unit.Unit
}

DateUnit returns the current time or one explicitly selected wall-clock time.

func NewDateUnit added in v1.2.8 

func NewDateUnit() DateUnit

func (*DateUnit) Execute added in v1.2.8 

func (u *DateUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*DateUnit) GetUnitMeta added in v1.2.8 

func (u *DateUnit) GetUnitMeta() *unit.Unit

func (*DateUnit) GetUnitName added in v1.2.8 

func (u *DateUnit) GetUnitName() string

type DictionaryUnit added in v1.2.8 

type DictionaryUnit struct {
	unit.Unit
}

DictionaryUnit builds a typed dictionary from visually configured entries.

func NewDictionaryUnit added in v1.2.8 

func NewDictionaryUnit() DictionaryUnit

func (*DictionaryUnit) Execute added in v1.2.8 

func (u *DictionaryUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*DictionaryUnit) GetUnitMeta added in v1.2.8 

func (u *DictionaryUnit) GetUnitMeta() *unit.Unit

func (*DictionaryUnit) GetUnitName added in v1.2.8 

func (u *DictionaryUnit) GetUnitName() string

type FormatDateUnit added in v1.2.8 

type FormatDateUnit struct {
	unit.Unit
}

FormatDateUnit renders a date using one selected no-code preset.

func NewFormatDateUnit added in v1.2.8 

func NewFormatDateUnit() FormatDateUnit

func (*FormatDateUnit) Execute added in v1.2.8 

func (u *FormatDateUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*FormatDateUnit) GetUnitMeta added in v1.2.8 

func (u *FormatDateUnit) GetUnitMeta() *unit.Unit

func (*FormatDateUnit) GetUnitName added in v1.2.8 

func (u *FormatDateUnit) GetUnitName() string

type GetDictionaryValueUnit added in v1.2.8 

type GetDictionaryValueUnit struct {
	unit.Unit
}

GetDictionaryValueUnit returns the value stored at an explicitly configured key.

func NewGetDictionaryValueUnit added in v1.2.8 

func NewGetDictionaryValueUnit() GetDictionaryValueUnit

func (*GetDictionaryValueUnit) Execute added in v1.2.8 

func (u *GetDictionaryValueUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*GetDictionaryValueUnit) GetUnitMeta added in v1.2.8 

func (u *GetDictionaryValueUnit) GetUnitMeta() *unit.Unit

func (*GetDictionaryValueUnit) GetUnitName added in v1.2.8 

func (u *GetDictionaryValueUnit) GetUnitName() string

type GetListItemUnit added in v1.2.8 

type GetListItemUnit struct {
	unit.Unit
}

GetListItemUnit selects one value from an incoming list.

func NewGetListItemUnit added in v1.2.8 

func NewGetListItemUnit() GetListItemUnit

func (*GetListItemUnit) Execute added in v1.2.8 

func (u *GetListItemUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*GetListItemUnit) GetUnitMeta added in v1.2.8 

func (u *GetListItemUnit) GetUnitMeta() *unit.Unit

func (*GetListItemUnit) GetUnitName added in v1.2.8 

func (u *GetListItemUnit) GetUnitName() string

type GotoUnit added in v0.8.3 

type GotoUnit struct {
	unit.Unit
}

func (*GotoUnit) Execute added in v0.8.3 

func (u *GotoUnit) Execute(ctx context.Context, state unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*GotoUnit) GetUnitMeta added in v0.8.3 

func (u *GotoUnit) GetUnitMeta() *unit.Unit

func (*GotoUnit) GetUnitName added in v0.8.3 

func (u *GotoUnit) GetUnitName() string

type HttpUnit 

type HttpUnit struct {
	unit.Unit
	// contains filtered or unexported fields
}

func NewHttpUnit 

func NewHttpUnit() HttpUnit

func (*HttpUnit) Execute 

func (t *HttpUnit) Execute(ctx context.Context, state unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*HttpUnit) GetUnitMeta 

func (t *HttpUnit) GetUnitMeta() *unit.Unit

func (*HttpUnit) GetUnitName 

func (t *HttpUnit) GetUnitName() string

type LLMUnit added in v1.2.8 

type LLMUnit struct {
	unit.Unit
	// contains filtered or unexported fields
}

LLMUnit executes a single OpenAI-compatible chat completion request.

func (*LLMUnit) Execute added in v1.2.8 

func (u *LLMUnit) Execute(ctx context.Context, state unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*LLMUnit) GetUnitMeta added in v1.2.8 

func (u *LLMUnit) GetUnitMeta() *unit.Unit

func (*LLMUnit) GetUnitName added in v1.2.8 

func (u *LLMUnit) GetUnitName() string

type ListUnit added in v1.2.8 

type ListUnit struct {
	unit.Unit
}

ListUnit returns configured items in their declared order.

func NewListUnit added in v1.2.8 

func NewListUnit() ListUnit

func (*ListUnit) Execute added in v1.2.8 

func (u *ListUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*ListUnit) GetUnitMeta added in v1.2.8 

func (u *ListUnit) GetUnitMeta() *unit.Unit

func (*ListUnit) GetUnitName added in v1.2.8 

func (u *ListUnit) GetUnitName() string

type LogicUnit 

type LogicUnit struct {
	unit.Unit
}

func NewLogUnit 

func NewLogUnit() LogicUnit

func (*LogicUnit) Execute 

func (t *LogicUnit) Execute(ctx context.Context, state unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*LogicUnit) GetUnitMeta added in v0.8.3 

func (t *LogicUnit) GetUnitMeta() *unit.Unit

func (*LogicUnit) GetUnitName 

func (t *LogicUnit) GetUnitName() string

type OpenAPIOperationUnit added in v1.2.8 

type OpenAPIOperationUnit struct {
	unit.Unit
	// contains filtered or unexported fields
}

func NewOpenAPIOperationUnit added in v1.2.8 

func NewOpenAPIOperationUnit() OpenAPIOperationUnit

func (*OpenAPIOperationUnit) Execute added in v1.2.8 

func (t *OpenAPIOperationUnit) Execute(
	ctx context.Context,
	state unit.ContextMap,
	self *unit.Node,
) (*unit.ExecutionResult, error)

func (*OpenAPIOperationUnit) GetUnitMeta added in v1.2.8 

func (t *OpenAPIOperationUnit) GetUnitMeta() *unit.Unit

func (*OpenAPIOperationUnit) GetUnitName added in v1.2.8 

func (t *OpenAPIOperationUnit) GetUnitName() string

type ReadableUnit added in v0.8.3 

type ReadableUnit struct {
	unit.Unit
	Format   string `json:"format,omitempty"`
	Template string `json:"template,omitempty"`
}

ReadableUnit renders workflow data into JSON-safe text.

func NewReadableUnit added in v0.8.3 

func NewReadableUnit() ReadableUnit

func (*ReadableUnit) Execute added in v0.8.3 

func (t *ReadableUnit) Execute(ctx context.Context, state unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*ReadableUnit) GetUnitMeta added in v0.8.3 

func (t *ReadableUnit) GetUnitMeta() *unit.Unit

func (*ReadableUnit) GetUnitName added in v0.8.3 

func (t *ReadableUnit) GetUnitName() string

type RemarkUnit 

type RemarkUnit struct {
	unit.Unit
}

func NewRemarkUnit 

func NewRemarkUnit() RemarkUnit

func (*RemarkUnit) Execute 

func (t *RemarkUnit) Execute(ctx context.Context, state unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*RemarkUnit) GetUnitMeta added in v0.8.3 

func (t *RemarkUnit) GetUnitMeta() *unit.Unit

func (*RemarkUnit) GetUnitName 

func (t *RemarkUnit) GetUnitName() string

type ReplaceTextUnit added in v1.2.8 

type ReplaceTextUnit struct {
	unit.Unit
}

ReplaceTextUnit replaces literal text in the incoming value.

func NewReplaceTextUnit added in v1.2.8 

func NewReplaceTextUnit() ReplaceTextUnit

func (*ReplaceTextUnit) Execute added in v1.2.8 

func (u *ReplaceTextUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*ReplaceTextUnit) GetUnitMeta added in v1.2.8 

func (u *ReplaceTextUnit) GetUnitMeta() *unit.Unit

func (*ReplaceTextUnit) GetUnitName added in v1.2.8 

func (u *ReplaceTextUnit) GetUnitName() string

type ScriptUnit 

type ScriptUnit struct {
	unit.Unit
	Language string `json:"language,omitempty"`
	Script   string `json:"script"`
}

ScriptUnit ===== ScriptUnit 动态 JS 执行单元 =====

func NewScriptUnit 

func NewScriptUnit(script string) ScriptUnit

func (*ScriptUnit) Execute 

func (t *ScriptUnit) Execute(ctx context.Context, state unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*ScriptUnit) GetUnitMeta added in v0.8.3 

func (t *ScriptUnit) GetUnitMeta() *unit.Unit

func (*ScriptUnit) GetUnitName 

func (t *ScriptUnit) GetUnitName() string

type SetEnvUnit 

type SetEnvUnit struct {
	unit.Unit
}

func NewSetEnvUnit 

func NewSetEnvUnit() SetEnvUnit

func (*SetEnvUnit) Execute 

func (t *SetEnvUnit) Execute(ctx context.Context, state unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*SetEnvUnit) GetUnitMeta added in v0.8.3 

func (t *SetEnvUnit) GetUnitMeta() *unit.Unit

func (*SetEnvUnit) GetUnitName 

func (t *SetEnvUnit) GetUnitName() string

type SplitTextUnit added in v1.2.8 

type SplitTextUnit struct {
	unit.Unit
}

SplitTextUnit separates incoming text into an ordered list.

func NewSplitTextUnit added in v1.2.8 

func NewSplitTextUnit() SplitTextUnit

func (*SplitTextUnit) Execute added in v1.2.8 

func (u *SplitTextUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*SplitTextUnit) GetUnitMeta added in v1.2.8 

func (u *SplitTextUnit) GetUnitMeta() *unit.Unit

func (*SplitTextUnit) GetUnitName added in v1.2.8 

func (u *SplitTextUnit) GetUnitName() string

type TerminalUnit 

type TerminalUnit struct {
	unit.Unit
}

func NewTerminalUnit 

func NewTerminalUnit() TerminalUnit

func (*TerminalUnit) Execute 

func (t *TerminalUnit) Execute(ctx context.Context, state unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*TerminalUnit) GetUnitMeta added in v0.8.3 

func (t *TerminalUnit) GetUnitMeta() *unit.Unit

func (*TerminalUnit) GetUnitName 

func (t *TerminalUnit) GetUnitName() string

type TextUnit added in v1.2.8 

type TextUnit struct {
	unit.Unit
}

TextUnit creates text from a fixed value or a resolved Magic Variable.

func NewTextUnit added in v1.2.8 

func NewTextUnit() TextUnit

func (*TextUnit) Execute added in v1.2.8 

func (u *TextUnit) Execute(_ context.Context, _ unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*TextUnit) GetUnitMeta added in v1.2.8 

func (u *TextUnit) GetUnitMeta() *unit.Unit

func (*TextUnit) GetUnitName added in v1.2.8 

func (u *TextUnit) GetUnitName() string

type TimeoutUnit 

type TimeoutUnit struct {
	unit.Unit
}

func NewTimeoutUnit 

func NewTimeoutUnit() TimeoutUnit

func (*TimeoutUnit) Execute 

func (t *TimeoutUnit) Execute(ctx context.Context, state unit.ContextMap, self *unit.Node) (*unit.ExecutionResult, error)

func (*TimeoutUnit) GetUnitMeta added in v0.8.3 

func (t *TimeoutUnit) GetUnitMeta() *unit.Unit

func (*TimeoutUnit) GetUnitName 

func (t *TimeoutUnit) GetUnitName() string

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.