Help us shape the future of Go! Take the 2026 Go Developer Survey

parcacol

package
v0.24.1 Latest Latest
Warning

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

 Go to latest Published: Sep 9, 2025 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

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.Record, name string) (*array.Binary, error)

func BooleanFieldFromRecord added in v0.13.0 

func BooleanFieldFromRecord(ar arrow.Record, 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.Record, 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.Record, 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 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,
	symbolizer Symbolizer,
	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) 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,
) ([]*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.Record,
	valueColumnName string,
	queryParts QueryParts,
	invertCallStacks bool,
	functionToFilterBy string,
) ([]arrow.Record, 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)

type QueryParts added in v0.16.0 

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

func ParseQuery added in v0.17.0 

func ParseQuery(query string) (QueryParts, error)

ParseQuery from a string into the QueryParts struct.

func QueryToFilterExprs added in v0.13.0 

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

type Symbolizer added in v0.22.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.