netflow

package
v0.1.8 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2021 License: AGPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Direction_name = map[int32]string{
		0: "INGRESS",
		1: "EGRESS",
	}
	Direction_value = map[string]int32{
		"INGRESS": 0,
		"EGRESS":  1,
	}
)

Enum value maps for Direction.

View Source 
var (
	SamplingAlgorithm_name = map[int32]string{
		0: "UNASSIGNED",
		1: "SYSTEMATIC_COUNT_BASED_SAMPLING",
		2: "SYSTEMATIC_TIME_BASED_SAMPLING",
		3: "RANDOM_N_OUT_OF_N_SAMPLING",
		4: "UNIFORM_PROBABILISTIC_SAMPLING",
		5: "PROPERTY_MATCH_FILTERING",
		6: "HASH_BASED_FILTERING",
		7: "FLOW_STATE_DEPENDENT_INTERMEDIATE_FLOW_SELECTION_PROCESS",
	}
	SamplingAlgorithm_value = map[string]int32{
		"UNASSIGNED":                                               0,
		"SYSTEMATIC_COUNT_BASED_SAMPLING":                          1,
		"SYSTEMATIC_TIME_BASED_SAMPLING":                           2,
		"RANDOM_N_OUT_OF_N_SAMPLING":                               3,
		"UNIFORM_PROBABILISTIC_SAMPLING":                           4,
		"PROPERTY_MATCH_FILTERING":                                 5,
		"HASH_BASED_FILTERING":                                     6,
		"FLOW_STATE_DEPENDENT_INTERMEDIATE_FLOW_SELECTION_PROCESS": 7,
	}
)

Enum value maps for SamplingAlgorithm.

View Source 
var (
	NetflowVersion_name = map[int32]string{
		0: "V5",
		1: "V9",
		2: "IPFIX",
	}
	NetflowVersion_value = map[string]int32{
		"V5":    0,
		"V9":    1,
		"IPFIX": 2,
	}
)

Enum value maps for NetflowVersion.

View Source 
var File_netflow_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Direction 

type Direction int32
const (
	Direction_INGRESS Direction = 0
	Direction_EGRESS  Direction = 1
)

func (Direction) Descriptor 

func (Direction) Descriptor() protoreflect.EnumDescriptor

func (Direction) Enum 

func (x Direction) Enum() *Direction

func (Direction) EnumDescriptor deprecated 

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

Deprecated: Use Direction.Descriptor instead.

func (Direction) Number 

func (x Direction) Number() protoreflect.EnumNumber

func (Direction) String 

func (x Direction) String() string

func (Direction) Type 

func (Direction) Type() protoreflect.EnumType

type FlowMessage 

