Toolkit com.teracloud.streams.network 5.1.1

General Information

Operators and functions for ingesting and parsing raw network data at the packet level.

Release notes

Requirements for DPDK operators

A Data Plane Development Kit (DPDK) installation is required and must be configured on all hosts expected to run a Streams application with DPDK operators.

Running applications with operators requiring Linux capabilities

The following operators require special privileges (Linux capabilities) to interact with raw network packets and kernel drivers:

Version

5.1.1

Required Product Version

7.2.0.0

Indexes

Namespaces

Operators

Functions

Types

Namespaces

com.teracloud.streams.network.content

Operators

• PacketContentAssembler

Functions

• EVENT()
• EVENT_FILE_CHUNK()
• EVENT_FLOW_DATA()
• EVENT_FLOW_END()
• EVENT_FLOW_START()
• EVENT_FLOW_TLS()
• EVENT_REQUEST()
• EVENT_RESPONSE()
• FILE_CHUNK_BINARY()
• FILE_CHUNK_COUNTER()
• FILE_CHUNK_FINAL()
• FILE_CHUNK_INITIAL()
• FILE_CHUNK_LENGTH()
• FILE_CHUNK_LENGTH_SUM()
• FILE_CHUNK_STRING()
• FILE_CONTENT_CHARSET()
• FILE_CONTENT_LENGTH()
• FILE_CONTENT_TYPE()
• FILE_FORMAT()
• FILE_ID()
• FILE_ID_PARENT()
• FLOW_DATA_BINARY()
• FLOW_DATA_COUNTER()
• FLOW_DATA_LENGTH()
• FLOW_DATA_STRING()
• FLOW_DIRECTION()
• FLOW_DISCONNECT_REASON()
• FLOW_DST_BYTES()
• FLOW_DST_PACKETS()
• FLOW_DST_PORT()
• FLOW_ELAPSED_TIME()
• FLOW_END_TIME()
• FLOW_ETHER_DST_ADDRESS()
• FLOW_ETHER_SRC_ADDRESS()
• FLOW_EVENT_TIME()
• FLOW_ID()
• FLOW_IPV4_DST_ADDRESS()
• FLOW_IPV4_SRC_ADDRESS()
• FLOW_IP_PROTOCOL()
• FLOW_PROTOCOL()
• FLOW_PROTOCOL_CONFIDENCE()
• FLOW_PROTOCOL_DEPTH()
• FLOW_REQUEST_HEADERS()
• FLOW_REQUEST_URI_AUTHORITY()
• FLOW_REQUEST_URI_FRAGMENT()
• FLOW_REQUEST_URI_METHOD()
• FLOW_REQUEST_URI_NORMALIZED()
• FLOW_REQUEST_URI_PATH()
• FLOW_REQUEST_URI_QUERY()
• FLOW_REQUEST_URI_RAW()
• FLOW_REQUEST_URI_SCHEME()
• FLOW_REQUEST_URI_USERNAME()
• FLOW_RESPONSE_HEADERS()
• FLOW_RESPONSE_STATUS_CODE()
• FLOW_SRC_BYTES()
• FLOW_SRC_PACKETS()
• FLOW_SRC_PORT()
• FLOW_START_TIME()
• FLOW_TRANSACTION_ID()
• OPEN_FILES()
• OPEN_FILES_HIGH_WATER_MARK()
• OPEN_FLOWS()
• OPEN_FLOWS_HIGH_WATER_MARK()
• TLS_RECORD_DIRECTION()
• TLS_RECORD_LENGTH()
• TLS_RECORD_MORE()
• TLS_RECORD_OFFSET()
• TLS_RECORD_TYPE()
• TLS_VERSION()
• TUNNEL_IPV4_DST_ADDRESS()
• TUNNEL_IPV4_SRC_ADDRESS()
• TUNNEL_IPV6_DST_ADDRESS()
• TUNNEL_IPV6_SRC_ADDRESS()
• TUNNEL_TYPE()

com.teracloud.streams.network.datetimeformat

Functions

• formatElapsedTime(float64)
• formatElapsedTime(float64, uint32)
• formatElapsedTime(uint32)
• formatEpoch(uint32, rstring)
• formatEpochDateTime(float64)
• formatEpochDateTime(float64, uint32)
• formatEpochDateTime(timestamp)
• formatEpochDateTime(timestamp, uint32)
• formatEpochDateTime(uint32)
• formatEpochTime(float64)
• formatEpochTime(float64, uint32)
• formatEpochTime(timestamp)
• formatEpochTime(timestamp, uint32)
• formatEpochTime(uint32)
• formatSubseconds(float64, uint32)
• formatSubseconds(timestamp, uint32)

com.teracloud.streams.network.dns

Operators

