network

Documentation

Index

• type AgentInfo
  • func NewAgentInfo() *AgentInfo
• type CMD
  • func NewCMD() *CMD
• type Ping
  • func NewPing() *Ping
• type Spans
  • func NewSpans() *Spans
• type SpansPacket
  • func NewSpansPacket() *SpansPacket
• type TracePack
  • func NewTracePack() *TracePack
  • func (t *TracePack) Decode(rdr io.Reader) error
  • func (t *TracePack) Encode() []byte

Types

type AgentInfo

type AgentInfo struct {
	AppName        string `db:"app_name" json:"applicationName"  msg:"applicationName"`
	AgentID        string `db:"agent_id" json:"agentId"  msg:"agentId"`
	ServiceType    int32  `db:"ser_type" json:"serviceType"  msg:"serviceType"`
	HostName       string `db:"host_name" json:"hostName" msg:"hostName"`
	IP4S           string `db:"ip" json:"ip" msg:"ip"`
	StartTimestamp int64  `db:"start_time" json:"startTimestamp" msg:"startTimestamp"`
	EndTimestamp   int64  `db:"end_time" json:"end_time" msg:"end_time"`
	IsContainer    bool   `db:"is_container" json:"is_container" msg:"is_container"`
	OperatingEnv   int32  `db:"operating_env" json:"operating_env" msg:"operating_env"`
	AgentInfo      string `db:"agent_info" json:"agent_info" msg:"agent_info"`
}

AgentInfo ...

func NewAgentInfo

func NewAgentInfo() *AgentInfo

NewAgentInfo ...

type CMD

type CMD struct {
	Type    uint16 `msg:"t"`
	Payload []byte `msg:"p"`
}

CMD ...

func NewCMD

func NewCMD() *CMD

NewCMD ...

type Ping

type Ping struct {
}

Ping ...

func NewPing

func NewPing() *Ping

NewPing ...

type Spans

type Spans struct {
	Type  uint16 `msg:"type"`
	Spans []byte `msg:"spans"`
}

type DataType : SpanV2 SpanChunk AgentStat AgentStatBatch Spans data

func NewSpans

func NewSpans() *Spans

NewSpans ...

type SpansPacket

type SpansPacket struct {
	Type     uint16   `msg:"type"` // tcp or udp
	AppName  string   `msg:"appName"`
	AgentID  string   `msg:"agentID"`
	SpanTime int64    `msg:"spanTime"`
	Payload  []*Spans `msg:"payload"`
}

SpansPacket pinpoint data

func NewSpansPacket

func NewSpansPacket() *SpansPacket

NewSpansPacket ...

type TracePack

type TracePack struct {
	Type       byte   `msgp:"t"`  // 类型
	IsSync     byte   `msgp:"is"` // 是否同步
	IsCompress byte   `msgp:"cp"` // 是否压缩
	ID         uint32 `msgp:"id"` // 报文ID
	Len        uint32 `msgp:"l"`  // 长度
	Payload    []byte `msgp:"p"`  // 数据
}

TracePack trace通信标准包

func NewTracePack

func NewTracePack() *TracePack

NewTracePack ...

func (*TracePack) Decode

func (t *TracePack) Decode(rdr io.Reader) error

Decode decode

func (*TracePack) Encode

func (t *TracePack) Encode() []byte

Encode encode