pb

package
v0.10.3-beta Latest Latest
Warning

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

 Go to latest Published: Jan 12, 2023 License: GPL-3.0 Imports: 7 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	FlowDirectionMap = map[uint32]string{
		0: "Incoming",
		1: "Outgoing"}
	EtypeMap = map[uint32]string{
		0x0800: "IPv4",
		0x0806: "ARP",
		0x0842: "Wake-on-LAN",
		0x86DD: "IPv6",
		0x8809: "Ethernet Slow Protocols (LACP)",
		0x8847: "MPLS unicast",
		0x8848: "MPLS multicast",
		0x8863: "PPPoE Discovery Stage",
		0x8864: "PPPoE Session Stage",
		0x889A: "HyperSCSI (SCSI over Ethernet)",
		0x88A2: "ATA over Ethernet",
		0x88A4: "EtherCAT Protocol",
		0x88CC: "LLDP",
		0x88E5: "MAC Security",
		0x8906: "Fibre Channel over Ethernet (FCoE)",
		0x8914: "FCoE Initialization Protocol",
		0x9000: "Ethernet Configuration Testing Protocol"}
	ForwardingStatusMap = map[uint32]string{
		0:   "Unknown",
		64:  "Forwarded (Unknown)",
		65:  "Forwarded (Fragmented)",
		66:  "Forwarded (Not Fragmented)",
		128: "Dropped (Unknown)",
		129: "Dropped (ACL Deny)",
		130: "Dropped (ACL Drop)",
		131: "Dropped (Unroutable)",
		132: "Dropped (Adjacency)",
		133: "Dropped (Fragmented and DF set)",
		134: "Dropped (Bad Header Checksum)",
		135: "Dropped (Bad Total Length)",
		136: "Dropped (Bad Header Length)",
		137: "Dropped (Bad TTL)",
		138: "Dropped (Policer)",
		139: "Dropped (WRED)",
		140: "Dropped (RPF)",
		141: "Dropped (For Us)",
		142: "Dropped (Bad Output Interface)",
		143: "Dropped (Hardware)",
		192: "Consumed (Unknown)",
		193: "Consumed (Terminate Punt Adjacency)",
		194: "Consumed (Terminate Incomplete Adjacency)",
		195: "Consumed (Terminate For Us)"}
)
View Source 
var (
	EnrichedFlow_FlowType_name = map[int32]string{
		0: "FLOWUNKNOWN",
		1: "SFLOW_5",
		2: "NETFLOW_V5",
		3: "NETFLOW_V9",
		4: "IPFIX",
		5: "EBPF",
	}
	EnrichedFlow_FlowType_value = map[string]int32{
		"FLOWUNKNOWN": 0,
		"SFLOW_5":     1,
		"NETFLOW_V5":  2,
		"NETFLOW_V9":  3,
		"IPFIX":       4,
		"EBPF":        5,
	}
)

Enum value maps for EnrichedFlow_FlowType.

View Source 
var (
	EnrichedFlow_AnonymizedType_name = map[int32]string{
		0: "NotAnonymized",
		1: "CryptoPAN",
	}
	EnrichedFlow_AnonymizedType_value = map[string]int32{
		"NotAnonymized": 0,
		"CryptoPAN":     1,
	}
)

Enum value maps for EnrichedFlow_AnonymizedType.

View Source 
var (
	EnrichedFlow_ValidationStatusType_name = map[int32]string{
		0: "Unknown",
		1: "Valid",
		2: "NotFound",
		3: "Invalid",
	}
	EnrichedFlow_ValidationStatusType_value = map[string]int32{
		"Unknown":  0,
		"Valid":    1,
		"NotFound": 2,
		"Invalid":  3,
	}
)

Enum value maps for EnrichedFlow_ValidationStatusType.

View Source 
var (
	EnrichedFlow_NormalizedType_name = map[int32]string{
		0: "No",
		1: "Yes",
	}
	EnrichedFlow_NormalizedType_value = map[string]int32{
		"No":  0,
		"Yes": 1,
	}
)

Enum value maps for EnrichedFlow_NormalizedType.

View Source 
var (
	EnrichedFlow_RemoteAddrType_name = map[int32]string{
		0: "Neither",
		1: "Src",
		2: "Dst",
	}
	EnrichedFlow_RemoteAddrType_value = map[string]int32{
		"Neither": 0,
		"Src":     1,
		"Dst":     2,
	}
)

Enum value maps for EnrichedFlow_RemoteAddrType.

View Source 
var File_flow_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type EnrichedFlow 