• DNSPacketDPDKSource
• DNSPacketFileSource
• DNSPacketLiveSource

Functions

• CAPTURE_MICROSECONDS()
• CAPTURE_SECONDS()
• CAPTURE_TSC_MICROSECONDS()
• DNS_ADDITIONAL_CLASSES()
• DNS_ADDITIONAL_COUNT()
• DNS_ADDITIONAL_DATA()
• DNS_ADDITIONAL_DATA(rstring)
• DNS_ADDITIONAL_NAMES()
• DNS_ADDITIONAL_TTLS()
• DNS_ADDITIONAL_TYPES()
• DNS_ALL_FIELDS(rstring, rstring, rstring)
• DNS_ALL_FIELDS(rstring, rstring, rstring, list<uint16>)
• DNS_ALL_FLAGS()
• DNS_ANSWER_ADDRESS()
• DNS_ANSWER_ADDRESSES()
• DNS_ANSWER_CANONICAL()
• DNS_ANSWER_CLASSES()
• DNS_ANSWER_COUNT()
• DNS_ANSWER_DATA()
• DNS_ANSWER_IPV4_ADDRESS()
• DNS_ANSWER_IPV4_ADDRESSES()
• DNS_ANSWER_IPV6_ADDRESS()
• DNS_ANSWER_IPV6_ADDRESSES()
• DNS_ANSWER_NAMES()
• DNS_ANSWER_TTLS()
• DNS_ANSWER_TYPES()
• DNS_AUTHORITATIVE_FLAG()
• DNS_EXTRA_DATA()
• DNS_IDENTIFIER()
• DNS_INCOMPATIBLE_FLAGS()
• DNS_NAMESERVER_CLASSES()
• DNS_NAMESERVER_COUNT()
• DNS_NAMESERVER_DATA()
• DNS_NAMESERVER_DATA(rstring)
• DNS_NAMESERVER_NAMES()
• DNS_NAMESERVER_TTLS()
• DNS_NAMESERVER_TYPES()
• DNS_OPCODE()
• DNS_QUESTION_CLASS()
• DNS_QUESTION_CLASSES()
• DNS_QUESTION_COUNT()
• DNS_QUESTION_NAME()
• DNS_QUESTION_NAMES()
• DNS_QUESTION_TYPE()
• DNS_QUESTION_TYPES()
• DNS_RESPONSE_CODE()
• DNS_RESPONSE_FLAG()
• DNS_TRUNCATION_FLAG()
• ETHER_DST_ADDRESS()
• ETHER_DST_ADDRESS_64()
• ETHER_PROTOCOL()
• ETHER_SRC_ADDRESS()
• IPV4_DST_ADDRESS()
• IPV4_SRC_ADDRESS()
• IPV6_DST_ADDRESS()
• IPV6_SRC_ADDRESS()
• IP_DONT_FRAGMENT()
• IP_FRAGMENT_OFFSET()
• IP_IDENTIFIER()
• IP_MORE_FRAGMENTS()
• IP_PROTOCOL()
• IP_VERSION()
• PACKET_DATA()
• PACKET_LENGTH()
• PAYLOAD_DATA()
• PAYLOAD_LENGTH()
• RATE_LIMITED()
• UDP_DST_PORT()
• UDP_PORT(uint16)
• UDP_SRC_PORT()
• VLAN_TAGS()
• bytesProcessed()
• bytesReceived()
• metricsIntervalBytesProcessed()
• metricsIntervalBytesReceived()
• metricsIntervalElapsed()
• metricsIntervalMaxQueueDepthSW()
• metricsIntervalPacketsDropped()
• metricsIntervalPacketsDroppedSW()
• metricsIntervalPacketsProcessed()
• metricsIntervalPacketsReceived()
• metricsUpdated()
• packetsDropped()
• packetsDroppedSW()
• packetsProcessed()
• packetsReceived()
• parseError()
• parseErrorCode()
• parseErrorDescription()
• parseErrorOffset()

com.teracloud.streams.network.domains

Operators

• ExtractDomain
• SimpleExtractDomain

com.teracloud.streams.network.enrichment

Operators

• IPASNEnricher
• IPSpatialEnricher

Types

• IPASNInfo_t
• IPASNumber_t
• IPLocation_t

com.teracloud.streams.network.filter

Operators

• IPFilter
• TextFilter

com.teracloud.streams.network.geohash

Functions

• geohashDecode(rstring)
• geohashEncode(float64, float64, int32)

com.teracloud.streams.network.ipv4

Functions

