protobuf

package
v0.5.11 Latest Latest
Warning

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

 Go to latest Published: Dec 10, 2021 License: Apache-2.0 Imports: 4 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_kafka_producer_protobuf_flow_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type FlowType1 

type FlowType1 struct {

	// Header of IPFIX Message.
	TimeReceived   uint32 `protobuf:"varint,1,opt,name=TimeReceived,proto3" json:"TimeReceived,omitempty"`
	SequenceNumber uint32 `protobuf:"varint,2,opt,name=SequenceNumber,proto3" json:"SequenceNumber,omitempty"`
	ObsDomainID    uint32 `protobuf:"varint,3,opt,name=ObsDomainID,proto3" json:"ObsDomainID,omitempty"`
	ExportAddress  string `protobuf:"bytes,33,opt,name=ExportAddress,proto3" json:"ExportAddress,omitempty"`
	// Fields of flow record.
	TimeFlowStartInSecs      uint32 `protobuf:"varint,4,opt,name=TimeFlowStartInSecs,proto3" json:"TimeFlowStartInSecs,omitempty"`
	TimeFlowEndInSecs        uint32 `protobuf:"varint,5,opt,name=TimeFlowEndInSecs,proto3" json:"TimeFlowEndInSecs,omitempty"`
	TimeFlowStartInMilliSecs uint64 `protobuf:"varint,27,opt,name=TimeFlowStartInMilliSecs,proto3" json:"TimeFlowStartInMilliSecs,omitempty"`
	TimeFlowEndInMilliSecs   uint32 `protobuf:"varint,28,opt,name=TimeFlowEndInMilliSecs,proto3" json:"TimeFlowEndInMilliSecs,omitempty"`
	// 5-tuple of flows
	SrcIP   string `protobuf:"bytes,6,opt,name=SrcIP,proto3" json:"SrcIP,omitempty"`
	DstIP   string `protobuf:"bytes,7,opt,name=DstIP,proto3" json:"DstIP,omitempty"`
	SrcPort uint32 `protobuf:"varint,8,opt,name=SrcPort,proto3" json:"SrcPort,omitempty"`
	DstPort uint32 `protobuf:"varint,9,opt,name=DstPort,proto3" json:"DstPort,omitempty"`
	Proto   uint32 `protobuf:"varint,10,opt,name=Proto,proto3" json:"Proto,omitempty"`
	// Statistics of flow in original and reverse directions.
	PacketsTotal        uint64 `protobuf:"varint,11,opt,name=PacketsTotal,proto3" json:"PacketsTotal,omitempty"`
	BytesTotal          uint64 `protobuf:"varint,12,opt,name=BytesTotal,proto3" json:"BytesTotal,omitempty"`
	PacketsDelta        uint64 `protobuf:"varint,13,opt,name=PacketsDelta,proto3" json:"PacketsDelta,omitempty"`
	BytesDelta          uint64 `protobuf:"varint,14,opt,name=BytesDelta,proto3" json:"BytesDelta,omitempty"`
	ReversePacketsTotal uint64 `protobuf:"varint,15,opt,name=ReversePacketsTotal,proto3" json:"ReversePacketsTotal,omitempty"`
	ReverseBytesTotal   uint64 `protobuf:"varint,16,opt,name=ReverseBytesTotal,proto3" json:"ReverseBytesTotal,omitempty"`
	ReversePacketsDelta uint64 `protobuf:"varint,17,opt,name=ReversePacketsDelta,proto3" json:"ReversePacketsDelta,omitempty"`
	ReverseBytesDelta   uint64 `protobuf:"varint,18,opt,name=ReverseBytesDelta,proto3" json:"ReverseBytesDelta,omitempty"`
	// Kubernetes metadata
	SrcPodName             string `protobuf:"bytes,19,opt,name=SrcPodName,proto3" json:"SrcPodName,omitempty"`
	SrcPodNamespace        string `protobuf:"bytes,20,opt,name=SrcPodNamespace,proto3" json:"SrcPodNamespace,omitempty"`
	SrcNodeName            string `protobuf:"bytes,21,opt,name=SrcNodeName,proto3" json:"SrcNodeName,omitempty"`
	DstPodName             string `protobuf:"bytes,22,opt,name=DstPodName,proto3" json:"DstPodName,omitempty"`
	DstPodNamespace        string `protobuf:"bytes,23,opt,name=DstPodNamespace,proto3" json:"DstPodNamespace,omitempty"`
	DstNodeName            string `protobuf:"bytes,24,opt,name=DstNodeName,proto3" json:"DstNodeName,omitempty"`
	DstClusterIP           string `protobuf:"bytes,25,opt,name=DstClusterIP,proto3" json:"DstClusterIP,omitempty"`
	DstServicePort         uint32 `protobuf:"varint,34,opt,name=DstServicePort,proto3" json:"DstServicePort,omitempty"`
	DstServicePortName     string `protobuf:"bytes,26,opt,name=DstServicePortName,proto3" json:"DstServicePortName,omitempty"`
	IngressPolicyName      string `protobuf:"bytes,29,opt,name=IngressPolicyName,proto3" json:"IngressPolicyName,omitempty"`
	IngressPolicyNamespace string `protobuf:"bytes,30,opt,name=IngressPolicyNamespace,proto3" json:"IngressPolicyNamespace,omitempty"`
	EgressPolicyName       string `protobuf:"bytes,31,opt,name=EgressPolicyName,proto3" json:"EgressPolicyName,omitempty"`
	EgressPolicyNamespace  string `protobuf:"bytes,32,opt,name=EgressPolicyNamespace,proto3" json:"EgressPolicyNamespace,omitempty"`
	// contains filtered or unexported fields
}

