Documentation
¶
Index ¶
- type 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
- type Writer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
Reader can query for and load traces from InfluxDB v2.x.
func NewReader ¶
func NewReader(fluxQueryService *influx2http.FluxQueryService, orgID influxdb.ID, bucket, spanMeasurement, spanMetaMeasurement, logMeasurement string, defaultLookback time.Duration, logger hclog.Logger) *Reader
NewReader returns a new SpanReader for InfluxDB 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(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 ¶
GetServices returns all services traced by Jaeger
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) DependencyReader ¶
func (s *Store) DependencyReader() dependencystore.Reader
func (*Store) SpanReader ¶
func (*Store) SpanWriter ¶
type Writer ¶
type Writer struct {
// contains filtered or unexported fields
}
Writer handles all writes to InfluxDB 2.x for the Jaeger data model
func NewWriter ¶
func NewWriter(writeService *influx2http.WriteService, orgID, bucketID influxdb.ID, spanMeasurement, spanMetaMeasurement, logMeasurement string, logger hclog.Logger) *Writer
NewWriter returns a Writer for InfluxDB v2.x
Source Files
Click to show internal directories.
Click to hide internal directories.