Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrBusy = errors.New("server busy")
ErrBusy signalizes that processor cannot process incoming data
Functions ¶
This section is empty.
Types ¶
type InboundTransport ¶
type InboundTransport string
InboundTransport identifies the transport used to receive spans.
const ( // GRPCTransport indicates spans received over gRPC. GRPCTransport InboundTransport = "grpc" // HTTPTransport indicates spans received over HTTP. HTTPTransport InboundTransport = "http" // UnknownTransport is the fallback/catch-all category. UnknownTransport InboundTransport = "unknown" )
type SpanFormat ¶
type SpanFormat string
SpanFormat identifies the data format in which the span was originally received.
const ( // JaegerSpanFormat is for Jaeger Thrift spans. JaegerSpanFormat SpanFormat = "jaeger" // ZipkinSpanFormat is for Zipkin Thrift spans. ZipkinSpanFormat SpanFormat = "zipkin" // ProtoSpanFormat is for Jaeger protobuf Spans. ProtoSpanFormat SpanFormat = "proto" // OTLPSpanFormat is for OpenTelemetry OTLP format. OTLPSpanFormat SpanFormat = "otlp" // UnknownSpanFormat is the fallback/catch-all category. UnknownSpanFormat SpanFormat = "unknown" )
type SpanProcessor ¶
type SpanProcessor interface {
// ProcessSpans processes model spans and return with either a list of true/false success or an error
ProcessSpans(mSpans []*model.Span, options SpansOptions) ([]bool, error)
io.Closer
}
SpanProcessor handles model spans
type SpansOptions ¶
type SpansOptions struct {
SpanFormat SpanFormat
InboundTransport InboundTransport
Tenant string
}
SpansOptions additional options passed to processor along with the spans.
Source Files
Click to show internal directories.
Click to hide internal directories.