Documentation
¶
Index ¶
- func ErrorCorrectSpans(inputCh <-chan proxy.Span, outputCh chan<- proxy.Span, opts CorrectionOptions)
- func Main(spanConverter SpanConverter)
- func MainWithRouting(routing Routing, spanConverter SpanConverter)
- type CorrectionOptions
- type Id
- type Routing
- type SpanConverter
- type SpanSlice
- type SpansBuffer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ErrorCorrectSpans ¶
func ErrorCorrectSpans(inputCh <-chan proxy.Span, outputCh chan<- proxy.Span, opts CorrectionOptions)
func Main ¶
func Main(spanConverter SpanConverter)
func MainWithRouting ¶ added in v1.8.0
func MainWithRouting(routing Routing, spanConverter SpanConverter)
Types ¶
type CorrectionOptions ¶ added in v1.8.1
type CorrectionOptions struct {
NoCorrectTreeTimings bool
}
type SpanSlice ¶ added in v1.8.1
func (SpanSlice) GetSpanRef ¶ added in v1.8.1
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 proxy.Span)
func (*SpansBuffer) ToSlice ¶
func (buffer *SpansBuffer) ToSlice() []proxy.Span
Click to show internal directories.
Click to hide internal directories.