FlowType1 and FlowType2 are two different proto schemas with same fields. Used two different proto schemas to demonstrate that the producer can be built in a flexible manner and can support multiple proto schemas.

func (*FlowType1) Descriptor deprecated 

func (*FlowType1) Descriptor() ([]byte, []int)

Deprecated: Use FlowType1.ProtoReflect.Descriptor instead.

func (*FlowType1) GetBytesDelta 

func (x *FlowType1) GetBytesDelta() uint64

func (*FlowType1) GetBytesTotal 

func (x *FlowType1) GetBytesTotal() uint64

func (*FlowType1) GetDstClusterIP 

func (x *FlowType1) GetDstClusterIP() string

func (*FlowType1) GetDstIP 

func (x *FlowType1) GetDstIP() string

func (*FlowType1) GetDstNodeName 

func (x *FlowType1) GetDstNodeName() string

func (*FlowType1) GetDstPodName 

func (x *FlowType1) GetDstPodName() string

func (*FlowType1) GetDstPodNamespace 

func (x *FlowType1) GetDstPodNamespace() string

func (*FlowType1) GetDstPort 

func (x *FlowType1) GetDstPort() uint32

func (*FlowType1) GetDstServicePort 

func (x *FlowType1) GetDstServicePort() uint32

func (*FlowType1) GetDstServicePortName 

func (x *FlowType1) GetDstServicePortName() string

func (*FlowType1) GetEgressPolicyName 

func (x *FlowType1) GetEgressPolicyName() string

func (*FlowType1) GetEgressPolicyNamespace 

func (x *FlowType1) GetEgressPolicyNamespace() string

func (*FlowType1) GetExportAddress 

func (x *FlowType1) GetExportAddress() string

func (*FlowType1) GetIngressPolicyName 

func (x *FlowType1) GetIngressPolicyName() string

func (*FlowType1) GetIngressPolicyNamespace 

func (x *FlowType1) GetIngressPolicyNamespace() string

func (*FlowType1) GetObsDomainID 

func (x *FlowType1) GetObsDomainID() uint32

func (*FlowType1) GetPacketsDelta 

func (x *FlowType1) GetPacketsDelta() uint64

func (*FlowType1) GetPacketsTotal 

func (x *FlowType1) GetPacketsTotal() uint64

func (*FlowType1) GetProto 

func (x *FlowType1) GetProto() uint32

func (*FlowType1) GetReverseBytesDelta 

func (x *FlowType1) GetReverseBytesDelta() uint64

