Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SinkProcessor ¶
type SinkProcessor struct { ISBSvcType dfv1.ISBSvcType VertexInstance *dfv1.VertexInstance }
type Sinker ¶
type Sinker interface { isb.BufferWriter forward.StarterStopper }
Sinker interface defines what a Sink should implement.
Click to show internal directories.
Click to hide internal directories.