flowexporter

Documentation

Index

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

Functions

func IsConnectionDying

func IsConnectionDying(conn *Connection) bool

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
	// IsPresent flag helps in cleaning up connections when they are not in conntrack table anymore.
	IsPresent bool
	// DoneExport marks whether the related flow records are already exported or not so that we can
	// safely delete the connection from the connection map.
	DoneExport         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
	TCPState                      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
	IsIPv6             bool
	LastExportTime     time.Time
	IsActive           bool
}

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
}