data

package
v0.0.0-...-da789b0 Latest Latest
Warning

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

Go to latest
Published: Mar 11, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New(b *base.Node, node *data.Data) graph.Node

func NewConfigProto

func NewConfigProto(value any) *data.Data

func NewInputProto

func NewInputProto() *data.Data

func NewProto

func NewProto(name string, d *data.Data) *gen.Node

Types

type ConfigNode

type ConfigNode struct {
	*base.Node
	*data.Config
}

func NewConfigNode

func NewConfigNode(b *base.Node, node *data.Config) *ConfigNode

func (*ConfigNode) NewConfigProvider

func (c *ConfigNode) NewConfigProvider(options ...config.YAMLOption) (config.Provider, error)

func (*ConfigNode) Wire

func (c *ConfigNode) Wire(ctx context.Context, input graph.IO) (graph.IO, error)

type InputNode

type InputNode struct {
	*base.Node
	*data.Input
	// contains filtered or unexported fields
}

func NewInputNode

func NewInputNode(base *base.Node, input *data.Input, ops ...InputOption) *InputNode

func (*InputNode) Wire

func (n *InputNode) Wire(ctx context.Context, input graph.IO) (graph.IO, error)

type InputOption

type InputOption func(*InputNode) *InputNode

func WithObservable

func WithObservable(io *graph.IO) InputOption

Jump to

Keyboard shortcuts

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