• compare(rstring, rstring)
• convertHostnameToIPV4AddressNumeric(rstring)
• convertHostnameToIPV4AddressString(rstring)
• convertIPV4AddressNumericToHostname(uint32)
• convertIPV4AddressNumericToString(uint32)
• convertIPV4AddressNumericToSubnet(uint32, int32)
• convertIPV4AddressStringToHostname(rstring)
• convertIPV4AddressStringToNumeric(rstring)
• convertIPV4AddressStringToSubnet(rstring, int32)
• getAddressRangeInNetworkInt(rstring, uint32, uint32)
• getAllAddressesInNetwork(rstring)
• getAllAddressesInNetworkInt(rstring)
• isEqualTo(rstring, rstring)
• isGlobal(rstring)
• isGreaterThan(rstring, rstring)
• isIPV4Address(rstring)
• isIPV4CIDRNotation(rstring)
• isInIPRange(rstring, rstring, rstring)
• isInNetwork(rstring, rstring)
• isInNetwork(rstring, uint32)
• isInNetworkList(list<rstring>, rstring)
• isLessThan(rstring, rstring)
• isLinkLocal(rstring)
• isLoopback(rstring)
• isMulticast(rstring)
• isNetworkOverlap(rstring, rstring)
• isPrivate(rstring)
• isReserved(rstring)
• numAddressesInIPRange(rstring, rstring)
• numAddressesInNetwork(rstring)

com.teracloud.streams.network.ipv6

Functions

• compactIPV6(rstring)
• convertIPV6AddressNumericToString(list<uint8>[16])
• convertIPV6AddressStringToNumeric(rstring)
• expandIPV6(rstring)
• isEqualTo(rstring, rstring)
• isGreaterThan(rstring, rstring)
• isIPV6Address(rstring)
• isIPV6CIDRNotation(rstring)
• isInIPRange(rstring, rstring, rstring)
• isInNetwork(rstring, rstring)
• isInNetworkList(list<rstring>, rstring)
• isLessThan(rstring, rstring)
• isLinkLocal(rstring)
• isLoopback(rstring)
• isMulticast(rstring)
• isSiteLocal(rstring)
• isUnspecified(rstring)
• isV4Compatible(rstring)
• isV4Mapped(rstring)

com.teracloud.streams.network.location

Operators

• IPAddressLocation

Functions

• locationCityName(list<uint8>[16])
• locationCityName(uint32)
• locationCityNames(list<uint32>)
• locationContinentCode(list<uint8>[16])
• locationContinentCode(uint32)
• locationContinentCodes(list<uint32>)
• locationContinentName(list<uint8>[16])
• locationContinentName(uint32)
• locationContinentNames(list<uint32>)
• locationCountryCode(list<uint8>[16])
• locationCountryCode(uint32)
• locationCountryCodes(list<uint32>)
• locationCountryName(list<uint8>[16])
• locationCountryName(uint32)
• locationCountryNames(list<uint32>)
• locationFound(list<uint8>[16])
• locationFound(uint32)
• locationGeohash(list<uint8>[16], int32)
• locationGeohash(uint32, int32)
• locationID(list<uint8>[16])
• locationID(uint32)
• locationIDs(list<uint32>)
• locationInEU(list<uint8>[16])
• locationInEU(uint32)
• locationLatitude(list<uint8>[16])
• locationLatitude(uint32)
• locationLatitudes(list<uint32>)
• locationLongitude(list<uint8>[16])
• locationLongitude(uint32)
• locationLongitudes(list<uint32>)
• locationMetroCode(list<uint8>[16])
• locationMetroCode(uint32)
• locationPostalCode(list<uint8>[16])
• locationPostalCode(uint32)
• locationPostalCodes(list<uint32>)
• locationRadii(list<uint32>)
• locationRadius(list<uint8>[16])
• locationRadius(uint32)
• locationSubdivision1Code(list<uint8>[16])
• locationSubdivision1Code(uint32)
• locationSubdivision1Codes(list<uint32>)
• locationSubdivision1Name(list<uint8>[16])
• locationSubdivision1Name(uint32)
• locationSubdivision1Names(list<uint32>)
• locationSubdivision2Code(list<uint8>[16])
• locationSubdivision2Code(uint32)
• locationSubdivision2Codes(list<uint32>)
• locationSubdivision2Name(list<uint8>[16])
• locationSubdivision2Name(uint32)
• locationSubdivision2Names(list<uint32>)
• locationSubnet(list<uint8>[16])
• locationSubnet(uint32)
• locationSubnetAddress(list<uint8>[16])
• locationSubnetAddress(uint32)
• locationSubnetAddresses(list<uint32>)
• locationSubnetMask(list<uint8>[16])
• locationSubnetMask(uint32)
• locationSubnetMasks(list<uint32>)
• locationSubnets(list<uint32>)
• locationTimezone(list<uint8>[16])
• locationTimezone(uint32)
• locationTimezones(list<uint32>)
• locationsFound(list<uint32>)