type EnrichedFlow struct {
	Type          EnrichedFlow_FlowType `protobuf:"varint,1,opt,name=Type,proto3,enum=flowpb.EnrichedFlow_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"`
	// 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"`
	// 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
	PacketBytesMin    uint32 `protobuf:"varint,1100,opt,name=PacketBytesMin,proto3" json:"PacketBytesMin,omitempty"`       // new, single packet means uint32 < MTU
	PacketBytesMax    uint32 `protobuf:"varint,1101,opt,name=PacketBytesMax,proto3" json:"PacketBytesMax,omitempty"`       // new
	PacketBytesMean   uint32 `protobuf:"varint,1102,opt,name=PacketBytesMean,proto3" json:"PacketBytesMean,omitempty"`     // new
	PacketBytesStdDev uint32 `protobuf:"varint,1103,opt,name=PacketBytesStdDev,proto3" json:"PacketBytesStdDev,omitempty"` // new
	PacketIATMin      uint64 `protobuf:"varint,1110,opt,name=PacketIATMin,proto3" json:"PacketIATMin,omitempty"`           // new
	PacketIATMax      uint64 `protobuf:"varint,1111,opt,name=PacketIATMax,proto3" json:"PacketIATMax,omitempty"`           // new
	PacketIATMean     uint64 `protobuf:"varint,1112,opt,name=PacketIATMean,proto3" json:"PacketIATMean,omitempty"`         // new
	PacketIATStdDev   uint64 `protobuf:"varint,1113,opt,name=PacketIATStdDev,proto3" json:"PacketIATStdDev,omitempty"`     // new
	HeaderBytes       uint32 `protobuf:"varint,1120,opt,name=HeaderBytes,proto3" json:"HeaderBytes,omitempty"`             // new
	FINFlagCount      uint64 `protobuf:"varint,1130,opt,name=FINFlagCount,proto3" json:"FINFlagCount,omitempty"`           // new
	SYNFlagCount      uint64 `protobuf:"varint,1131,opt,name=SYNFlagCount,proto3" json:"SYNFlagCount,omitempty"`           // new
	RSTFlagCount      uint64 `protobuf:"varint,1132,opt,name=RSTFlagCount,proto3" json:"RSTFlagCount,omitempty"`           // new
	PSHFlagCount      uint64 `protobuf:"varint,1133,opt,name=PSHFlagCount,proto3" json:"PSHFlagCount,omitempty"`           // new
	ACKFlagCount      uint64 `protobuf:"varint,1134,opt,name=ACKFlagCount,proto3" json:"ACKFlagCount,omitempty"`           // new
	URGFlagCount      uint64 `protobuf:"varint,1135,opt,name=URGFlagCount,proto3" json:"URGFlagCount,omitempty"`           // new
	CWRFlagCount      uint64 `protobuf:"varint,1136,opt,name=CWRFlagCount,proto3" json:"CWRFlagCount,omitempty"`           // new
	ECEFlagCount      uint64 `protobuf:"varint,1137,opt,name=ECEFlagCount,proto3" json:"ECEFlagCount,omitempty"`           // new
	PayloadPackets    uint64 `protobuf:"varint,1140,opt,name=PayloadPackets,proto3" json:"PayloadPackets,omitempty"`       // new
	TimeActiveMin     uint64 `protobuf:"varint,1150,opt,name=TimeActiveMin,proto3" json:"TimeActiveMin,omitempty"`         // new
	TimeActiveMax     uint64 `protobuf:"varint,1151,opt,name=TimeActiveMax,proto3" json:"TimeActiveMax,omitempty"`         // new
	TimeActiveMean    uint64 `protobuf:"varint,1152,opt,name=TimeActiveMean,proto3" json:"TimeActiveMean,omitempty"`       // new
	TimeActiveStdDev  uint64 `protobuf:"varint,1153,opt,name=TimeActiveStdDev,proto3" json:"TimeActiveStdDev,omitempty"`   // new
	TimeIdleMin       uint64 `protobuf:"varint,1154,opt,name=TimeIdleMin,proto3" json:"TimeIdleMin,omitempty"`             // new
	TimeIdleMax       uint64 `protobuf:"varint,1155,opt,name=TimeIdleMax,proto3" json:"TimeIdleMax,omitempty"`             // new
	TimeIdleMean      uint64 `protobuf:"varint,1156,opt,name=TimeIdleMean,proto3" json:"TimeIdleMean,omitempty"`           // new
	TimeIdleStdDev    uint64 `protobuf:"varint,1157,opt,name=TimeIdleStdDev,proto3" json:"TimeIdleStdDev,omitempty"`       // new
	// modify/addcid
	Cid                               uint32                      `protobuf:"varint,1000,opt,name=Cid,proto3" json:"Cid,omitempty"`            // TODO: deprecate and provide as helper?
	CidString                         string                      `protobuf:"bytes,1001,opt,name=CidString,proto3" json:"CidString,omitempty"` // deprecated, delete for v1.0.0
	SrcCid                            uint32                      `protobuf:"varint,1012,opt,name=SrcCid,proto3" json:"SrcCid,omitempty"`
	DstCid                            uint32                      `protobuf:"varint,1013,opt,name=DstCid,proto3" json:"DstCid,omitempty"`
	SrcAddrAnon                       EnrichedFlow_AnonymizedType `protobuf:"varint,1160,opt,name=SrcAddrAnon,proto3,enum=flowpb.EnrichedFlow_AnonymizedType" json:"SrcAddrAnon,omitempty"`
	DstAddrAnon                       EnrichedFlow_AnonymizedType `protobuf:"varint,1161,opt,name=DstAddrAnon,proto3,enum=flowpb.EnrichedFlow_AnonymizedType" json:"DstAddrAnon,omitempty"`
	SrcAddrPreservedLen               uint32                      `protobuf:"varint,1162,opt,name=SrcAddrPreservedLen,proto3" json:"SrcAddrPreservedLen,omitempty"`
	DstAddrPreservedLen               uint32                      `protobuf:"varint,1163,opt,name=DstAddrPreservedLen,proto3" json:"DstAddrPreservedLen,omitempty"`
	SamplerAddrAnon                   EnrichedFlow_AnonymizedType `` /* 127-byte string literal not displayed */
	SamplerAddrAnonPreservedPrefixLen uint32                      `protobuf:"varint,1165,opt,name=SamplerAddrAnonPreservedPrefixLen,proto3" json:"SamplerAddrAnonPreservedPrefixLen,omitempty"`
	// modify/bgp
	// as done by a number of Netflow implementations, these refer to the destination
	ASPath           []uint32                          `protobuf:"varint,1171,rep,packed,name=ASPath,proto3" json:"ASPath,omitempty"`
	Med              uint32                            `protobuf:"varint,1172,opt,name=Med,proto3" json:"Med,omitempty"`
	LocalPref        uint32                            `protobuf:"varint,1173,opt,name=LocalPref,proto3" json:"LocalPref,omitempty"`
	ValidationStatus EnrichedFlow_ValidationStatusType `` /* 135-byte string literal not displayed */
	// modify/geolocation
	RemoteCountry string                      `protobuf:"bytes,1010,opt,name=RemoteCountry,proto3" json:"RemoteCountry,omitempty"` // TODO: deprecate and provide as helper
	SrcCountry    string                      `protobuf:"bytes,1014,opt,name=SrcCountry,proto3" json:"SrcCountry,omitempty"`
	DstCountry    string                      `protobuf:"bytes,1015,opt,name=DstCountry,proto3" json:"DstCountry,omitempty"`
	Normalized    EnrichedFlow_NormalizedType `protobuf:"varint,1002,opt,name=Normalized,proto3,enum=flowpb.EnrichedFlow_NormalizedType" json:"Normalized,omitempty"` // TODO: deprecate and replace with helper?
	// modify/protomap
	ProtoName  string                      `protobuf:"bytes,1009,opt,name=ProtoName,proto3" json:"ProtoName,omitempty"`                                            // TODO: deprecate and replace with helper, why lug a string along...
	RemoteAddr EnrichedFlow_RemoteAddrType `protobuf:"varint,1011,opt,name=RemoteAddr,proto3,enum=flowpb.EnrichedFlow_RemoteAddrType" json:"RemoteAddr,omitempty"` // TODO: figure out a better system? applicable only to service providers right now...
	// modify/reversedns
	SrcAddrName string `protobuf:"bytes,1180,opt,name=SrcAddrName,proto3" json:"SrcAddrName,omitempty"` // new
	DstAddrName string `protobuf:"bytes,1181,opt,name=DstAddrName,proto3" json:"DstAddrName,omitempty"` // new
	// modify/snmp
	SrcIfName  string `protobuf:"bytes,1003,opt,name=SrcIfName,proto3" json:"SrcIfName,omitempty"`    // TODO: rename to match InIf and OutIf
	SrcIfDesc  string `protobuf:"bytes,1004,opt,name=SrcIfDesc,proto3" json:"SrcIfDesc,omitempty"`    // TODO: rename to match InIf and OutIf
	SrcIfSpeed uint32 `protobuf:"varint,1005,opt,name=SrcIfSpeed,proto3" json:"SrcIfSpeed,omitempty"` // TODO: rename to match InIf and OutIf
	DstIfName  string `protobuf:"bytes,1006,opt,name=DstIfName,proto3" json:"DstIfName,omitempty"`    // TODO: rename to match InIf and OutIf
	DstIfDesc  string `protobuf:"bytes,1007,opt,name=DstIfDesc,proto3" json:"DstIfDesc,omitempty"`    // TODO: rename to match InIf and OutIf
	DstIfSpeed uint32 `protobuf:"varint,1008,opt,name=DstIfSpeed,proto3" json:"DstIfSpeed,omitempty"` // TODO: rename to match InIf and OutIf
	// general
	Note string `protobuf:"bytes,1016,opt,name=Note,proto3" json:"Note,omitempty"` // free-form field to implement anything
	// contains filtered or unexported fields
}

