Versions in this module Expand all Collapse all v1 v1.6.65 Sep 23, 2024 Changes in this version type L7Protocol + const L7_PROTOCOL_SOME_IP v1.6.64 Sep 13, 2024 v1.6.4 Sep 13, 2024 Changes in this version + const AGENTID_OFFSET + const ARP_HEADER_SIZE + const ARP_VALID_TIME + const CIDR_TYPE_LAN + const CIDR_TYPE_WAN + const COM_FIELD_LIST + const COM_INIT_DB + const COM_MAX + const COM_QUERY + const COM_QUIT + const COM_STMT_CLOSE + const COM_STMT_EXECUTE + const COM_STMT_FETCH + const COM_STMT_PREPARE + const DATA_VALID_TIME + const ENCODER_OFFSET + const EPC_FROM_DEEPFLOW + const EPC_FROM_INTERNET + const EPC_UNKNOWN + const ERSPANIII_FLAGS_OFFSET + const ERSPANIII_HEADER_SIZE + const ERSPANIII_SUBHEADER_SIZE + const ERSPANII_HEADER_SIZE + const ERSPANI_HEADER_SIZE + const ERSPAN_ID_OFFSET + const ETH_HEADER_SIZE + const ETH_TYPE_LEN + const FLOW_HEADER_LEN + const FLOW_METRICS_PEER_DST + const FLOW_METRICS_PEER_MAX + const FLOW_METRICS_PEER_SRC + const FLOW_ORGID_OFFSET + const FLOW_TEAMID_OFFSET + const FLOW_VERSION_OFFSET + const FLOW_VTAPID_OFFSET + const GRE_CSUM_LEN + const GRE_FLAGS_CSUM_MASK + const GRE_FLAGS_KEY_MASK + const GRE_FLAGS_OFFSET + const GRE_FLAGS_SEQ_MASK + const GRE_FLAGS_VER_MASK + const GRE_HEADER_SIZE + const GRE_KEY_LEN + const GRE_KEY_OFFSET + const GRE_PROTOCOL_OFFSET + const GRE_SEQ_LEN + const GROUP_INTERNET + const HEADER_TYPE_ARP + const HEADER_TYPE_ETH + const HEADER_TYPE_IPV4 + const HEADER_TYPE_IPV4_ICMP + const HEADER_TYPE_IPV4_TCP + const HEADER_TYPE_IPV4_UDP + const HEADER_TYPE_IPV6 + const HEADER_TYPE_IPV6_L3 + const HEADER_TYPE_IPV6_L4 + const HEADER_TYPE_IPV6_TCP + const HEADER_TYPE_IPV6_UDP + const HEADER_TYPE_L3 + const HEADER_TYPE_L4 + const HEADER_TYPE_LEN + const ICMP_HEADER_SIZE + const IF_TYPE_WAN + const IP6_DIP_OFFSET + const IP6_HEADER_SIZE + const IP6_PROTO_OFFSET + const IP6_SIP_OFFSET + const IPV4_FLAGS_FRAG_OFFSET_LEN + const IPV4_FRAG_DONT_FRAGMENT + const IPV4_FRAG_MORE_FRAGMENT + const IPV4_FRAG_OFFSET_MASK + const IPV4_PROTO_LEN + const IPV4_TTL_LEN + const IP_ADDR_LEN + const IP_GROUP_ID_FLAG + const IP_HEADER_SIZE + const IP_IHL_OFFSET + const L7PROTOCOL_LOG_RESP_CODE_NONE + const LAST_SIMPLE_CODEC_VERSION + const LATEST_VERSION + const LAYER_L2_SIZE + const LAYER_L3_SIZE + const LAYER_TUNNEL_SIZE + const LE_ERSPAN_PROTO_TYPE_II + const LE_ERSPAN_PROTO_TYPE_III + const LE_IPV4_PROTO_TYPE_I + const LE_IPV6_PROTO_TYPE_I + const LE_TEB_PROTO + const LE_VXLAN_PROTO_UDP_DPORT + const LE_VXLAN_PROTO_UDP_DPORT2 + const LE_VXLAN_PROTO_UDP_DPORT3 + const MAC_ADDR_LEN + const MASK_LEN_NUM + const MATCHED_FIELD6_BITS_LEN + const MATCHED_FIELD6_LEN + const MATCHED_FIELD_BITS_LEN + const MATCHED_FIELD_LEN + const MAX_MASK6_LEN + const MAX_MASK_LEN + const MAX_TCP_OPTION_SIZE + const MESSAGE_FRAME_SIZE_MAX + const MESSAGE_FRAME_SIZE_OFFSET + const MESSAGE_HEADER_LEN + const MESSAGE_TYPE_OFFSET + const MESSAGE_VALUE_OFFSET + const META_PACKET_SIZE_PER_BLOCK + const MIN_IPV4_HEADER_SIZE + const MIN_MASK_LEN + const MIN_TCP_HEADER_SIZE + const MIRRORED_TRAFFIC + const MYSQL_RESPONSE_CODE_EOF + const MYSQL_RESPONSE_CODE_ERR + const MYSQL_RESPONSE_CODE_OK + const NPB_TUNNEL_TYPE_GRE_ERSPAN + const NPB_TUNNEL_TYPE_NPB_DROP + const NPB_TUNNEL_TYPE_PCAP + const NPB_TUNNEL_TYPE_VXLAN + const NUM_64_MASK + const NUM_64_OFFSET + const OFFSET_DA + const OFFSET_DA_LOW4B + const OFFSET_DIP + const OFFSET_DPORT + const OFFSET_ETH_TYPE + const OFFSET_IP_PROTOCOL + const OFFSET_SA + const OFFSET_SA_LOW4B + const OFFSET_SIP + const OFFSET_VXLAN_FLAGS + const OFFSET_VXLAN_VNI + const ORGID_OFFSET + const PACKET_SOURCE_ISP + const PACKET_SOURCE_SPINE + const PACKET_SOURCE_TOR + const PORT_LEN + const RESERVED1_OFFSET + const STANDARD_MASK_LEN + const TAPPORT_FROM_EBPF + const TAPPORT_FROM_GATEWAY_MAC + const TAPPORT_FROM_ID + const TAPPORT_FROM_LOCAL_MAC + const TAPPORT_FROM_NETFLOW + const TAPPORT_FROM_OTEL + const TAPPORT_FROM_SFLOW + const TAPPORT_FROM_TUNNEL_IPV4 + const TAPPORT_FROM_TUNNEL_IPV6 + const TAPSIDE_ALL + const TAPSIDE_DST + const TAPSIDE_MASK + const TAPSIDE_SRC + const TCP_OPT_FLAG_MSS + const TCP_OPT_FLAG_SACK + const TCP_OPT_FLAG_SACK_PERMIT + const TCP_OPT_FLAG_WIN_SCALE + const TCP_OPT_MSS_LEN + const TCP_OPT_WIN_SCALE_LEN + const TCP_WIN_LEN + const TEAMID_OFFSET + const TUNNEL_ID_LEN + const TUNNEL_TYPE_ERSPAN_OR_TEB + const TUNNEL_TYPE_IPIP + const TUNNEL_TYPE_LEN + const TUNNEL_TYPE_NONE + const TUNNEL_TYPE_TENCENT_GRE + const TUNNEL_TYPE_VXLAN + const UDP_DPORT_OFFSET + const UDP_HEADER_SIZE + const VERSION + const VERSION_OFFSET + const VLANTAG_LEN + const VLAN_ID_MASK + const VXLAN_FLAGS + const VXLAN_FLAGS_OFFSET + const VXLAN_HEADER_SIZE + const VXLAN_VNI_OFFSET + var DnsCommandString = []string + var INVALID_ENDPOINT_DATA = &EndpointData + var INVALID_ENDPOINT_DATA_L3EPCID = &EndpointData + var INVALID_ENDPOINT_INFO = new(EndpointInfo) + var INVALID_ENDPOINT_INFO_L2AND3END = &EndpointInfo + var INVALID_ENDPOINT_INFO_L2AND3END_L3EPCID = &EndpointInfo + var INVALID_ENDPOINT_INFO_L2END = &EndpointInfo + var INVALID_ENDPOINT_INFO_L2END_L3EPCID = &EndpointInfo + var INVALID_ENDPOINT_INFO_L3END = &EndpointInfo + var INVALID_ENDPOINT_INFO_L3END_L3EPCID = &EndpointInfo + var INVALID_ENDPOINT_INFO_L3EPCID = &EndpointInfo + var INVALID_POLICY_DATA = new(PolicyData) + var KafkaCommandString = []string + var L7ProtocolStringMap = map[string]L7Protocol + var MAX_NETMASK = utils.MaskLenToNetmask(MAX_MASK_LEN) + var MessageHeaderTypes = [MESSAGE_TYPE_MAX]MessageHeaderType + var MessageTypeString = [MESSAGE_TYPE_MAX]string + var MysqlCommandString = []string + func DecodePB(decoder *codec.SimpleDecoder, t *pb.TaggedFlow) + func FormatGroupId(id uint32) uint32 + func GetDNSQueryType(query uint8) string + func GetTunnelIp(aclGid uint16) net.IP + func GetTunnelIpId(aclGid uint16) uint16 + func GroupIdToString(id uint32) string + func IpRangeConvert2CIDR(startIp, endIp net.IP) []net.IPNet + func IsGrePseudoInnerMac(mac uint64) bool + func PseudoCloneTaggedFlowHelper(items []interface{}) + func ReleaseAppProtoLogsData(d *AppProtoLogsData) + func ReleaseDNSInfo(d *DNSInfo) + func ReleaseDubboInfo(d *DubboInfo) + func ReleaseEndpointData(d *EndpointData) + func ReleaseEndpointInfo(i *EndpointInfo) + func ReleaseFlowPerfStats(s *FlowPerfStats) + func ReleaseHTTPInfo(h *HTTPInfo) + func ReleaseKafkaInfo(d *KafkaInfo) + func ReleaseMYSQLInfo(d *MysqlInfo) + func ReleaseMetaPacketBlock(x *MetaPacketBlock) + func ReleaseMqttInfo(d *MqttInfo) + func ReleaseREDISInfo(d *RedisInfo) + func ReleaseTaggedFlow(taggedFlow *TaggedFlow) + func SplitGroup2Int(src []int32) []uint32 + func TapPortValueToString(tapPort uint32, tapPortType uint8, tunnelType TunnelType) string + func TrimCommand(sql string, commandMaxLength int) string + func UpdateTunnelMaps(aclGids, ipIds []uint16, ips []net.IP) + type ActionFlag uint16 + const ACTION_NPB + const ACTION_NPB_DROP + const ACTION_PCAP + func (f ActionFlag) String() string + type AppProtoHead struct + Code uint16 + MsgType LogMessageType + Proto L7Protocol + RRT time.Duration + Status uint8 + func (h *AppProtoHead) WriteToPB(p *pb.AppProtoHead) + type AppProtoLogsBaseInfo struct + EndTime time.Duration + FlowId uint64 + IP6Dst [net.IPv6len]byte + IP6Src [net.IPv6len]byte + IPDst IPv4Int + IPSrc IPv4Int + IsIPv6 bool + IsVIPInterfaceDst bool + IsVIPInterfaceSrc bool + L3EpcIDDst int32 + L3EpcIDSrc int32 + MacDst uint64 + MacSrc uint64 + PortDst uint16 + PortSrc uint16 + Protocol uint8 + ReqTcpSeq uint32 + RespTcpSeq uint32 + StartTime time.Duration + TapPort TapPort + TapSide uint8 + TapType uint16 + VtapId uint16 + func (i *AppProtoLogsBaseInfo) String() string + func (l *AppProtoLogsBaseInfo) WriteToPB(p *pb.AppProtoLogsBaseInfo) + type AppProtoLogsData struct + Detail ProtoSpecialInfo + func AcquireAppProtoLogsData() *AppProtoLogsData + func CloneAppProtoLogsData(d *AppProtoLogsData) *AppProtoLogsData + func (l *AppProtoLogsData) EncodePB(encoder *codec.SimpleEncoder, i interface{}) error + func (l *AppProtoLogsData) Release() + func (l *AppProtoLogsData) String() string + func (l *AppProtoLogsData) WriteToPB(p *pb.AppProtoLogsData) + type BaseHeader struct + FrameSize uint32 + Type MessageType + func (h *BaseHeader) Decode(buf []byte) error + func (h *BaseHeader) Encode(chunk []byte) + type ByteStream struct + func NewByteStream(data []byte) ByteStream + func (s *ByteStream) Field(len int) []byte + func (s *ByteStream) Len() int + func (s *ByteStream) Skip(n int) + func (s *ByteStream) Slice() []byte + func (s *ByteStream) U16() uint16 + func (s *ByteStream) U32() uint32 + func (s *ByteStream) U64() uint64 + func (s *ByteStream) U8() uint8 + type Cidr struct + EpcId int32 + IpNet *net.IPNet + IsVIP bool + RegionId uint32 + TunnelId uint32 + Type uint8 + type CloseType uint8 + const CloseTypeClientAckMiss + const CloseTypeClientEstablishReset + const CloseTypeClientHalfClose + const CloseTypeClientSourcePortReuse + const CloseTypeForcedReport + const CloseTypeServerEstablishReset + const CloseTypeServerHalfClose + const CloseTypeServerQueueLack + const CloseTypeServerReset + const CloseTypeServerSynMiss + const CloseTypeTCPClientRst + const CloseTypeTCPFin + const CloseTypeTCPFinClientRst + const CloseTypeTCPServerRst + const CloseTypeTimeout + const CloseTypeUnknown + const MaxCloseType + func (t CloseType) IsClientError() bool + func (t CloseType) IsServerError() bool + type DNSInfo struct + Answers string + QueryName string + QueryType uint16 + TransID uint16 + func AcquireDNSInfo() *DNSInfo + func (d *DNSInfo) Merge(r interface{}) + func (d *DNSInfo) String() string + func (h *DNSInfo) WriteToPB(p *pb.AppProtoLogsData, msgType LogMessageType) + type DeviceType uint8 + const FloatingIP + const HostDevice + const NSPVGateway + const NetworkDevice + const ThirdPartyDevice + const VGw + const VM + const VMWAF + type DirectionType uint8 + const BACKWARD + const FORWARD + const NO_DIRECTION + type DubboInfo struct + DubboVersion string + ID int64 + MethodName string + ReqBodyLen int32 + RespBodyLen int32 + SerialID uint8 + ServiceName string + ServiceVersion string + TraceId string + Type uint8 + func AcquireDubboInfo() *DubboInfo + func (i *DubboInfo) Merge(r interface{}) + func (i *DubboInfo) String() string + func (i *DubboInfo) WriteToPB(p *pb.AppProtoLogsData, msgType LogMessageType) + type EndpointData struct + DstInfo *EndpointInfo + SrcInfo *EndpointInfo + func AcquireEndpointData(infos ...*EndpointInfo) *EndpointData + func CloneEndpointData(d *EndpointData) *EndpointData + func ShallowCopyEndpointData(d *EndpointData) *EndpointData + func (d *EndpointData) ReverseData() *EndpointData + func (d *EndpointData) SetL2End(key *LookupKey) + func (d *EndpointData) String() string + func (d *EndpointData) Valid() bool + type EndpointInfo struct + IsDevice bool + IsLocalIp bool + IsLocalMac bool + IsVIP bool + IsVIPInterface bool + L2End bool + L2EpcId int32 + L3End bool + L3EpcId int32 + RealIP net.IP + func AcquireEndpointInfo() *EndpointInfo + func CloneEndpointInfo(i *EndpointInfo) *EndpointInfo + func ShallowCopyEndpointInfo(i *EndpointInfo) *EndpointInfo + func (i *EndpointInfo) GetL3Epc() uint16 + func (i *EndpointInfo) GetL3L2End() L3L2End + func (i *EndpointInfo) SetL2Data(data *PlatformData) + func (i *EndpointInfo) SetL3Data(data *PlatformData) + func (i *EndpointInfo) SetL3L2End(ends L3L2End) + func (i *EndpointInfo) String() string + type EndpointStore struct + Datas [L3_L2_END_MAX][L3_L2_END_MAX]EndpointData + DstInfos [L3_L2_END_MAX]EndpointInfo + Endpoints *EndpointData + SrcInfos [L3_L2_END_MAX]EndpointInfo + func (s *EndpointStore) InitPointer(d *EndpointData) + func (s *EndpointStore) UpdatePointer(l2End0, l2End1, l3End0, l3End1 bool) *EndpointData + type FeatureFlags uint32 + const NPB + const NPM + type Flow struct + AclGids []uint16 + Duration time.Duration + EndTime time.Duration + EthType layers.EthernetType + FlowID uint64 + FlowMetricsPeers [FLOW_METRICS_PEER_MAX]FlowMetricsPeer + FlowStatTime time.Duration + IsActiveService bool + IsNewFlow bool + LastKeepaliveAck uint32 + LastKeepaliveSeq uint32 + QueueHash uint8 + Reversed bool + SYNACKSeq uint32 + SYNSeq uint32 + StartTime time.Duration + TapSide uint8 + Tunnel TunnelField + VLAN uint16 + func (f *Flow) Reverse() + func (f *Flow) SequentialMerge(rhs *Flow) + func (f *Flow) String() string + func (f *Flow) WriteToPB(p *pb.Flow) + type FlowHeader struct + AgentID uint16 + Encoder uint8 + OrgID uint16 + Reserved1 uint16 + Reserved2 uint8 + TeamID uint32 + Version uint16 + func (h *FlowHeader) Decode(buf []byte) + func (h *FlowHeader) Encode(chunk []byte) + type FlowHeaderOld struct + OrgID uint32 + TeamID uint32 + VTAPID uint16 + Version uint32 + type FlowKey struct + IP6Dst net.IP + IP6Src net.IP + IPDst IPv4Int + IPSrc IPv4Int + MACDst MacInt + MACSrc MacInt + PortDst uint16 + PortSrc uint16 + Proto layers.IPProtocol + TapPort TapPort + TapType TapType + VtapId uint16 + func (_ *FlowKey) SequentialMerge(_ *FlowKey) + func (f *FlowKey) String() string + func (f *FlowKey) WriteToPB(p *pb.FlowKey) + type FlowMetricsPeer struct + ByteCount uint64 + First time.Duration + IsActiveHost bool + IsDevice bool + IsL2End bool + IsL3End bool + IsLocalIp bool + IsLocalMac bool + IsVIP bool + IsVIPInterface bool + L3ByteCount uint64 + L3EpcID int32 + L4ByteCount uint64 + Last time.Duration + NatRealIp net.IP + PacketCount uint64 + TCPFlags uint8 + TotalByteCount uint64 + TotalPacketCount uint64 + TotalTCPFlags uint8 + func (f *FlowMetricsPeer) SequentialMerge(rhs *FlowMetricsPeer) + func (f *FlowMetricsPeer) String() string + func (f *FlowMetricsPeer) WriteToPB(p *pb.FlowMetricsPeer) + type FlowPerfStats struct + var ZeroFlowPerfStats FlowPerfStats = FlowPerfStats{} + func AcquireFlowPerfStats() *FlowPerfStats + func CloneFlowPerfStats(s *FlowPerfStats) *FlowPerfStats + func (f *FlowPerfStats) SequentialMerge(rhs *FlowPerfStats) + func (f *FlowPerfStats) WriteToPB(p *pb.FlowPerfStats) + func (p *FlowPerfStats) String() string + type HTTPInfo struct + ClientIP string + Host string + Method string + Path string + ReqContentLength int64 + RespContentLength int64 + SpanID string + StreamID uint32 + TraceID string + Version string + XRequestId string + func AcquireHTTPInfo() *HTTPInfo + func (h *HTTPInfo) Merge(r interface{}) + func (h *HTTPInfo) String() string + func (h *HTTPInfo) WriteToPB(p *pb.AppProtoLogsData, msgType LogMessageType) + type HeaderType uint8 + const HEADER_TYPE_INVALID + const HEADER_TYPE_L2 + func (t HeaderType) IsIpv6() bool + func (t HeaderType) IsL3() bool + type IP struct + func NewIPFromInt(ipInt uint32) *IP + func NewIPFromString(ipStr string) *IP + func (ip *IP) Equals(other *IP) bool + func (ip *IP) GobDecode(buffer []byte) error + func (ip *IP) GobEncode() ([]byte, error) + func (ip *IP) Int() uint32 + func (ip *IP) String() string + type IP4 uint32 + func (ip4 IP4) String() string + type IPv4Int = uint32 + type IpNet struct + Netmask uint32 + RawIp net.IP + SubnetId uint32 + type KafkaCommand uint8 + const AddOffsetsToTxn + const AddPartitionsToTxn + const AllocateProducerIds + const AlterClientQuotas + const AlterConfigs + const AlterIsr + const AlterPartitionReassignments + const AlterReplicaLogDirs + const AlterUserScramCredentials + const ApiVersions + const ControlledShutdown + const CreateAcls + const CreateDelegationToken + const CreatePartitions + const CreateTopics + const DeleteAcls + const DeleteGroups + const DeleteRecords + const DeleteTopics + const DescribeAcls + const DescribeClientQuotas + const DescribeCluster + const DescribeConfigs + const DescribeDelegationToken + const DescribeGroups + const DescribeLogDirs + const DescribeProducers + const DescribeTransactions + const DescribeUserScramCredentials + const ElectLeaders + const EndTxn + const ExpireDelegationToken + const Fetch + const FindCoordinator + const Heartbeat + const IncrementalAlterConfigs + const InitProducerId + const JoinGroup + const LeaderAndIsr + const LeaveGroup + const ListGroups + const ListOffsets + const ListPartitionReassignments + const ListTransactions + const Metadata + const OffsetCommit + const OffsetDelete + const OffsetFetch + const OffsetForLeaderEpoch + const Produce + const RenewDelegationToken + const SaslAuthenticate + const SaslHandshake + const StopReplica + const SyncGroup + const TxnOffsetCommit + const UpdateFeatures + const UpdateMetadata + const WriteTxnMarkers + func (m KafkaCommand) String() string + type KafkaInfo struct + ApiKey uint16 + ApiVersion uint16 + ClientID string + CorrelationId uint32 + ReqMsgSize int32 + RespMsgSize int32 + func AcquireKafkaInfo() *KafkaInfo + func (i *KafkaInfo) Merge(r interface{}) + func (i *KafkaInfo) String() string + func (i *KafkaInfo) WriteToPB(p *pb.AppProtoLogsData, msgType LogMessageType) + type L3L2End int + const L3_L2_END_FALSE_FALSE + const L3_L2_END_FALSE_TRUE + const L3_L2_END_MAX + const L3_L2_END_TRUE_FALSE + const L3_L2_END_TRUE_TRUE + func NewL3L2End(l2End, l3End bool) L3L2End + type L4Protocol uint8 + const L4_PROTOCOL_MAX + const L4_PROTOCOL_TCP + const L4_PROTOCOL_UDP + const L4_PROTOCOL_UNKOWN + func (p *L4Protocol) String() string + type L7PerfStats struct + ErrClientCount uint32 + ErrServerCount uint32 + ErrTimeout uint32 + RRTCount uint32 + RRTMax uint32 + RRTSum uint64 + RequestCount uint32 + ResponseCount uint32 + func (p *L7PerfStats) SequentialMerge(rhs *L7PerfStats) + func (p *L7PerfStats) String() string + func (p *L7PerfStats) WriteToPB(b *pb.L7PerfStats) + type L7Protocol uint8 + const L7_PROTOCOL_AMQP + const L7_PROTOCOL_BRPC + const L7_PROTOCOL_CUSTOM + const L7_PROTOCOL_DNS + const L7_PROTOCOL_DUBBO + const L7_PROTOCOL_FASTCGI + const L7_PROTOCOL_GRPC + const L7_PROTOCOL_HTTP_1 + const L7_PROTOCOL_HTTP_2 + const L7_PROTOCOL_KAFKA + const L7_PROTOCOL_MONGODB + const L7_PROTOCOL_MQTT + const L7_PROTOCOL_MYSQL + const L7_PROTOCOL_NATS + const L7_PROTOCOL_OPENWIRE + const L7_PROTOCOL_ORACLE + const L7_PROTOCOL_POSTGRE + const L7_PROTOCOL_PULSAR + const L7_PROTOCOL_REDIS + const L7_PROTOCOL_SOFARPC + const L7_PROTOCOL_TARS + const L7_PROTOCOL_TLS + const L7_PROTOCOL_UNKNOWN + const L7_PROTOCOL_ZMTP + func (p L7Protocol) String(isTLS bool) string + type LogMessageStatus uint8 + const STATUS_CLIENT_ERROR + const STATUS_ERROR + const STATUS_NOT_EXIST + const STATUS_OK + const STATUS_SERVER_ERROR + func (t LogMessageStatus) String() string + type LogMessageType uint8 + const MSG_T_MAX + const MSG_T_OTHER + const MSG_T_REQUEST + const MSG_T_RESPONSE + const MSG_T_SESSION + func (t *LogMessageType) String() string + type LookupKey struct + BackwardMatched MatchedField + BackwardMatched6 MatchedField6 + Dst6Ip net.IP + DstIp uint32 + DstMac uint64 + DstPort uint16 + EthType EthernetType + FastIndex int + FeatureFlag FeatureFlags + ForwardMatched MatchedField + ForwardMatched6 MatchedField6 + L2End0 bool + L2End1 bool + L3End0 bool + L3End1 bool + L3EpcId0 uint16 + L3EpcId1 uint16 + Proto uint8 + Src6Ip net.IP + SrcIp uint32 + SrcMac uint64 + SrcPort uint16 + TapType TapType + Timestamp time.Duration + TunnelId uint32 + func (k *LookupKey) GenerateMatchedField(srcEpc, dstEpc uint16) + func (k *LookupKey) HasFeatureFlag(featureFlag FeatureFlags) bool + func (k *LookupKey) String() string + type MACAddr struct + func NewMACAddrFromInt(addrInt uint64) *MACAddr + func NewMACAddrFromString(addrStr string) *MACAddr + func (m *MACAddr) Equals(other *MACAddr) bool + func (m *MACAddr) Int() uint64 + func (m *MACAddr) String() string + type MacInt = uint64 + func MacIntFromBytes(bytes []byte) MacInt + type MatchFlags uint16 + const MATCHED6_DST_EPC + const MATCHED6_DST_IP0 + const MATCHED6_DST_IP1 + const MATCHED6_DST_PORT + const MATCHED6_PROTO + const MATCHED6_SRC_EPC + const MATCHED6_SRC_IP0 + const MATCHED6_SRC_IP1 + const MATCHED6_SRC_PORT + const MATCHED6_TAP_TYPE + const MATCHED_DST_EPC + const MATCHED_DST_IP + const MATCHED_DST_PORT + const MATCHED_PROTO + const MATCHED_SRC_EPC + const MATCHED_SRC_IP + const MATCHED_SRC_PORT + const MATCHED_TAP_TYPE + type MatchedField struct + func (f *MatchedField) And(n *MatchedField) MatchedField + func (f *MatchedField) Equal(n *MatchedField) bool + func (f *MatchedField) Get(flag MatchFlags) uint64 + func (f *MatchedField) GetAllTableIndex(maskVector, mask *MatchedField, min, max int, vectorBits []int) []uint16 + func (f *MatchedField) GetTableIndex(maskVector *MatchedField, min, max int) uint16 + func (f *MatchedField) GobDecode(in []byte) error + func (f *MatchedField) GobEncode() ([]byte, error) + func (f *MatchedField) IsBitZero(offset int) bool + func (f *MatchedField) Or(n *MatchedField) MatchedField + func (f *MatchedField) Set(flag MatchFlags, value uint64) + func (f *MatchedField) SetBits(whichs ...int) + func (f *MatchedField) SetMask(flag MatchFlags, value uint64) + func (f MatchedField) String() string + type MatchedField6 struct + func (f *MatchedField6) And(n *MatchedField6) MatchedField6 + func (f *MatchedField6) Equal(n *MatchedField6) bool + func (f *MatchedField6) Get(flag MatchFlags) uint64 + func (f *MatchedField6) GetAllTableIndex(maskVector, mask *MatchedField6, min, max int, vectorBits []int) []uint16 + func (f *MatchedField6) GetTableIndex(maskVector *MatchedField6, min, max int) uint16 + func (f *MatchedField6) GobDecode(in []byte) error + func (f *MatchedField6) GobEncode() ([]byte, error) + func (f *MatchedField6) IsBitZero(offset int) bool + func (f *MatchedField6) Or(n *MatchedField6) MatchedField6 + func (f *MatchedField6) Set(flag MatchFlags, value uint64) + func (f *MatchedField6) SetBits(whichs ...int) + func (f *MatchedField6) SetMask(flag MatchFlags, value uint64) + func (f MatchedField6) String() string + type MessageHeaderType uint8 + const HEADER_TYPE_LT + const HEADER_TYPE_LT_NOCHECK + const HEADER_TYPE_LT_VTAP + const HEADER_TYPE_UNKNOWN + type MessageType uint8 + const MESSAGE_TYPE_AGENT_LOG + const MESSAGE_TYPE_ALERT_EVENT + const MESSAGE_TYPE_APPLICATION_LOG + const MESSAGE_TYPE_COMPRESS + const MESSAGE_TYPE_DFSTATS + const MESSAGE_TYPE_K8S_EVENT + const MESSAGE_TYPE_MAX + const MESSAGE_TYPE_METRICS + const MESSAGE_TYPE_OPENTELEMETRY + const MESSAGE_TYPE_OPENTELEMETRY_COMPRESSED + const MESSAGE_TYPE_PACKETSEQUENCE + const MESSAGE_TYPE_PROC_EVENT + const MESSAGE_TYPE_PROFILE + const MESSAGE_TYPE_PROMETHEUS + const MESSAGE_TYPE_PROTOCOLLOG + const MESSAGE_TYPE_RAW_PCAP + const MESSAGE_TYPE_SERVER_DFSTATS + const MESSAGE_TYPE_SYSLOG + const MESSAGE_TYPE_TAGGEDFLOW + const MESSAGE_TYPE_TELEGRAF + func (m MessageType) HeaderType() MessageHeaderType + func (m MessageType) String() string + type MetaPacket struct + Direction PacketDirection + EndpointData EndpointData + EthType EthernetType + IHL uint8 + Ip6Dst net.IP + Ip6Src net.IP + IpDst uint32 + IpFlags uint16 + IpID uint16 + IpSrc uint32 + IsActiveService bool + L2End0 bool + L2End1 bool + L3End0 bool + L3End1 bool + L3EpcId0 uint16 + L3EpcId1 uint16 + MacDst MacInt + MacSrc MacInt + NextHeader IPProtocol + Options []byte + PacketLen uint16 + PolicyData PolicyData + PortDst uint16 + PortSrc uint16 + Protocol IPProtocol + QueueHash uint8 + RawHeader []byte + RawHeaderSize uint16 + RawIcmp []byte + TTL uint8 + TapPort uint32 + TapType TapType + TcpData MetaPacketTcpHeader + Timestamp time.Duration + Tunnel *TunnelInfo + Vlan uint16 + VtapId uint16 + func (p *MetaPacket) String() string + type MetaPacketBlock struct + ActionFlags ActionFlag + Count uint8 + Metas [META_PACKET_SIZE_PER_BLOCK]MetaPacket + QueueIndex uint8 + func AcquireMetaPacketBlock() *MetaPacketBlock + func (b *MetaPacketBlock) String() string + type MetaPacketTcpHeader struct + Ack uint32 + DataOffset uint8 + Flags uint8 + MSS uint16 + SACKPermitted bool + Sack []byte + Seq uint32 + WinScale uint8 + WinSize uint16 + func (h *MetaPacketTcpHeader) String() string + type Metering struct + ByteCount0 uint64 + ByteCount1 uint64 + IPDst IP + IPSrc IP + InPort0 uint32 + L3EpcID0 uint32 + L3EpcID1 uint32 + PacketCount0 uint64 + PacketCount1 uint64 + PortDst uint16 + PortSrc uint16 + Proto layers.IPProtocol + Timestamp time.Duration + VLAN uint16 + func (m *Metering) String() string + type MqttInfo struct + ClientID string + MqttType string + ProtoVersion uint16 + ReqMsgSize int32 + RespMsgSize int32 + func AcquireMqttInfo() *MqttInfo + func (i *MqttInfo) Merge(r interface{}) + func (i *MqttInfo) String() string + func (i *MqttInfo) WriteToPB(p *pb.AppProtoLogsData, msgType LogMessageType) + type MysqlCommand uint8 + func (m MysqlCommand) String() string + type MysqlInfo struct + AffectedRows uint64 + Command uint8 + Context string + ErrorCode uint16 + ErrorMessage string + ProtocolVersion uint8 + ResponseCode uint8 + ServerThreadID uint32 + ServerVersion string + func AcquireMYSQLInfo() *MysqlInfo + func (i *MysqlInfo) Merge(r interface{}) + func (i *MysqlInfo) String() string + func (i *MysqlInfo) WriteToPB(p *pb.AppProtoLogsData, msgType LogMessageType) + type NATSource uint8 + const NAT_SOURCE_NONE + const NAT_SOURCE_RTOA + const NAT_SOURCE_TOA + const NAT_SOURCE_VIP + func (n NATSource) String() string + type NpbAction uint64 + func ToNpbAction(aclGid, id uint32, tunnelType, tapSide uint8, slice uint16) NpbAction + func (a *NpbAction) AddTapSide(flag int) + func (a *NpbAction) ReverseTapSide() NpbAction + func (a *NpbAction) SetPayloadSlice(payload uint16) + func (a *NpbAction) SetTapSide(flag int) + func (a *NpbAction) SetTunnelId(id uint32) + func (a NpbAction) GetDirections() DirectionType + func (a NpbAction) PayloadSlice() uint16 + func (a NpbAction) String() string + func (a NpbAction) TapSide() int + func (a NpbAction) TapSideCompare(flag int) bool + func (a NpbAction) TunnelGid() uint16 + func (a NpbAction) TunnelId() uint32 + func (a NpbAction) TunnelIp() net.IP + func (a NpbAction) TunnelIpId() uint16 + func (a NpbAction) TunnelType() uint8 + type NpbActions struct + func ToNpbActions(aclGid, id uint32, tunnelType, tapSide uint8, slice uint16) NpbActions + func (a *NpbActions) AddAclGid(aclGids ...uint16) + func (a *NpbActions) ReverseTapSide() NpbActions + func (a NpbActions) GetAclGid() []uint16 + func (a NpbActions) String() string + func (n *NpbActions) Decode(decoder *codec.SimpleDecoder) + func (n *NpbActions) Encode(encoder *codec.SimpleEncoder) + type PacketDirection uint8 + const CLIENT_TO_SERVER + const SERVER_TO_CLIENT + func OppositePacketDirection(d PacketDirection) PacketDirection + type PacketFlag uint16 + const CFLAG_DATAOFF_IHL + const CFLAG_FLAGS_FRAG_OFFSET + const CFLAG_FULL + const CFLAG_HEADER_TYPE + const CFLAG_IP0 + const CFLAG_IP1 + const CFLAG_MAC0 + const CFLAG_MAC1 + const CFLAG_PORT0 + const CFLAG_PORT1 + const CFLAG_TTL + const CFLAG_VLANTAG + const PFLAG_DST_ENDPOINT + const PFLAG_DST_L3ENDPOINT + const PFLAG_NONE + const PFLAG_SRC_ENDPOINT + const PFLAG_SRC_L3ENDPOINT + const PFLAG_TUNNEL + func (f PacketFlag) IsSet(flag PacketFlag) bool + type PeerConnection struct + Id uint32 + LocalEpc int32 + RemoteEpc int32 + type PlatformData struct + DeviceType uint8 + EpcId int32 + Id uint32 + IfType uint8 + Ips []IpNet + IsLocal bool + IsVIPInterface bool + Mac uint64 + PodClusterId uint32 + PodNodeId uint32 + RegionId uint32 + SkipMac bool + type PolicyData struct + AclId uint32 + ActionFlags ActionFlag + NpbActions []NpbActions + func (d *PolicyData) ContainNpb() bool + func (d *PolicyData) ContainPcap() bool + func (d *PolicyData) Dedup(packet *LookupKey) + func (d *PolicyData) FormatNpbAction() + func (d *PolicyData) GobDecode(in []byte) error + func (d *PolicyData) GobEncode() ([]byte, error) + func (d *PolicyData) Merge(npbActions []NpbActions, aclID uint32, directions ...DirectionType) + func (d *PolicyData) MergeAndSwapDirection(npbActions []NpbActions, aclID uint32) + func (d *PolicyData) MergeNpbAction(actions []NpbActions, aclID uint32, directions ...DirectionType) + func (d *PolicyData) MergeNpbAndSwapDirection(actions []NpbActions, aclID uint32) + func (d *PolicyData) String() string + func (d *PolicyData) Valid() bool + func (p *PolicyData) Decode(decoder *codec.SimpleDecoder) + func (p *PolicyData) Encode(encoder *codec.SimpleEncoder) + type PortRange uint32 + func GetPortRanges(raw []PortRange) []PortRange + func NewPortRange(min, max uint16) PortRange + func SplitPort2Int(src string) []PortRange + func (p PortRange) Max() uint16 + func (p PortRange) Min() uint16 + func (p PortRange) String() string + type PortStatus uint8 + const RANGE_EDGE + const RANGE_IN + const RANGE_LEFT + const RANGE_NONE + const RANGE_RIGHT + type ProtoSpecialInfo interface + Merge func(interface{}) + String func() string + type RawPacket = []byte + type RedisInfo struct + Error string + Request string + RequestType string + Response string + Status string + func AcquireREDISInfo() *RedisInfo + func (i *RedisInfo) Merge(r interface{}) + func (i *RedisInfo) String() string + func (i *RedisInfo) WriteToPB(p *pb.AppProtoLogsData, msgType LogMessageType) + type SignalSource uint8 + const SIGNAL_SOURCE_EBPF + const SIGNAL_SOURCE_OTEL + const SIGNAL_SOURCE_PACKET + const SIGNAL_SOURCE_XFLOW + func (t SignalSource) String() string + type TCPPerfStats struct + ARTCount uint32 + ARTMax uint32 + ARTSum uint32 + RTT uint32 + RTTClientCount uint32 + RTTClientMax uint32 + RTTClientSum uint32 + RTTServerCount uint32 + RTTServerMax uint32 + RTTServerSum uint32 + SRTCount uint32 + SRTMax uint32 + SRTSum uint32 + TcpPerfCountsPeers [2]TcpPerfCountsPeer + TotalRetransCount uint32 + func (f *TCPPerfStats) Reverse() + func (f *TCPPerfStats) SequentialMerge(rhs *TCPPerfStats) + func (f *TCPPerfStats) WriteToPB(p *pb.TCPPerfStats, l4Protocol L4Protocol) + func (p *TCPPerfStats) String() string + type Tag struct + PolicyData [2]PolicyData + func (t *Tag) Decode(decoder *codec.SimpleDecoder) + func (t *Tag) Encode(encoder *codec.SimpleEncoder) + func (t *Tag) Reverse() + type TaggedFlow struct + func AcquireTaggedFlow() *TaggedFlow + func CloneTaggedFlow(taggedFlow *TaggedFlow) *TaggedFlow + func CloneTaggedFlowForPacketStat(taggedFlow *TaggedFlow) *TaggedFlow + func (f *TaggedFlow) EncodePB(encoder *codec.SimpleEncoder, i interface{}) error + func (f *TaggedFlow) Release() + func (f *TaggedFlow) Reverse() + func (f *TaggedFlow) SequentialMerge(rhs *TaggedFlow) + func (f *TaggedFlow) String() string + func (f *TaggedFlow) WriteToPB(p *pb.TaggedFlow) error + type TaggedMetering struct + func (m *TaggedMetering) BitCount() uint64 + func (m *TaggedMetering) PacketCount() uint64 + func (t *TaggedMetering) String() string + type TapPort uint64 + func FromGatewayMAC(tunnelType TunnelType, mac uint32) TapPort + func FromID(tunnelType TunnelType, id int) TapPort + func FromLocalMAC(tunnelType TunnelType, mac uint32) TapPort + func FromNetFlow(mac uint32) TapPort + func FromSFlow(mac uint32) TapPort + func FromTunnelIP(ip uint32, isIPv6 bool) TapPort + func (p TapPort) SetReservedBytes(v uint32) TapPort + func (p TapPort) SplitToPortTypeTunnel() (uint32, uint8, NATSource, TunnelType) + func (p TapPort) String() string + type TapType uint16 + const TAP_ANY + const TAP_CLOUD + const TAP_IDC_MIN + const TAP_MAX + const TAP_MIN + func (t *TapType) CheckTapType(tapType TapType) bool + type TcpPerfCountsPeer struct + RetransCount uint32 + ZeroWinCount uint32 + func (f *TcpPerfCountsPeer) SequentialMerge(rhs *TcpPerfCountsPeer) + func (t *TcpPerfCountsPeer) WriteToPB(p *pb.TcpPerfCountsPeer) + type TunnelField struct + IsIPv6 bool + RxIP0 IPv4Int + RxIP1 IPv4Int + RxId uint32 + RxMAC0 uint32 + RxMAC1 uint32 + Tier uint8 + TxIP0 IPv4Int + TxIP1 IPv4Int + TxId uint32 + TxMAC0 uint32 + TxMAC1 uint32 + Type TunnelType + func (f *TunnelField) WriteToPB(p *pb.TunnelField) + func (t *TunnelField) String() string + type TunnelInfo struct + Dst IPv4Int + Id uint32 + IsIPv6 bool + MacDst uint32 + MacSrc uint32 + Src IPv4Int + Tier uint8 + Type TunnelType + func (t *TunnelInfo) Decapsulate(packet []byte, l2Len int, tunnelTypeBitmap TunnelTypeBitmap) int + func (t *TunnelInfo) Decapsulate6(packet []byte, l2Len int, tunnelTypeBitmap TunnelTypeBitmap) int + func (t *TunnelInfo) Decapsulate6Vxlan(packet []byte, l2Len int) int + func (t *TunnelInfo) DecapsulateErspan(packet []byte, l2Len int, flags, greProtocolType uint16, ipHeaderSize int) int + func (t *TunnelInfo) DecapsulateGre(packet []byte, l2Len int, tunnelTypeBitmap TunnelTypeBitmap) int + func (t *TunnelInfo) DecapsulateIPIP(packet []byte, l2Len int, underlayIpv6, overlayIpv6 bool) int + func (t *TunnelInfo) DecapsulateTeb(packet []byte, l2Len int, flags, greProtocolType uint16, ipHeaderSize int) int + func (t *TunnelInfo) DecapsulateTencentGre(packet []byte, l2Len int, flags, greProtocolType uint16, ipHeaderSize int) int + func (t *TunnelInfo) DecapsulateVxlan(packet []byte, l2Len int) int + func (t *TunnelInfo) String() string + func (t *TunnelInfo) Valid() bool + type TunnelType uint8 + func (t TunnelType) String() string + type TunnelTypeBitmap uint16 + func NewTunnelTypeBitmap(items ...TunnelType) TunnelTypeBitmap + func (b *TunnelTypeBitmap) Add(tunnelType TunnelType) + func (b TunnelTypeBitmap) Has(tunnelType TunnelType) bool + func (b TunnelTypeBitmap) IsEmpty() bool + func (b TunnelTypeBitmap) String() string
Go to main page