func (*FlowType1) GetReverseBytesTotal 

func (x *FlowType1) GetReverseBytesTotal() uint64

func (*FlowType1) GetReversePacketsDelta 

func (x *FlowType1) GetReversePacketsDelta() uint64

func (*FlowType1) GetReversePacketsTotal 

func (x *FlowType1) GetReversePacketsTotal() uint64

func (*FlowType1) GetSequenceNumber 

func (x *FlowType1) GetSequenceNumber() uint32

func (*FlowType1) GetSrcIP 

func (x *FlowType1) GetSrcIP() string

func (*FlowType1) GetSrcNodeName 

func (x *FlowType1) GetSrcNodeName() string

func (*FlowType1) GetSrcPodName 

func (x *FlowType1) GetSrcPodName() string

func (*FlowType1) GetSrcPodNamespace 

func (x *FlowType1) GetSrcPodNamespace() string

func (*FlowType1) GetSrcPort 

func (x *FlowType1) GetSrcPort() uint32

func (*FlowType1) GetTimeFlowEndInMilliSecs 

func (x *FlowType1) GetTimeFlowEndInMilliSecs() uint32

func (*FlowType1) GetTimeFlowEndInSecs 

func (x *FlowType1) GetTimeFlowEndInSecs() uint32

func (*FlowType1) GetTimeFlowStartInMilliSecs 

func (x *FlowType1) GetTimeFlowStartInMilliSecs() uint64

func (*FlowType1) GetTimeFlowStartInSecs 

func (x *FlowType1) GetTimeFlowStartInSecs() uint32

func (*FlowType1) GetTimeReceived 

func (x *FlowType1) GetTimeReceived() uint32

func (*FlowType1) ProtoMessage 

func (*FlowType1) ProtoMessage()

func (*FlowType1) ProtoReflect 

func (x *FlowType1) ProtoReflect() protoreflect.Message

func (*FlowType1) Reset 

func (x *FlowType1) Reset()

func (*FlowType1) String 

func (x *FlowType1) String() string

type FlowType2 