type FlowMessage struct {
	Timestamp     uint64                  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                              // Flow timestamp in milliseconds.
	NumBytes      *wrapperspb.UInt64Value `protobuf:"bytes,2,opt,name=num_bytes,json=numBytes,proto3" json:"num_bytes,omitempty"`                 // Number of bytes transferred in the flow
	Direction     Direction               `protobuf:"varint,3,opt,name=direction,proto3,enum=Direction" json:"direction,omitempty"`               // Direction of the flow (egress vs ingress)
	DstAddress    string                  `protobuf:"bytes,4,opt,name=dst_address,json=dstAddress,proto3" json:"dst_address,omitempty"`           //  Destination address.
	DstHostname   string                  `protobuf:"bytes,5,opt,name=dst_hostname,json=dstHostname,proto3" json:"dst_hostname,omitempty"`        // Destination address hostname.
	DstAs         *wrapperspb.UInt64Value `protobuf:"bytes,6,opt,name=dst_as,json=dstAs,proto3" json:"dst_as,omitempty"`                          // Destination autonomous system (AS).
	DstMaskLen    *wrapperspb.UInt32Value `protobuf:"bytes,7,opt,name=dst_mask_len,json=dstMaskLen,proto3" json:"dst_mask_len,omitempty"`         // The number of contiguous bits in the source address subnet mask.
	DstPort       *wrapperspb.UInt32Value `protobuf:"bytes,8,opt,name=dst_port,json=dstPort,proto3" json:"dst_port,omitempty"`                    // Destination port.
	EngineId      *wrapperspb.UInt32Value `protobuf:"bytes,9,opt,name=engine_id,json=engineId,proto3" json:"engine_id,omitempty"`                 // Slot number of the flow-switching engine.
	EngineType    *wrapperspb.UInt32Value `protobuf:"bytes,10,opt,name=engine_type,json=engineType,proto3" json:"engine_type,omitempty"`          // Type of flow-switching engine.
	DeltaSwitched *wrapperspb.UInt64Value `protobuf:"bytes,11,opt,name=delta_switched,json=deltaSwitched,proto3" json:"delta_switched,omitempty"` // Unix timestamp in ms at which the previous exported packet-
	// -associated with this flow was switched.
	FirstSwitched *wrapperspb.UInt64Value `protobuf:"bytes,12,opt,name=first_switched,json=firstSwitched,proto3" json:"first_switched,omitempty"` // Unix timestamp in ms at which the first packet-
	// -associated with this flow was switched.
	LastSwitched      *wrapperspb.UInt64Value `protobuf:"bytes,13,opt,name=last_switched,json=lastSwitched,proto3" json:"last_switched,omitempty"`
	NumFlowRecords    *wrapperspb.UInt32Value `protobuf:"bytes,14,opt,name=num_flow_records,json=numFlowRecords,proto3" json:"num_flow_records,omitempty"`          // Number of flow records in the associated packet.
	NumPackets        *wrapperspb.UInt64Value `protobuf:"bytes,15,opt,name=num_packets,json=numPackets,proto3" json:"num_packets,omitempty"`                        // Number of packets in the flow.
	FlowSeqNum        *wrapperspb.UInt64Value `protobuf:"bytes,16,opt,name=flow_seq_num,json=flowSeqNum,proto3" json:"flow_seq_num,omitempty"`                      // Flow packet sequence number.
	InputSnmpIfindex  *wrapperspb.UInt32Value `protobuf:"bytes,17,opt,name=input_snmp_ifindex,json=inputSnmpIfindex,proto3" json:"input_snmp_ifindex,omitempty"`    // Input SNMP ifIndex.
	OutputSnmpIfindex *wrapperspb.UInt32Value `protobuf:"bytes,18,opt,name=output_snmp_ifindex,json=outputSnmpIfindex,proto3" json:"output_snmp_ifindex,omitempty"` // Output SNMP ifIndex.
	IpProtocolVersion *wrapperspb.UInt32Value `protobuf:"bytes,19,opt,name=ip_protocol_version,json=ipProtocolVersion,proto3" json:"ip_protocol_version,omitempty"` // IPv4 vs IPv6.
	NextHopAddress    string                  `protobuf:"bytes,20,opt,name=next_hop_address,json=nextHopAddress,proto3" json:"next_hop_address,omitempty"`          // Next hop IpAddress.
	NextHopHostname   string                  `protobuf:"bytes,21,opt,name=next_hop_hostname,json=nextHopHostname,proto3" json:"next_hop_hostname,omitempty"`       // Next hop hostname.
	Protocol          *wrapperspb.UInt32Value `protobuf:"bytes,22,opt,name=protocol,proto3" json:"protocol,omitempty"`                                              // IP protocol number i.e 6 for TCP, 17 for UDP
	SamplingAlgorithm SamplingAlgorithm       ``                                                                                                                    // Sampling algorithm ID.
	/* 137-byte string literal not displayed */
	SamplingInterval *wrapperspb.DoubleValue `protobuf:"bytes,24,opt,name=sampling_interval,json=samplingInterval,proto3" json:"sampling_interval,omitempty"`                // Sampling interval.
	SrcAddress       string                  `protobuf:"bytes,26,opt,name=src_address,json=srcAddress,proto3" json:"src_address,omitempty"`                                  // Source address.
	SrcHostname      string                  `protobuf:"bytes,27,opt,name=src_hostname,json=srcHostname,proto3" json:"src_hostname,omitempty"`                               // Source hostname.
	SrcAs            *wrapperspb.UInt64Value `protobuf:"bytes,28,opt,name=src_as,json=srcAs,proto3" json:"src_as,omitempty"`                                                 // Source AS number.
	SrcMaskLen       *wrapperspb.UInt32Value `protobuf:"bytes,29,opt,name=src_mask_len,json=srcMaskLen,proto3" json:"src_mask_len,omitempty"`                                // The number of contiguous bits in the destination address subnet mask.
	SrcPort          *wrapperspb.UInt32Value `protobuf:"bytes,30,opt,name=src_port,json=srcPort,proto3" json:"src_port,omitempty"`                                           // Source port.
	TcpFlags         *wrapperspb.UInt32Value `protobuf:"bytes,31,opt,name=tcp_flags,json=tcpFlags,proto3" json:"tcp_flags,omitempty"`                                        // TCP Flags.
	Tos              *wrapperspb.UInt32Value `protobuf:"bytes,32,opt,name=tos,proto3" json:"tos,omitempty"`                                                                  // TOS
	NetflowVersion   NetflowVersion          `protobuf:"varint,33,opt,name=netflow_version,json=netflowVersion,proto3,enum=NetflowVersion" json:"netflow_version,omitempty"` // Netflow version
	Vlan             *wrapperspb.UInt32Value `protobuf:"bytes,34,opt,name=vlan,proto3" json:"vlan,omitempty"`                                                                // VLAN ID.
	NodeIdentifier   string                  `protobuf:"bytes,35,opt,name=node_identifier,json=nodeIdentifier,proto3" json:"node_identifier,omitempty"`                      // node lookup identifier.
	// contains filtered or unexported fields
}

