Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Branch ¶
type Branch struct {
segments.BaseSegment
// contains filtered or unexported fields
}
func (*Branch) ImportBranches ¶
func (segment *Branch) ImportBranches(condition interface{}, then_branch interface{}, else_branch interface{})
type Pipeline ¶
type Pipeline interface {
Start()
Close()
GetInput() chan *pb.EnrichedFlow
GetOutput() <-chan *pb.EnrichedFlow
GetDrop() <-chan *pb.EnrichedFlow
}
This mirrors the proper implementation in the pipeline package. This duplication is to avoid the import cycle.
Source Files
Click to show internal directories.
Click to hide internal directories.