type FlowType2 struct {

	// Header of IPFIX Message.
	TimeReceived   uint32 `protobuf:"varint,1,opt,name=TimeReceived,proto3" json:"TimeReceived,omitempty"`
	SequenceNumber uint32 `protobuf:"varint,2,opt,name=SequenceNumber,proto3" json:"SequenceNumber,omitempty"`
	ObsDomainID    uint32 `protobuf:"varint,3,opt,name=ObsDomainID,proto3" json:"ObsDomainID,omitempty"`
	ExportAddress  string `protobuf:"bytes,33,opt,name=ExportAddress,proto3" json:"ExportAddress,omitempty"`
	// Fields of flow record.
	TimeFlowStartInSecs      uint32 `protobuf:"varint,4,opt,name=TimeFlowStartInSecs,proto3" json:"TimeFlowStartInSecs,omitempty"`
	TimeFlowEndInSecs        uint32 `protobuf:"varint,5,opt,name=TimeFlowEndInSecs,proto3" json:"TimeFlowEndInSecs,omitempty"`
	TimeFlowStartInMilliSecs uint64 `protobuf:"varint,27,opt,name=TimeFlowStartInMilliSecs,proto3" json:"TimeFlowStartInMilliSecs,omitempty"`
	TimeFlowEndInMilliSecs   uint32 `protobuf:"varint,28,opt,name=TimeFlowEndInMilliSecs,proto3" json:"TimeFlowEndInMilliSecs,omitempty"`
	FlowEndReason            uint32 `protobuf:"varint,35,opt,name=FlowEndReason,proto3" json:"FlowEndReason,omitempty"`
	TcpState                 string `protobuf:"bytes,36,opt,name=TcpState,proto3" json:"TcpState,omitempty"`
	// 5-tuple of flows
	SrcIP   string `protobuf:"bytes,6,opt,name=SrcIP,proto3" json:"SrcIP,omitempty"`
	DstIP   string `protobuf:"bytes,7,opt,name=DstIP,proto3" json:"DstIP,omitempty"`
	SrcPort uint32 `protobuf:"varint,8,opt,name=SrcPort,proto3" json:"SrcPort,omitempty"`
	DstPort uint32 `protobuf:"varint,9,opt,name=DstPort,proto3" json:"DstPort,omitempty"`
	Proto   uint32 `protobuf:"varint,10,opt,name=Proto,proto3" json:"Proto,omitempty"`
	// Statistics of flow in original and reverse directions.
	PacketsTotal        uint64 `protobuf:"varint,11,opt,name=PacketsTotal,proto3" json:"PacketsTotal,omitempty"`
	BytesTotal          uint64 `protobuf:"varint,12,opt,name=BytesTotal,proto3" json:"BytesTotal,omitempty"`
	PacketsDelta        uint64 `protobuf:"varint,13,opt,name=PacketsDelta,proto3" json:"PacketsDelta,omitempty"`
	BytesDelta          uint64 `protobuf:"varint,14,opt,name=BytesDelta,proto3" json:"BytesDelta,omitempty"`
	ReversePacketsTotal uint64 `protobuf:"varint,15,opt,name=ReversePacketsTotal,proto3" json:"ReversePacketsTotal,omitempty"`
	ReverseBytesTotal   uint64 `protobuf:"varint,16,opt,name=ReverseBytesTotal,proto3" json:"ReverseBytesTotal,omitempty"`
	ReversePacketsDelta uint64 `protobuf:"varint,17,opt,name=ReversePacketsDelta,proto3" json:"ReversePacketsDelta,omitempty"`
	ReverseBytesDelta   uint64 `protobuf:"varint,18,opt,name=ReverseBytesDelta,proto3" json:"ReverseBytesDelta,omitempty"`
	// Kubernetes metadata
	SrcPodName             string `protobuf:"bytes,19,opt,name=SrcPodName,proto3" json:"SrcPodName,omitempty"`
	SrcPodNamespace        string `protobuf:"bytes,20,opt,name=SrcPodNamespace,proto3" json:"SrcPodNamespace,omitempty"`
	SrcNodeName            string `protobuf:"bytes,21,opt,name=SrcNodeName,proto3" json:"SrcNodeName,omitempty"`
	DstPodName             string `protobuf:"bytes,22,opt,name=DstPodName,proto3" json:"DstPodName,omitempty"`
	DstPodNamespace        string `protobuf:"bytes,23,opt,name=DstPodNamespace,proto3" json:"DstPodNamespace,omitempty"`
	DstNodeName            string `protobuf:"bytes,24,opt,name=DstNodeName,proto3" json:"DstNodeName,omitempty"`
	DstClusterIP           string `protobuf:"bytes,25,opt,name=DstClusterIP,proto3" json:"DstClusterIP,omitempty"`
	DstServicePort         uint32 `protobuf:"varint,34,opt,name=DstServicePort,proto3" json:"DstServicePort,omitempty"`
	DstServicePortName     string `protobuf:"bytes,26,opt,name=DstServicePortName,proto3" json:"DstServicePortName,omitempty"`
	IngressPolicyName      string `protobuf:"bytes,29,opt,name=IngressPolicyName,proto3" json:"IngressPolicyName,omitempty"`
	IngressPolicyNamespace string `protobuf:"bytes,30,opt,name=IngressPolicyNamespace,proto3" json:"IngressPolicyNamespace,omitempty"`
	EgressPolicyName       string `protobuf:"bytes,31,opt,name=EgressPolicyName,proto3" json:"EgressPolicyName,omitempty"`
	EgressPolicyNamespace  string `protobuf:"bytes,32,opt,name=EgressPolicyNamespace,proto3" json:"EgressPolicyNamespace,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowType2) Descriptor deprecated 

func (*FlowType2) Descriptor() ([]byte, []int)

Deprecated: Use FlowType2.ProtoReflect.Descriptor instead.

func (*FlowType2) GetBytesDelta 

func (x *FlowType2) GetBytesDelta() uint64

func (*FlowType2) GetBytesTotal 

func (x *FlowType2) GetBytesTotal() uint64

func (*FlowType2) GetDstClusterIP 

func (x *FlowType2) GetDstClusterIP() string

func (*FlowType2) GetDstIP 

func (x *FlowType2) GetDstIP() string

func (*FlowType2) GetDstNodeName 

func (x *FlowType2) GetDstNodeName() string

func (*FlowType2) GetDstPodName 

func (x *FlowType2) GetDstPodName() string

func (*FlowType2) GetDstPodNamespace 

func (x *FlowType2) GetDstPodNamespace() string

func (*FlowType2) GetDstPort 

func (x *FlowType2) GetDstPort() uint32

func (*FlowType2) GetDstServicePort 

func (x *FlowType2) GetDstServicePort() uint32

func (*FlowType2) GetDstServicePortName 

func (x *FlowType2) GetDstServicePortName() string

func (*FlowType2) GetEgressPolicyName 

func (x *FlowType2) GetEgressPolicyName() string

func (*FlowType2) GetEgressPolicyNamespace 

func (x *FlowType2) GetEgressPolicyNamespace() string

func (*FlowType2) GetExportAddress 

func (x *FlowType2) GetExportAddress() string

func (*FlowType2) GetFlowEndReason 

func (x *FlowType2) GetFlowEndReason() uint32

func (*FlowType2) GetIngressPolicyName 

func (x *FlowType2) GetIngressPolicyName() string

func (*FlowType2) GetIngressPolicyNamespace 

func (x *FlowType2) GetIngressPolicyNamespace() string

func (*FlowType2) GetObsDomainID 

func (x *FlowType2) GetObsDomainID() uint32

func (*FlowType2) GetPacketsDelta 

func (x *FlowType2) GetPacketsDelta() uint64

func (*FlowType2) GetPacketsTotal 

func (x *FlowType2) GetPacketsTotal() uint64

func (*FlowType2) GetProto 

func (x *FlowType2) GetProto() uint32

func (*FlowType2) GetReverseBytesDelta 

func (x *FlowType2) GetReverseBytesDelta() uint64

func (*FlowType2) GetReverseBytesTotal 

func (x *FlowType2) GetReverseBytesTotal() uint64

func (*FlowType2) GetReversePacketsDelta 

func (x *FlowType2) GetReversePacketsDelta() uint64

func (*FlowType2) GetReversePacketsTotal 

func (x *FlowType2) GetReversePacketsTotal() uint64

func (*FlowType2) GetSequenceNumber 

func (x *FlowType2) GetSequenceNumber() uint32

func (*FlowType2) GetSrcIP 

func (x *FlowType2) GetSrcIP() string

func (*FlowType2) GetSrcNodeName 

func (x *FlowType2) GetSrcNodeName() string

func (*FlowType2) GetSrcPodName 

func (x *FlowType2) GetSrcPodName() string

func (*FlowType2) GetSrcPodNamespace 

func (x *FlowType2) GetSrcPodNamespace() string

func (*FlowType2) GetSrcPort 

func (x *FlowType2) GetSrcPort() uint32

func (*FlowType2) GetTcpState 

func (x *FlowType2) GetTcpState() string

func (*FlowType2) GetTimeFlowEndInMilliSecs 

func (x *FlowType2) GetTimeFlowEndInMilliSecs() uint32

func (*FlowType2) GetTimeFlowEndInSecs 

func (x *FlowType2) GetTimeFlowEndInSecs() uint32

func (*FlowType2) GetTimeFlowStartInMilliSecs 

func (x *FlowType2) GetTimeFlowStartInMilliSecs() uint64

func (*FlowType2) GetTimeFlowStartInSecs 

func (x *FlowType2) GetTimeFlowStartInSecs() uint32

func (*FlowType2) GetTimeReceived 

func (x *FlowType2) GetTimeReceived() uint32

func (*FlowType2) ProtoMessage 

func (*FlowType2) ProtoMessage()

func (*FlowType2) ProtoReflect 

func (x *FlowType2) ProtoReflect() protoreflect.Message

func (*FlowType2) Reset 

func (x *FlowType2) Reset()

func (*FlowType2) String 

func (x *FlowType2) 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.