store

Documentation

Index

• Constants
• type Store
  • func NewStore(ctx context.Context) *Store
  • func (s *Store) AddSpans(ctx context.Context, spans []telemetry.SpanData) error
  • func (s *Store) ClearTraces(ctx context.Context) error
  • func (s *Store) Close() error
  • func (s *Store) GetTrace(ctx context.Context, traceID string) (telemetry.TraceData, error)
  • func (s *Store) GetTraceSummaries(ctx context.Context) (*[]telemetry.TraceSummary, error)

Constants

const (
	CREATE_SPANS_TABLE string = `` /* 585-byte string literal not displayed */

	SELECT_ORDERED_TRACES = `
		SELECT traceID 
		FROM spans
		GROUP BY traceID
		ORDER BY MAX(startTime) DESC
	`
	SELECT_TRACE string = `
		SELECT *
		FROM spans 
		WHERE traceID = ?
	`
	SELECT_ROOT_SPAN string = `` /* 143-byte string literal not displayed */

	SELECT_SPAN_COUNT string = `
		SELECT count(*) 
		FROM spans
		WHERE traceID = ?
	`

	TRUNCATE_SPANS string = `
		TRUNCATE spans;
	`
	ENABLE_JSON string = `
		INSTALL json;
		LOAD json;
	`
)

Types

type Store

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

func NewStore

func NewStore(ctx context.Context) *Store

func (*Store) AddSpans

func (s *Store) AddSpans(ctx context.Context, spans []telemetry.SpanData) error

func (*Store) ClearTraces

func (s *Store) ClearTraces(ctx context.Context) error

func (*Store) Close

func (s *Store) Close() error

func (*Store) GetTrace

func (s *Store) GetTrace(ctx context.Context, traceID string) (telemetry.TraceData, error)

func (*Store) GetTraceSummaries

func (s *Store) GetTraceSummaries(ctx context.Context) (*[]telemetry.TraceSummary, error)