func NewFromGoflow 

func NewFromGoflow(msg *goflowpb.FlowMessage) *EnrichedFlow

func NewFromOld 

func NewFromOld(msg *oldpb.FlowMessage) *EnrichedFlow

func (*EnrichedFlow) Descriptor deprecated 

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

Deprecated: Use EnrichedFlow.ProtoReflect.Descriptor instead.

func (*EnrichedFlow) DstAddrObj 

func (flow *EnrichedFlow) DstAddrObj() net.IP

func (*EnrichedFlow) EtypeString 

func (flow *EnrichedFlow) EtypeString() string

func (*EnrichedFlow) FlowDirectionString 

func (flow *EnrichedFlow) FlowDirectionString() string

func (*EnrichedFlow) ForwardingStatusString 

func (flow *EnrichedFlow) ForwardingStatusString() string

func (*EnrichedFlow) GetACKFlagCount 

func (x *EnrichedFlow) GetACKFlagCount() uint64

func (*EnrichedFlow) GetASPath 

func (x *EnrichedFlow) GetASPath() []uint32

func (*EnrichedFlow) GetBiFlowDirection 

func (x *EnrichedFlow) GetBiFlowDirection() uint32

func (*EnrichedFlow) GetBps 

func (flow *EnrichedFlow) GetBps() uint64

