parcacol

Documentation

Index

• Constants
• func BinaryFieldFromRecord(ar arrow.Record, name string) (*array.Binary, error)
• func BooleanFieldFromRecord(ar arrow.Record, name string) (*array.Boolean, error)
• func BuildArrowLocations(allocator memory.Allocator, stacktraces []*pb.Stacktrace, ...) (arrow.Record, error)
• func CreateDiffColumn(pool memory.Allocator, rows int) arrow.Array
• func DictionaryFromRecord(ar arrow.Record, name string) (*array.Dictionary, error)
• func MatcherToBooleanExpression(matcher *labels.Matcher) (logicalplan.Expr, error)
• func MatchersToBooleanExpressions(matchers []*labels.Matcher) ([]logicalplan.Expr, error)
• func StringValueFromDictionary(arr *array.Dictionary, i int) string
• type ArrowToProfileConverter
  • func NewArrowToProfileConverter(tracer trace.Tracer, keyMaker *kv.KeyMaker) *ArrowToProfileConverter
  • func (c *ArrowToProfileConverter) Convert(ctx context.Context, p profile.Profile) (profile.OldProfile, error)
• type Engine
• type ErrMissingColumn
  • func (e ErrMissingColumn) Error() string
• type MappingLocations
• type Querier
  • func NewQuerier(logger log.Logger, tracer trace.Tracer, engine Engine, tableName string, ...) *Querier
  • func (q *Querier) GetProfileMetadataLabels(ctx context.Context, start, end time.Time) ([]string, error)
  • func (q *Querier) GetProfileMetadataMappings(ctx context.Context, query string, startTime, endTime time.Time) ([]string, error)
  • func (q *Querier) Labels(ctx context.Context, match []string, startTime, endTime time.Time, ...) ([]string, error)
  • func (q *Querier) ProfileTypes(ctx context.Context) ([]*pb.ProfileType, error)
  • func (q *Querier) QueryMerge(ctx context.Context, query string, start, end time.Time, ...) (profile.Profile, error)
  • func (q *Querier) QueryRange(ctx context.Context, query string, startTime, endTime time.Time, ...) ([]*pb.MetricsSeries, error)
  • func (q *Querier) QuerySingle(ctx context.Context, query string, time time.Time, invertCallStacks bool) (profile.Profile, error)
  • func (q *Querier) SymbolizeArrowRecord(ctx context.Context, records []arrow.Record, valueColumnName string, ...) ([]arrow.Record, error)
  • func (q *Querier) Values(ctx context.Context, labelName string, match []string, ...) ([]string, error)
• type QueryParts
  • func ParseQuery(query string) (QueryParts, error)
  • func QueryToFilterExprs(query string) (QueryParts, []logicalplan.Expr, error)
• type Symbolizer

Constants

const (
	ValuePerSecond  = "value_per_second"
	TimestampBucket = "timestamp_bucket"
)

Functions

func BinaryFieldFromRecord

func BinaryFieldFromRecord(ar arrow.Record, name string) (*array.Binary, error)

func BooleanFieldFromRecord

func BooleanFieldFromRecord(ar arrow.Record, name string) (*array.Boolean, error)

func BuildArrowLocations

func BuildArrowLocations(allocator memory.Allocator, stacktraces []*pb.Stacktrace, resolvedLocations []*profile.Location, locationIndex map[string]int) (arrow.Record, error)

func CreateDiffColumn

func CreateDiffColumn(pool memory.Allocator, rows int) arrow.Array

func DictionaryFromRecord

func DictionaryFromRecord(ar arrow.Record, name string) (*array.Dictionary, error)

func MatcherToBooleanExpression

func MatcherToBooleanExpression(matcher *labels.Matcher) (logicalplan.Expr, error)

func MatchersToBooleanExpressions

func MatchersToBooleanExpressions(matchers []*labels.Matcher) ([]logicalplan.Expr, error)

func StringValueFromDictionary

func StringValueFromDictionary(arr *array.Dictionary, i int) string

Types

type ArrowToProfileConverter

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

func NewArrowToProfileConverter

func NewArrowToProfileConverter(
	tracer trace.Tracer,
	keyMaker *kv.KeyMaker,
) *ArrowToProfileConverter

func (*ArrowToProfileConverter) Convert

func (c *ArrowToProfileConverter) Convert(
	ctx context.Context,
	p profile.Profile,
) (profile.OldProfile, error)

type Engine

type Engine interface {
	ScanTable(name string) query.Builder
	ScanSchema(name string) query.Builder
}

type ErrMissingColumn

type ErrMissingColumn struct {
	Column  string
	Columns int
}

func (ErrMissingColumn) Error

func (e ErrMissingColumn) Error() string

type MappingLocations

type MappingLocations struct {
	Mapping   *metapb.Mapping
	Locations map[uint64]*profile.Location
}

type Querier

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

func NewQuerier

func NewQuerier(
	logger log.Logger,
	tracer trace.Tracer,
	engine Engine,
	tableName string,
	symbolizer Symbolizer,
	pool memory.Allocator,
) *Querier

func (*Querier) GetProfileMetadataLabels

func (q *Querier) GetProfileMetadataLabels(
	ctx context.Context,
	start, end time.Time,
) ([]string, error)

func (*Querier) GetProfileMetadataMappings

func (q *Querier) GetProfileMetadataMappings(
	ctx context.Context,
	query string, startTime, endTime time.Time,
) ([]string, error)

func (*Querier) Labels

func (q *Querier) Labels(
	ctx context.Context,
	match []string,
	startTime, endTime time.Time,
	profileType string,
) ([]string, error)

func (*Querier) ProfileTypes

func (q *Querier) ProfileTypes(
	ctx context.Context,
) ([]*pb.ProfileType, error)

func (*Querier) QueryMerge

func (q *Querier) QueryMerge(ctx context.Context, query string, start, end time.Time, aggregateByLabels, invertCallStacks bool) (profile.Profile, error)

func (*Querier) QueryRange

func (q *Querier) QueryRange(
	ctx context.Context,
	query string,
	startTime, endTime time.Time,
	step time.Duration,
	limit uint32,
	sumBy []string,
) ([]*pb.MetricsSeries, error)

func (*Querier) QuerySingle

func (q *Querier) QuerySingle(
	ctx context.Context,
	query string,
	time time.Time,
	invertCallStacks bool,
) (profile.Profile, error)

func (*Querier) SymbolizeArrowRecord

func (q *Querier) SymbolizeArrowRecord(
	ctx context.Context,
	records []arrow.Record,
	valueColumnName string,
	queryParts QueryParts,
	invertCallStacks bool,
) ([]arrow.Record, error)

func (*Querier) Values

func (q *Querier) Values(
	ctx context.Context,
	labelName string,
	match []string,
	startTime, endTime time.Time,
	profileType string,
) ([]string, error)

type QueryParts

type QueryParts struct {
	Meta     profile.Meta
	Delta    bool
	Matchers []*labels.Matcher
}

func ParseQuery

func ParseQuery(query string) (QueryParts, error)

ParseQuery from a string into the QueryParts struct.

func QueryToFilterExprs

func QueryToFilterExprs(query string) (QueryParts, []logicalplan.Expr, error)

type Symbolizer

type Symbolizer interface {
	Symbolize(
		ctx context.Context,
		req symbolizer.SymbolizationRequest,
	) error
}