network

Documentation

Index

• Variables
• type Network
  • func New() *Network
  • func (n *Network) AddNode(name string, node tributary.Node) error
  • func (n *Network) Edges() map[string][]string
  • func (n *Network) Fanin(b string, an ...string) error
  • func (n *Network) Fanout(a string, bn ...string) error
  • func (n *Network) GetNode(a string) (tributary.Node, bool)
  • func (n *Network) IsConnected() bool
  • func (n *Network) Link(a, b string) error
  • func (n *Network) NodeExists(a string) bool
  • func (n *Network) NodeUnconnected(a string) bool
  • func (n *Network) Start()
  • func (n *Network) Stop()

Variables

var (
	ErrNodeNotFound     = errors.New("node doesn't exist")
	ErrUnknownNodeType  = errors.New("node type not recognized")
	ErrReservedNodeName = errors.New("node name is reserved")
)

Types

type Network

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

func New

func New() *Network

func (*Network) AddNode

func (n *Network) AddNode(name string, node tributary.Node) error

func (*Network) Edges

func (n *Network) Edges() map[string][]string

func (*Network) Fanin

func (n *Network) Fanin(b string, an ...string) error

func (*Network) Fanout

func (n *Network) Fanout(a string, bn ...string) error

Fanout links the source to all outputs

func (*Network) GetNode

func (n *Network) GetNode(a string) (tributary.Node, bool)

func (*Network) IsConnected

func (n *Network) IsConnected() bool

func (*Network) Link

func (n *Network) Link(a, b string) error

func (*Network) NodeExists

func (n *Network) NodeExists(a string) bool

func (*Network) NodeUnconnected

func (n *Network) NodeUnconnected(a string) bool

func (*Network) Start

func (n *Network) Start()

func (*Network) Stop

func (n *Network) Stop()