parcacol

package

v0.29.1 Latest Latest Go to latest Published: Sep 28, 2026 License: Apache-2.0 Imports: 30 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/parca-dev/parca

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func BinaryFieldFromRecord(ar arrow.RecordBatch, name string) (*array.Binary, error)
func BooleanFieldFromRecord(ar arrow.RecordBatch, name string) (*array.Boolean, error)
func BuildArrowLocations(allocator memory.Allocator, stacktraces []*pb.Stacktrace, ...) (arrow.RecordBatch, error)
func CreateDiffColumn(pool memory.Allocator, rows int) arrow.Array
func DictionaryFromRecord(ar arrow.RecordBatch, name string) (*array.Dictionary, error)
func MatcherToBooleanExpression(matcher *labels.Matcher) (logicalplan.Expr, error)
func MatchersToBooleanExpressions(matchers []*labels.Matcher) ([]logicalplan.Expr, error)
func QueryToFilterExprs(query string) (profile.QueryParts, []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, query string, startTime, endTime time.Time) ([]string, error)
- func (q *Querier) GetProfileMetadataMappings(ctx context.Context, query string, startTime, endTime time.Time) ([]string, error)
- func (q *Querier) HasProfileData(ctx context.Context) (bool, error)
- func (q *Querier) Labels(ctx context.Context, match []string, startTime, endTime time.Time, ...) ([]string, error)
- func (q *Querier) ProfileTypes(ctx context.Context, startTime time.Time, endTime time.Time) ([]*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.RecordBatch, valueColumnName string, ...) ([]arrow.RecordBatch, error)
- func (q *Querier) Values(ctx context.Context, labelName string, match []string, ...) ([]string, error)

Constants ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

func BinaryFieldFromRecord ¶ added in v0.13.0

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

func BooleanFieldFromRecord ¶ added in v0.13.0

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

func BuildArrowLocations ¶ added in v0.19.0

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

func CreateDiffColumn ¶ added in v0.19.0

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

func DictionaryFromRecord ¶ added in v0.16.0

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

func MatcherToBooleanExpression ¶ added in v0.13.0

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

func MatchersToBooleanExpressions ¶ added in v0.13.0

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

func QueryToFilterExprs ¶ added in v0.13.0

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

func StringValueFromDictionary ¶ added in v0.16.0

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

Types ¶

type ArrowToProfileConverter ¶ added in v0.13.0

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

func NewArrowToProfileConverter ¶ added in v0.13.0

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

func (*ArrowToProfileConverter) Convert ¶ added in v0.13.0

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

type Engine ¶ added in v0.13.0

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

type ErrMissingColumn ¶ added in v0.12.0

type ErrMissingColumn struct {
	Column  string
	Columns int
}

func (ErrMissingColumn) Error ¶ added in v0.12.0

func (e ErrMissingColumn) Error() string

type MappingLocations ¶ added in v0.22.0

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

type Querier ¶ added in v0.13.0

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

func NewQuerier ¶ added in v0.13.0

func NewQuerier(
	logger log.Logger,
	tracer trace.Tracer,
	engine Engine,
	tableName string,
	sym symbolizer.SymbolizationClient,
	demangler profile.Demangler,
	pool memory.Allocator,
) *Querier

func (*Querier) GetProfileMetadataLabels ¶ added in v0.22.0

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

func (*Querier) GetProfileMetadataMappings ¶ added in v0.22.0

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

func (*Querier) HasProfileData ¶ added in v0.25.0

func (q *Querier) HasProfileData(ctx context.Context) (bool, error)

func (*Querier) Labels ¶ added in v0.13.0

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

func (*Querier) ProfileTypes ¶ added in v0.13.0

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

func (*Querier) QueryMerge ¶ added in v0.13.0

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

func (*Querier) QueryRange ¶ added in v0.13.0

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 ¶ added in v0.13.0

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

func (*Querier) SymbolizeArrowRecord ¶ added in v0.19.0

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

func (*Querier) Values ¶ added in v0.13.0

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

Source Files ¶

View all Source files

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