func (*EnrichedFlow) GetBytes 

func (x *EnrichedFlow) GetBytes() uint64

func (*EnrichedFlow) GetCWRFlagCount 

func (x *EnrichedFlow) GetCWRFlagCount() uint64

func (*EnrichedFlow) GetCid 

func (x *EnrichedFlow) GetCid() uint32

func (*EnrichedFlow) GetCidString 

func (x *EnrichedFlow) GetCidString() string

func (*EnrichedFlow) GetDstAS 

func (x *EnrichedFlow) GetDstAS() uint32

func (*EnrichedFlow) GetDstAddr 

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

func (*EnrichedFlow) GetDstAddrAnon 

func (x *EnrichedFlow) GetDstAddrAnon() EnrichedFlow_AnonymizedType

func (*EnrichedFlow) GetDstAddrName 

func (x *EnrichedFlow) GetDstAddrName() string

func (*EnrichedFlow) GetDstAddrPreservedLen 

func (x *EnrichedFlow) GetDstAddrPreservedLen() uint32

func (*EnrichedFlow) GetDstCid 

func (x *EnrichedFlow) GetDstCid() uint32

func (*EnrichedFlow) GetDstCountry 

func (x *EnrichedFlow) GetDstCountry() string

func (*EnrichedFlow) GetDstIfDesc 

func (x *EnrichedFlow) GetDstIfDesc() string

func (*EnrichedFlow) GetDstIfName 

func (x *EnrichedFlow) GetDstIfName() string

func (*EnrichedFlow) GetDstIfSpeed 

func (x *EnrichedFlow) GetDstIfSpeed() uint32

func (*EnrichedFlow) GetDstMac 

func (x *EnrichedFlow) GetDstMac() uint64

func (*EnrichedFlow) GetDstNet 

func (x *EnrichedFlow) GetDstNet() uint32

func (*EnrichedFlow) GetDstPort 

func (x *EnrichedFlow) GetDstPort() uint32

func (*EnrichedFlow) GetDstVlan 

func (x *EnrichedFlow) GetDstVlan() uint32

func (*EnrichedFlow) GetECEFlagCount 

func (x *EnrichedFlow) GetECEFlagCount() uint64

func (*EnrichedFlow) GetEgressVrfID 

func (x *EnrichedFlow) GetEgressVrfID() uint32

func (*EnrichedFlow) GetEtype 

func (x *EnrichedFlow) GetEtype() uint32

func (*EnrichedFlow) GetFINFlagCount 

func (x *EnrichedFlow) GetFINFlagCount() uint64

func (*EnrichedFlow) GetFlowDirection 

func (x *EnrichedFlow) GetFlowDirection() uint32

