flowexporter

Documentation

Index

• type Connection
• type ConnectionKey
  • func NewConnectionKey(conn *Connection) ConnectionKey
• type ConnectionMapCallBack
• type FlowRecord
• type FlowRecordCallBack
• type Tuple

Types

type Connection

type Connection struct {
	// Fields from conntrack flows
	ID        uint32
	Timeout   uint32
	StartTime time.Time
	// For invalid and closed connections: StopTime is the time when connection was updated last.
	// For established connections: StopTime is latest time when it was polled.
	StopTime time.Time
	// IsActive flag helps in cleaning up connections when they are not in conntrack any module more.
	IsActive bool
	// DoExport flag helps in tagging connections that can be exported by Flow Exporter
	DoExport           bool
	Zone               uint16
	Mark               uint32
	StatusFlag         uint32
	Labels, LabelsMask []byte
	// TODO: Have a separate field for protocol. No need to keep it in Tuple.
	TupleOrig, TupleReply          Tuple
	OriginalPackets, OriginalBytes uint64
	ReversePackets, ReverseBytes   uint64
	// Fields specific to Antrea
	SourcePodNamespace            string
	SourcePodName                 string
	DestinationPodNamespace       string
	DestinationPodName            string
	DestinationServicePortName    string
	IngressNetworkPolicyName      string
	IngressNetworkPolicyNamespace string
	EgressNetworkPolicyName       string
	EgressNetworkPolicyNamespace  string
}

type ConnectionKey

type ConnectionKey [5]string

func NewConnectionKey

func NewConnectionKey(conn *Connection) ConnectionKey

NewConnectionKey creates 5-tuple of flow as connection key

type ConnectionMapCallBack

type ConnectionMapCallBack func(key ConnectionKey, conn Connection) error

type FlowRecord

type FlowRecord struct {
	Conn               *Connection
	PrevPackets        uint64
	PrevBytes          uint64
	PrevReversePackets uint64
	PrevReverseBytes   uint64
}

type FlowRecordCallBack

type FlowRecordCallBack func(key ConnectionKey, record FlowRecord) error

type Tuple

type Tuple struct {
	SourceAddress      net.IP
	DestinationAddress net.IP
	Protocol           uint8
	SourcePort         uint16
	DestinationPort    uint16
}