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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Branch ¶
type Branch struct { Id int32 Name string Predicate Predicate // contains filtered or unexported fields }
func (*Branch) AddChildBuilder ¶
func (b *Branch) AddChildBuilder(builder topology.NodeBuilder)
func (*Branch) ChildBuilders ¶
func (b *Branch) ChildBuilders() []topology.NodeBuilder
type Splitter ¶
type Splitter struct { Id int32 Branches []topology.Node BranchBuilders []topology.NodeBuilder }
func (*Splitter) AddChildBuilder ¶
func (bs *Splitter) AddChildBuilder(builder topology.NodeBuilder)
func (*Splitter) ChildBuilders ¶
func (bs *Splitter) ChildBuilders() []topology.NodeBuilder
Click to show internal directories.
Click to hide internal directories.