wait

package

v0.2.0 Latest Latest Go to latest Published: Oct 22, 2026 License: BSD-2-Clause Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dukex/operion

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewWaitFactory() protocol.NodeFactory
func NewWaitUntilFactory() protocol.NodeFactory
type Factory
type Node
- func NewWait(id string, config map[string]any) (*Node, error)
- func NewWaitUntil(id string, config map[string]any) (*Node, error)

Constants ¶

View Source

const (
	InputPortMain     = "main"
	OutputPortSuccess = "success"
	TypeWait          = "wait"
	TypeWaitUntil     = "wait_until"
	ConfigDuration    = "duration"
	ConfigUntil       = "until"
)

Variables ¶

This section is empty.

Functions ¶

func NewWaitFactory ¶

func NewWaitFactory() protocol.NodeFactory

func NewWaitUntilFactory ¶

func NewWaitUntilFactory() protocol.NodeFactory

Types ¶

type Factory ¶

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

func (*Factory) Create ¶

func (f *Factory) Create(_ context.Context, id string, config map[string]any) (protocol.Node, error)

func (*Factory) Description ¶

func (f *Factory) Description() string

func (*Factory) ID ¶

func (f *Factory) ID() string

func (*Factory) Name ¶

func (f *Factory) Name() string

func (*Factory) Schema ¶

func (f *Factory) Schema() map[string]any

type Node ¶

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

func NewWait ¶

func NewWait(id string, config map[string]any) (*Node, error)

func NewWaitUntil ¶

func NewWaitUntil(id string, config map[string]any) (*Node, error)

func (*Node) Execute ¶

func (n *Node) Execute(_ models.ExecutionContext, inputs map[string]models.NodeResult) (map[string]models.NodeResult, error)

func (*Node) ID ¶

func (n *Node) ID() string

func (*Node) InputPorts ¶

func (n *Node) InputPorts() []models.InputPort

func (*Node) OutputPorts ¶

func (n *Node) OutputPorts() []models.OutputPort

func (*Node) Type ¶

func (n *Node) Type() string

func (*Node) Validate ¶

func (n *Node) Validate(config map[string]any) error

func (*Node) WaitUntil ¶

func (n *Node) WaitUntil(ctx models.ExecutionContext, _ map[string]models.NodeResult) (time.Time, error)

Source Files ¶

View all Source files

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