zipkinreceiver

Documentation

Index

• type ZipkinReceiver
  • func New(address string) (*ZipkinReceiver, error)
  • func (zr *ZipkinReceiver) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (zr *ZipkinReceiver) StartTraceReception(ctx context.Context, spanSink receiver.TraceReceiverSink) error
  • func (zr *ZipkinReceiver) StopTraceReception(ctx context.Context) error

Types

type ZipkinReceiver

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

ZipkinReceiver type is used to handle spans received in the Zipkin format.

func New

func New(address string) (*ZipkinReceiver, error)

New creates a new zipkinreceiver.ZipkinReceiver reference.

func (*ZipkinReceiver) ServeHTTP

func (zr *ZipkinReceiver) ServeHTTP(w http.ResponseWriter, r *http.Request)

The ZipkinReceiver receives spans from endpoint /api/v2 as JSON, unmarshals them and sends them along to the spansink.Sink.

func (*ZipkinReceiver) StartTraceReception

func (zr *ZipkinReceiver) StartTraceReception(ctx context.Context, spanSink receiver.TraceReceiverSink) error

StartTraceReception spins up the receiver's HTTP server and makes the receiver start its processing.

func (*ZipkinReceiver) StopTraceReception

func (zr *ZipkinReceiver) StopTraceReception(ctx context.Context) error

StopTraceReception tells the receiver that should stop reception, giving it a chance to perform any necessary clean-up and shutting down its HTTP server.