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: 1

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for FlowMessageExt_FlowType.

View Source 
var File_cmd_enricher_pb_flowext_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type FlowMessageExt 

type FlowMessageExt struct {
	Type          FlowMessageExt_FlowType `protobuf:"varint,1,opt,name=type,proto3,enum=flowpb.FlowMessageExt_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"`
	SrcCountry          string `protobuf:"bytes,1000,opt,name=src_country,json=srcCountry,proto3" json:"src_country,omitempty"`
	DstCountry          string `protobuf:"bytes,1001,opt,name=dst_country,json=dstCountry,proto3" json:"dst_country,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowMessageExt) Descriptor deprecated 

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

Deprecated: Use FlowMessageExt.ProtoReflect.Descriptor instead.

func (*FlowMessageExt) GetAsPath added in v1.2.0 

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

func (*FlowMessageExt) GetBgpCommunities added in v1.2.0 

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

func (*FlowMessageExt) GetBgpNextHop added in v1.2.0 

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

func (*FlowMessageExt) GetBiFlowDirection 

func (x *FlowMessageExt) GetBiFlowDirection() uint32

func (*FlowMessageExt) GetBytes 

func (x *FlowMessageExt) GetBytes() uint64

func (*FlowMessageExt) GetDstAddr 

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

func (*FlowMessageExt) GetDstAs added in v1.2.0 

func (x *FlowMessageExt) GetDstAs() uint32

func (*FlowMessageExt) GetDstCountry 

func (x *FlowMessageExt) GetDstCountry() string

func (*FlowMessageExt) GetDstMac 

func (x *FlowMessageExt) GetDstMac() uint64

func (*FlowMessageExt) GetDstNet 

func (x *FlowMessageExt) GetDstNet() uint32

func (*FlowMessageExt) GetDstPort 

func (x *FlowMessageExt) GetDstPort() uint32

func (*FlowMessageExt) GetDstVlan 

func (x *FlowMessageExt) GetDstVlan() uint32

func (*FlowMessageExt) GetEgressVrfId added in v1.2.0 

func (x *FlowMessageExt) GetEgressVrfId() uint32

func (*FlowMessageExt) GetEtype 

func (x *FlowMessageExt) GetEtype() uint32

func (*FlowMessageExt) GetFlowDirection 

func (x *FlowMessageExt) GetFlowDirection() uint32

func (*FlowMessageExt) GetForwardingStatus 

func (x *FlowMessageExt) GetForwardingStatus() uint32

func (*FlowMessageExt) GetFragmentId 

func (x *FlowMessageExt) GetFragmentId() uint32

func (*FlowMessageExt) GetFragmentOffset 

func (x *FlowMessageExt) GetFragmentOffset() uint32

func (*FlowMessageExt) GetHasMpls added in v1.2.0 

func (x *FlowMessageExt) GetHasMpls() bool

func (*FlowMessageExt) GetIcmpCode 

func (x *FlowMessageExt) GetIcmpCode() uint32

func (*FlowMessageExt) GetIcmpType 

func (x *FlowMessageExt) GetIcmpType() uint32

func (*FlowMessageExt) GetInIf 

func (x *FlowMessageExt) GetInIf() uint32

func (*FlowMessageExt) GetIngressVrfId added in v1.2.0 

func (x *FlowMessageExt) GetIngressVrfId() uint32

func (*FlowMessageExt) GetIpTos added in v1.2.0 

func (x *FlowMessageExt) GetIpTos() uint32

func (*FlowMessageExt) GetIpTtl added in v1.2.0 

func (x *FlowMessageExt) GetIpTtl() uint32

func (*FlowMessageExt) GetIpv6FlowLabel added in v1.2.0 

func (x *FlowMessageExt) GetIpv6FlowLabel() uint32

func (*FlowMessageExt) GetMplsCount added in v1.2.0 

func (x *FlowMessageExt) GetMplsCount() uint32

func (*FlowMessageExt) GetMplsLabelIp added in v1.2.0 

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

func (*FlowMessageExt) GetMplsLastLabel added in v1.2.0 

func (x *FlowMessageExt) GetMplsLastLabel() uint32

func (*FlowMessageExt) GetMplsLastTtl added in v1.2.0 

func (x *FlowMessageExt) GetMplsLastTtl() uint32

func (*FlowMessageExt) GetMpls_1Label added in v1.2.0 

func (x *FlowMessageExt) GetMpls_1Label() uint32

func (*FlowMessageExt) GetMpls_1Ttl added in v1.2.0 

func (x *FlowMessageExt) GetMpls_1Ttl() uint32

func (*FlowMessageExt) GetMpls_2Label added in v1.2.0 

func (x *FlowMessageExt) GetMpls_2Label() uint32

func (*FlowMessageExt) GetMpls_2Ttl added in v1.2.0 

func (x *FlowMessageExt) GetMpls_2Ttl() uint32

func (*FlowMessageExt) GetMpls_3Label added in v1.2.0 

func (x *FlowMessageExt) GetMpls_3Label() uint32

func (*FlowMessageExt) GetMpls_3Ttl added in v1.2.0 

func (x *FlowMessageExt) GetMpls_3Ttl() uint32

func (*FlowMessageExt) GetNextHop 

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

func (*FlowMessageExt) GetNextHopAs added in v1.2.0 

func (x *FlowMessageExt) GetNextHopAs() uint32

func (*FlowMessageExt) GetObservationDomainId added in v1.2.0 

func (x *FlowMessageExt) GetObservationDomainId() uint32

func (*FlowMessageExt) GetObservationPointId added in v1.2.0 

func (x *FlowMessageExt) GetObservationPointId() uint32

func (*FlowMessageExt) GetOutIf 

func (x *FlowMessageExt) GetOutIf() uint32

func (*FlowMessageExt) GetPackets 

func (x *FlowMessageExt) GetPackets() uint64

func (*FlowMessageExt) GetProto 

func (x *FlowMessageExt) GetProto() uint32

func (*FlowMessageExt) GetSamplerAddress 

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

func (*FlowMessageExt) GetSamplingRate 

func (x *FlowMessageExt) GetSamplingRate() uint64

func (*FlowMessageExt) GetSequenceNum 

func (x *FlowMessageExt) GetSequenceNum() uint32

func (*FlowMessageExt) GetSrcAddr 

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

func (*FlowMessageExt) GetSrcAs added in v1.2.0 

func (x *FlowMessageExt) GetSrcAs() uint32

func (*FlowMessageExt) GetSrcCountry 

func (x *FlowMessageExt) GetSrcCountry() string

func (*FlowMessageExt) GetSrcMac 

func (x *FlowMessageExt) GetSrcMac() uint64

func (*FlowMessageExt) GetSrcNet 

func (x *FlowMessageExt) GetSrcNet() uint32

func (*FlowMessageExt) GetSrcPort 

func (x *FlowMessageExt) GetSrcPort() uint32

func (*FlowMessageExt) GetSrcVlan 

func (x *FlowMessageExt) GetSrcVlan() uint32

func (*FlowMessageExt) GetTcpFlags added in v1.2.0 

func (x *FlowMessageExt) GetTcpFlags() uint32

func (*FlowMessageExt) GetTimeFlowEnd 

func (x *FlowMessageExt) GetTimeFlowEnd() uint64

func (*FlowMessageExt) GetTimeFlowEndMs added in v1.2.0 

func (x *FlowMessageExt) GetTimeFlowEndMs() uint64

func (*FlowMessageExt) GetTimeFlowStart 

func (x *FlowMessageExt) GetTimeFlowStart() uint64

func (*FlowMessageExt) GetTimeFlowStartMs added in v1.2.0 

func (x *FlowMessageExt) GetTimeFlowStartMs() uint64

func (*FlowMessageExt) GetTimeReceived 

func (x *FlowMessageExt) GetTimeReceived() uint64

func (*FlowMessageExt) GetType 

func (x *FlowMessageExt) GetType() FlowMessageExt_FlowType

func (*FlowMessageExt) GetVlanId 

func (x *FlowMessageExt) GetVlanId() uint32

func (*FlowMessageExt) ProtoMessage 

func (*FlowMessageExt) ProtoMessage()

func (*FlowMessageExt) ProtoReflect 

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

func (*FlowMessageExt) Reset 

func (x *FlowMessageExt) Reset()

func (*FlowMessageExt) String 

func (x *FlowMessageExt) String() string

type FlowMessageExt_FlowType 

type FlowMessageExt_FlowType int32
const (
	FlowMessageExt_FLOWUNKNOWN FlowMessageExt_FlowType = 0
	FlowMessageExt_SFLOW_5     FlowMessageExt_FlowType = 1
	FlowMessageExt_NETFLOW_V5  FlowMessageExt_FlowType = 2
	FlowMessageExt_NETFLOW_V9  FlowMessageExt_FlowType = 3
	FlowMessageExt_IPFIX       FlowMessageExt_FlowType = 4
)

func (FlowMessageExt_FlowType) Descriptor 

func (FlowMessageExt_FlowType) Descriptor() protoreflect.EnumDescriptor

func (FlowMessageExt_FlowType) Enum 

func (x FlowMessageExt_FlowType) Enum() *FlowMessageExt_FlowType

func (FlowMessageExt_FlowType) EnumDescriptor deprecated 

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

Deprecated: Use FlowMessageExt_FlowType.Descriptor instead.

func (FlowMessageExt_FlowType) Number 

func (x FlowMessageExt_FlowType) Number() protoreflect.EnumNumber

func (FlowMessageExt_FlowType) String 

func (x FlowMessageExt_FlowType) String() string

func (FlowMessageExt_FlowType) Type 

func (FlowMessageExt_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.