func (*EnrichedFlow) GetForwardingStatus 

func (x *EnrichedFlow) GetForwardingStatus() uint32

func (*EnrichedFlow) GetFragmentId 

func (x *EnrichedFlow) GetFragmentId() uint32

func (*EnrichedFlow) GetFragmentOffset 

func (x *EnrichedFlow) GetFragmentOffset() uint32

func (*EnrichedFlow) GetHasMPLS 

func (x *EnrichedFlow) GetHasMPLS() bool

func (*EnrichedFlow) GetHeaderBytes 

func (x *EnrichedFlow) GetHeaderBytes() uint32

func (*EnrichedFlow) GetIPTTL 

func (x *EnrichedFlow) GetIPTTL() uint32

func (*EnrichedFlow) GetIPTos 

func (x *EnrichedFlow) GetIPTos() uint32

func (*EnrichedFlow) GetIPv6FlowLabel 

func (x *EnrichedFlow) GetIPv6FlowLabel() uint32

func (*EnrichedFlow) GetIcmpCode 

func (x *EnrichedFlow) GetIcmpCode() uint32

func (*EnrichedFlow) GetIcmpType 

func (x *EnrichedFlow) GetIcmpType() uint32

func (*EnrichedFlow) GetInIf 

func (x *EnrichedFlow) GetInIf() uint32

func (*EnrichedFlow) GetIngressVrfID 

func (x *EnrichedFlow) GetIngressVrfID() uint32

func (*EnrichedFlow) GetLocalPref 

func (x *EnrichedFlow) GetLocalPref() uint32

func (*EnrichedFlow) GetMPLS1Label 

func (x *EnrichedFlow) GetMPLS1Label() uint32

func (*EnrichedFlow) GetMPLS1TTL 

func (x *EnrichedFlow) GetMPLS1TTL() uint32

func (*EnrichedFlow) GetMPLS2Label 

func (x *EnrichedFlow) GetMPLS2Label() uint32

func (*EnrichedFlow) GetMPLS2TTL 

func (x *EnrichedFlow) GetMPLS2TTL() uint32

func (*EnrichedFlow) GetMPLS3Label 

func (x *EnrichedFlow) GetMPLS3Label() uint32

func (*EnrichedFlow) GetMPLS3TTL 

func (x *EnrichedFlow) GetMPLS3TTL() uint32

func (*EnrichedFlow) GetMPLSCount 

func (x *EnrichedFlow) GetMPLSCount() uint32

func (*EnrichedFlow) GetMPLSLastLabel 

func (x *EnrichedFlow) GetMPLSLastLabel() uint32

func (*EnrichedFlow) GetMPLSLastTTL 

func (x *EnrichedFlow) GetMPLSLastTTL() uint32

func (*EnrichedFlow) GetMed 

func (x *EnrichedFlow) GetMed() uint32

func (*EnrichedFlow) GetNextHop 

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

func (*EnrichedFlow) GetNextHopAS 

func (x *EnrichedFlow) GetNextHopAS() uint32

func (*EnrichedFlow) GetNormalized 

func (x *EnrichedFlow) GetNormalized() EnrichedFlow_NormalizedType

func (*EnrichedFlow) GetNote 

func (x *EnrichedFlow) GetNote() string

func (*EnrichedFlow) GetOutIf 

func (x *EnrichedFlow) GetOutIf() uint32

func (*EnrichedFlow) GetPSHFlagCount 

func (x *EnrichedFlow) GetPSHFlagCount() uint64

func (*EnrichedFlow) GetPacketBytesMax 

func (x *EnrichedFlow) GetPacketBytesMax() uint32

func (*EnrichedFlow) GetPacketBytesMean 

func (x *EnrichedFlow) GetPacketBytesMean() uint32

func (*EnrichedFlow) GetPacketBytesMin 

func (x *EnrichedFlow) GetPacketBytesMin() uint32

func (*EnrichedFlow) GetPacketBytesStdDev 

func (x *EnrichedFlow) GetPacketBytesStdDev() uint32

func (*EnrichedFlow) GetPacketIATMax 

func (x *EnrichedFlow) GetPacketIATMax() uint64

func (*EnrichedFlow) GetPacketIATMean 

func (x *EnrichedFlow) GetPacketIATMean() uint64

func (*EnrichedFlow) GetPacketIATMin 

func (x *EnrichedFlow) GetPacketIATMin() uint64

func (*EnrichedFlow) GetPacketIATStdDev 

func (x *EnrichedFlow) GetPacketIATStdDev() uint64

func (*EnrichedFlow) GetPackets 

func (x *EnrichedFlow) GetPackets() uint64

