flowdocument

package
v0.3.4 Latest Latest
Warning

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

 Go to latest Published: Mar 14, 2024 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",
		255: "UNKNOWN",
	}
	Direction_value = map[string]int32{
		"INGRESS": 0,
		"EGRESS":  1,
		"UNKNOWN": 255,
	}
)

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",
		3: "SFLOW",
	}
	NetflowVersion_value = map[string]int32{
		"V5":    0,
		"V9":    1,
		"IPFIX": 2,
		"SFLOW": 3,
	}
)

Enum value maps for NetflowVersion.

View Source 
var (
	Locality_name = map[int32]string{
		0: "PUBLIC",
		1: "PRIVATE",
	}
	Locality_value = map[string]int32{
		"PUBLIC":  0,
		"PRIVATE": 1,
	}
)

Enum value maps for Locality.

View Source 
var File_flowdocument_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Direction 

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

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 FlowDocument 

type FlowDocument 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=flowdocument.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.
	/* 150-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          ``                                                                                                               // Netflow version
	/* 138-byte string literal not displayed */
	Vlan            string                  `protobuf:"bytes,34,opt,name=vlan,proto3" json:"vlan,omitempty"` // VLAN ID.
	SrcNode         *NodeInfo               `protobuf:"bytes,35,opt,name=src_node,json=srcNode,proto3" json:"src_node,omitempty"`
	ExporterNode    *NodeInfo               `protobuf:"bytes,36,opt,name=exporter_node,json=exporterNode,proto3" json:"exporter_node,omitempty"`
	DestNode        *NodeInfo               `protobuf:"bytes,37,opt,name=dest_node,json=destNode,proto3" json:"dest_node,omitempty"`
	Application     string                  `protobuf:"bytes,38,opt,name=application,proto3" json:"application,omitempty"`
	Host            string                  `protobuf:"bytes,39,opt,name=host,proto3" json:"host,omitempty"`
	Location        string                  `protobuf:"bytes,40,opt,name=location,proto3" json:"location,omitempty"`
	SrcLocality     Locality                `protobuf:"varint,41,opt,name=src_locality,json=srcLocality,proto3,enum=flowdocument.Locality" json:"src_locality,omitempty"`
	DstLocality     Locality                `protobuf:"varint,42,opt,name=dst_locality,json=dstLocality,proto3,enum=flowdocument.Locality" json:"dst_locality,omitempty"`
	FlowLocality    Locality                ``                                                                                                             /* 126-byte string literal not displayed */
	ClockCorrection uint64                  `protobuf:"varint,45,opt,name=clock_correction,json=clockCorrection,proto3" json:"clock_correction,omitempty"` // Applied clock correction im milliseconds.
	Dscp            *wrapperspb.UInt32Value `protobuf:"bytes,46,opt,name=dscp,proto3" json:"dscp,omitempty"`                                               // DSCP; upper 6 bits of TOS
	Ecn             *wrapperspb.UInt32Value `protobuf:"bytes,47,opt,name=ecn,proto3" json:"ecn,omitempty"`                                                 // ECN; lower 2 bits of TOS
	// contains filtered or unexported fields
}

func (*FlowDocument) Descriptor deprecated 

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

Deprecated: Use FlowDocument.ProtoReflect.Descriptor instead.

func (*FlowDocument) GetApplication 

func (x *FlowDocument) GetApplication() string

func (*FlowDocument) GetClockCorrection 

func (x *FlowDocument) GetClockCorrection() uint64

func (*FlowDocument) GetDeltaSwitched 

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

func (*FlowDocument) GetDestNode 

func (x *FlowDocument) GetDestNode() *NodeInfo

func (*FlowDocument) GetDirection 

func (x *FlowDocument) GetDirection() Direction

func (*FlowDocument) GetDscp added in v0.3.3 

func (x *FlowDocument) GetDscp() *wrapperspb.UInt32Value

func (*FlowDocument) GetDstAddress 

func (x *FlowDocument) GetDstAddress() string

func (*FlowDocument) GetDstAs 

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

func (*FlowDocument) GetDstHostname 

func (x *FlowDocument) GetDstHostname() string

func (*FlowDocument) GetDstLocality 

func (x *FlowDocument) GetDstLocality() Locality

func (*FlowDocument) GetDstMaskLen 

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

func (*FlowDocument) GetDstPort 

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

func (*FlowDocument) GetEcn added in v0.3.3 

func (x *FlowDocument) GetEcn() *wrapperspb.UInt32Value