com.teracloud.streams.network.mac

Functions

• convertMACAddressNumericToString(list<uint8>[6])
• convertMACAddressStringToNumeric(rstring)

com.teracloud.streams.network.parse

Operators

• DHCPMessageParser
• DNSMessageParser
• IPFIXMessageParser
• NetflowMessageParser

Functions

• DHCP_ADDRESS_LEASE_TIME()
• DHCP_ALL_SUBNETS_LOCAL()
• DHCP_ARP_CACHE_TIMEOUT()
• DHCP_BOOTFILE_NAME()
• DHCP_BOOT_FILE_SIZE()
• DHCP_BROADCAST_ADDRESS()
• DHCP_CLIENT_ADDRESS()
• DHCP_CLIENT_HARDWARE_ADDRESS()
• DHCP_CLIENT_HARDWARE_TYPE()
• DHCP_CLIENT_IDENTIFIER()
• DHCP_COOKIE_SERVERS()
• DHCP_DNS_SERVERS()
• DHCP_DOMAIN_NAME()
• DHCP_ERROR_MESSAGE()
• DHCP_ETHERNET_ENCAPSULATION()
• DHCP_EXTENSIONS_PATH()
• DHCP_FINGER_SERVERS()
• DHCP_FLAGS()
• DHCP_HOP_COUNT()
• DHCP_HOST_NAME()
• DHCP_IMPRESS_SERVERS()
• DHCP_INTERFACE_MTU()
• DHCP_IP_DEFAULT_TTL()
• DHCP_IP_FORWARDING()
• DHCP_IRC_SERVERS()
• DHCP_LOG_SERVERS()
• DHCP_LPR_SERVERS()
• DHCP_MASK_SUPPLIER()
• DHCP_MAXIMUM_MESSAGE_SIZE()
• DHCP_MAXIMUM_REASSEMBLY_SIZE()
• DHCP_MERIT_DUMP_FILE()
• DHCP_MESSAGE_TYPE()
• DHCP_MOBILE_IP_HOME_AGENTS()
• DHCP_MTU_AGING_TIMEOUT()
• DHCP_MTU_PLATEAU_TABLE()
• DHCP_NAME_SERVERS()
• DHCP_NETBIOS_NAME_SERVERS()
• DHCP_NETBIOS_NBDD_SERVERS()
• DHCP_NETBIOS_NODE_TYPE()
• DHCP_NETBIOS_SCOPE()
• DHCP_NISPLUS_DOMAIN()
• DHCP_NISPLUS_SERVERS()
• DHCP_NIS_DOMAIN()
• DHCP_NIS_SERVERS()
• DHCP_NNTP_SERVERS()
• DHCP_NONLOCAL_SOURCE_FILTERS()
• DHCP_NONLOCAL_SOURCE_ROUTING()
• DHCP_NTP_SERVERS()
• DHCP_OPCODE()
• DHCP_OPTION_OVERLOAD_FLAGS()
• DHCP_PARAMETER_REQUESTS()
• DHCP_PERFORM_MASK_DISCOVERY()
• DHCP_PERFORM_ROUTER_DISCOVERY()
• DHCP_POP3_SERVERS()
• DHCP_REBINDING_TIME()
• DHCP_RELAY_AGENT()
• DHCP_RENEWAL_TIME()
• DHCP_REQUESTED_ADDRESS()
• DHCP_RESOURCE_SERVERS()
• DHCP_ROOT_PATH()
• DHCP_ROUTERS()
• DHCP_ROUTER_SOLICITATION_ADDRESS()
• DHCP_SECONDS()
• DHCP_SERVER_ADDRESS()
• DHCP_SERVER_HOSTNAME()
• DHCP_SERVER_NEXT()
• DHCP_SMTP_SERVERS()
• DHCP_STATIC_ROUTES()
• DHCP_STDA_SERVERS()
• DHCP_STREETTALK_SERVERS()
• DHCP_SUBNET_MASK()
• DHCP_SWAP_SERVER()
• DHCP_TCP_DEFUALT_TTL()
• DHCP_TCP_KEEPALIVE_GARBAGE()
• DHCP_TCP_KEEPALIVE_INTERVAL()
• DHCP_TIME_OFFSET()
• DHCP_TIME_SERVERS()
• DHCP_TRAILER_ENCAPSULATION()
• DHCP_TRANSACTION_IDENTIFIER()
• DHCP_VENDOR_IDENTIFIER()
• DHCP_VENDOR_INFORMATION()
• DHCP_WWW_SERVERS()
• DHCP_XWINDOW_DISPLAY_MANAGERS()
• DHCP_XWINDOW_FONT_SERVERS()
• DHCP_YOUR_ADDRESS()
• DNS_ADDITIONAL_CLASSES()
• DNS_ADDITIONAL_COUNT()
• DNS_ADDITIONAL_DATA()
• DNS_ADDITIONAL_DATA(rstring)
• DNS_ADDITIONAL_NAMES()
• DNS_ADDITIONAL_TTLS()
• DNS_ADDITIONAL_TYPES()
• DNS_ALL_FIELDS(rstring, rstring, rstring)
• DNS_ALL_FIELDS(rstring, rstring, rstring, list<uint16>)
• DNS_ALL_FIELDS(rstring, rstring, rstring, list<uint16>, uint64, uint32, uint32, uint32, uint16, uint16, uint8, uint32, uint16)
• DNS_ALL_FLAGS()
• DNS_ANSWER_ADDRESS()
• DNS_ANSWER_ADDRESSES()
• DNS_ANSWER_CANONICAL()
• DNS_ANSWER_CLASSES()
• DNS_ANSWER_COUNT()
• DNS_ANSWER_DATA()
• DNS_ANSWER_IPV4_ADDRESS()
• DNS_ANSWER_IPV4_ADDRESSES()
• DNS_ANSWER_IPV6_ADDRESS()
• DNS_ANSWER_IPV6_ADDRESSES()
• DNS_ANSWER_NAMES()
• DNS_ANSWER_TTLS()
• DNS_ANSWER_TYPES()
• DNS_AUTHORITATIVE_FLAG()
• DNS_EXTRA_DATA()
• DNS_IDENTIFIER()
• DNS_INCOMPATIBLE_FLAGS()
• DNS_NAMESERVER_CLASSES()
• DNS_NAMESERVER_COUNT()
• DNS_NAMESERVER_DATA()
• DNS_NAMESERVER_DATA(rstring)
• DNS_NAMESERVER_NAMES()
• DNS_NAMESERVER_TTLS()
• DNS_NAMESERVER_TYPES()
• DNS_OPCODE()
• DNS_QUESTION_CLASS()
• DNS_QUESTION_CLASSES()
• DNS_QUESTION_COUNT()
• DNS_QUESTION_NAME()
• DNS_QUESTION_NAMES()
• DNS_QUESTION_TYPE()
• DNS_QUESTION_TYPES()
• DNS_RESPONSE_CODE()
• DNS_RESPONSE_FLAG()
• DNS_TRUNCATION_FLAG()
• IPFIX_bgpDestinationAsNumber()
• IPFIX_bgpNextAdjacentAsNumber()
• IPFIX_bgpNextHopIPv4Address()
• IPFIX_bgpNextHopIPv6Address()
• IPFIX_bgpPrevAdjacentAsNumber()
• IPFIX_bgpSourceAsNumber()
• IPFIX_collectorIPv4Address()
• IPFIX_collectorIPv6Address()
• IPFIX_collectorTransportPort()
• IPFIX_commonPropertiesId()
• IPFIX_destinationIPv4Address()
• IPFIX_destinationIPv4Prefix()
• IPFIX_destinationIPv4PrefixLength()
• IPFIX_destinationIPv6Address()
• IPFIX_destinationIPv6Prefix()
• IPFIX_destinationIPv6PrefixLength()
• IPFIX_destinationMacAddress()
• IPFIX_destinationTransportPort()
• IPFIX_droppedOctetDeltaCount()
• IPFIX_droppedOctetTotalCount()
• IPFIX_droppedPacketDeltaCount()
• IPFIX_droppedPacketTotalCount()
• IPFIX_egressInterface()
• IPFIX_enterpriseBasicListFieldAsByteLists(int32)
• IPFIX_enterpriseBasicListFieldAsIntegers(int32)
• IPFIX_enterpriseBasicListFieldAsStrings(int32)
• IPFIX_enterpriseBasicListFieldElementIdentifier(int32)
• IPFIX_enterpriseBasicListFieldEnterpriseIdentifier(int32)
• IPFIX_enterpriseBasicListFieldSemantic(int32)
• IPFIX_enterpriseFieldAsByteList(int32)
• IPFIX_enterpriseFieldAsInteger(int32)
• IPFIX_enterpriseFieldAsString(int32)
• IPFIX_enterpriseIdentifier(int32)
• IPFIX_exportInterface()
• IPFIX_exportProtocolVersion()
• IPFIX_exportTransportProtocol()
• IPFIX_exportedFlowRecordTotalCount()
• IPFIX_exportedMessageTotalCount()
• IPFIX_exportedOctetTotalCount()
• IPFIX_exporterIPv4Address()
• IPFIX_exporterIPv6Address()
• IPFIX_exporterTransportPort()
• IPFIX_exportingProcessId()
• IPFIX_flowActiveTimeout()
• IPFIX_flowDirection()
• IPFIX_flowDurationMicroseconds()
• IPFIX_flowDurationMilliseconds()
• IPFIX_flowEndDeltaMicroseconds()
• IPFIX_flowEndMicroseconds()
• IPFIX_flowEndMilliseconds()
• IPFIX_flowEndNanoseconds()
• IPFIX_flowEndReason()
• IPFIX_flowEndSeconds()
• IPFIX_flowEndSysUpTime()
• IPFIX_flowId()
• IPFIX_flowIdleTimeout()
• IPFIX_flowKeyIndicator()
• IPFIX_flowLabelIPv6()
• IPFIX_flowStartDeltaMicroseconds()
• IPFIX_flowStartMicroseconds()
• IPFIX_flowStartMilliseconds()
• IPFIX_flowStartNanoseconds()
• IPFIX_flowStartSeconds()
• IPFIX_flowStartSysUpTime()
• IPFIX_fragmentFlags()
• IPFIX_fragmentIdentification()
• IPFIX_fragmentOffset()
• IPFIX_icmpCodeIPv4()
• IPFIX_icmpCodeIPv6()
• IPFIX_icmpTypeCodeIPv4()
• IPFIX_icmpTypeCodeIPv6()
• IPFIX_icmpTypeIPv4()
• IPFIX_icmpTypeIPv6()
• IPFIX_igmpType()
• IPFIX_ignoredOctetTotalCount()
• IPFIX_ignoredPacketTotalCount()
• IPFIX_ingressInterface()
• IPFIX_ipClassOfService()
• IPFIX_ipDiffServCodePoint()
• IPFIX_ipHeaderLength()
• IPFIX_ipNextHopIPv4Address()
• IPFIX_ipNextHopIPv6Address()
• IPFIX_ipPayloadLength()
• IPFIX_ipPrecedence()
• IPFIX_ipTTL()
• IPFIX_ipTotalLength()
• IPFIX_ipVersion()
• IPFIX_ipv4IHL()
• IPFIX_ipv4Options()
• IPFIX_ipv6ExtensionHeaders()
• IPFIX_isMulticast()
• IPFIX_lineCardId()
• IPFIX_maximumIpTotalLength()
• IPFIX_maximumTTL()
• IPFIX_meteringProcessId()
• IPFIX_minimumIpTotalLength()
• IPFIX_minimumTTL()
• IPFIX_mplsLabelStackDepth()
• IPFIX_mplsLabelStackLength()
• IPFIX_mplsLabelStackSection10()
• IPFIX_mplsLabelStackSection2()
• IPFIX_mplsLabelStackSection3()
• IPFIX_mplsLabelStackSection4()
• IPFIX_mplsLabelStackSection5()
• IPFIX_mplsLabelStackSection6()
• IPFIX_mplsLabelStackSection7()
• IPFIX_mplsLabelStackSection8()
• IPFIX_mplsLabelStackSection9()
• IPFIX_mplsPayloadLength()
• IPFIX_mplsTopLabelExp()
• IPFIX_mplsTopLabelIPv4Address()
• IPFIX_mplsTopLabelIPv6Address()
• IPFIX_mplsTopLabelStackSection()
• IPFIX_mplsTopLabelTTL()
• IPFIX_mplsTopLabelType()
• IPFIX_mplsVpnRouteDistinguisher()
• IPFIX_nextHeaderIPv6()
• IPFIX_notSentFlowTotalCount()
• IPFIX_notSentOctetTotalCount()
• IPFIX_notSentPacketTotalCount()
• IPFIX_observationDomainId()
• IPFIX_observationPointId()
• IPFIX_observedFlowTotalCount()
• IPFIX_octetDeltaCount()
• IPFIX_octetDeltaSumOfSquares()
• IPFIX_octetTotalCount()
• IPFIX_octetTotalSumOfSquares()
• IPFIX_packetDeltaCount()
• IPFIX_packetTotalCount()
• IPFIX_paddingOctets()
• IPFIX_payloadLengthIPv6()
• IPFIX_portId()
• IPFIX_postDestinationMacAddress()
• IPFIX_postIpClassOfService()
• IPFIX_postMCastOctetDeltaCount()
• IPFIX_postMCastOctetTotalCount()
• IPFIX_postMCastPacketDeltaCount()
• IPFIX_postMCastPacketTotalCount()
• IPFIX_postMplsTopLabelExp()
• IPFIX_postOctetDeltaCount()
• IPFIX_postOctetTotalCount()
• IPFIX_postPacketDeltaCount()
• IPFIX_postPacketTotalCount()
• IPFIX_postSourceMacAddress()
• IPFIX_postVlanId()
• IPFIX_protocolIdentifier()
• IPFIX_sourceIPv4Address()
• IPFIX_sourceIPv4Prefix()
• IPFIX_sourceIPv4PrefixLength()
• IPFIX_sourceIPv6Address()
• IPFIX_sourceIPv6Prefix()
• IPFIX_sourceIPv6PrefixLength()
• IPFIX_sourceMacAddress()
• IPFIX_sourceTransportPort()
• IPFIX_standardFieldAsByteList(int32)
• IPFIX_standardFieldAsInteger(int32)
• IPFIX_standardFieldAsString(int32)
• IPFIX_systemInitTimeMilliseconds()
• IPFIX_tcpAckTotalCount()
• IPFIX_tcpAcknowledgementNumber()
• IPFIX_tcpControlBits()
• IPFIX_tcpDestinationPort()
• IPFIX_tcpFinTotalCount()
• IPFIX_tcpHeaderLength()
• IPFIX_tcpOptions()
• IPFIX_tcpPshTotalCount()
• IPFIX_tcpRstTotalCount()
• IPFIX_tcpSequenceNumber()
• IPFIX_tcpSourcePort()
• IPFIX_tcpSynTotalCount()
• IPFIX_tcpUrgTotalCount()
• IPFIX_tcpUrgentPointer()
• IPFIX_tcpWindowScale()
• IPFIX_tcpWindowSize()
• IPFIX_templateId()
• IPFIX_totalLengthIPv4()
• IPFIX_udpDestinationPort()
• IPFIX_udpMessageLength()
• IPFIX_udpSourcePort()
• IPFIX_vlanId()
• IPFIX_wlanChannelId()
• IPFIX_wlanSSID()
• NETFLOW_APPLICATION_DESCRIPTION()
• NETFLOW_APPLICATION_NAME()
• NETFLOW_APPLICATION_TAG()
• NETFLOW_BGP_IPV4_NEXT_HOP()
• NETFLOW_BPG_IPV6_NEXT_HOP()
• NETFLOW_COUNT()
• NETFLOW_DIRECTION()
• NETFLOW_DST_AS()
• NETFLOW_DST_MASK()
• NETFLOW_DST_PORT()
• NETFLOW_DST_TOS()
• NETFLOW_DST_TRAFFIC_INDEX()
• NETFLOW_DST_VLAN()
• NETFLOW_ENGINE_ID()
• NETFLOW_ENGINE_TYPE()
• NETFLOW_FIELD_AS_BYTE_LIST(int32)
• NETFLOW_FIELD_AS_INTEGER(int32)
• NETFLOW_FIELD_AS_STRING(int32)
• NETFLOW_FIRST_SWITCHED()
• NETFLOW_FLOWS()
• NETFLOW_FLOW_ACTIVE_TIMEOUT()
• NETFLOW_FLOW_INACTIVE_TIMEOUT()
• NETFLOW_FLOW_SAMPLER_ID()
• NETFLOW_FLOW_SAMPLER_MODE()
• NETFLOW_FLOW_SAMPLER_RANDOM_INTERVAL()
• NETFLOW_FORWARDING_STATUS()
• NETFLOW_FRAGMENT_OFFSET()
• NETFLOW_ICMP_TYPE()
• NETFLOW_IF_DESC()
• NETFLOW_IF_NAME()
• NETFLOW_INPUT_INTERFACE()
• NETFLOW_IN_BYTES()
• NETFLOW_IN_PERMANENT_BYTES()
• NETFLOW_IN_PERMANENT_PKTS()
• NETFLOW_IN_PKTS()
• NETFLOW_IPV4_DST_ADDR()
• NETFLOW_IPV4_DST_PREFIX()
• NETFLOW_IPV4_IDENT()
• NETFLOW_IPV4_NEXT_HOP()
• NETFLOW_IPV4_SRC_ADDR()
• NETFLOW_IPV4_SRC_PREFIX()
• NETFLOW_IPV6_DST_ADDR()
• NETFLOW_IPV6_DST_MASK()
• NETFLOW_IPV6_FLOW_LABEL()
• NETFLOW_IPV6_NEXT_HOP()
• NETFLOW_IPV6_OPTION_HEADERS()
• NETFLOW_IPV6_SRC_ADDR()
• NETFLOW_IPV6_SRC_MASK()
• NETFLOW_IP_PROTOCOL_VERSION()
• NETFLOW_LAST_SWITCHED()
• NETFLOW_MAC_DST_ADDR_IN()
• NETFLOW_MAC_DST_ADDR_OUT()
• NETFLOW_MAC_SRC_ADDR_IN()
• NETFLOW_MAC_SRC_ADDR_OUT()
• NETFLOW_MAX_PKT_LNGTH()
• NETFLOW_MAX_TTL()
• NETFLOW_MIN_PKT_LNGTH()
• NETFLOW_MIN_TTL()
• NETFLOW_MPLS_LABEL(int32)
• NETFLOW_MPLS_PAL_RD()
• NETFLOW_MPLS_PREFIX_LEN()
• NETFLOW_MPLS_TOP_LABEL_IPV4_ADDR()
• NETFLOW_MPLS_TOP_LABEL_TYPE()
• NETFLOW_MUL_DST_BYTES()
• NETFLOW_MUL_DST_PKTS()
• NETFLOW_MUL_IGMP_TYPE()
• NETFLOW_OUTPUT_INTERFACE()
• NETFLOW_OUT_BYTES()
• NETFLOW_OUT_PKTS()
• NETFLOW_POST_IP_DSCP()
• NETFLOW_PROTOCOL()
• NETFLOW_REPLICATION_FACTOR()
• NETFLOW_SAMPLER_NAME()
• NETFLOW_SAMPLING_ALGORITHM()
• NETFLOW_SAMPLING_INTERVAL()
• NETFLOW_SEQUENCE_NUMBER()
• NETFLOW_SOURCE_ID()
• NETFLOW_SRC_AS()
• NETFLOW_SRC_MASK()
• NETFLOW_SRC_PORT()
• NETFLOW_SRC_TOS()
• NETFLOW_SRC_TRAFFIC_INDEX()
• NETFLOW_SRC_VLAN()
• NETFLOW_SYSTEM_UPTIME()
• NETFLOW_TCP_FLAGS()
• NETFLOW_TOTAL_BYTES_EXP()
• NETFLOW_TOTAL_FLOWS_EXP()
• NETFLOW_TOTAL_PKTS_EXP()
• NETFLOW_UNIX_NANOSECONDS()
• NETFLOW_UNIX_SECONDS()
• NETFLOW_VERSION()
• messagesProcessed()
• parseError()
• parseErrorCode()
• parseErrorDescription()
• parseErrorOffset()