func (*EnrichedFlow) GetPayloadPackets 

func (x *EnrichedFlow) GetPayloadPackets() uint64

func (*EnrichedFlow) GetPps 

func (flow *EnrichedFlow) GetPps() uint64

func (*EnrichedFlow) GetProto 

func (x *EnrichedFlow) GetProto() uint32

func (*EnrichedFlow) GetProtoName 

func (x *EnrichedFlow) GetProtoName() string

func (*EnrichedFlow) GetRSTFlagCount 

func (x *EnrichedFlow) GetRSTFlagCount() uint64

func (*EnrichedFlow) GetRemoteAddr 

func (x *EnrichedFlow) GetRemoteAddr() EnrichedFlow_RemoteAddrType

func (*EnrichedFlow) GetRemoteCountry 

func (x *EnrichedFlow) GetRemoteCountry() string

func (*EnrichedFlow) GetSYNFlagCount 

func (x *EnrichedFlow) GetSYNFlagCount() uint64

func (*EnrichedFlow) GetSamplerAddrAnon 

func (x *EnrichedFlow) GetSamplerAddrAnon() EnrichedFlow_AnonymizedType

func (*EnrichedFlow) GetSamplerAddrAnonPreservedPrefixLen 

func (x *EnrichedFlow) GetSamplerAddrAnonPreservedPrefixLen() uint32

func (*EnrichedFlow) GetSamplerAddress 

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

func (*EnrichedFlow) GetSamplingRate 

func (x *EnrichedFlow) GetSamplingRate() uint64

func (*EnrichedFlow) GetSequenceNum 

func (x *EnrichedFlow) GetSequenceNum() uint32

func (*EnrichedFlow) GetSrcAS 

func (x *EnrichedFlow) GetSrcAS() uint32

func (*EnrichedFlow) GetSrcAddr 

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

func (*EnrichedFlow) GetSrcAddrAnon 

func (x *EnrichedFlow) GetSrcAddrAnon() EnrichedFlow_AnonymizedType

func (*EnrichedFlow) GetSrcAddrName 

func (x *EnrichedFlow) GetSrcAddrName() string

func (*EnrichedFlow) GetSrcAddrPreservedLen 

func (x *EnrichedFlow) GetSrcAddrPreservedLen() uint32

func (*EnrichedFlow) GetSrcCid 

func (x *EnrichedFlow) GetSrcCid() uint32

func (*EnrichedFlow) GetSrcCountry 

func (x *EnrichedFlow) GetSrcCountry() string

func (*EnrichedFlow) GetSrcIfDesc 

func (x *EnrichedFlow) GetSrcIfDesc() string

func (*EnrichedFlow) GetSrcIfName 

func (x *EnrichedFlow) GetSrcIfName() string

func (*EnrichedFlow) GetSrcIfSpeed 

func (x *EnrichedFlow) GetSrcIfSpeed() uint32

func (*EnrichedFlow) GetSrcMac 

func (x *EnrichedFlow) GetSrcMac() uint64

func (*EnrichedFlow) GetSrcNet 

func (x *EnrichedFlow) GetSrcNet() uint32

func (*EnrichedFlow) GetSrcPort 

func (x *EnrichedFlow) GetSrcPort() uint32

func (*EnrichedFlow) GetSrcVlan 

func (x *EnrichedFlow) GetSrcVlan() uint32

func (*EnrichedFlow) GetTCPFlags 

func (x *EnrichedFlow) GetTCPFlags() uint32

func (*EnrichedFlow) GetTimeActiveMax 

func (x *EnrichedFlow) GetTimeActiveMax() uint64

func (*EnrichedFlow) GetTimeActiveMean 

func (x *EnrichedFlow) GetTimeActiveMean() uint64

func (*EnrichedFlow) GetTimeActiveMin 

func (x *EnrichedFlow) GetTimeActiveMin() uint64

func (*EnrichedFlow) GetTimeActiveStdDev 

func (x *EnrichedFlow) GetTimeActiveStdDev() uint64

func (*EnrichedFlow) GetTimeFlowEnd 

func (x *EnrichedFlow) GetTimeFlowEnd() uint64

func (*EnrichedFlow) GetTimeFlowStart 

func (x *EnrichedFlow) GetTimeFlowStart() uint64

func (*EnrichedFlow) GetTimeIdleMax 

func (x *EnrichedFlow) GetTimeIdleMax() uint64

func (*EnrichedFlow) GetTimeIdleMean 

func (x *EnrichedFlow) GetTimeIdleMean() uint64

func (*EnrichedFlow) GetTimeIdleMin 

func (x *EnrichedFlow) GetTimeIdleMin() uint64

