flowpb

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Oct 8, 2022 License: BSD-3-Clause Imports: 4 Imported by: 9

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	FlowMessage_FlowType_name = map[int32]string{
		0: "FLOWUNKNOWN",
		1: "SFLOW_5",
		2: "NETFLOW_V5",
		3: "NETFLOW_V9",
		4: "IPFIX",
	}
	FlowMessage_FlowType_value = map[string]int32{
		"FLOWUNKNOWN": 0,
		"SFLOW_5":     1,
		"NETFLOW_V5":  2,
		"NETFLOW_V9":  3,
		"IPFIX":       4,
	}
)

Enum value maps for FlowMessage_FlowType.

View Source 
var File_pb_flow_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type FlowMessage 

type FlowMessage struct {
	Type          FlowMessage_FlowType `protobuf:"varint,1,opt,name=Type,proto3,enum=flowpb.FlowMessage_FlowType" json:"Type,omitempty"`
	TimeReceived  uint64               `protobuf:"varint,2,opt,name=TimeReceived,proto3" json:"TimeReceived,omitempty"`
	SequenceNum   uint32               `protobuf:"varint,4,opt,name=SequenceNum,proto3" json:"SequenceNum,omitempty"`
	SamplingRate  uint64               `protobuf:"varint,3,opt,name=SamplingRate,proto3" json:"SamplingRate,omitempty"`
	FlowDirection uint32               `protobuf:"varint,42,opt,name=FlowDirection,proto3" json:"FlowDirection,omitempty"`
	// Sampler information
	SamplerAddress []byte `protobuf:"bytes,11,opt,name=SamplerAddress,proto3" json:"SamplerAddress,omitempty"`
	// Found inside packet
	TimeFlowStart   uint64 `protobuf:"varint,38,opt,name=TimeFlowStart,proto3" json:"TimeFlowStart,omitempty"`
	TimeFlowEnd     uint64 `protobuf:"varint,5,opt,name=TimeFlowEnd,proto3" json:"TimeFlowEnd,omitempty"`
	TimeFlowStartMs uint64 `protobuf:"varint,63,opt,name=TimeFlowStartMs,proto3" json:"TimeFlowStartMs,omitempty"`
	TimeFlowEndMs   uint64 `protobuf:"varint,64,opt,name=TimeFlowEndMs,proto3" json:"TimeFlowEndMs,omitempty"`
	// Size of the sampled packet
	Bytes   uint64 `protobuf:"varint,9,opt,name=Bytes,proto3" json:"Bytes,omitempty"`
	Packets uint64 `protobuf:"varint,10,opt,name=Packets,proto3" json:"Packets,omitempty"`
	// Source/destination addresses
	SrcAddr []byte `protobuf:"bytes,6,opt,name=SrcAddr,proto3" json:"SrcAddr,omitempty"`
	DstAddr []byte `protobuf:"bytes,7,opt,name=DstAddr,proto3" json:"DstAddr,omitempty"`
	// Layer 3 protocol (IPv4/IPv6/ARP/MPLS...)
	Etype uint32 `protobuf:"varint,30,opt,name=Etype,proto3" json:"Etype,omitempty"`
	// Layer 4 protocol
	Proto uint32 `protobuf:"varint,20,opt,name=Proto,proto3" json:"Proto,omitempty"`
	// Ports for UDP and TCP
	SrcPort uint32 `protobuf:"varint,21,opt,name=SrcPort,proto3" json:"SrcPort,omitempty"`
	DstPort uint32 `protobuf:"varint,22,opt,name=DstPort,proto3" json:"DstPort,omitempty"`
	// Interfaces
	InIf  uint32 `protobuf:"varint,18,opt,name=InIf,proto3" json:"InIf,omitempty"`
	OutIf uint32 `protobuf:"varint,19,opt,name=OutIf,proto3" json:"OutIf,omitempty"`
	// Ethernet information
	SrcMac uint64 `protobuf:"varint,27,opt,name=SrcMac,proto3" json:"SrcMac,omitempty"`
	DstMac uint64 `protobuf:"varint,28,opt,name=DstMac,proto3" json:"DstMac,omitempty"`
	// Vlan
	SrcVlan uint32 `protobuf:"varint,33,opt,name=SrcVlan,proto3" json:"SrcVlan,omitempty"`
	DstVlan uint32 `protobuf:"varint,34,opt,name=DstVlan,proto3" json:"DstVlan,omitempty"`
	// 802.1q VLAN in sampled packet
	VlanId uint32 `protobuf:"varint,29,opt,name=VlanId,proto3" json:"VlanId,omitempty"`
	// VRF
	IngressVrfID uint32 `protobuf:"varint,39,opt,name=IngressVrfID,proto3" json:"IngressVrfID,omitempty"`
	EgressVrfID  uint32 `protobuf:"varint,40,opt,name=EgressVrfID,proto3" json:"EgressVrfID,omitempty"`
	// IP and TCP special flags
	IPTos            uint32 `protobuf:"varint,23,opt,name=IPTos,proto3" json:"IPTos,omitempty"`
	ForwardingStatus uint32 `protobuf:"varint,24,opt,name=ForwardingStatus,proto3" json:"ForwardingStatus,omitempty"`
	IPTTL            uint32 `protobuf:"varint,25,opt,name=IPTTL,proto3" json:"IPTTL,omitempty"`
	TCPFlags         uint32 `protobuf:"varint,26,opt,name=TCPFlags,proto3" json:"TCPFlags,omitempty"`
	IcmpType         uint32 `protobuf:"varint,31,opt,name=IcmpType,proto3" json:"IcmpType,omitempty"`
	IcmpCode         uint32 `protobuf:"varint,32,opt,name=IcmpCode,proto3" json:"IcmpCode,omitempty"`
	IPv6FlowLabel    uint32 `protobuf:"varint,37,opt,name=IPv6FlowLabel,proto3" json:"IPv6FlowLabel,omitempty"`
	// Fragments (IPv4/IPv6)
	FragmentId      uint32 `protobuf:"varint,35,opt,name=FragmentId,proto3" json:"FragmentId,omitempty"`
	FragmentOffset  uint32 `protobuf:"varint,36,opt,name=FragmentOffset,proto3" json:"FragmentOffset,omitempty"`
	BiFlowDirection uint32 `protobuf:"varint,41,opt,name=BiFlowDirection,proto3" json:"BiFlowDirection,omitempty"`
	// Autonomous system information
	SrcAS     uint32 `protobuf:"varint,14,opt,name=SrcAS,proto3" json:"SrcAS,omitempty"`
	DstAS     uint32 `protobuf:"varint,15,opt,name=DstAS,proto3" json:"DstAS,omitempty"`
	NextHop   []byte `protobuf:"bytes,12,opt,name=NextHop,proto3" json:"NextHop,omitempty"`
	NextHopAS uint32 `protobuf:"varint,13,opt,name=NextHopAS,proto3" json:"NextHopAS,omitempty"`
	// Prefix size
	SrcNet uint32 `protobuf:"varint,16,opt,name=SrcNet,proto3" json:"SrcNet,omitempty"`
	DstNet uint32 `protobuf:"varint,17,opt,name=DstNet,proto3" json:"DstNet,omitempty"`
	// BGP information
	BgpNextHop     []byte   `protobuf:"bytes,100,opt,name=BgpNextHop,proto3" json:"BgpNextHop,omitempty"`
	BgpCommunities []uint32 `protobuf:"varint,101,rep,packed,name=BgpCommunities,proto3" json:"BgpCommunities,omitempty"`
	AsPath         []uint32 `protobuf:"varint,102,rep,packed,name=AsPath,proto3" json:"AsPath,omitempty"`
	// MPLS information
	HasMPLS             bool   `protobuf:"varint,53,opt,name=HasMPLS,proto3" json:"HasMPLS,omitempty"`
	MPLSCount           uint32 `protobuf:"varint,54,opt,name=MPLSCount,proto3" json:"MPLSCount,omitempty"`
	MPLS1TTL            uint32 `protobuf:"varint,55,opt,name=MPLS1TTL,proto3" json:"MPLS1TTL,omitempty"`           // First TTL
	MPLS1Label          uint32 `protobuf:"varint,56,opt,name=MPLS1Label,proto3" json:"MPLS1Label,omitempty"`       // First Label
	MPLS2TTL            uint32 `protobuf:"varint,57,opt,name=MPLS2TTL,proto3" json:"MPLS2TTL,omitempty"`           // Second TTL
	MPLS2Label          uint32 `protobuf:"varint,58,opt,name=MPLS2Label,proto3" json:"MPLS2Label,omitempty"`       // Second Label
	MPLS3TTL            uint32 `protobuf:"varint,59,opt,name=MPLS3TTL,proto3" json:"MPLS3TTL,omitempty"`           // Third TTL
	MPLS3Label          uint32 `protobuf:"varint,60,opt,name=MPLS3Label,proto3" json:"MPLS3Label,omitempty"`       // Third Label
	MPLSLastTTL         uint32 `protobuf:"varint,61,opt,name=MPLSLastTTL,proto3" json:"MPLSLastTTL,omitempty"`     // Last TTL
	MPLSLastLabel       uint32 `protobuf:"varint,62,opt,name=MPLSLastLabel,proto3" json:"MPLSLastLabel,omitempty"` // Last Label
	MPLSLabelIP         []byte `protobuf:"bytes,65,opt,name=MPLSLabelIP,proto3" json:"MPLSLabelIP,omitempty"`      // MPLS TOP Label IP
	ObservationDomainID uint32 `protobuf:"varint,70,opt,name=ObservationDomainID,proto3" json:"ObservationDomainID,omitempty"`
	ObservationPointID  uint32 `protobuf:"varint,71,opt,name=ObservationPointID,proto3" json:"ObservationPointID,omitempty"`
	// Custom allocations
	CustomInteger1 uint64 `protobuf:"varint,1001,opt,name=CustomInteger1,proto3" json:"CustomInteger1,omitempty"`
	CustomInteger2 uint64 `protobuf:"varint,1002,opt,name=CustomInteger2,proto3" json:"CustomInteger2,omitempty"`
	CustomInteger3 uint64 `protobuf:"varint,1003,opt,name=CustomInteger3,proto3" json:"CustomInteger3,omitempty"`
	CustomInteger4 uint64 `protobuf:"varint,1004,opt,name=CustomInteger4,proto3" json:"CustomInteger4,omitempty"`
	CustomInteger5 uint64 `protobuf:"varint,1005,opt,name=CustomInteger5,proto3" json:"CustomInteger5,omitempty"`
	CustomBytes1   []byte `protobuf:"bytes,1011,opt,name=CustomBytes1,proto3" json:"CustomBytes1,omitempty"`
	CustomBytes2   []byte `protobuf:"bytes,1012,opt,name=CustomBytes2,proto3" json:"CustomBytes2,omitempty"`
	CustomBytes3   []byte `protobuf:"bytes,1013,opt,name=CustomBytes3,proto3" json:"CustomBytes3,omitempty"`
	CustomBytes4   []byte `protobuf:"bytes,1014,opt,name=CustomBytes4,proto3" json:"CustomBytes4,omitempty"`
	CustomBytes5   []byte `protobuf:"bytes,1015,opt,name=CustomBytes5,proto3" json:"CustomBytes5,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowMessage) Descriptor deprecated 

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

Deprecated: Use FlowMessage.ProtoReflect.Descriptor instead.

func (*FlowMessage) GetAsPath added in v1.1.1 

func (x *FlowMessage) GetAsPath() []uint32

func (*FlowMessage) GetBgpCommunities added in v1.1.1 

func (x *FlowMessage) GetBgpCommunities() []uint32

func (*FlowMessage) GetBgpNextHop added in v1.1.1 

func (x *FlowMessage) GetBgpNextHop() []byte

func (*FlowMessage) GetBiFlowDirection 

func (x *FlowMessage) GetBiFlowDirection() uint32

func (*FlowMessage) GetBytes 

func (x *FlowMessage) GetBytes() uint64

func (*FlowMessage) GetCustomBytes1 

func (x *FlowMessage) GetCustomBytes1() []byte

func (*FlowMessage) GetCustomBytes2 

func (x *FlowMessage) GetCustomBytes2() []byte

func (*FlowMessage) GetCustomBytes3 added in v1.1.1 

func (x *FlowMessage) GetCustomBytes3() []byte

func (*FlowMessage) GetCustomBytes4 added in v1.1.1 

func (x *FlowMessage) GetCustomBytes4() []byte

func (*FlowMessage) GetCustomBytes5 added in v1.1.1 

func (x *FlowMessage) GetCustomBytes5() []byte

func (*FlowMessage) GetCustomInteger1 

func (x *FlowMessage) GetCustomInteger1() uint64

func (*FlowMessage) GetCustomInteger2 

func (x *FlowMessage) GetCustomInteger2() uint64

func (*FlowMessage) GetCustomInteger3 added in v1.1.1 

func (x *FlowMessage) GetCustomInteger3() uint64

func (*FlowMessage) GetCustomInteger4 added in v1.1.1 

func (x *FlowMessage) GetCustomInteger4() uint64

func (*FlowMessage) GetCustomInteger5 added in v1.1.1 

func (x *FlowMessage) GetCustomInteger5() uint64

func (*FlowMessage) GetDstAS 

func (x *FlowMessage) GetDstAS() uint32

func (*FlowMessage) GetDstAddr 

func (x *FlowMessage) GetDstAddr() []byte

func (*FlowMessage) GetDstMac 

func (x *FlowMessage) GetDstMac() uint64

func (*FlowMessage) GetDstNet 

func (x *FlowMessage) GetDstNet() uint32

func (*FlowMessage) GetDstPort 

func (x *FlowMessage) GetDstPort() uint32

func (*FlowMessage) GetDstVlan 

func (x *FlowMessage) GetDstVlan() uint32

func (*FlowMessage) GetEgressVrfID 

func (x *FlowMessage) GetEgressVrfID() uint32

func (*FlowMessage) GetEtype 

func (x *FlowMessage) GetEtype() uint32

func (*FlowMessage) GetFlowDirection 

func (x *FlowMessage) GetFlowDirection() uint32

func (*FlowMessage) GetForwardingStatus 

func (x *FlowMessage) GetForwardingStatus() uint32

func (*FlowMessage) GetFragmentId 

func (x *FlowMessage) GetFragmentId() uint32

func (*FlowMessage) GetFragmentOffset 

func (x *FlowMessage) GetFragmentOffset() uint32

func (*FlowMessage) GetHasMPLS 

func (x *FlowMessage) GetHasMPLS() bool

func (*FlowMessage) GetIPTTL 

func (x *FlowMessage) GetIPTTL() uint32

func (*FlowMessage) GetIPTos 

func (x *FlowMessage) GetIPTos() uint32

func (*FlowMessage) GetIPv6FlowLabel 

func (x *FlowMessage) GetIPv6FlowLabel() uint32

func (*FlowMessage) GetIcmpCode 

func (x *FlowMessage) GetIcmpCode() uint32

func (*FlowMessage) GetIcmpType 

func (x *FlowMessage) GetIcmpType() uint32

func (*FlowMessage) GetInIf 

func (x *FlowMessage) GetInIf() uint32

func (*FlowMessage) GetIngressVrfID 

func (x *FlowMessage) GetIngressVrfID() uint32

func (*FlowMessage) GetMPLS1Label 

func (x *FlowMessage) GetMPLS1Label() uint32

func (*FlowMessage) GetMPLS1TTL 

func (x *FlowMessage) GetMPLS1TTL() uint32

func (*FlowMessage) GetMPLS2Label 

func (x *FlowMessage) GetMPLS2Label() uint32

func (*FlowMessage) GetMPLS2TTL 

func (x *FlowMessage) GetMPLS2TTL() uint32

func (*FlowMessage) GetMPLS3Label 

func (x *FlowMessage) GetMPLS3Label() uint32

func (*FlowMessage) GetMPLS3TTL 

func (x *FlowMessage) GetMPLS3TTL() uint32

func (*FlowMessage) GetMPLSCount 

func (x *FlowMessage) GetMPLSCount() uint32

func (*FlowMessage) GetMPLSLabelIP added in v1.1.1 

func (x *FlowMessage) GetMPLSLabelIP() []byte

func (*FlowMessage) GetMPLSLastLabel 

func (x *FlowMessage) GetMPLSLastLabel() uint32

func (*FlowMessage) GetMPLSLastTTL 

func (x *FlowMessage) GetMPLSLastTTL() uint32

func (*FlowMessage) GetNextHop 

func (x *FlowMessage) GetNextHop() []byte

func (*FlowMessage) GetNextHopAS 

func (x *FlowMessage) GetNextHopAS() uint32

func (*FlowMessage) GetObservationDomainID added in v1.1.1 

func (x *FlowMessage) GetObservationDomainID() uint32

func (*FlowMessage) GetObservationPointID added in v1.1.1 

func (x *FlowMessage) GetObservationPointID() uint32

func (*FlowMessage) GetOutIf 

func (x *FlowMessage) GetOutIf() uint32

func (*FlowMessage) GetPackets 

func (x *FlowMessage) GetPackets() uint64

func (*FlowMessage) GetProto 

func (x *FlowMessage) GetProto() uint32

func (*FlowMessage) GetSamplerAddress 

func (x *FlowMessage) GetSamplerAddress() []byte

func (*FlowMessage) GetSamplingRate 

func (x *FlowMessage) GetSamplingRate() uint64

func (*FlowMessage) GetSequenceNum 

func (x *FlowMessage) GetSequenceNum() uint32

func (*FlowMessage) GetSrcAS 

func (x *FlowMessage) GetSrcAS() uint32

func (*FlowMessage) GetSrcAddr 

func (x *FlowMessage) GetSrcAddr() []byte

func (*FlowMessage) GetSrcMac 

func (x *FlowMessage) GetSrcMac() uint64

func (*FlowMessage) GetSrcNet 

func (x *FlowMessage) GetSrcNet() uint32

func (*FlowMessage) GetSrcPort 

func (x *FlowMessage) GetSrcPort() uint32

func (*FlowMessage) GetSrcVlan 

func (x *FlowMessage) GetSrcVlan() uint32

func (*FlowMessage) GetTCPFlags 

func (x *FlowMessage) GetTCPFlags() uint32

func (*FlowMessage) GetTimeFlowEnd 

func (x *FlowMessage) GetTimeFlowEnd() uint64

func (*FlowMessage) GetTimeFlowEndMs added in v1.1.1 

func (x *FlowMessage) GetTimeFlowEndMs() uint64

func (*FlowMessage) GetTimeFlowStart 

func (x *FlowMessage) GetTimeFlowStart() uint64

func (*FlowMessage) GetTimeFlowStartMs added in v1.1.1 

func (x *FlowMessage) GetTimeFlowStartMs() uint64

func (*FlowMessage) GetTimeReceived 

func (x *FlowMessage) GetTimeReceived() uint64

func (*FlowMessage) GetType 

func (x *FlowMessage) GetType() FlowMessage_FlowType

func (*FlowMessage) GetVlanId 

func (x *FlowMessage) GetVlanId() uint32

func (*FlowMessage) ProtoMessage 

func (*FlowMessage) ProtoMessage()

func (*FlowMessage) ProtoReflect 

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

func (*FlowMessage) Reset 

func (x *FlowMessage) Reset()

func (*FlowMessage) String 

func (x *FlowMessage) String() string

type FlowMessage_FlowType 

type FlowMessage_FlowType int32
const (
	FlowMessage_FLOWUNKNOWN FlowMessage_FlowType = 0
	FlowMessage_SFLOW_5     FlowMessage_FlowType = 1
	FlowMessage_NETFLOW_V5  FlowMessage_FlowType = 2
	FlowMessage_NETFLOW_V9  FlowMessage_FlowType = 3
	FlowMessage_IPFIX       FlowMessage_FlowType = 4
)

func (FlowMessage_FlowType) Descriptor 

func (FlowMessage_FlowType) Descriptor() protoreflect.EnumDescriptor

func (FlowMessage_FlowType) Enum 

func (x FlowMessage_FlowType) Enum() *FlowMessage_FlowType

func (FlowMessage_FlowType) EnumDescriptor deprecated 

func (FlowMessage_FlowType) EnumDescriptor() ([]byte, []int)

Deprecated: Use FlowMessage_FlowType.Descriptor instead.

func (FlowMessage_FlowType) Number 

func (x FlowMessage_FlowType) Number() protoreflect.EnumNumber

func (FlowMessage_FlowType) String 

func (x FlowMessage_FlowType) String() string

func (FlowMessage_FlowType) Type 

func (FlowMessage_FlowType) Type() protoreflect.EnumType

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.