reader

package
v1.9.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 15, 2024 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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")
)

Functions

This section is empty.

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

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL