Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func NewNodeCtx ¶
func NewNodeCtx(node Node) *nodeCtx
func WrapErrRegDispather ¶
Types ¶
type BaseNode ¶
type BaseNode struct {
// contains filtered or unexported fields
}
func NewBaseNode ¶
func (*BaseNode) MaxQueueLength ¶
length of pipeline input chnnel
type StreamPipeline ¶
type StreamPipeline interface { Pipeline ConsumeMsgStream(ctx context.Context, position *msgpb.MsgPosition) error Status() string }
func NewPipelineWithStream ¶
func NewPipelineWithStream(dispatcher msgdispatcher.Client, nodeTtInterval time.Duration, enableTtChecker bool, vChannel string) StreamPipeline
Click to show internal directories.
Click to hide internal directories.