nodes

Documentation

Index

• func TryGetOutputValue[T any](output NodeOutput[T], fallback T) T
• type Alertable
• type Dependent
• type Describable
• type Input
• type Named
• type Node
• type NodeDependency
• type NodeOutput
• type NodeOutputReference
• type NodeState
• type Output
• type Pathed
• type Processor
• type StateData
  • func (s StateData) State() NodeState
• type Stateful
• type Struct
  • func NewStruct[T StructProcesor[G], G any](p T) *Struct[G, T]
  • func (sn *Struct[T, G]) AddSubscription(a Alertable)
  • func (sn Struct[T, G]) Dependencies() []NodeDependency
  • func (sn Struct[T, G]) Description() string
  • func (sn Struct[T, G]) Inputs() []Input
  • func (sn Struct[T, G]) Name() string
  • func (sn *Struct[T, G]) Node() Node
  • func (sn *Struct[T, G]) Out() StructOutput[T, G]
  • func (sn Struct[T, G]) Outdated() bool
  • func (sn *Struct[T, G]) Outputs() []Output
  • func (sn Struct[T, G]) Path() string
  • func (sn *Struct[T, G]) Port() string
  • func (sn *Struct[T, G]) SetInput(input string, output Output)
  • func (sn *Struct[T, G]) State() NodeState
  • func (sn Struct[T, G]) Type() string
  • func (sn *Struct[T, G]) Value() T
  • func (sn Struct[T, G]) Version() int
• type StructDependency
  • func (snd StructDependency) Dependency() Node
  • func (snd StructDependency) DependencyPort() string
  • func (snd StructDependency) Name() string
• type StructOutput
  • func (sno StructOutput[T, G]) Node() Node
  • func (sno StructOutput[T, G]) Port() string
  • func (sno StructOutput[T, G]) Value() T
• type StructProcesor
• type Subscribable
• type Typed
• type ValueNode
  • func FuncValue[T any](f func() T) *ValueNode[T]
  • func Value[T any](startingValue T) *ValueNode[T]
  • func (v *ValueNode[T]) AddSubscription(a Alertable)
  • func (v *ValueNode[T]) Dependencies() []NodeDependency
  • func (tn ValueNode[T]) Inputs() []Input
  • func (in ValueNode[T]) Name() string
  • func (in *ValueNode[T]) Node() Node
  • func (in *ValueNode[T]) Out() ValueNodeOutput[T]
  • func (tn *ValueNode[T]) Outputs() []Output
  • func (in *ValueNode[T]) Port() string
  • func (in *ValueNode[T]) Set(value T)
  • func (vn ValueNode[T]) SetInput(input string, output Output)
  • func (v *ValueNode[T]) State() NodeState
  • func (in ValueNode[T]) Value() T
• type ValueNodeOutput
  • func (sno ValueNodeOutput[T]) Node() Node
  • func (sno ValueNodeOutput[T]) Port() string
  • func (sno ValueNodeOutput[T]) Value() T
• type VersionData
  • func (v *VersionData) Increment() int
  • func (v VersionData) Version() int
• type Versioned

Functions

func TryGetOutputValue

func TryGetOutputValue[T any](output NodeOutput[T], fallback T) T

Types

type Alertable

type Alertable interface {
	Alert(version int, state NodeState)
}

type Dependent

type Dependent interface {
	Dependencies() []NodeDependency
}

type Describable

type Describable interface {
	Description() string
}

type Input

type Input struct {
	Name  string
	Type  string
	Array bool
}

type Named

type Named interface {
	Name() string
}

type Node

type Node interface {
	Versioned
	Stateful
	Dependent

	SetInput(input string, output Output)
	Outputs() []Output
	Inputs() []Input
}

type NodeDependency

type NodeDependency interface {
	Named
	Dependency() Node
	DependencyPort() string
}

type NodeOutput

type NodeOutput[T any] interface {
	NodeOutputReference
	Value() T
}

type NodeOutputReference

type NodeOutputReference interface {
	Node() Node
	Port() string
}

type NodeState

type NodeState int

const (
	Stale NodeState = iota
	Processed
	Error
)

type Output

type Output struct {
	Type       string
	NodeOutput NodeOutputReference
}

type Pathed

type Pathed interface {
	Path() string
}

type Processor

type Processor[T any] interface {
	Process() (T, error)
}

type StateData

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

func (StateData) State

func (s StateData) State() NodeState

type Stateful

type Stateful interface {
	State() NodeState
}

type Struct

type Struct[T any, G StructProcesor[T]] struct {
	Data G
	// contains filtered or unexported fields
}