com.teracloud.streams.network.rtp

Operators

• RtpDecode

com.teracloud.streams.network.sink

Operators

• PacketFileSink

com.teracloud.streams.network.source

Operators

• PacketDPDKSource
• PacketFileSource
• PacketLiveSource

Functions

• CAPTURE_MICROSECONDS()
• CAPTURE_SECONDS()
• CAPTURE_TSC_MICROSECONDS()
• DNS_RESPONSE_FLAG_HINT()
• ERSPAN_DST_ADDRESS()
• ERSPAN_SRC_ADDRESS()
• ETHER_DST_ADDRESS()
• ETHER_DST_ADDRESS_64()
• ETHER_PROTOCOL()
• ETHER_SRC_ADDRESS()
• IPV4_DST_ADDRESS()
• IPV4_SRC_ADDRESS()
• IPV6_DST_ADDRESS()
• IPV6_SRC_ADDRESS()
• IP_DONT_FRAGMENT()
• IP_DST_PORT()
• IP_FRAGMENT_OFFSET()
• IP_IDENTIFIER()
• IP_MORE_FRAGMENTS()
• IP_PROTOCOL()
• IP_SRC_PORT()
• IP_VERSION()
• JMIRROR_DST_ADDRESS()
• JMIRROR_DST_PORT()
• JMIRROR_INTERCEPT_ID()
• JMIRROR_SESSION_ID()
• JMIRROR_SRC_ADDRESS()
• JMIRROR_SRC_PORT()
• PACKET_DATA()
• PACKET_LENGTH()
• PAYLOAD_DATA()
• PAYLOAD_LENGTH()
• RATE_LIMITED()
• TCP_ACKNOWLEDGEMENT()
• TCP_DST_PORT()
• TCP_FLAGS_ACK()
• TCP_FLAGS_FIN()
• TCP_FLAGS_PUSH()
• TCP_FLAGS_RESET()
• TCP_FLAGS_SYN()
• TCP_FLAGS_URGENT()
• TCP_PORT(uint16)
• TCP_SEQUENCE()
• TCP_SRC_PORT()
• TCP_WINDOW()
• UDP_DST_PORT()
• UDP_PORT(uint16)
• UDP_SRC_PORT()
• VLAN_TAGS()
• bytesProcessed()
• bytesReceived()
• metricsIntervalBytesProcessed()
• metricsIntervalBytesReceived()
• metricsIntervalElapsed()
• metricsIntervalMaxQueueDepthSW()
• metricsIntervalPacketsDropped()
• metricsIntervalPacketsDroppedSW()
• metricsIntervalPacketsProcessed()
• metricsIntervalPacketsReceived()
• metricsUpdated()
• packetsDropped()
• packetsDroppedSW()
• packetsProcessed()
• packetsReceived()