parser

Documentation

Index

• Constants
• Variables
• func BuildExternalKey(keyValue *cache.ReusedKeyValue, pid string, containerId string, ...) string
• func BuildServerKey(keyValue *cache.ReusedKeyValue, pid string, containerId string, ...) string
• func GetClientPeer(attr pcommon.Map) string
• type DbParser
  • func NewDbParser() *DbParser
  • func (parser *DbParser) Parse(logger *zap.Logger, pid string, containerId string, serviceName string, ...) string
• type HttpParser
  • func NewHttpParser(urlParser string) *HttpParser
  • func (parser *HttpParser) Parse(logger *zap.Logger, pid string, containerId string, serviceName string, ...) string
• type MqParser
  • func NewMqParser() *MqParser
  • func (parser *MqParser) Parse(logger *zap.Logger, pid string, containerId string, serviceName string, ...) string
• type Parser
• type RpcParser
  • func NewRpcParser() *RpcParser
  • func (parser *RpcParser) Parse(logger *zap.Logger, pid string, containerId string, serviceName string, ...) string

Constants

const (
	AttributeHttpMethod        = "http.method"         // 1.x
	AttributeHttpRequestMethod = "http.request.method" // 2.x

	AttributeHttpUrl = "http.url" // 1.x
	AttributeUrlFull = "url.full" // 2.x
)

const (
	AttributeMessageDest     = "messaging.destination"
	AttributeMessageDestName = "messaging.destination.name"
)

const (
	Unknown = "unknown"

	AttributeNetPeerName   = "net.peer.name"  // 1.x
	AttributeNetPeerPort   = "net.peer.port"  // 1.x
	AttributeServerAddress = "server.address" // 2.x
	AttributeServerPort    = "server.port"    // 2.x

	AttributeNetSockPeerAddr    = "net.sock.peer.addr"   // 1.x
	AttributeNetSockPeerPort    = "net.sock.peer.port"   // 1.x
	AttributeNetworkPeerAddress = "network.peer.address" // 2.x
	AttributeNetworkPeerPort    = "network.peer.port"    // 2.x

)

Variables

var (
	NodeName = getNodeName()
	NodeIp   = getNodeIp()
)

Functions

func BuildExternalKey

func BuildExternalKey(keyValue *cache.ReusedKeyValue, pid string, containerId string, serviceName string, name string, peer string, system string, isError bool) string

buildExternalKey Http/Rpc Red指标

func BuildServerKey

func BuildServerKey(keyValue *cache.ReusedKeyValue, pid string, containerId string, serviceName string, name string, topSpan bool, isError bool) string

func GetClientPeer

func GetClientPeer(attr pcommon.Map) string

Types

type DbParser

type DbParser struct {
}

func NewDbParser

func NewDbParser() *DbParser

func (*DbParser) Parse

func (parser *DbParser) Parse(logger *zap.Logger, pid string, containerId string, serviceName string, span ptrace.Span, spanAttr pcommon.Map, keyValue *cache.ReusedKeyValue) string

type HttpParser

type HttpParser struct {
	// contains filtered or unexported fields
}

func NewHttpParser

func NewHttpParser(urlParser string) *HttpParser

func (*HttpParser) Parse

func (parser *HttpParser) Parse(logger *zap.Logger, pid string, containerId string, serviceName string, span ptrace.Span, spanAttr pcommon.Map, keyValue *cache.ReusedKeyValue) string

type MqParser

type MqParser struct {
}

func NewMqParser

func NewMqParser() *MqParser

func (*MqParser) Parse

func (parser *MqParser) Parse(logger *zap.Logger, pid string, containerId string, serviceName string, span ptrace.Span, spanAttr pcommon.Map, keyValue *cache.ReusedKeyValue) string

type Parser

type Parser interface {
	Parse(logger *zap.Logger, pid string, containerId string, serviceName string, span ptrace.Span, spanAttr pcommon.Map, keyValue *cache.ReusedKeyValue) string
}

type RpcParser

type RpcParser struct {
}

func NewRpcParser

func NewRpcParser() *RpcParser

func (*RpcParser) Parse

func (parser *RpcParser) Parse(logger *zap.Logger, pid string, containerId string, serviceName string, span ptrace.Span, spanAttr pcommon.Map, keyValue *cache.ReusedKeyValue) string