trace

Documentation

Index

• 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

Functions

func ResponseWithJSON

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

Types

type Receiver

type Receiver struct {
	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"`
}