 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildFlow ¶
func BuildFlow(f *FlowRecord) *pb.EnrichedFlow
Types ¶
type Aggregate ¶
type Aggregate struct {
	segments.BaseSegment
	// contains filtered or unexported fields
}
    type FlowExporter ¶
type FlowExporter struct {
	Flows chan *pb.EnrichedFlow
	// contains filtered or unexported fields
}
    func NewFlowExporter ¶
func NewFlowExporter(activeTimeout string, inactiveTimeout string) (*FlowExporter, error)
func (*FlowExporter) ConsumeFrom ¶
func (f *FlowExporter) ConsumeFrom(pkts chan gopacket.Packet)
func (*FlowExporter) Insert ¶
func (f *FlowExporter) Insert(pkt gopacket.Packet)
func (*FlowExporter) InsertFlow ¶
func (f *FlowExporter) InsertFlow(flow *pb.EnrichedFlow)
func (*FlowExporter) Start ¶
func (f *FlowExporter) Start(samplerAddress net.IP, hardwareAddress net.HardwareAddr)
func (*FlowExporter) Stop ¶
func (f *FlowExporter) Stop()
type FlowKey ¶
type FlowKey struct {
	SrcAddr string
	DstAddr string
	SrcPort uint16
	DstPort uint16
	Proto   uint32
	IPTos   uint8
	InIface uint32
}
    func NewFlowKey ¶
func NewFlowKeyFromFlow ¶
func NewFlowKeyFromFlow(flow *pb.EnrichedFlow) FlowKey
type FlowRecord ¶
 Click to show internal directories. 
   Click to hide internal directories.