agent

type AgentRouter struct {
	AgentMap map[string]*GrpcAgent
	PingId   int32
	Quit     chan bool
	WG       *sync.WaitGroup
	// contains filtered or unexported fields
}

type Filter interface {
	Interceptor(span *TSpan) bool
}

type GetMaxAvg func() (max, avg uint32)

type GetReqTimeCounter func() [4]uint16

type GrpcAgent struct {
	AgentId string

	StartTime string
	BaseMD    metadata.MD

	PingId int32

	AgentOnLine bool

	ExitCh chan bool
	// contains filtered or unexported fields
}

type I_PacketRouter interface {
	DispatchPacket(*RawPacket) error
	Clean()
}

type I_SendMeta interface {
	SenderGrpcMetaData(name string, id int32, Type int32, params PARAMS_TYPE) error
}

type MetaData struct {
	MetaDataType int32
	IDMap        PARAMS_TYPE
	Sender       I_SendMeta
}

type PARAMS_TYPE map[string]int32

type RawPacket struct {
	Type    uint32
	RawData []byte
}

type RequestProfiler struct {
	CTime int64
	// contains filtered or unexported fields
}

type SpanSender struct {
	Md     metadata.MD
	ExitCh chan bool
	// contains filtered or unexported fields
}

type TErrorInfo struct {
	Msg  string `json:"msg"`
	File string `json:"file"`
	Line int    `json:"line"`
}

type TSpan struct {
	AppServerType         int32        `json:"FT"`
	AppServerTypeV2       int32        `json:":FT"`
	ParentAppServerType   int32        `json:"ptype,string"`
	ParentSpanId          int64        `json:"psid,string"`
	ParentApplicationName string       `json:"pname"`
	StartTime             int64        `json:"S"`
	StartTimeV2           int64        `json:":S"`
	ElapsedTime           int32        `json:"E"`
	ElapsedTimeV2         int32        `json:":E"`
	AppId                 string       `json:"appid"`
	AppIdV2               string       `json:":appid"`
	AppName               string       `json:"appname"`
	AppNameV2             string       `json:":appname"`
	Calls                 []TSpanEvent `json:"calls"`
	Clues                 []string     `json:"clues,omitempty"`
	SpanName              string       `json:"name"`
	SpanId                int64        `json:"sid,string"`
	ServerType            int32        `json:"stp,string"`
	TransactionId         string       `json:"tid"`
	Uri                   string       `json:"uri"`
	UT                    string       `json:"UT,omitempty"`
	EndPoint              string       `json:"server"`
	RemoteAddr            string       `json:"client"`
	AcceptorHost          string       `json:"Ah"`
	ExceptionInfo         string       `json:"EXP,omitempty"`
	ErrorInfo             *TErrorInfo  `json:"ERR,omitempty"`
	NginxHeader           string       `json:"NP,omitempty"`
	ApacheHeader          string       `json:"AP,omitempty"`
}

type TSpanEvent struct {
	Name           string       `json:"name"`
	ExceptionInfo  string       `json:"EXP,omitempty"`
	DestinationId  string       `json:"dst,omitempty"`
	NextSpanId     int64        `json:"nsid,string,omitempty"`
	EndPoint       string       `json:"server,omitempty"`
	StartElapsed   int32        `json:"S"`
	EndElapsed     int32        `json:"E"`
	StartElapsedV2 int32        `json:":S"`
	EndElapsedV2   int32        `json:":E"`
	ServiceType    int32        `json:"stp,string"`
	Clues          []string     `json:"clues,omitempty"`
	Calls          []TSpanEvent `json:"calls,omitempty"`
	SqlMeta        string       `json:"SQL,omitempty"`
}

type UrlTemplateReport struct {
	BucketVersion int32
	// contains filtered or unexported fields
}