func (*EnrichedFlow) GetTimeIdleStdDev 

func (x *EnrichedFlow) GetTimeIdleStdDev() uint64

func (*EnrichedFlow) GetTimeReceived 

func (x *EnrichedFlow) GetTimeReceived() uint64

func (*EnrichedFlow) GetType 

func (x *EnrichedFlow) GetType() EnrichedFlow_FlowType

func (*EnrichedFlow) GetURGFlagCount 

func (x *EnrichedFlow) GetURGFlagCount() uint64

func (*EnrichedFlow) GetValidationStatus 

func (x *EnrichedFlow) GetValidationStatus() EnrichedFlow_ValidationStatusType

func (*EnrichedFlow) GetVlanId 

func (x *EnrichedFlow) GetVlanId() uint32

func (*EnrichedFlow) IPVersion 

func (flow *EnrichedFlow) IPVersion() uint8

func (*EnrichedFlow) IPVersionString 

func (flow *EnrichedFlow) IPVersionString() string

func (*EnrichedFlow) IsConsumed 

func (flow *EnrichedFlow) IsConsumed() bool

func (*EnrichedFlow) IsDropped 

func (flow *EnrichedFlow) IsDropped() bool

func (*EnrichedFlow) IsForwarded 

func (flow *EnrichedFlow) IsForwarded() bool

func (*EnrichedFlow) IsIPv4 

func (flow *EnrichedFlow) IsIPv4() bool

func (*EnrichedFlow) IsIPv6 

func (flow *EnrichedFlow) IsIPv6() bool

func (*EnrichedFlow) IsIncoming 

func (flow *EnrichedFlow) IsIncoming() bool

func (*EnrichedFlow) IsOutgoing 

func (flow *EnrichedFlow) IsOutgoing() bool

func (*EnrichedFlow) IsUnknownForwardingStatus 

func (flow *EnrichedFlow) IsUnknownForwardingStatus() bool

func (*EnrichedFlow) NextHopObj 

func (flow *EnrichedFlow) NextHopObj() net.IP

func (*EnrichedFlow) Peer 

func (flow *EnrichedFlow) Peer() string

func (*EnrichedFlow) ProtoMessage 

func (*EnrichedFlow) ProtoMessage()

func (*EnrichedFlow) ProtoReflect 

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

func (*EnrichedFlow) Reset 

func (x *EnrichedFlow) Reset()

func (*EnrichedFlow) SamplerAddressObj 

func (flow *EnrichedFlow) SamplerAddressObj() net.IP

func (*EnrichedFlow) SrcAddrObj 

func (flow *EnrichedFlow) SrcAddrObj() net.IP

func (*EnrichedFlow) String 

func (x *EnrichedFlow) String() string

type EnrichedFlow_AnonymizedType 

type EnrichedFlow_AnonymizedType int32

modify/anonymize 

const (
	EnrichedFlow_NotAnonymized EnrichedFlow_AnonymizedType = 0
	EnrichedFlow_CryptoPAN     EnrichedFlow_AnonymizedType = 1
)

func (EnrichedFlow_AnonymizedType) Descriptor 

func (EnrichedFlow_AnonymizedType) Descriptor() protoreflect.EnumDescriptor

func (EnrichedFlow_AnonymizedType) Enum 

func (x EnrichedFlow_AnonymizedType) Enum() *EnrichedFlow_AnonymizedType

func (EnrichedFlow_AnonymizedType) EnumDescriptor deprecated 

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

Deprecated: Use EnrichedFlow_AnonymizedType.Descriptor instead.

func (EnrichedFlow_AnonymizedType) Number 

func (x EnrichedFlow_AnonymizedType) Number() protoreflect.EnumNumber

func (EnrichedFlow_AnonymizedType) String 

func (x EnrichedFlow_AnonymizedType) String() string

func (EnrichedFlow_AnonymizedType) Type 

func (EnrichedFlow_AnonymizedType) Type() protoreflect.EnumType

type EnrichedFlow_FlowType 

type EnrichedFlow_FlowType int32
const (
	EnrichedFlow_FLOWUNKNOWN EnrichedFlow_FlowType = 0
	EnrichedFlow_SFLOW_5     EnrichedFlow_FlowType = 1
	EnrichedFlow_NETFLOW_V5  EnrichedFlow_FlowType = 2
	EnrichedFlow_NETFLOW_V9  EnrichedFlow_FlowType = 3
	EnrichedFlow_IPFIX       EnrichedFlow_FlowType = 4
	EnrichedFlow_EBPF        EnrichedFlow_FlowType = 5
)

func (EnrichedFlow_FlowType) Descriptor 

