protobuf

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 15, 2024 License: Apache-2.0 Imports: 4 Imported by: 1

Documentation

Index

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.