trace

Nov 17, 2021

Changes in this version

+ const DefaultTraceCacheWindow

+ type BufferedDirectTraceExporter struct

+ func NewBufferedDirectTraceExporter(log *logrus.Logger, consumer consumer.Traces, bufferSize int) *BufferedDirectTraceExporter

+ func (s *BufferedDirectTraceExporter) Export(ctx context.Context, flows <-chan protoreflect.Message) error

+ type BufferedTraceExporter struct

+ func NewBufferedTraceExporter(otlpConn *grpc.ClientConn, bufferSize int, headers map[string]string, ...) *BufferedTraceExporter

+ func (s *BufferedTraceExporter) Export(ctx context.Context, flows <-chan protoreflect.Message) error

+ type FlowConverter struct

+ func NewFlowConverter(log *logrus.Logger, dir string, options *common.EncodingOptions, ...) (*FlowConverter, error)

+ func (c *FlowConverter) CloseCache() error

+ func (c *FlowConverter) Convert(hubbleResp *hubbleObserver.GetFlowsResponse) (protoreflect.Message, error)

+ func (c *FlowConverter) DeleteCache()

+ type IDTuple struct

+ SpanID trace.SpanID

+ TraceID trace.TraceID

+ type TraceCache struct

+ StoreFlowData bool

+ Strict bool

+ TraceCacheWindow time.Duration

+ func NewTraceCache(opt badger.Options, traceCacheWindow time.Duration) (*TraceCache, error)

+ func (tc *TraceCache) Close() error

+ func (tc *TraceCache) Delete()

+ func (tc *TraceCache) GetSpanContext(f *flow.Flow, parseHeaders bool) (*trace.SpanContext, *trace.SpanContext, error)