trace

Documentation

Index

• Constants
• func ProtoToTraces(segment *agentV3.SegmentObject, pid int, containerId string) ptrace.Traces
• func ResponseWithJSON(rsp http.ResponseWriter, response *Response, code int)
• type Receiver
  • func NewReceiver(nextConsumer consumer.Traces, set receiver.Settings) (*Receiver, error)
  • func (r *Receiver) Collect(stream agent.TraceSegmentReportService_CollectServer) error
  • func (r *Receiver) CollectInSync(ctx context.Context, segments *agent.SegmentCollection) (*common.Commands, error)
  • func (r *Receiver) HTTPHandler(rsp http.ResponseWriter, req *http.Request)
• type Response
• type UndertowCache
  • func (c *UndertowCache) CheckUndertow(segment *agent.SegmentObject, ptd *ptrace.Traces) *ptrace.Traces

Constants

const (
	AttributeRefType                   = "refType"
	AttributeParentService             = "parent.service"
	AttributeParentInstance            = "parent.service.instance"
	AttributeParentEndpoint            = "parent.endpoint"
	AttributeSkywalkingSpanID          = "sw8.span_id"
	AttributeSkywalkingTraceID         = "sw8.trace_id"
	AttributeSkywalkingSegmentID       = "sw8.segment_id"
	AttributeSkywalkingComponmentID    = "sw8.componment_id"
	AttributeSkywalkingParentSpanID    = "sw8.parent_span_id"
	AttributeSkywalkingParentSegmentID = "sw8.parent_segment_id"
	AttributeNetworkAddressUsedAtPeer  = "network.AddressUsedAtPeer"
)

const (
	ComponentUndertow   int32 = 84
	ComponentSpringMVC  int32 = 14
	OperateNameUndertow       = "UndertowDispatch"
)

Functions

func ProtoToTraces

func ProtoToTraces(segment *agentV3.SegmentObject, pid int, containerId string) ptrace.Traces

ProtoToTraces converts multiple skywalking proto batches to internal traces

func ResponseWithJSON

func ResponseWithJSON(rsp http.ResponseWriter, response *Response, code int)

Types

type Receiver

type Receiver struct {
	FillProcExtension fillproc.FillProc

	agent.UnimplementedTraceSegmentReportServiceServer
	// contains filtered or unexported fields
}

func NewReceiver

func NewReceiver(nextConsumer consumer.Traces, set receiver.Settings) (*Receiver, error)

NewReceiver creates a new Receiver reference.

func (*Receiver) Collect

func (r *Receiver) Collect(stream agent.TraceSegmentReportService_CollectServer) error

Collect implements the service Collect traces func.

func (*Receiver) CollectInSync

func (r *Receiver) CollectInSync(ctx context.Context, segments *agent.SegmentCollection) (*common.Commands, error)

CollectInSync implements the service CollectInSync traces func.

func (*Receiver) HTTPHandler

func (r *Receiver) HTTPHandler(rsp http.ResponseWriter, req *http.Request)

type Response

type Response struct {
	Status string `json:"status"`
	Msg    string `json:"msg"`
}

type UndertowCache

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

func (*UndertowCache) CheckUndertow

func (c *UndertowCache) CheckUndertow(segment *agent.SegmentObject, ptd *ptrace.Traces) *ptrace.Traces