Categorygithub.com/milvus-io/milvusinternalutilflowgraph
package
2.5.7+incompatible
Repository: https://github.com/milvus-io/milvus.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
18
Dependents
1
Files
576 SLOC

# Functions

GenerateMsgStreamMsg is used to create a new MsgStreamMsg object.
No description provided by the author
NewInputNode composes an InputNode with provided input channel, name and parameters.
NewNodeCtxManager init with the inputNode and fg.closeWg.
NewTimeTickedFlowGraph create timetick flowgraph.

# Constants

No description provided by the author
No description provided by the author

# Structs

No description provided by the author
BaseNode defines some common node attributes and behavior.
InputNode is the entry point of flowgragh.
MsgStreamMsg is a wrapper of TsMsg in flowgraph.
TimeTickedFlowGraph flowgraph with input from tt msg stream.

# Interfaces

Msg is an abstract class that contains a method to get the time tick of this message.
Node is the interface defines the behavior of flowgraph.

# Type aliases

MsgPosition shortcut for msgpb.MsgPosition.
NodeName shortcut for string key.
Timestamp shortcut for typeutil.Timestamp.