flowpb

package
v1.3.7 Latest Latest
Warning

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

Go to latest
Published: Dec 6, 2023 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=time_received,json=timeReceived,proto3" json:"time_received,omitempty"`
	SequenceNum   uint32               `protobuf:"varint,4,opt,name=sequence_num,json=sequenceNum,proto3" json:"sequence_num,omitempty"`
	SamplingRate  uint64               `protobuf:"varint,3,opt,name=sampling_rate,json=samplingRate,proto3" json:"sampling_rate,omitempty"`
	FlowDirection uint32               `protobuf:"varint,42,opt,name=flow_direction,json=flowDirection,proto3" json:"flow_direction,omitempty"`
	// Sampler information
	SamplerAddress []byte `protobuf:"bytes,11,opt,name=sampler_address,json=samplerAddress,proto3" json:"sampler_address,omitempty"`
	// Found inside packet
	TimeFlowStart   uint64 `protobuf:"varint,38,opt,name=time_flow_start,json=timeFlowStart,proto3" json:"time_flow_start,omitempty"`
	TimeFlowEnd     uint64 `protobuf:"varint,5,opt,name=time_flow_end,json=timeFlowEnd,proto3" json:"time_flow_end,omitempty"`
	TimeFlowStartMs uint64 `protobuf:"varint,63,opt,name=time_flow_start_ms,json=timeFlowStartMs,proto3" json:"time_flow_start_ms,omitempty"`
	TimeFlowEndMs   uint64 `protobuf:"varint,64,opt,name=time_flow_end_ms,json=timeFlowEndMs,proto3" json:"time_flow_end_ms,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=src_addr,json=srcAddr,proto3" json:"src_addr,omitempty"`
	DstAddr []byte `protobuf:"bytes,7,opt,name=dst_addr,json=dstAddr,proto3" json:"dst_addr,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=src_port,json=srcPort,proto3" json:"src_port,omitempty"`
	DstPort uint32 `protobuf:"varint,22,opt,name=dst_port,json=dstPort,proto3" json:"dst_port,omitempty"`
	// Interfaces
	InIf  uint32 `protobuf:"varint,18,opt,name=in_if,json=inIf,proto3" json:"in_if,omitempty"`
	OutIf uint32 `protobuf:"varint,19,opt,name=out_if,json=outIf,proto3" json:"out_if,omitempty"`
	// Ethernet information
	SrcMac uint64 `protobuf:"varint,27,opt,name=src_mac,json=srcMac,proto3" json:"src_mac,omitempty"`
	DstMac uint64 `protobuf:"varint,28,opt,name=dst_mac,json=dstMac,proto3" json:"dst_mac,omitempty"`
	// Vlan
	SrcVlan uint32 `protobuf:"varint,33,opt,name=src_vlan,json=srcVlan,proto3" json:"src_vlan,omitempty"`
	DstVlan uint32 `protobuf:"varint,34,opt,name=dst_vlan,json=dstVlan,proto3" json:"dst_vlan,omitempty"`
	// 802.1q VLAN in sampled packet
	VlanId uint32 `protobuf:"varint,29,opt,name=vlan_id,json=vlanId,proto3" json:"vlan_id,omitempty"`
	// VRF
	IngressVrfId uint32 `protobuf:"varint,39,opt,name=ingress_vrf_id,json=ingressVrfId,proto3" json:"ingress_vrf_id,omitempty"`
	EgressVrfId  uint32 `protobuf:"varint,40,opt,name=egress_vrf_id,json=egressVrfId,proto3" json:"egress_vrf_id,omitempty"`
	// IP and TCP special flags
	IpTos            uint32 `protobuf:"varint,23,opt,name=ip_tos,json=ipTos,proto3" json:"ip_tos,omitempty"`
	ForwardingStatus uint32 `protobuf:"varint,24,opt,name=forwarding_status,json=forwardingStatus,proto3" json:"forwarding_status,omitempty"`
	IpTtl            uint32 `protobuf:"varint,25,opt,name=ip_ttl,json=ipTtl,proto3" json:"ip_ttl,omitempty"`
	TcpFlags         uint32 `protobuf:"varint,26,opt,name=tcp_flags,json=tcpFlags,proto3" json:"tcp_flags,omitempty"`
	IcmpType         uint32 `protobuf:"varint,31,opt,name=icmp_type,json=icmpType,proto3" json:"icmp_type,omitempty"`
	IcmpCode         uint32 `protobuf:"varint,32,opt,name=icmp_code,json=icmpCode,proto3" json:"icmp_code,omitempty"`
	Ipv6FlowLabel    uint32 `protobuf:"varint,37,opt,name=ipv6_flow_label,json=ipv6FlowLabel,proto3" json:"ipv6_flow_label,omitempty"`
	// Fragments (IPv4/IPv6)
	FragmentId      uint32 `protobuf:"varint,35,opt,name=fragment_id,json=fragmentId,proto3" json:"fragment_id,omitempty"`
	FragmentOffset  uint32 `protobuf:"varint,36,opt,name=fragment_offset,json=fragmentOffset,proto3" json:"fragment_offset,omitempty"`
	BiFlowDirection uint32 `protobuf:"varint,41,opt,name=bi_flow_direction,json=biFlowDirection,proto3" json:"bi_flow_direction,omitempty"`
	// Autonomous system information
	SrcAs     uint32 `protobuf:"varint,14,opt,name=src_as,json=srcAs,proto3" json:"src_as,omitempty"`
	DstAs     uint32 `protobuf:"varint,15,opt,name=dst_as,json=dstAs,proto3" json:"dst_as,omitempty"`
	NextHop   []byte `protobuf:"bytes,12,opt,name=next_hop,json=nextHop,proto3" json:"next_hop,omitempty"`
	NextHopAs uint32 `protobuf:"varint,13,opt,name=next_hop_as,json=nextHopAs,proto3" json:"next_hop_as,omitempty"`
	// Prefix size
	SrcNet uint32 `protobuf:"varint,16,opt,name=src_net,json=srcNet,proto3" json:"src_net,omitempty"`
	DstNet uint32 `protobuf:"varint,17,opt,name=dst_net,json=dstNet,proto3" json:"dst_net,omitempty"`
	// BGP information
	BgpNextHop     []byte   `protobuf:"bytes,100,opt,name=bgp_next_hop,json=bgpNextHop,proto3" json:"bgp_next_hop,omitempty"`
	BgpCommunities []uint32 `protobuf:"varint,101,rep,packed,name=bgp_communities,json=bgpCommunities,proto3" json:"bgp_communities,omitempty"`
	AsPath         []uint32 `protobuf:"varint,102,rep,packed,name=as_path,json=asPath,proto3" json:"as_path,omitempty"`
	// MPLS information
	HasMpls             bool   `protobuf:"varint,53,opt,name=has_mpls,json=hasMpls,proto3" json:"has_mpls,omitempty"`
	MplsCount           uint32 `protobuf:"varint,54,opt,name=mpls_count,json=mplsCount,proto3" json:"mpls_count,omitempty"`
	Mpls_1Ttl           uint32 `protobuf:"varint,55,opt,name=mpls_1_ttl,json=mpls1Ttl,proto3" json:"mpls_1_ttl,omitempty"`                // First TTL
	Mpls_1Label         uint32 `protobuf:"varint,56,opt,name=mpls_1_label,json=mpls1Label,proto3" json:"mpls_1_label,omitempty"`          // First Label
	Mpls_2Ttl           uint32 `protobuf:"varint,57,opt,name=mpls_2_ttl,json=mpls2Ttl,proto3" json:"mpls_2_ttl,omitempty"`                // Second TTL
	Mpls_2Label         uint32 `protobuf:"varint,58,opt,name=mpls_2_label,json=mpls2Label,proto3" json:"mpls_2_label,omitempty"`          // Second Label
	Mpls_3Ttl           uint32 `protobuf:"varint,59,opt,name=mpls_3_ttl,json=mpls3Ttl,proto3" json:"mpls_3_ttl,omitempty"`                // Third TTL
	Mpls_3Label         uint32 `protobuf:"varint,60,opt,name=mpls_3_label,json=mpls3Label,proto3" json:"mpls_3_label,omitempty"`          // Third Label
	MplsLastTtl         uint32 `protobuf:"varint,61,opt,name=mpls_last_ttl,json=mplsLastTtl,proto3" json:"mpls_last_ttl,omitempty"`       // Last TTL
	MplsLastLabel       uint32 `protobuf:"varint,62,opt,name=mpls_last_label,json=mplsLastLabel,proto3" json:"mpls_last_label,omitempty"` // Last Label
	MplsLabelIp         []byte `protobuf:"bytes,65,opt,name=mpls_label_ip,json=mplsLabelIp,proto3" json:"mpls_label_ip,omitempty"`        // MPLS TOP Label IP
	ObservationDomainId uint32 `protobuf:"varint,70,opt,name=observation_domain_id,json=observationDomainId,proto3" json:"observation_domain_id,omitempty"`
	ObservationPointId  uint32 `protobuf:"varint,71,opt,name=observation_point_id,json=observationPointId,proto3" json:"observation_point_id,omitempty"`
	// Custom allocations
	CustomInteger_1 uint64   `protobuf:"varint,1001,opt,name=custom_integer_1,json=customInteger1,proto3" json:"custom_integer_1,omitempty"`
	CustomInteger_2 uint64   `protobuf:"varint,1002,opt,name=custom_integer_2,json=customInteger2,proto3" json:"custom_integer_2,omitempty"`
	CustomInteger_3 uint64   `protobuf:"varint,1003,opt,name=custom_integer_3,json=customInteger3,proto3" json:"custom_integer_3,omitempty"`
	CustomInteger_4 uint64   `protobuf:"varint,1004,opt,name=custom_integer_4,json=customInteger4,proto3" json:"custom_integer_4,omitempty"`
	CustomInteger_5 uint64   `protobuf:"varint,1005,opt,name=custom_integer_5,json=customInteger5,proto3" json:"custom_integer_5,omitempty"`
	CustomBytes_1   []byte   `protobuf:"bytes,1011,opt,name=custom_bytes_1,json=customBytes1,proto3" json:"custom_bytes_1,omitempty"`
	CustomBytes_2   []byte   `protobuf:"bytes,1012,opt,name=custom_bytes_2,json=customBytes2,proto3" json:"custom_bytes_2,omitempty"`
	CustomBytes_3   []byte   `protobuf:"bytes,1013,opt,name=custom_bytes_3,json=customBytes3,proto3" json:"custom_bytes_3,omitempty"`
	CustomBytes_4   []byte   `protobuf:"bytes,1014,opt,name=custom_bytes_4,json=customBytes4,proto3" json:"custom_bytes_4,omitempty"`
	CustomBytes_5   []byte   `protobuf:"bytes,1015,opt,name=custom_bytes_5,json=customBytes5,proto3" json:"custom_bytes_5,omitempty"`
	CustomList_1    []uint32 `protobuf:"varint,1021,rep,packed,name=custom_list_1,json=customList1,proto3" json:"custom_list_1,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) GetCustomBytes_1 added in v1.2.0

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

func (*FlowMessage) GetCustomBytes_2 added in v1.2.0

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

func (*FlowMessage) GetCustomBytes_3 added in v1.2.0

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

func (*FlowMessage) GetCustomBytes_4 added in v1.2.0

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

func (*FlowMessage) GetCustomBytes_5 added in v1.2.0

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

func (*FlowMessage) GetCustomInteger_1 added in v1.2.0

func (x *FlowMessage) GetCustomInteger_1() uint64

func (*FlowMessage) GetCustomInteger_2 added in v1.2.0

func (x *FlowMessage) GetCustomInteger_2() uint64

func (*FlowMessage) GetCustomInteger_3 added in v1.2.0

func (x *FlowMessage) GetCustomInteger_3() uint64

func (*FlowMessage) GetCustomInteger_4 added in v1.2.0

func (x *FlowMessage) GetCustomInteger_4() uint64

func (*FlowMessage) GetCustomInteger_5 added in v1.2.0

func (x *FlowMessage) GetCustomInteger_5() uint64

func (*FlowMessage) GetCustomList_1 added in v1.2.0

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

func (*FlowMessage) GetDstAddr

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

func (*FlowMessage) GetDstAs added in v1.2.0

func (x *FlowMessage) GetDstAs() uint32

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 added in v1.2.0

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 added in v1.2.0

func (x *FlowMessage) GetHasMpls() bool

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 added in v1.2.0

func (x *FlowMessage) GetIngressVrfId() uint32

func (*FlowMessage) GetIpTos added in v1.2.0

func (x *FlowMessage) GetIpTos() uint32

func (*FlowMessage) GetIpTtl added in v1.2.0

func (x *FlowMessage) GetIpTtl() uint32

func (*FlowMessage) GetIpv6FlowLabel added in v1.2.0

func (x *FlowMessage) GetIpv6FlowLabel() uint32

func (*FlowMessage) GetMplsCount added in v1.2.0

func (x *FlowMessage) GetMplsCount() uint32

func (*FlowMessage) GetMplsLabelIp added in v1.2.0

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

func (*FlowMessage) GetMplsLastLabel added in v1.2.0

func (x *FlowMessage) GetMplsLastLabel() uint32

func (*FlowMessage) GetMplsLastTtl added in v1.2.0

func (x *FlowMessage) GetMplsLastTtl() uint32

func (*FlowMessage) GetMpls_1Label added in v1.2.0

func (x *FlowMessage) GetMpls_1Label() uint32

func (*FlowMessage) GetMpls_1Ttl added in v1.2.0

func (x *FlowMessage) GetMpls_1Ttl() uint32

func (*FlowMessage) GetMpls_2Label added in v1.2.0

func (x *FlowMessage) GetMpls_2Label() uint32

func (*FlowMessage) GetMpls_2Ttl added in v1.2.0

func (x *FlowMessage) GetMpls_2Ttl() uint32

func (*FlowMessage) GetMpls_3Label added in v1.2.0

func (x *FlowMessage) GetMpls_3Label() uint32

func (*FlowMessage) GetMpls_3Ttl added in v1.2.0

func (x *FlowMessage) GetMpls_3Ttl() uint32

func (*FlowMessage) GetNextHop

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

func (*FlowMessage) GetNextHopAs added in v1.2.0

func (x *FlowMessage) GetNextHopAs() uint32

func (*FlowMessage) GetObservationDomainId added in v1.2.0

func (x *FlowMessage) GetObservationDomainId() uint32

func (*FlowMessage) GetObservationPointId added in v1.2.0

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) GetSrcAddr

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

func (*FlowMessage) GetSrcAs added in v1.2.0

func (x *FlowMessage) GetSrcAs() uint32

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 added in v1.2.0

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) Enum

func (FlowMessage_FlowType) EnumDescriptor deprecated

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

Deprecated: Use FlowMessage_FlowType.Descriptor instead.

func (FlowMessage_FlowType) Number

func (FlowMessage_FlowType) String

func (x FlowMessage_FlowType) String() string

func (FlowMessage_FlowType) Type

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL