query

Documentation

Index

• Variables
• func GenerateFlamegraphFlat(ctx context.Context, tracer trace.Tracer, metaStore metastore.ProfileMetaStore, ...) (*pb.Flamegraph, error)
• func GenerateFlatPprof(ctx context.Context, metaStore metastore.ProfileMetaStore, ...) (*profile.Profile, error)
• func GenerateTopTable(ctx context.Context, p *parcaprofile.StacktraceSamples) (*pb.Top, error)
• type ColumnQueryAPI
  • func NewColumnQueryAPI(logger log.Logger, tracer trace.Tracer, metaStore metastore.ProfileMetaStore, ...) *ColumnQueryAPI
  • func (q *ColumnQueryAPI) Labels(ctx context.Context, req *pb.LabelsRequest) (*pb.LabelsResponse, error)
  • func (q *ColumnQueryAPI) ProfileTypes(ctx context.Context, req *pb.ProfileTypesRequest) (*pb.ProfileTypesResponse, error)
  • func (q *ColumnQueryAPI) Query(ctx context.Context, req *pb.QueryRequest) (*pb.QueryResponse, error)
  • func (q *ColumnQueryAPI) QueryRange(ctx context.Context, req *pb.QueryRangeRequest) (*pb.QueryRangeResponse, error)
  • func (q *ColumnQueryAPI) Values(ctx context.Context, req *pb.ValuesRequest) (*pb.ValuesResponse, error)
• type Engine
• type FlamegraphIterator
  • func NewFlamegraphIterator(fgRoot *querypb.FlamegraphNode) *FlamegraphIterator
  • func (fgi *FlamegraphIterator) At() *querypb.FlamegraphNode
  • func (fgi *FlamegraphIterator) HasMore() bool
  • func (fgi *FlamegraphIterator) NextChild() bool
  • func (fgi *FlamegraphIterator) StepInto() bool
  • func (fgi *FlamegraphIterator) StepUp()
• type LocationStack
  • func (s *LocationStack) IsEmpty() bool
  • func (s *LocationStack) Peek() *profile.Location
  • func (s *LocationStack) Pop() (*profile.Location, bool)
  • func (s *LocationStack) Push(e *profile.Location)
  • func (s *LocationStack) Size() int
  • func (s *LocationStack) ToLocationStacktrace() []*profile.Location
• type Locations
• type TreeStack
  • func (s *TreeStack) IsEmpty() bool
  • func (s *TreeStack) Peek() *TreeStackEntry
  • func (s *TreeStack) Pop() (*TreeStackEntry, bool)
  • func (s *TreeStack) Push(e *TreeStackEntry)
  • func (s *TreeStack) Size() int
• type TreeStackEntry

Variables

var (
	ErrTimestampColumnNotFound = errors.New("timestamp column not found")
	ErrValueColumnNotFound     = errors.New("value column not found")
)

Functions

func GenerateFlamegraphFlat

func GenerateFlamegraphFlat(ctx context.Context, tracer trace.Tracer, metaStore metastore.ProfileMetaStore, p *profile.StacktraceSamples) (*pb.Flamegraph, error)

func GenerateFlatPprof

func GenerateFlatPprof(ctx context.Context, metaStore metastore.ProfileMetaStore, ip *parcaprofile.StacktraceSamples) (*profile.Profile, error)

func GenerateTopTable

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

Types

type ColumnQueryAPI

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

func NewColumnQueryAPI(
	logger log.Logger,
	tracer trace.Tracer,
	metaStore metastore.ProfileMetaStore,
	engine Engine,
	tableName string,
) *ColumnQueryAPI

func (*ColumnQueryAPI) Labels

func (q *ColumnQueryAPI) Labels(ctx context.Context, req *pb.LabelsRequest) (*pb.LabelsResponse, error)

Labels issues a labels request against the storage.

func (*ColumnQueryAPI) ProfileTypes

func (q *ColumnQueryAPI) ProfileTypes(ctx context.Context, req *pb.ProfileTypesRequest) (*pb.ProfileTypesResponse, error)

Types returns the available types of profiles.

func (*ColumnQueryAPI) Query

func (q *ColumnQueryAPI) Query(ctx context.Context, req *pb.QueryRequest) (*pb.QueryResponse, error)

Query issues a instant query against the storage.

func (*ColumnQueryAPI) QueryRange

func (q *ColumnQueryAPI) QueryRange(ctx context.Context, req *pb.QueryRangeRequest) (*pb.QueryRangeResponse, error)

QueryRange issues a range query against the storage.

func (*ColumnQueryAPI) Values

func (q *ColumnQueryAPI) Values(ctx context.Context, req *pb.ValuesRequest) (*pb.ValuesResponse, error)

Values issues a values request against the storage.

type Engine

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

type FlamegraphIterator

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

func NewFlamegraphIterator

func NewFlamegraphIterator(fgRoot *querypb.FlamegraphNode) *FlamegraphIterator

func (*FlamegraphIterator) At

func (fgi *FlamegraphIterator) At() *querypb.FlamegraphNode

func (*FlamegraphIterator) HasMore

func (fgi *FlamegraphIterator) HasMore() bool

func (*FlamegraphIterator) NextChild

func (fgi *FlamegraphIterator) NextChild() bool

func (*FlamegraphIterator) StepInto

func (fgi *FlamegraphIterator) StepInto() bool

func (*FlamegraphIterator) StepUp

func (fgi *FlamegraphIterator) StepUp()

type LocationStack

type LocationStack []*profile.Location

func (*LocationStack) IsEmpty

func (s *LocationStack) IsEmpty() bool

func (*LocationStack) Peek

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

func (*LocationStack) Pop

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

func (*LocationStack) Push

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

func (*LocationStack) Size

func (s *LocationStack) Size() int

func (*LocationStack) ToLocationStacktrace

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

type Locations

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

type TreeStack

type TreeStack []*TreeStackEntry

func (*TreeStack) IsEmpty

func (s *TreeStack) IsEmpty() bool

func (*TreeStack) Peek

func (s *TreeStack) Peek() *TreeStackEntry

func (*TreeStack) Pop

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

func (*TreeStack) Push

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

func (*TreeStack) Size

func (s *TreeStack) Size() int

type TreeStackEntry

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