branch

Documentation

Index

• type Branch
  • func (b *Branch) AddChild(node topology.Node)
  • func (b *Branch) AddChildBuilder(builder topology.NodeBuilder)
  • func (b *Branch) Build() (topology.Node, error)
  • func (b *Branch) ChildBuilders() []topology.NodeBuilder
  • func (b *Branch) Childs() []topology.Node
  • func (b *Branch) ID() int32
  • func (b *Branch) Next() bool
  • func (b *Branch) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, cont bool, err error)
  • func (b *Branch) Type() topology.Type
• type Details
• type Predicate
• type Splitter
  • func (bs *Splitter) AddChild(node topology.Node)
  • func (bs *Splitter) AddChildBuilder(builder topology.NodeBuilder)
  • func (bs *Splitter) Build() (topology.Node, error)
  • func (bs *Splitter) ChildBuilders() []topology.NodeBuilder
  • func (bs *Splitter) Childs() []topology.Node
  • func (bs *Splitter) ID() int32
  • func (bs *Splitter) Next() bool
  • func (bs *Splitter) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, cont bool, err error)
  • func (bs *Splitter) Type() topology.Type

Types

type Branch

type Branch struct {
	Id        int32
	Name      string
	Predicate Predicate
	// contains filtered or unexported fields
}

func (*Branch) AddChild

func (b *Branch) AddChild(node topology.Node)

func (*Branch) AddChildBuilder

func (b *Branch) AddChildBuilder(builder topology.NodeBuilder)

func (*Branch) Build

func (b *Branch) Build() (topology.Node, error)

func (*Branch) ChildBuilders

func (b *Branch) ChildBuilders() []topology.NodeBuilder

func (*Branch) Childs

func (b *Branch) Childs() []topology.Node

func (*Branch) ID

func (b *Branch) ID() int32

func (*Branch) Next

func (b *Branch) Next() bool

func (*Branch) Run

func (b *Branch) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, cont bool, err error)

func (*Branch) Type

func (b *Branch) Type() topology.Type

type Details

type Details struct {
	Name      string
	Predicate Predicate
}

type Predicate

type Predicate func(ctx context.Context, key interface{}, val interface{}) (bool, error)

type Splitter

type Splitter struct {
	Id             int32
	Branches       []topology.Node
	BranchBuilders []topology.NodeBuilder
}

func (*Splitter) AddChild

func (bs *Splitter) AddChild(node topology.Node)

func (*Splitter) AddChildBuilder

func (bs *Splitter) AddChildBuilder(builder topology.NodeBuilder)

func (*Splitter) Build

func (bs *Splitter) Build() (topology.Node, error)

func (*Splitter) ChildBuilders

func (bs *Splitter) ChildBuilders() []topology.NodeBuilder

func (*Splitter) Childs

func (bs *Splitter) Childs() []topology.Node

func (*Splitter) ID

func (bs *Splitter) ID() int32

func (*Splitter) Next

func (bs *Splitter) Next() bool

func (*Splitter) Run

func (bs *Splitter) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, cont bool, err error)

func (*Splitter) Type

func (bs *Splitter) Type() topology.Type