func (*FlowMessage) Descriptor deprecated 

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

Deprecated: Use FlowMessage.ProtoReflect.Descriptor instead.

func (*FlowMessage) GetDeltaSwitched 

func (x *FlowMessage) GetDeltaSwitched() *wrapperspb.UInt64Value

func (*FlowMessage) GetDirection 

func (x *FlowMessage) GetDirection() Direction

func (*FlowMessage) GetDstAddress 

func (x *FlowMessage) GetDstAddress() string

func (*FlowMessage) GetDstAs 

func (x *FlowMessage) GetDstAs() *wrapperspb.UInt64Value

func (*FlowMessage) GetDstHostname 

func (x *FlowMessage) GetDstHostname() string

func (*FlowMessage) GetDstMaskLen 

func (x *FlowMessage) GetDstMaskLen() *wrapperspb.UInt32Value

func (*FlowMessage) GetDstPort 

func (x *FlowMessage) GetDstPort() *wrapperspb.UInt32Value

func (*FlowMessage) GetEngineId 

func (x *FlowMessage) GetEngineId() *wrapperspb.UInt32Value

func (*FlowMessage) GetEngineType 

func (x *FlowMessage) GetEngineType() *wrapperspb.UInt32Value

func (*FlowMessage) GetFirstSwitched 

func (x *FlowMessage) GetFirstSwitched() *wrapperspb.UInt64Value

func (*FlowMessage) GetFlowSeqNum 

func (x *FlowMessage) GetFlowSeqNum() *wrapperspb.UInt64Value

func (*FlowMessage) GetInputSnmpIfindex 

func (x *FlowMessage) GetInputSnmpIfindex() *wrapperspb.UInt32Value

func (*FlowMessage) GetIpProtocolVersion 

func (x *FlowMessage) GetIpProtocolVersion() *wrapperspb.UInt32Value

func (*FlowMessage) GetLastSwitched 

func (x *FlowMessage) GetLastSwitched() *wrapperspb.UInt64Value

func (*FlowMessage) GetNetflowVersion 

func (x *FlowMessage) GetNetflowVersion() NetflowVersion

func (*FlowMessage) GetNextHopAddress 

func (x *FlowMessage) GetNextHopAddress() string

func (*FlowMessage) GetNextHopHostname 

func (x *FlowMessage) GetNextHopHostname() string

func (*FlowMessage) GetNodeIdentifier 

func (x *FlowMessage) GetNodeIdentifier() string

func (*FlowMessage) GetNumBytes 

func (x *FlowMessage) GetNumBytes() *wrapperspb.UInt64Value

func (*FlowMessage) GetNumFlowRecords 

func (x *FlowMessage) GetNumFlowRecords() *wrapperspb.UInt32Value

func (*FlowMessage) GetNumPackets 

func (x *FlowMessage) GetNumPackets() *wrapperspb.UInt64Value

func (*FlowMessage) GetOutputSnmpIfindex 

