Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Metrics = metrics.NewPrefixedRegistry("zipkin.proxy.")
Functions ¶
func ErrorCorrectSpans ¶
func ErrorCorrectSpans(spanChannel <-chan *zipkincore.Span, output chan<- *zipkincore.Span)
func Main ¶
func Main(spanConverter SpanConverter)
func PipeThroughSpans ¶ added in v1.5.7
func PipeThroughSpans(in <-chan *zipkincore.Span, out chan<- *zipkincore.Span)
Types ¶
type SpanConverter ¶ added in v1.6.0
type SpanConverter func(span *zipkincore.Span) *zipkincore.Span
type SpansBuffer ¶
type SpansBuffer struct {
// contains filtered or unexported fields
}
func NewSpansBuffer ¶
func NewSpansBuffer(capacity uint) *SpansBuffer
func (*SpansBuffer) ReadFrom ¶
func (buffer *SpansBuffer) ReadFrom(spans <-chan *zipkincore.Span)
func (*SpansBuffer) ToSlice ¶
func (buffer *SpansBuffer) ToSlice() []jsoncodec.SpanV1
Click to show internal directories.
Click to hide internal directories.