reader

Documentation

Index

• Variables
• type SpanReader
  • func NewSpanReader(pool table.Client, opts SpanReaderOptions, logger *zap.Logger, ...) *SpanReader
  • func (s *SpanReader) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error)
  • func (s *SpanReader) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)
  • func (s *SpanReader) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)
  • func (s *SpanReader) GetServices(ctx context.Context) ([]string, error)
  • func (s *SpanReader) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)
• type SpanReaderOptions

Variables

var (
	// ErrServiceNameNotSet occurs when attempting to query with an empty service name
	ErrServiceNameNotSet = status.Error(codes.InvalidArgument, "Service name must be set")

	// ErrStartTimeMinGreaterThanMax occurs when start time min is above start time max
	ErrStartTimeMinGreaterThanMax = status.Error(codes.InvalidArgument, "Start Time Minimum is above Maximum")

	// ErrDurationMinGreaterThanMax occurs when duration min is above duration max
	ErrDurationMinGreaterThanMax = status.Error(codes.InvalidArgument, "Duration Minimum is above Maximum")

	// ErrMalformedRequestObject occurs when a request object is nil
	ErrMalformedRequestObject = status.Error(codes.InvalidArgument, "Malformed request object")

	// ErrDurationAndTagQueryNotSupported occurs when duration and tags are both set
	ErrDurationAndTagQueryNotSupported = status.Error(codes.InvalidArgument, "Cannot query for duration and tags simultaneously")

	// ErrStartAndEndTimeNotSet occurs when start time and end time are not set
	ErrStartAndEndTimeNotSet = status.Error(codes.InvalidArgument, "Start and End Time must be set")

	ErrTraceNotFound = status.Error(codes.NotFound, "trace not found")

	ErrEmptyPartitionList = errors.New("partition list is empty")

	ErrNoPartitions = errors.New("no partitions to query")

	ErrNothingResultSets = errors.New("nothing result sets")
)

Types

type SpanReader

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

func NewSpanReader

func NewSpanReader(pool table.Client, opts SpanReaderOptions, logger *zap.Logger, jaegerLogger hclog.Logger) *SpanReader

NewSpanReader returns a new SpanReader.

func (*SpanReader) FindTraceIDs

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

FindTraceIDs retrieve traceIDs that match the traceQuery

func (*SpanReader) FindTraces

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

FindTraces retrieves traces that match the traceQuery

func (*SpanReader) GetOperations

func (s *SpanReader) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)

GetOperations returns all operations for a specific service traced by Jaeger

func (*SpanReader) GetServices

func (s *SpanReader) GetServices(ctx context.Context) ([]string, error)

GetServices returns all services traced by Jaeger

func (*SpanReader) GetTrace

func (s *SpanReader) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)

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

type SpanReaderOptions

type SpanReaderOptions struct {
	DbPath        schema.DbPath
	ReadTimeout   time.Duration
	OpLimit       uint64 // max number of operations to fetch from operation_names index
	SvcLimit      uint64 // max number of services to fetch
	QueryParallel int
	ArchiveReader bool
}