edge

Documentation

Index

• func New(edge *gen.Edge) graph.Edge
• func NewEdgeProto(from, to string) *gen.Edge
• func NewMap(edge *gen.Edge, p *gen.Map) graph.Edge
• func NewMapProto(from, to string) *gen.Edge
• func NewProvides(edge *gen.Edge, p *gen.Provides) graph.Edge
• func NewProvidesProto(from, to string) *gen.Edge
• type Base
  • func NewBase(edge *gen.Edge) *Base
  • func (b *Base) From() string
  • func (b *Base) ID() string
  • func (b *Base) To() string
• type Map
  • func (p *Map) Connect(from, to graph.Node) error
• type MapListener
  • func NewMapListener(n graph.Node, e *Map) *MapListener
  • func (p *MapListener) GetNode() graph.Node
  • func (p *MapListener) Transform(ctx context.Context, input *graph.IO) (*graph.IO, error)
• type Provides
  • func (p *Provides) Connect(from, to graph.Node) error

Functions

func New

func New(edge *gen.Edge) graph.Edge

func NewEdgeProto

func NewEdgeProto(from, to string) *gen.Edge

TODO breadchris find a better package for this

func NewMap

func NewMap(edge *gen.Edge, p *gen.Map) graph.Edge

func NewMapProto

func NewMapProto(from, to string) *gen.Edge

func NewProvides

func NewProvides(edge *gen.Edge, p *gen.Provides) graph.Edge

func NewProvidesProto

func NewProvidesProto(from, to string) *gen.Edge

Types

type Base

type Base struct {
	Edge *gen.Edge
}

func NewBase

func NewBase(edge *gen.Edge) *Base

func (*Base) From

func (b *Base) From() string

func (*Base) ID

func (b *Base) ID() string

func (*Base) To

func (b *Base) To() string

type Map

type Map struct {
	*Base
	*gen.Map
}

func (*Map) Connect

func (p *Map) Connect(from, to graph.Node) error

type MapListener

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

func NewMapListener

func NewMapListener(n graph.Node, e *Map) *MapListener

func (*MapListener) GetNode

func (p *MapListener) GetNode() graph.Node

func (*MapListener) Transform

func (p *MapListener) Transform(ctx context.Context, input *graph.IO) (*graph.IO, error)

type Provides

type Provides struct {
	*Base
	*gen.Provides
}

func (*Provides) Connect

func (p *Provides) Connect(from, to graph.Node) error