func (x *FlowMessage) GetOutputSnmpIfindex() *wrapperspb.UInt32Value

func (*FlowMessage) GetProtocol 

func (x *FlowMessage) GetProtocol() *wrapperspb.UInt32Value

func (*FlowMessage) GetSamplingAlgorithm 

func (x *FlowMessage) GetSamplingAlgorithm() SamplingAlgorithm

func (*FlowMessage) GetSamplingInterval 

func (x *FlowMessage) GetSamplingInterval() *wrapperspb.DoubleValue

func (*FlowMessage) GetSrcAddress 

func (x *FlowMessage) GetSrcAddress() string

func (*FlowMessage) GetSrcAs 

func (x *FlowMessage) GetSrcAs() *wrapperspb.UInt64Value

func (*FlowMessage) GetSrcHostname 

func (x *FlowMessage) GetSrcHostname() string

func (*FlowMessage) GetSrcMaskLen 

func (x *FlowMessage) GetSrcMaskLen() *wrapperspb.UInt32Value

func (*FlowMessage) GetSrcPort 

func (x *FlowMessage) GetSrcPort() *wrapperspb.UInt32Value

func (*FlowMessage) GetTcpFlags 

func (x *FlowMessage) GetTcpFlags() *wrapperspb.UInt32Value

func (*FlowMessage) GetTimestamp 

func (x *FlowMessage) GetTimestamp() uint64

func (*FlowMessage) GetTos 

func (x *FlowMessage) GetTos() *wrapperspb.UInt32Value

func (*FlowMessage) GetVlan 

func (x *FlowMessage) GetVlan() *wrapperspb.UInt32Value

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 NetflowVersion 

type NetflowVersion int32
const (
	NetflowVersion_V5    NetflowVersion = 0
	NetflowVersion_V9    NetflowVersion = 1
	NetflowVersion_IPFIX NetflowVersion = 2
)

func (NetflowVersion) Descriptor 

func (NetflowVersion) Descriptor() protoreflect.EnumDescriptor

func (NetflowVersion) Enum 

func (x NetflowVersion) Enum() *NetflowVersion

func (NetflowVersion) EnumDescriptor deprecated 

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

Deprecated: Use NetflowVersion.Descriptor instead.

func (NetflowVersion) Number 

func (x NetflowVersion) Number() protoreflect.EnumNumber

func (NetflowVersion) String 

func (x NetflowVersion) String() string

func (NetflowVersion) Type 

func (NetflowVersion) Type() protoreflect.EnumType

type SamplingAlgorithm 

type SamplingAlgorithm int32
const (
	SamplingAlgorithm_UNASSIGNED                                               SamplingAlgorithm = 0
	SamplingAlgorithm_SYSTEMATIC_COUNT_BASED_SAMPLING                          SamplingAlgorithm = 1
	SamplingAlgorithm_SYSTEMATIC_TIME_BASED_SAMPLING                           SamplingAlgorithm = 2
	SamplingAlgorithm_RANDOM_N_OUT_OF_N_SAMPLING                               SamplingAlgorithm = 3
	SamplingAlgorithm_UNIFORM_PROBABILISTIC_SAMPLING                           SamplingAlgorithm = 4
	SamplingAlgorithm_PROPERTY_MATCH_FILTERING                                 SamplingAlgorithm = 5
	SamplingAlgorithm_HASH_BASED_FILTERING                                     SamplingAlgorithm = 6
	SamplingAlgorithm_FLOW_STATE_DEPENDENT_INTERMEDIATE_FLOW_SELECTION_PROCESS SamplingAlgorithm = 7
)

func (SamplingAlgorithm) Descriptor 

func (SamplingAlgorithm) Descriptor() protoreflect.EnumDescriptor

func (SamplingAlgorithm) Enum 

func (x SamplingAlgorithm) Enum() *SamplingAlgorithm

func (SamplingAlgorithm) EnumDescriptor deprecated 

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

Deprecated: Use SamplingAlgorithm.Descriptor instead.

func (SamplingAlgorithm) Number 

func (x SamplingAlgorithm) Number() protoreflect.EnumNumber

func (SamplingAlgorithm) String 

func (x SamplingAlgorithm) String() string

func (SamplingAlgorithm) Type 

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