Documentation
¶
Index ¶
- Variables
- type AntreaFlowMsg
- func (*AntreaFlowMsg) Descriptor() ([]byte, []int)deprecated
- func (x *AntreaFlowMsg) GetBytesDelta() uint64
- func (x *AntreaFlowMsg) GetBytesTotal() uint64
- func (x *AntreaFlowMsg) GetDstClusterIP() string
- func (x *AntreaFlowMsg) GetDstIP() string
- func (x *AntreaFlowMsg) GetDstNodeName() string
- func (x *AntreaFlowMsg) GetDstPodName() string
- func (x *AntreaFlowMsg) GetDstPodNamespace() string
- func (x *AntreaFlowMsg) GetDstPort() uint32
- func (x *AntreaFlowMsg) GetDstServicePort() uint32
- func (x *AntreaFlowMsg) GetDstServicePortName() string
- func (x *AntreaFlowMsg) GetEgressPolicyName() string
- func (x *AntreaFlowMsg) GetEgressPolicyNamespace() string
- func (x *AntreaFlowMsg) GetExportAddress() string
- func (x *AntreaFlowMsg) GetIngressPolicyName() string
- func (x *AntreaFlowMsg) GetIngressPolicyNamespace() string
- func (x *AntreaFlowMsg) GetObsDomainID() uint32
- func (x *AntreaFlowMsg) GetPacketsDelta() uint64
- func (x *AntreaFlowMsg) GetPacketsTotal() uint64
- func (x *AntreaFlowMsg) GetProto() uint32
- func (x *AntreaFlowMsg) GetReverseBytesDelta() uint64
- func (x *AntreaFlowMsg) GetReverseBytesTotal() uint64
- func (x *AntreaFlowMsg) GetReversePacketsDelta() uint64
- func (x *AntreaFlowMsg) GetReversePacketsTotal() uint64
- func (x *AntreaFlowMsg) GetSequenceNumber() uint32
- func (x *AntreaFlowMsg) GetSrcIP() string
- func (x *AntreaFlowMsg) GetSrcNodeName() string
- func (x *AntreaFlowMsg) GetSrcPodName() string
- func (x *AntreaFlowMsg) GetSrcPodNamespace() string
- func (x *AntreaFlowMsg) GetSrcPort() uint32
- func (x *AntreaFlowMsg) GetTimeFlowEndInMilliSecs() uint32
- func (x *AntreaFlowMsg) GetTimeFlowEndInSecs() uint32
- func (x *AntreaFlowMsg) GetTimeFlowStartInMilliSecs() uint64
- func (x *AntreaFlowMsg) GetTimeFlowStartInSecs() uint32
- func (x *AntreaFlowMsg) GetTimeReceived() uint32
- func (*AntreaFlowMsg) ProtoMessage()
- func (x *AntreaFlowMsg) ProtoReflect() protoreflect.Message
- func (x *AntreaFlowMsg) Reset()
- func (x *AntreaFlowMsg) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_pkg_flowaggregator_kafka_protobuf_antrea_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AntreaFlowMsg ¶
type AntreaFlowMsg struct {
// From the header of IPFIX Message.
TimeReceived uint32 `protobuf:"varint,1,opt,name=TimeReceived,json=timeReceived,proto3" json:"TimeReceived,omitempty"`
SequenceNumber uint32 `protobuf:"varint,2,opt,name=SequenceNumber,json=sequenceNumber,proto3" json:"SequenceNumber,omitempty"`
ObsDomainID uint32 `protobuf:"varint,3,opt,name=ObsDomainID,json=obsDomainID,proto3" json:"ObsDomainID,omitempty"`
ExportAddress string `protobuf:"bytes,33,opt,name=ExportAddress,json=exportAddress,proto3" json:"ExportAddress,omitempty"`
// Fields of flow record.
TimeFlowStartInSecs uint32 `protobuf:"varint,4,opt,name=TimeFlowStartInSecs,json=timeFlowStartInSecs,proto3" json:"TimeFlowStartInSecs,omitempty"`
TimeFlowEndInSecs uint32 `protobuf:"varint,5,opt,name=TimeFlowEndInSecs,json=timeFlowEndInSecs,proto3" json:"TimeFlowEndInSecs,omitempty"`
TimeFlowStartInMilliSecs uint64 `` /* 133-byte string literal not displayed */
TimeFlowEndInMilliSecs uint32 `` /* 127-byte string literal not displayed */
// 5-tuple of flows
SrcIP string `protobuf:"bytes,6,opt,name=SrcIP,json=srcIP,proto3" json:"SrcIP,omitempty"`
DstIP string `protobuf:"bytes,7,opt,name=DstIP,json=dstIP,proto3" json:"DstIP,omitempty"`
SrcPort uint32 `protobuf:"varint,8,opt,name=SrcPort,json=srcPort,proto3" json:"SrcPort,omitempty"`
DstPort uint32 `protobuf:"varint,9,opt,name=DstPort,json=dstPort,proto3" json:"DstPort,omitempty"`
Proto uint32 `protobuf:"varint,10,opt,name=Proto,json=proto,proto3" json:"Proto,omitempty"`
// Statistics of flow in original and reverse directions.
PacketsTotal uint64 `protobuf:"varint,11,opt,name=PacketsTotal,json=packetsTotal,proto3" json:"PacketsTotal,omitempty"`
BytesTotal uint64 `protobuf:"varint,12,opt,name=BytesTotal,json=bytesTotal,proto3" json:"BytesTotal,omitempty"`
PacketsDelta uint64 `protobuf:"varint,13,opt,name=PacketsDelta,json=packetsDelta,proto3" json:"PacketsDelta,omitempty"`
BytesDelta uint64 `protobuf:"varint,14,opt,name=BytesDelta,json=bytesDelta,proto3" json:"BytesDelta,omitempty"`
ReversePacketsTotal uint64 `protobuf:"varint,15,opt,name=ReversePacketsTotal,json=reversePacketsTotal,proto3" json:"ReversePacketsTotal,omitempty"`
ReverseBytesTotal uint64 `protobuf:"varint,16,opt,name=ReverseBytesTotal,json=reverseBytesTotal,proto3" json:"ReverseBytesTotal,omitempty"`
ReversePacketsDelta uint64 `protobuf:"varint,17,opt,name=ReversePacketsDelta,json=reversePacketsDelta,proto3" json:"ReversePacketsDelta,omitempty"`
ReverseBytesDelta uint64 `protobuf:"varint,18,opt,name=ReverseBytesDelta,json=reverseBytesDelta,proto3" json:"ReverseBytesDelta,omitempty"`
// Kubernetes metadata
SrcPodName string `protobuf:"bytes,19,opt,name=SrcPodName,json=srcPodName,proto3" json:"SrcPodName,omitempty"`
SrcPodNamespace string `protobuf:"bytes,20,opt,name=SrcPodNamespace,json=srcPodNamespace,proto3" json:"SrcPodNamespace,omitempty"`
SrcNodeName string `protobuf:"bytes,21,opt,name=SrcNodeName,json=srcNodeName,proto3" json:"SrcNodeName,omitempty"`
DstPodName string `protobuf:"bytes,22,opt,name=DstPodName,json=dstPodName,proto3" json:"DstPodName,omitempty"`
DstPodNamespace string `protobuf:"bytes,23,opt,name=DstPodNamespace,json=dstPodNamespace,proto3" json:"DstPodNamespace,omitempty"`
DstNodeName string `protobuf:"bytes,24,opt,name=DstNodeName,json=dstNodeName,proto3" json:"DstNodeName,omitempty"`
DstClusterIP string `protobuf:"bytes,25,opt,name=DstClusterIP,json=dstClusterIP,proto3" json:"DstClusterIP,omitempty"`
DstServicePort uint32 `protobuf:"varint,34,opt,name=DstServicePort,json=dstServicePort,proto3" json:"DstServicePort,omitempty"`
DstServicePortName string `protobuf:"bytes,26,opt,name=DstServicePortName,json=dstServicePortName,proto3" json:"DstServicePortName,omitempty"`
IngressPolicyName string `protobuf:"bytes,29,opt,name=IngressPolicyName,json=ingressPolicyName,proto3" json:"IngressPolicyName,omitempty"`
IngressPolicyNamespace string `` /* 126-byte string literal not displayed */
EgressPolicyName string `protobuf:"bytes,31,opt,name=EgressPolicyName,json=egressPolicyName,proto3" json:"EgressPolicyName,omitempty"`
EgressPolicyNamespace string `protobuf:"bytes,32,opt,name=EgressPolicyNamespace,json=egressPolicyNamespace,proto3" json:"EgressPolicyNamespace,omitempty"`
// contains filtered or unexported fields
}
Antrea proto schema is compatible with go-ipfix Kafka consumer.
func (*AntreaFlowMsg) Descriptor
deprecated
func (*AntreaFlowMsg) Descriptor() ([]byte, []int)
Deprecated: Use AntreaFlowMsg.ProtoReflect.Descriptor instead.
func (*AntreaFlowMsg) GetBytesDelta ¶
func (x *AntreaFlowMsg) GetBytesDelta() uint64
func (*AntreaFlowMsg) GetBytesTotal ¶
func (x *AntreaFlowMsg) GetBytesTotal() uint64
func (*AntreaFlowMsg) GetDstClusterIP ¶
func (x *AntreaFlowMsg) GetDstClusterIP() string
func (*AntreaFlowMsg) GetDstIP ¶
func (x *AntreaFlowMsg) GetDstIP() string
func (*AntreaFlowMsg) GetDstNodeName ¶
func (x *AntreaFlowMsg) GetDstNodeName() string
func (*AntreaFlowMsg) GetDstPodName ¶
func (x *AntreaFlowMsg) GetDstPodName() string
func (*AntreaFlowMsg) GetDstPodNamespace ¶
func (x *AntreaFlowMsg) GetDstPodNamespace() string
func (*AntreaFlowMsg) GetDstPort ¶
func (x *AntreaFlowMsg) GetDstPort() uint32
func (*AntreaFlowMsg) GetDstServicePort ¶
func (x *AntreaFlowMsg) GetDstServicePort() uint32
func (*AntreaFlowMsg) GetDstServicePortName ¶
func (x *AntreaFlowMsg) GetDstServicePortName() string
func (*AntreaFlowMsg) GetEgressPolicyName ¶
func (x *AntreaFlowMsg) GetEgressPolicyName() string
func (*AntreaFlowMsg) GetEgressPolicyNamespace ¶
func (x *AntreaFlowMsg) GetEgressPolicyNamespace() string
func (*AntreaFlowMsg) GetExportAddress ¶
func (x *AntreaFlowMsg) GetExportAddress() string
func (*AntreaFlowMsg) GetIngressPolicyName ¶
func (x *AntreaFlowMsg) GetIngressPolicyName() string
func (*AntreaFlowMsg) GetIngressPolicyNamespace ¶
func (x *AntreaFlowMsg) GetIngressPolicyNamespace() string
func (*AntreaFlowMsg) GetObsDomainID ¶
func (x *AntreaFlowMsg) GetObsDomainID() uint32
func (*AntreaFlowMsg) GetPacketsDelta ¶
func (x *AntreaFlowMsg) GetPacketsDelta() uint64
func (*AntreaFlowMsg) GetPacketsTotal ¶
func (x *AntreaFlowMsg) GetPacketsTotal() uint64
func (*AntreaFlowMsg) GetProto ¶
func (x *AntreaFlowMsg) GetProto() uint32
func (*AntreaFlowMsg) GetReverseBytesDelta ¶
func (x *AntreaFlowMsg) GetReverseBytesDelta() uint64
func (*AntreaFlowMsg) GetReverseBytesTotal ¶
func (x *AntreaFlowMsg) GetReverseBytesTotal() uint64
func (*AntreaFlowMsg) GetReversePacketsDelta ¶
func (x *AntreaFlowMsg) GetReversePacketsDelta() uint64
func (*AntreaFlowMsg) GetReversePacketsTotal ¶
func (x *AntreaFlowMsg) GetReversePacketsTotal() uint64
func (*AntreaFlowMsg) GetSequenceNumber ¶
func (x *AntreaFlowMsg) GetSequenceNumber() uint32
func (*AntreaFlowMsg) GetSrcIP ¶
func (x *AntreaFlowMsg) GetSrcIP() string
func (*AntreaFlowMsg) GetSrcNodeName ¶
func (x *AntreaFlowMsg) GetSrcNodeName() string
func (*AntreaFlowMsg) GetSrcPodName ¶
func (x *AntreaFlowMsg) GetSrcPodName() string
func (*AntreaFlowMsg) GetSrcPodNamespace ¶
func (x *AntreaFlowMsg) GetSrcPodNamespace() string
func (*AntreaFlowMsg) GetSrcPort ¶
func (x *AntreaFlowMsg) GetSrcPort() uint32
func (*AntreaFlowMsg) GetTimeFlowEndInMilliSecs ¶
func (x *AntreaFlowMsg) GetTimeFlowEndInMilliSecs() uint32
func (*AntreaFlowMsg) GetTimeFlowEndInSecs ¶
func (x *AntreaFlowMsg) GetTimeFlowEndInSecs() uint32
func (*AntreaFlowMsg) GetTimeFlowStartInMilliSecs ¶
func (x *AntreaFlowMsg) GetTimeFlowStartInMilliSecs() uint64
func (*AntreaFlowMsg) GetTimeFlowStartInSecs ¶
func (x *AntreaFlowMsg) GetTimeFlowStartInSecs() uint32
func (*AntreaFlowMsg) GetTimeReceived ¶
func (x *AntreaFlowMsg) GetTimeReceived() uint32
func (*AntreaFlowMsg) ProtoMessage ¶
func (*AntreaFlowMsg) ProtoMessage()
func (*AntreaFlowMsg) ProtoReflect ¶
func (x *AntreaFlowMsg) ProtoReflect() protoreflect.Message
func (*AntreaFlowMsg) Reset ¶
func (x *AntreaFlowMsg) Reset()
func (*AntreaFlowMsg) String ¶
func (x *AntreaFlowMsg) String() string
Click to show internal directories.
Click to hide internal directories.