query

package
v0.15.0 Latest Latest
Warning

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

Go to latest
Published: Dec 20, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const (
	NodeCutOffFraction = 0.005
)

Variables

This section is empty.

Functions

func GenerateCallgraph added in v0.13.0

func GenerateCallgraph(ctx context.Context, p *profile.Profile) (*querypb.Callgraph, error)

func GenerateFlamegraphFlat added in v0.7.0

func GenerateFlamegraphFlat(ctx context.Context, tracer trace.Tracer, p *profile.Profile) (*pb.Flamegraph, error)

func GenerateFlamegraphTable added in v0.14.0

func GenerateFlamegraphTable(ctx context.Context, tracer trace.Tracer, p *profile.Profile) (*querypb.Flamegraph, error)

func GenerateFlatPprof added in v0.7.0

func GenerateFlatPprof(ctx context.Context, ip *parcaprofile.Profile) (*profile.Profile, error)

func GenerateTopTable added in v0.8.0

func GenerateTopTable(ctx context.Context, p *parcaprofile.Profile) (*pb.Top, error)

Types

type ColumnQueryAPI added in v0.11.0

type ColumnQueryAPI struct {
	pb.UnimplementedQueryServiceServer
	// contains filtered or unexported fields
}

ColumnQueryAPI is the read api interface for parca It implements the proto/query/query.proto APIServer interface.

func NewColumnQueryAPI added in v0.11.0

func NewColumnQueryAPI(
	logger log.Logger,
	tracer trace.Tracer,
	shareClient sharepb.ShareServiceClient,
	querier Querier,
) *ColumnQueryAPI

func (*ColumnQueryAPI) Labels added in v0.11.0

Labels issues a labels request against the storage.

func (*ColumnQueryAPI) ProfileTypes added in v0.11.0

Types returns the available types of profiles.

func (*ColumnQueryAPI) Query added in v0.11.0

Query issues a instant query against the storage.

func (*ColumnQueryAPI) QueryRange added in v0.11.0

QueryRange issues a range query against the storage.

func (*ColumnQueryAPI) ShareProfile added in v0.12.0

func (*ColumnQueryAPI) Values added in v0.11.0

Values issues a values request against the storage.

type FlamegraphIterator added in v0.7.0

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

func NewFlamegraphIterator added in v0.7.0

func NewFlamegraphIterator(fgRoot *querypb.FlamegraphNode) *FlamegraphIterator

func (*FlamegraphIterator) At added in v0.7.0

func (*FlamegraphIterator) HasMore added in v0.7.0

func (fgi *FlamegraphIterator) HasMore() bool

func (*FlamegraphIterator) NextChild added in v0.7.0

func (fgi *FlamegraphIterator) NextChild() bool

func (*FlamegraphIterator) StepInto added in v0.7.0

func (fgi *FlamegraphIterator) StepInto() bool

func (*FlamegraphIterator) StepUp added in v0.7.0

func (fgi *FlamegraphIterator) StepUp()

type LocationStack added in v0.7.0

type LocationStack []*profile.Location

func (*LocationStack) IsEmpty added in v0.7.0

func (s *LocationStack) IsEmpty() bool

func (*LocationStack) Peek added in v0.7.0

func (s *LocationStack) Peek() *profile.Location

func (*LocationStack) Pop added in v0.7.0

func (s *LocationStack) Pop() (*profile.Location, bool)

func (*LocationStack) Push added in v0.7.0

func (s *LocationStack) Push(e *profile.Location)

func (*LocationStack) Size added in v0.7.0

func (s *LocationStack) Size() int

func (*LocationStack) ToLocationStacktrace added in v0.7.0

func (s *LocationStack) ToLocationStacktrace() []*profile.Location

type Locations added in v0.7.0

type Locations interface {
	GetLocationsByIDs(ctx context.Context, id ...[]byte) (map[string]*pb.Location, [][]byte, error)
}

type Querier added in v0.13.0

type Querier interface {
	Labels(ctx context.Context, match []string, start, end time.Time) ([]string, error)
	Values(ctx context.Context, labelName string, match []string, start, end time.Time) ([]string, error)
	QueryRange(ctx context.Context, query string, startTime, endTime time.Time, limit uint32) ([]*pb.MetricsSeries, error)
	ProfileTypes(ctx context.Context) ([]*pb.ProfileType, error)
	QuerySingle(ctx context.Context, query string, time time.Time) (*profile.Profile, error)
	QueryMerge(ctx context.Context, query string, start, end time.Time) (*profile.Profile, error)
}

type TableGetter added in v0.14.0

type TableGetter interface {
	Strings() []string
	GetLocation(index uint32) *metastorev1alpha1.Location
	GetFunction(index uint32) *metastorev1alpha1.Function
}

type TreeStack added in v0.7.0

type TreeStack []*TreeStackEntry

func (*TreeStack) IsEmpty added in v0.7.0

func (s *TreeStack) IsEmpty() bool

func (*TreeStack) Peek added in v0.7.0

func (s *TreeStack) Peek() *TreeStackEntry

func (*TreeStack) Pop added in v0.7.0

func (s *TreeStack) Pop() (*TreeStackEntry, bool)

func (*TreeStack) Push added in v0.7.0

func (s *TreeStack) Push(e *TreeStackEntry)

func (*TreeStack) Size added in v0.7.0

func (s *TreeStack) Size() int

type TreeStackEntry added in v0.7.0

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

Jump to

Keyboard shortcuts

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