func (EnrichedFlow_FlowType) Descriptor() protoreflect.EnumDescriptor

func (EnrichedFlow_FlowType) Enum 

func (x EnrichedFlow_FlowType) Enum() *EnrichedFlow_FlowType

func (EnrichedFlow_FlowType) EnumDescriptor deprecated 

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

Deprecated: Use EnrichedFlow_FlowType.Descriptor instead.

func (EnrichedFlow_FlowType) Number 

func (x EnrichedFlow_FlowType) Number() protoreflect.EnumNumber

func (EnrichedFlow_FlowType) String 

func (x EnrichedFlow_FlowType) String() string

func (EnrichedFlow_FlowType) Type 

func (EnrichedFlow_FlowType) Type() protoreflect.EnumType

type EnrichedFlow_NormalizedType 

type EnrichedFlow_NormalizedType int32

modify/normalize 

const (
	EnrichedFlow_No  EnrichedFlow_NormalizedType = 0
	EnrichedFlow_Yes EnrichedFlow_NormalizedType = 1
)

func (EnrichedFlow_NormalizedType) Descriptor 

func (EnrichedFlow_NormalizedType) Descriptor() protoreflect.EnumDescriptor

func (EnrichedFlow_NormalizedType) Enum 

func (x EnrichedFlow_NormalizedType) Enum() *EnrichedFlow_NormalizedType

func (EnrichedFlow_NormalizedType) EnumDescriptor deprecated 

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

Deprecated: Use EnrichedFlow_NormalizedType.Descriptor instead.

func (EnrichedFlow_NormalizedType) Number 

func (x EnrichedFlow_NormalizedType) Number() protoreflect.EnumNumber

func (EnrichedFlow_NormalizedType) String 

func (x EnrichedFlow_NormalizedType) String() string

func (EnrichedFlow_NormalizedType) Type 

func (EnrichedFlow_NormalizedType) Type() protoreflect.EnumType

type EnrichedFlow_RemoteAddrType 

type EnrichedFlow_RemoteAddrType int32

modify/remoteaddress 

const (
	EnrichedFlow_Neither EnrichedFlow_RemoteAddrType = 0
	EnrichedFlow_Src     EnrichedFlow_RemoteAddrType = 1
	EnrichedFlow_Dst     EnrichedFlow_RemoteAddrType = 2
)

func (EnrichedFlow_RemoteAddrType) Descriptor 

func (EnrichedFlow_RemoteAddrType) Descriptor() protoreflect.EnumDescriptor

func (EnrichedFlow_RemoteAddrType) Enum 

func (x EnrichedFlow_RemoteAddrType) Enum() *EnrichedFlow_RemoteAddrType

func (EnrichedFlow_RemoteAddrType) EnumDescriptor deprecated 

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

Deprecated: Use EnrichedFlow_RemoteAddrType.Descriptor instead.

func (EnrichedFlow_RemoteAddrType) Number 

func (x EnrichedFlow_RemoteAddrType) Number() protoreflect.EnumNumber

func (EnrichedFlow_RemoteAddrType) String 

func (x EnrichedFlow_RemoteAddrType) String() string

func (EnrichedFlow_RemoteAddrType) Type 

func (EnrichedFlow_RemoteAddrType) Type() protoreflect.EnumType

type EnrichedFlow_ValidationStatusType 

type EnrichedFlow_ValidationStatusType int32
const (
	EnrichedFlow_Unknown  EnrichedFlow_ValidationStatusType = 0
	EnrichedFlow_Valid    EnrichedFlow_ValidationStatusType = 1
	EnrichedFlow_NotFound EnrichedFlow_ValidationStatusType = 2
	EnrichedFlow_Invalid  EnrichedFlow_ValidationStatusType = 3
)

func (EnrichedFlow_ValidationStatusType) Descriptor 

func (EnrichedFlow_ValidationStatusType) Descriptor() protoreflect.EnumDescriptor

func (EnrichedFlow_ValidationStatusType) Enum 

func (x EnrichedFlow_ValidationStatusType) Enum() *EnrichedFlow_ValidationStatusType

func (EnrichedFlow_ValidationStatusType) EnumDescriptor deprecated 

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

Deprecated: Use EnrichedFlow_ValidationStatusType.Descriptor instead.

func (EnrichedFlow_ValidationStatusType) Number 

func (x EnrichedFlow_ValidationStatusType) Number() protoreflect.EnumNumber

func (EnrichedFlow_ValidationStatusType) String 

func (x EnrichedFlow_ValidationStatusType) String() string

func (EnrichedFlow_ValidationStatusType) Type 

func (EnrichedFlow_ValidationStatusType) 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.