store

Documentation

Index

• func DecodeLogs(raw []byte) ([]model.Log, error)
• func DecodeSpanID(raw []byte) model.SpanID
• func DecodeSpanRefs(data []byte) ([]model.SpanRef, error)
• func DecodeTags(input []byte) ([]model.KeyValue, error)
• func DecodeTraceID(raw []byte) model.TraceID
• func EncodeInterval(duration time.Duration) pgtype.Interval
• func EncodeLogs(logs []model.Log) ([]byte, error)
• func EncodeSpanID(spanID model.SpanID) []byte
• func EncodeSpanKind(modelKind trace.SpanKind) sql.Spankind
• func EncodeSpanRefs(spanrefs []model.SpanRef) ([]byte, error)
• func EncodeTags(input []model.KeyValue) ([]byte, error)
• func EncodeTimestamp(t time.Time) pgtype.Timestamp
• func EncodeTraceID(traceID model.TraceID) []byte
• func TruncateTime(ts time.Time) time.Time
• type InstrumentedReader
  • func NewInstrumentedReader(embedded spanstore.Reader, logger *slog.Logger) *InstrumentedReader
  • func (r *InstrumentedReader) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error)
  • func (r *InstrumentedReader) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)
  • func (r *InstrumentedReader) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)
• type InstrumentedWriter
  • func NewInstrumentedWriter(embedded spanstore.Writer, logger *slog.Logger) *InstrumentedWriter
  • func (w InstrumentedWriter) WriteSpan(ctx context.Context, span *model.Span) error
• type Reader
  • func NewReader(q *sql.Queries, logger *slog.Logger) *Reader
  • func (r *Reader) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error)
  • func (r *Reader) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)
  • func (r *Reader) GetDependencies(ctx context.Context, endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)
  • func (r *Reader) GetOperations(ctx context.Context, param spanstore.OperationQueryParameters) ([]spanstore.Operation, error)
  • func (r *Reader) GetServices(ctx context.Context) ([]string, error)
  • func (r *Reader) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)
• type Writer
  • func NewWriter(q *sql.Queries, logger *slog.Logger) *Writer
  • func (w *Writer) Close() error
  • func (w *Writer) WriteSpan(ctx context.Context, span *model.Span) error

Functions

func DecodeLogs

func DecodeLogs(raw []byte) ([]model.Log, error)

func DecodeSpanID

func DecodeSpanID(raw []byte) model.SpanID

DecodeSpanID decodes a span id form a byte slice.

func DecodeSpanRefs

func DecodeSpanRefs(data []byte) ([]model.SpanRef, error)

func DecodeTags

func DecodeTags(input []byte) ([]model.KeyValue, error)

func DecodeTraceID

func DecodeTraceID(raw []byte) model.TraceID

DecodeTraceID converts a slice of raw bytes into a trace id.

func EncodeInterval

func EncodeInterval(duration time.Duration) pgtype.Interval

func EncodeLogs

func EncodeLogs(logs []model.Log) ([]byte, error)

func EncodeSpanID

func EncodeSpanID(spanID model.SpanID) []byte

EncodeSpanID encodes a span id into a slice of bytes.

func EncodeSpanKind

func EncodeSpanKind(modelKind trace.SpanKind) sql.Spankind

func EncodeSpanRefs

func EncodeSpanRefs(spanrefs []model.SpanRef) ([]byte, error)

func EncodeTags

func EncodeTags(input []model.KeyValue) ([]byte, error)

func EncodeTimestamp

func EncodeTimestamp(t time.Time) pgtype.Timestamp

func EncodeTraceID

func EncodeTraceID(traceID model.TraceID) []byte

EncodeTraceID converts a trace id to a slice of raw bytes.

func TruncateTime

func TruncateTime(ts time.Time) time.Time

Types

type InstrumentedReader

type InstrumentedReader struct {
	spanstore.Reader
	// contains filtered or unexported fields
}

InstrumentedReader is a reader that has been instrumented.

func NewInstrumentedReader

func NewInstrumentedReader(embedded spanstore.Reader, logger *slog.Logger) *InstrumentedReader

NewInstrumentedReader returns a new spanstore.Reader that is instrumented.

func (*InstrumentedReader) FindTraceIDs

func (r *InstrumentedReader) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error)

FindTraceIDs retrieve traceIDs that match the traceQuery

func (*InstrumentedReader) FindTraces

func (r *InstrumentedReader) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)

FindTraces retrieve traces that match the traceQuery

func (*InstrumentedReader) GetTrace

func (r *InstrumentedReader) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)

GetTrace takes a traceID and returns a Trace associated with that traceID

type InstrumentedWriter

type InstrumentedWriter struct {
	spanstore.Writer
	// contains filtered or unexported fields
}

InstrumentedWriter is a writer that has been instrumented.

func NewInstrumentedWriter

func NewInstrumentedWriter(embedded spanstore.Writer, logger *slog.Logger) *InstrumentedWriter

NewInstrumentedWriter returns a new spanstore.Writer that is instrumented.

func (InstrumentedWriter) WriteSpan

func (w InstrumentedWriter) WriteSpan(ctx context.Context, span *model.Span) error

type Reader

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

Reader can query for and load traces from PostgreSQL v2.x.

func NewReader

func NewReader(q *sql.Queries, logger *slog.Logger) *Reader

NewReader returns a new SpanReader for PostgreSQL v2.x.

func (*Reader) FindTraceIDs

func (r *Reader) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error)

FindTraceIDs retrieve traceIDs that match the traceQuery

func (*Reader) FindTraces

func (r *Reader) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)

FindTraces retrieve traces that match the traceQuery

func (*Reader) GetDependencies

func (r *Reader) GetDependencies(ctx context.Context, endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)

GetDependencies returns all inter-service dependencies

func (*Reader) GetOperations

func (r *Reader) GetOperations(ctx context.Context, param spanstore.OperationQueryParameters) ([]spanstore.Operation, error)

GetOperations returns all operations for a specific service traced by Jaeger

func (*Reader) GetServices

func (r *Reader) GetServices(ctx context.Context) ([]string, error)

GetServices returns all services traced by Jaeger

func (*Reader) GetTrace

func (r *Reader) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)

GetTrace takes a traceID and returns a Trace associated with that traceID

type Writer

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

Writer handles all writes to PostgreSQL 2.x for the Jaeger data model

func NewWriter

func NewWriter(q *sql.Queries, logger *slog.Logger) *Writer

NewWriter returns a Writer.

func (*Writer) Close

func (w *Writer) Close() error

Close triggers a graceful shutdown

func (*Writer) WriteSpan

func (w *Writer) WriteSpan(ctx context.Context, span *model.Span) error

WriteSpan saves the span into PostgreSQL