trace

Documentation

Index

• Constants
• func ResponseWithJSON(rsp http.ResponseWriter, response *Response, code int)
• func SkywalkingToTraces(segment *agentV3.SegmentObject) ptrace.Traces
• type Receiver
  • func NewReceiver(nextConsumer consumer.Traces, set receiver.CreateSettings) (*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

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"
	AttributeSkywalkingParentSpanID    = "sw8.parent_span_id"
	AttributeSkywalkingParentSegmentID = "sw8.parent_segment_id"
	AttributeNetworkAddressUsedAtPeer  = "network.AddressUsedAtPeer"
)

Functions

func ResponseWithJSON

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

func SkywalkingToTraces

func SkywalkingToTraces(segment *agentV3.SegmentObject) ptrace.Traces

Types

type Receiver

type Receiver struct {
	agent.UnimplementedTraceSegmentReportServiceServer
	// contains filtered or unexported fields
}

func NewReceiver

func NewReceiver(nextConsumer consumer.Traces, set receiver.CreateSettings) (*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"`
}