storev1

Documentation

Index

• type Reader
  • func NewReader(client *client.Client, ...) *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(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 Store
  • func NewStore(conf *config.Configuration, logger hclog.Logger) (*Store, func() error, error)
  • func (s *Store) Close() error
  • func (s *Store) DependencyReader() dependencystore.Reader
  • func (s *Store) SpanReader() spanstore.Reader
  • func (s *Store) SpanWriter() spanstore.Writer
• type Writer
  • func NewWriter(client *client.Client, ...) *Writer
  • func (w *Writer) Close() error
  • func (w *Writer) WriteSpan(span *model.Span) error

Types

type Reader

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

Reader can query for and load traces from InfluxDB v1.x.

func NewReader

func NewReader(client *client.Client, database, retentionPolicy, spanMeasurement, spanMetaMeasurement, logMeasurement string, defaultLookback time.Duration, logger hclog.Logger) *Reader

NewReader returns a new SpanReader for InfluxDB v1.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(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 Store

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

func NewStore

func NewStore(conf *config.Configuration, logger hclog.Logger) (*Store, func() error, error)

func (*Store) Close

func (s *Store) Close() error

func (*Store) DependencyReader

func (s *Store) DependencyReader() dependencystore.Reader

func (*Store) SpanReader

func (s *Store) SpanReader() spanstore.Reader

func (*Store) SpanWriter

func (s *Store) SpanWriter() spanstore.Writer

type Writer

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

Writer handles all writes to InfluxDB v1.x for the Jaeger data model

func NewWriter

func NewWriter(client *client.Client, database, retentionPolicy, spanMeasurement, spanMetaMeasurement, logMeasurement string, logger hclog.Logger) *Writer

NewWriter returns a Writer for InfluxDB v1.x

func (*Writer) Close

func (w *Writer) Close() error

Close triggers a graceful shutdown

func (*Writer) WriteSpan

func (w *Writer) WriteSpan(span *model.Span) error

WriteSpan saves the span into Cassandra