Versions in this module Expand all Collapse all v1 v1.2.53 Jun 14, 2020 v1.2.52 Jun 13, 2020 v1.2.51 Jun 13, 2020 v1.2.51-beta Jun 13, 2020 v1.2.50 Jun 11, 2020 v1.2.41 May 8, 2020 v1.2.4 May 7, 2020 v1.2.3 May 4, 2020 v1.2.2 Apr 30, 2020 v1.2.1 Apr 27, 2020 v1.2.0 Apr 24, 2020 v1.1.2 Apr 5, 2020 v1.1.1 Apr 4, 2020 v1.1.0 Mar 20, 2020 Changes in this version + type GlobalTableJoiner struct + Id int32 + KeyMapper KeyMapper + Registry store.Registry + Store string + Typ Type + ValueMapper ValueMapper + func (j *GlobalTableJoiner) AddChild(node topology.Node) + func (j *GlobalTableJoiner) AddChildBuilder(builder topology.NodeBuilder) + func (j *GlobalTableJoiner) Build() (topology.Node, error) + func (j *GlobalTableJoiner) ChildBuilders() []topology.NodeBuilder + func (j *GlobalTableJoiner) Childs() []topology.Node + func (j *GlobalTableJoiner) ID() int32 + func (j *GlobalTableJoiner) Join(ctx context.Context, key interface{}, leftVal interface{}) (joinedVal interface{}, err error) + func (j *GlobalTableJoiner) Name() string + func (j *GlobalTableJoiner) Next() bool + func (j *GlobalTableJoiner) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, next bool, err error) + func (j *GlobalTableJoiner) Type() topology.Type + type Joiner interface + Join func(ctx context.Context, key, val interface{}) (joinedVal interface{}, err error) + type KeyMapper func(key, value interface{}) (mappedKey interface{}, err error) + type SideJoiner struct + Id int32 + LeftWindow *Window + RightWindow *Window + Side string + ValueMapper ValueMapper + func (sj *SideJoiner) AddChild(node topology.Node) + func (sj *SideJoiner) AddChildBuilder(builder topology.NodeBuilder) + func (sj *SideJoiner) Build() (topology.Node, error) + func (sj *SideJoiner) ChildBuilders() []topology.NodeBuilder + func (sj *SideJoiner) Childs() []topology.Node + func (sj *SideJoiner) ID() int32 + func (sj *SideJoiner) Next() bool + func (sj *SideJoiner) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, cont bool, err error) + func (sj *SideJoiner) Type() topology.Type + type StreamJoiner struct + Id int32 + func (j *StreamJoiner) AddChild(node topology.Node) + func (j *StreamJoiner) AddChildBuilder(builder topology.NodeBuilder) + func (j *StreamJoiner) Build() (topology.Node, error) + func (j *StreamJoiner) ChildBuilders() []topology.NodeBuilder + func (j *StreamJoiner) Childs() []topology.Node + func (j *StreamJoiner) ID() int32 + func (j *StreamJoiner) Name() string + func (j *StreamJoiner) Next() bool + func (j *StreamJoiner) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, cont bool, err error) + func (j *StreamJoiner) Type() topology.Type + type Type int + const InnerJoin + const LeftJoin + type ValueMapper func(left, right interface{}) (joined interface{}, err error) + type Window struct + func NewWindow() *Window + func (w *Window) Read(key interface{}) (interface{}, bool) + func (w *Window) Write(key, value interface{})