branch

package
Version: v1.3.2 Latest Latest
Warning

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

Go to latest
Published: Aug 16, 2021 License: MIT Imports: 3 Imported by: 0

Documentation

Index

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) 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

Source Files

Jump to

Keyboard shortcuts

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