func NewStruct

func NewStruct[T StructProcesor[G], G any](p T) *Struct[G, T]

func (*Struct[T, G]) AddSubscription

func (sn *Struct[T, G]) AddSubscription(a Alertable)

func (Struct[T, G]) Dependencies

func (sn Struct[T, G]) Dependencies() []NodeDependency

func (Struct[T, G]) Description

func (sn Struct[T, G]) Description() string

func (Struct[T, G]) Inputs

func (sn Struct[T, G]) Inputs() []Input

func (Struct[T, G]) Name

func (sn Struct[T, G]) Name() string

func (*Struct[T, G]) Node

func (sn *Struct[T, G]) Node() Node

func (*Struct[T, G]) Out

func (sn *Struct[T, G]) Out() StructOutput[T, G]

func (Struct[T, G]) Outdated

func (sn Struct[T, G]) Outdated() bool

func (*Struct[T, G]) Outputs

func (sn *Struct[T, G]) Outputs() []Output

func (Struct[T, G]) Path

func (sn Struct[T, G]) Path() string

func (*Struct[T, G]) Port

func (sn *Struct[T, G]) Port() string

func (*Struct[T, G]) SetInput

func (sn *Struct[T, G]) SetInput(input string, output Output)

func (*Struct[T, G]) State

func (sn *Struct[T, G]) State() NodeState

func (Struct[T, G]) Type

func (sn Struct[T, G]) Type() string

func (*Struct[T, G]) Value

func (sn *Struct[T, G]) Value() T

func (Struct[T, G]) Version

func (sn Struct[T, G]) Version() int

type StructDependency

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

func (StructDependency) Dependency

func (snd StructDependency) Dependency() Node

func (StructDependency) DependencyPort

func (snd StructDependency) DependencyPort() string

func (StructDependency) Name

func (snd StructDependency) Name() string

type StructOutput

type StructOutput[T any, G StructProcesor[T]] struct {
	Struct *Struct[T, G]
	Name   string
}

func (StructOutput[T, G]) Node

func (sno StructOutput[T, G]) Node() Node

func (StructOutput[T, G]) Port

func (sno StructOutput[T, G]) Port() string

func (StructOutput[T, G]) Value

func (sno StructOutput[T, G]) Value() T

type StructProcesor

type StructProcesor[T any] interface {
	Process() (T, error)
}

type Subscribable

type Subscribable interface {
	AddSubscription(a Alertable)
}

type Typed

type Typed interface {
	Type() string
}

type ValueNode

type ValueNode[T any] struct {
	VersionData
	// contains filtered or unexported fields
}

func FuncValue

func FuncValue[T any](f func() T) *ValueNode[T]

func Value

func Value[T any](startingValue T) *ValueNode[T]

func (*ValueNode[T]) AddSubscription

func (v *ValueNode[T]) AddSubscription(a Alertable)

func (*ValueNode[T]) Dependencies

func (v *ValueNode[T]) Dependencies() []NodeDependency

func (ValueNode[T]) Inputs

func (tn ValueNode[T]) Inputs() []Input

func (ValueNode[T]) Name

func (in ValueNode[T]) Name() string

func (*ValueNode[T]) Node

func (in *ValueNode[T]) Node() Node

func (*ValueNode[T]) Out

func (in *ValueNode[T]) Out() ValueNodeOutput[T]

func (*ValueNode[T]) Outputs

func (tn *ValueNode[T]) Outputs() []Output

func (*ValueNode[T]) Port

func (in *ValueNode[T]) Port() string

func (*ValueNode[T]) Set

func (in *ValueNode[T]) Set(value T)

func (ValueNode[T]) SetInput

func (vn ValueNode[T]) SetInput(input string, output Output)

func (*ValueNode[T]) State

func (v *ValueNode[T]) State() NodeState

func (ValueNode[T]) Value

func (in ValueNode[T]) Value() T

type ValueNodeOutput

type ValueNodeOutput[T any] struct {
	Val *ValueNode[T]
}

func (ValueNodeOutput[T]) Node

func (sno ValueNodeOutput[T]) Node() Node

func (ValueNodeOutput[T]) Port

func (sno ValueNodeOutput[T]) Port() string

func (ValueNodeOutput[T]) Value

func (sno ValueNodeOutput[T]) Value() T

type VersionData

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

func (*VersionData) Increment

func (v *VersionData) Increment() int

func (VersionData) Version

func (v VersionData) Version() int

type Versioned

type Versioned interface {
	Version() int
}