func (*FlowDocument) GetEngineId 

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

func (*FlowDocument) GetEngineType 

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

func (*FlowDocument) GetExporterNode 

func (x *FlowDocument) GetExporterNode() *NodeInfo

func (*FlowDocument) GetFirstSwitched 

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

func (*FlowDocument) GetFlowLocality 

func (x *FlowDocument) GetFlowLocality() Locality

func (*FlowDocument) GetFlowSeqNum 

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

func (*FlowDocument) GetHost 

func (x *FlowDocument) GetHost() string

func (*FlowDocument) GetInputSnmpIfindex 

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

func (*FlowDocument) GetIpProtocolVersion 

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

func (*FlowDocument) GetLastSwitched 

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

func (*FlowDocument) GetLocation 

func (x *FlowDocument) GetLocation() string

func (*FlowDocument) GetNetflowVersion 

func (x *FlowDocument) GetNetflowVersion() NetflowVersion

func (*FlowDocument) GetNextHopAddress 

func (x *FlowDocument) GetNextHopAddress() string

func (*FlowDocument) GetNextHopHostname 

func (x *FlowDocument) GetNextHopHostname() string

func (*FlowDocument) GetNumBytes 

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

func (*FlowDocument) GetNumFlowRecords 

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

func (*FlowDocument) GetNumPackets 

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

func (*FlowDocument) GetOutputSnmpIfindex 

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

func (*FlowDocument) GetProtocol 

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

func (*FlowDocument) GetSamplingAlgorithm 

func (x *FlowDocument) GetSamplingAlgorithm() SamplingAlgorithm

func (*FlowDocument) GetSamplingInterval 

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

func (*FlowDocument) GetSrcAddress 

func (x *FlowDocument) GetSrcAddress() string

func (*FlowDocument) GetSrcAs 

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

func (*FlowDocument) GetSrcHostname 

func (x *FlowDocument) GetSrcHostname() string

func (*FlowDocument) GetSrcLocality 

func (x *FlowDocument) GetSrcLocality() Locality

func (*FlowDocument) GetSrcMaskLen 

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

func (*FlowDocument) GetSrcNode 

func (x *FlowDocument) GetSrcNode() *NodeInfo

func (*FlowDocument) GetSrcPort 

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

func (*FlowDocument) GetTcpFlags 

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

func (*FlowDocument) GetTimestamp 

func (x *FlowDocument) GetTimestamp() uint64

func (*FlowDocument) GetTos 

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

func (*FlowDocument) GetVlan 

func (x *FlowDocument) GetVlan() string

func (*FlowDocument) ProtoMessage 

func (*FlowDocument) ProtoMessage()

func (*FlowDocument) ProtoReflect 

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

func (*FlowDocument) Reset 

func (x *FlowDocument) Reset()

func (*FlowDocument) String 

func (x *FlowDocument) String() string

type Locality 

type Locality int32
const (
	Locality_PUBLIC  Locality = 0
	Locality_PRIVATE Locality = 1
)

func (Locality) Descriptor 

func (Locality) Descriptor() protoreflect.EnumDescriptor

func (Locality) Enum 

func (x Locality) Enum() *Locality

func (Locality) EnumDescriptor deprecated 

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

Deprecated: Use Locality.Descriptor instead.

func (Locality) Number 

func (x Locality) Number() protoreflect.EnumNumber

func (Locality) String 

func (x Locality) String() string

func (Locality) Type 

func (Locality) Type() protoreflect.EnumType

type NetflowVersion 

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

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 NodeInfo 

type NodeInfo struct {
	ForeignSource string   `protobuf:"bytes,1,opt,name=foreign_source,json=foreignSource,proto3" json:"foreign_source,omitempty"`
	ForeginId     string   `protobuf:"bytes,2,opt,name=foregin_id,json=foreginId,proto3" json:"foregin_id,omitempty"`
	NodeId        uint32   `protobuf:"varint,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Categories    []string `protobuf:"bytes,4,rep,name=categories,proto3" json:"categories,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated 

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

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetCategories 

func (x *NodeInfo) GetCategories() []string

func (*NodeInfo) GetForeginId 

func (x *NodeInfo) GetForeginId() string

func (*NodeInfo) GetForeignSource 

func (x *NodeInfo) GetForeignSource() string

func (*NodeInfo) GetNodeId 

func (x *NodeInfo) GetNodeId() uint32

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect 

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

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

func (x *NodeInfo) String() string

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.