factoryadapter

README

Storage Factory Converter

A temporary v1 storage factory wrapper to implement v2 storage APIs. This way, the existing v1 storage factories declared in jaegerstorageextension can act as v2 storage while we migrate to v2 storage APIs.

Documentation

Index

• func NewFactory(ss storage_v1.Factory) spanstore.Factory
• func NewTraceWriter(spanWriter spanstore_v1.Writer) spanstore.Writer
• type Factory
  • func (f *Factory) Close(_ context.Context) error
  • func (*Factory) CreateTraceReader() (spanstore.Reader, error)
  • func (f *Factory) CreateTraceWriter() (spanstore.Writer, error)
  • func (*Factory) Initialize(_ context.Context) error
• type TraceWriter
  • func (t *TraceWriter) WriteTraces(ctx context.Context, td ptrace.Traces) error

Functions

func NewFactory

func NewFactory(ss storage_v1.Factory) spanstore.Factory

func NewTraceWriter

func NewTraceWriter(spanWriter spanstore_v1.Writer) spanstore.Writer

Types

type Factory

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

func (*Factory) Close

func (f *Factory) Close(_ context.Context) error

Close implements spanstore.Factory.

func (*Factory) CreateTraceReader

func (*Factory) CreateTraceReader() (spanstore.Reader, error)

CreateTraceReader implements spanstore.Factory.

func (*Factory) CreateTraceWriter

func (f *Factory) CreateTraceWriter() (spanstore.Writer, error)

CreateTraceWriter implements spanstore.Factory.

func (*Factory) Initialize

func (*Factory) Initialize(_ context.Context) error

Initialize implements spanstore.Factory.

type TraceWriter

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

func (*TraceWriter) WriteTraces

func (t *TraceWriter) WriteTraces(ctx context.Context, td ptrace.Traces) error

WriteTraces implements spanstore.Writer.