queryv1alpha1

package
v0.2.2 Latest Latest
Warning

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

 Go to latest Published: Oct 25, 2021 License: Apache-2.0 Imports: 20 Imported by: 1

Documentation

Overview

Package queryv1alpha1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ProfileDiffSelection_Mode_name = map[int32]string{
		0: "MODE_SINGLE_UNSPECIFIED",
		1: "MODE_MERGE",
	}
	ProfileDiffSelection_Mode_value = map[string]int32{
		"MODE_SINGLE_UNSPECIFIED": 0,
		"MODE_MERGE":              1,
	}
)

Enum value maps for ProfileDiffSelection_Mode.

View Source 
var (
	QueryRequest_Mode_name = map[int32]string{
		0: "MODE_SINGLE_UNSPECIFIED",
		1: "MODE_DIFF",
		2: "MODE_MERGE",
	}
	QueryRequest_Mode_value = map[string]int32{
		"MODE_SINGLE_UNSPECIFIED": 0,
		"MODE_DIFF":               1,
		"MODE_MERGE":              2,
	}
)

Enum value maps for QueryRequest_Mode.

View Source 
var (
	QueryRequest_ReportType_name = map[int32]string{
		0: "REPORT_TYPE_FLAMEGRAPH_UNSPECIFIED",
	}
	QueryRequest_ReportType_value = map[string]int32{
		"REPORT_TYPE_FLAMEGRAPH_UNSPECIFIED": 0,
	}
)

Enum value maps for QueryRequest_ReportType.

View Source 
var File_parca_query_v1alpha1_query_proto protoreflect.FileDescriptor
View Source 
var QueryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "parca.query.v1alpha1.QueryService",
	HandlerType: (*QueryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QueryRange",
			Handler:    _QueryService_QueryRange_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _QueryService_Query_Handler,
		},
		{
			MethodName: "Series",
			Handler:    _QueryService_Series_Handler,
		},
		{
			MethodName: "Labels",
			Handler:    _QueryService_Labels_Handler,
		},
		{
			MethodName: "Values",
			Handler:    _QueryService_Values_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "parca/query/v1alpha1/query.proto",
}

QueryService_ServiceDesc is the grpc.ServiceDesc for QueryService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterQueryServiceHandler 

func RegisterQueryServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryServiceHandler registers the http handlers for service QueryService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryServiceHandlerClient 

func RegisterQueryServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryServiceClient) error

RegisterQueryServiceHandlerClient registers the http handlers for service QueryService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryServiceClient" to call the correct interceptors.

func RegisterQueryServiceHandlerFromEndpoint 

func RegisterQueryServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryServiceHandlerFromEndpoint is same as RegisterQueryServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryServiceHandlerServer 

func RegisterQueryServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServiceServer) error

RegisterQueryServiceHandlerServer registers the http handlers for service QueryService to "mux". UnaryRPC :call QueryServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryServiceHandlerFromEndpoint instead.

func RegisterQueryServiceServer 

func RegisterQueryServiceServer(s grpc.ServiceRegistrar, srv QueryServiceServer)

Types

type AfterRule 

type AfterRule struct {
	Timestamp *timestamppb.Timestamp
}

AfterRule validates that the timestamp is after the given value

func (AfterRule) Validate 

func (a AfterRule) Validate(t interface{}) error

Validate runs the validation function for the AfterRule

type DiffProfile 

type DiffProfile struct {

	// a is the first profile to diff
	A *ProfileDiffSelection `protobuf:"bytes,1,opt,name=a,proto3" json:"a,omitempty"`
	// b is the second profile to diff
	B *ProfileDiffSelection `protobuf:"bytes,2,opt,name=b,proto3" json:"b,omitempty"`
	// contains filtered or unexported fields
}

DiffProfile contains parameters for a profile diff request

func (*DiffProfile) Descriptor deprecated 

func (*DiffProfile) Descriptor() ([]byte, []int)

Deprecated: Use DiffProfile.ProtoReflect.Descriptor instead.

func (*DiffProfile) GetA 

func (x *DiffProfile) GetA() *ProfileDiffSelection

func (*DiffProfile) GetB 

func (x *DiffProfile) GetB() *ProfileDiffSelection

func (*DiffProfile) ProtoMessage 

func (*DiffProfile) ProtoMessage()

func (*DiffProfile) ProtoReflect 

func (x *DiffProfile) ProtoReflect() protoreflect.Message

func (*DiffProfile) Reset 

func (x *DiffProfile) Reset()

func (*DiffProfile) String 

func (x *DiffProfile) String() string

type DiffProfileSelectionOptionMatchesRule 

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

DiffProfileSelectionOptionMatchesRule ensure the options match the requested mode

func (DiffProfileSelectionOptionMatchesRule) Validate 

func (o DiffProfileSelectionOptionMatchesRule) Validate(v interface{}) error

Validate the option matches mode

type DiffSelectionModeRule 

type DiffSelectionModeRule struct{}

func (DiffSelectionModeRule) Validate 

func (r DiffSelectionModeRule) Validate(v interface{}) error

type Flamegraph 

type Flamegraph struct {

	// root is the root of the flame graph
	Root *FlamegraphRootNode `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"`
	// total is the total weight of the flame graph
	Total int64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// unit is the unit represented by the flame graph
	Unit string `protobuf:"bytes,3,opt,name=unit,proto3" json:"unit,omitempty"`
	// height is the max height of the graph
	Height int32 `protobuf:"varint,4,opt,name=height,proto3" json:"height,omitempty"`
	// contains filtered or unexported fields
}

Flamegraph is the flame graph report type

func (*Flamegraph) Descriptor deprecated 

func (*Flamegraph) Descriptor() ([]byte, []int)

Deprecated: Use Flamegraph.ProtoReflect.Descriptor instead.

func (*Flamegraph) GetHeight 

func (x *Flamegraph) GetHeight() int32

func (*Flamegraph) GetRoot 

func (x *Flamegraph) GetRoot() *FlamegraphRootNode

func (*Flamegraph) GetTotal 

func (x *Flamegraph) GetTotal() int64

func (*Flamegraph) GetUnit 

func (x *Flamegraph) GetUnit() string

func (*Flamegraph) ProtoMessage 

func (*Flamegraph) ProtoMessage()

func (*Flamegraph) ProtoReflect 

func (x *Flamegraph) ProtoReflect() protoreflect.Message

func (*Flamegraph) Reset 

func (x *Flamegraph) Reset()

func (*Flamegraph) String 

func (x *Flamegraph) String() string

type FlamegraphNode 

type FlamegraphNode struct {

	// meta is the metadata about the node
	Meta *FlamegraphNodeMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	// cumulative is the cumulative value of the node
	Cumulative int64 `protobuf:"varint,2,opt,name=cumulative,proto3" json:"cumulative,omitempty"`
	// diff is the diff
	Diff int64 `protobuf:"varint,3,opt,name=diff,proto3" json:"diff,omitempty"`
	// children are the child nodes
	Children []*FlamegraphNode `protobuf:"bytes,4,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

FlamegraphNode represents a node in the graph

func (*FlamegraphNode) Descriptor deprecated 

func (*FlamegraphNode) Descriptor() ([]byte, []int)

Deprecated: Use FlamegraphNode.ProtoReflect.Descriptor instead.

func (*FlamegraphNode) GetChildren 

func (x *FlamegraphNode) GetChildren() []*FlamegraphNode

func (*FlamegraphNode) GetCumulative 

func (x *FlamegraphNode) GetCumulative() int64

func (*FlamegraphNode) GetDiff 

func (x *FlamegraphNode) GetDiff() int64

func (*FlamegraphNode) GetMeta 

func (x *FlamegraphNode) GetMeta() *FlamegraphNodeMeta

func (*FlamegraphNode) ProtoMessage 

func (*FlamegraphNode) ProtoMessage()

func (*FlamegraphNode) ProtoReflect 

func (x *FlamegraphNode) ProtoReflect() protoreflect.Message

func (*FlamegraphNode) Reset 

func (x *FlamegraphNode) Reset()

func (*FlamegraphNode) String 

func (x *FlamegraphNode) String() string

type FlamegraphNodeMeta 

type FlamegraphNodeMeta struct {

	// location is the location for the code
	Location *Location `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// mapping is the mapping into code
	Mapping *Mapping `protobuf:"bytes,2,opt,name=mapping,proto3" json:"mapping,omitempty"`
	// function is the function information
	Function *Function `protobuf:"bytes,3,opt,name=function,proto3" json:"function,omitempty"`
	// line is the line location
	Line *Line `protobuf:"bytes,4,opt,name=line,proto3" json:"line,omitempty"`
	// contains filtered or unexported fields
}

FlamegraphNodeMeta is the metadata for a given node

func (*FlamegraphNodeMeta) Descriptor deprecated 

func (*FlamegraphNodeMeta) Descriptor() ([]byte, []int)

Deprecated: Use FlamegraphNodeMeta.ProtoReflect.Descriptor instead.

func (*FlamegraphNodeMeta) GetFunction 

func (x *FlamegraphNodeMeta) GetFunction() *Function

func (*FlamegraphNodeMeta) GetLine 

func (x *FlamegraphNodeMeta) GetLine() *Line

func (*FlamegraphNodeMeta) GetLocation 

func (x *FlamegraphNodeMeta) GetLocation() *Location

func (*FlamegraphNodeMeta) GetMapping 

func (x *FlamegraphNodeMeta) GetMapping() *Mapping

func (*FlamegraphNodeMeta) ProtoMessage 

func (*FlamegraphNodeMeta) ProtoMessage()

func (*FlamegraphNodeMeta) ProtoReflect 

func (x *FlamegraphNodeMeta) ProtoReflect() protoreflect.Message

func (*FlamegraphNodeMeta) Reset 

func (x *FlamegraphNodeMeta) Reset()

func (*FlamegraphNodeMeta) String 

func (x *FlamegraphNodeMeta) String() string

type FlamegraphRootNode 

type FlamegraphRootNode struct {

	// cumulative is the cumulative value of the graph
	Cumulative int64 `protobuf:"varint,1,opt,name=cumulative,proto3" json:"cumulative,omitempty"`
	// diff is the diff
	Diff int64 `protobuf:"varint,2,opt,name=diff,proto3" json:"diff,omitempty"`
	// children are the list of the children of the root node
	Children []*FlamegraphNode `protobuf:"bytes,3,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

FlamegraphRootNode is a root node of a flame graph

func (*FlamegraphRootNode) Descriptor deprecated 

func (*FlamegraphRootNode) Descriptor() ([]byte, []int)

Deprecated: Use FlamegraphRootNode.ProtoReflect.Descriptor instead.

func (*FlamegraphRootNode) GetChildren 

func (x *FlamegraphRootNode) GetChildren() []*FlamegraphNode

func (*FlamegraphRootNode) GetCumulative 

func (x *FlamegraphRootNode) GetCumulative() int64

func (*FlamegraphRootNode) GetDiff 

func (x *FlamegraphRootNode) GetDiff() int64

func (*FlamegraphRootNode) ProtoMessage 

func (*FlamegraphRootNode) ProtoMessage()

func (*FlamegraphRootNode) ProtoReflect 

func (x *FlamegraphRootNode) ProtoReflect() protoreflect.Message

func (*FlamegraphRootNode) Reset 

func (x *FlamegraphRootNode) Reset()

func (*FlamegraphRootNode) String 

func (x *FlamegraphRootNode) String() string

type Function 

type Function struct {

	// id ...
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// name ...
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// system_name ...
	SystemName string `protobuf:"bytes,3,opt,name=system_name,json=systemName,proto3" json:"system_name,omitempty"`
	// filename ...
	Filename string `protobuf:"bytes,4,opt,name=filename,proto3" json:"filename,omitempty"`
	// start_line ...
	StartLine int64 `protobuf:"varint,5,opt,name=start_line,json=startLine,proto3" json:"start_line,omitempty"`
	// contains filtered or unexported fields
}

Function ...

func (*Function) Descriptor deprecated 

func (*Function) Descriptor() ([]byte, []int)

Deprecated: Use Function.ProtoReflect.Descriptor instead.

func (*Function) GetFilename 

func (x *Function) GetFilename() string

func (*Function) GetId 

func (x *Function) GetId() uint64

func (*Function) GetName 

func (x *Function) GetName() string

func (*Function) GetStartLine 

func (x *Function) GetStartLine() int64

func (*Function) GetSystemName 

func (x *Function) GetSystemName() string

func (*Function) ProtoMessage 

func (*Function) ProtoMessage()

func (*Function) ProtoReflect 

func (x *Function) ProtoReflect() protoreflect.Message

func (*Function) Reset 

func (x *Function) Reset()

func (*Function) String 

func (x *Function) String() string

type LabelsRequest 

type LabelsRequest struct {

	// match are the set of matching strings
	Match []string `protobuf:"bytes,1,rep,name=match,proto3" json:"match,omitempty"`
	// start is the start of the time window to perform the query
	Start *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	// end is the end of the time window to perform the query
	End *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

LabelsRequest are the request values for labels

func (*LabelsRequest) Descriptor deprecated 

func (*LabelsRequest) Descriptor() ([]byte, []int)

Deprecated: Use LabelsRequest.ProtoReflect.Descriptor instead.

func (*LabelsRequest) GetEnd 

func (x *LabelsRequest) GetEnd() *timestamppb.Timestamp

func (*LabelsRequest) GetMatch 

func (x *LabelsRequest) GetMatch() []string

func (*LabelsRequest) GetStart 

func (x *LabelsRequest) GetStart() *timestamppb.Timestamp

func (*LabelsRequest) ProtoMessage 

func (*LabelsRequest) ProtoMessage()

func (*LabelsRequest) ProtoReflect 

func (x *LabelsRequest) ProtoReflect() protoreflect.Message

func (*LabelsRequest) Reset 

func (x *LabelsRequest) Reset()

func (*LabelsRequest) String 

func (x *LabelsRequest) String() string

type LabelsResponse 

type LabelsResponse struct {

	/// label_names are the set of matching label names
	LabelNames []string `protobuf:"bytes,1,rep,name=label_names,json=labelNames,proto3" json:"label_names,omitempty"`
	// warnings is unimplemented
	Warnings []string `protobuf:"bytes,2,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

LabelsResponse is the set of matching label names

func (*LabelsResponse) Descriptor deprecated 

func (*LabelsResponse) Descriptor() ([]byte, []int)

Deprecated: Use LabelsResponse.ProtoReflect.Descriptor instead.

func (*LabelsResponse) GetLabelNames 

func (x *LabelsResponse) GetLabelNames() []string

func (*LabelsResponse) GetWarnings 

func (x *LabelsResponse) GetWarnings() []string

func (*LabelsResponse) ProtoMessage 

func (*LabelsResponse) ProtoMessage()

func (*LabelsResponse) ProtoReflect 

func (x *LabelsResponse) ProtoReflect() protoreflect.Message

func (*LabelsResponse) Reset 

func (x *LabelsResponse) Reset()

func (*LabelsResponse) String 

func (x *LabelsResponse) String() string

type Line 

type Line struct {

	// location_id ...
	LocationId uint64 `protobuf:"varint,1,opt,name=location_id,json=locationId,proto3" json:"location_id,omitempty"`
	// function_id ...
	FunctionId uint64 `protobuf:"varint,2,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	// line ...
	Line int64 `protobuf:"varint,3,opt,name=line,proto3" json:"line,omitempty"`
	// contains filtered or unexported fields
}

Line ...

func (*Line) Descriptor deprecated 

func (*Line) Descriptor() ([]byte, []int)

Deprecated: Use Line.ProtoReflect.Descriptor instead.

func (*Line) GetFunctionId 

func (x *Line) GetFunctionId() uint64

func (*Line) GetLine 

func (x *Line) GetLine() int64

func (*Line) GetLocationId 

func (x *Line) GetLocationId() uint64

func (*Line) ProtoMessage 

func (*Line) ProtoMessage()

func (*Line) ProtoReflect 

func (x *Line) ProtoReflect() protoreflect.Message

func (*Line) Reset 

func (x *Line) Reset()

func (*Line) String 

func (x *Line) String() string

type Location 

type Location struct {

	// id ...
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// mapping_id ...
	MappingId uint64 `protobuf:"varint,2,opt,name=mapping_id,json=mappingId,proto3" json:"mapping_id,omitempty"`
	// address ...
	Address uint64 `protobuf:"varint,3,opt,name=address,proto3" json:"address,omitempty"`
	// is_folded ...
	IsFolded bool `protobuf:"varint,4,opt,name=is_folded,json=isFolded,proto3" json:"is_folded,omitempty"`
	// contains filtered or unexported fields
}

Location is the location metadata

func (*Location) Descriptor deprecated 

func (*Location) Descriptor() ([]byte, []int)

Deprecated: Use Location.ProtoReflect.Descriptor instead.

func (*Location) GetAddress 

func (x *Location) GetAddress() uint64

func (*Location) GetId 

func (x *Location) GetId() uint64

func (*Location) GetIsFolded 

func (x *Location) GetIsFolded() bool

func (*Location) GetMappingId 

func (x *Location) GetMappingId() uint64

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) ProtoReflect 

func (x *Location) ProtoReflect() protoreflect.Message

func (*Location) Reset 

func (x *Location) Reset()

func (*Location) String 

func (x *Location) String() string

type Mapping 

type Mapping struct {

	// id ...
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// start ...
	Start uint64 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	// limit ...
	Limit uint64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// offset ...
	Offset uint64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	// file ...
	File string `protobuf:"bytes,5,opt,name=file,proto3" json:"file,omitempty"`
	// build_id ...
	BuildId string `protobuf:"bytes,6,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// contains filtered or unexported fields
}

Mapping ...

func (*Mapping) Descriptor deprecated 

func (*Mapping) Descriptor() ([]byte, []int)

Deprecated: Use Mapping.ProtoReflect.Descriptor instead.

func (*Mapping) GetBuildId 

func (x *Mapping) GetBuildId() string

func (*Mapping) GetFile 

func (x *Mapping) GetFile() string

func (*Mapping) GetId 

func (x *Mapping) GetId() uint64

func (*Mapping) GetLimit 

func (x *Mapping) GetLimit() uint64

func (*Mapping) GetOffset 

func (x *Mapping) GetOffset() uint64

func (*Mapping) GetStart 

func (x *Mapping) GetStart() uint64

func (*Mapping) ProtoMessage 

func (*Mapping) ProtoMessage()

func (*Mapping) ProtoReflect 

func (x *Mapping) ProtoReflect() protoreflect.Message

func (*Mapping) Reset 

func (x *Mapping) Reset()

func (*Mapping) String 

func (x *Mapping) String() string

type MergeProfile 

type MergeProfile struct {

	// query is the query string to match profiles for merge
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// start is the beginning of the evaluation time window
	Start *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	// end is the end of the evaluation time window
	End *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

MergeProfile contains parameters for a merge request

func (*MergeProfile) Descriptor deprecated 

func (*MergeProfile) Descriptor() ([]byte, []int)

Deprecated: Use MergeProfile.ProtoReflect.Descriptor instead.

func (*MergeProfile) GetEnd 

func (x *MergeProfile) GetEnd() *timestamppb.Timestamp

func (*MergeProfile) GetQuery 

func (x *MergeProfile) GetQuery() string

func (*MergeProfile) GetStart 

func (x *MergeProfile) GetStart() *timestamppb.Timestamp

func (*MergeProfile) ProtoMessage 

func (*MergeProfile) ProtoMessage()

func (*MergeProfile) ProtoReflect 

func (x *MergeProfile) ProtoReflect() protoreflect.Message

func (*MergeProfile) Reset 

func (x *MergeProfile) Reset()

func (*MergeProfile) String 

func (x *MergeProfile) String() string

type MetricsSample 

type MetricsSample struct {

	// timestamp is the time the profile was ingested
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// value is the cumulative value for the profile
	Value int64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

MetricsSample is a cumulative value and timestamp of a profile

func (*MetricsSample) Descriptor deprecated 

func (*MetricsSample) Descriptor() ([]byte, []int)

Deprecated: Use MetricsSample.ProtoReflect.Descriptor instead.

func (*MetricsSample) GetTimestamp 

func (x *MetricsSample) GetTimestamp() *timestamppb.Timestamp

func (*MetricsSample) GetValue 

func (x *MetricsSample) GetValue() int64

func (*MetricsSample) ProtoMessage 

func (*MetricsSample) ProtoMessage()

func (*MetricsSample) ProtoReflect 

func (x *MetricsSample) ProtoReflect() protoreflect.Message

func (*MetricsSample) Reset 

func (x *MetricsSample) Reset()

func (*MetricsSample) String 

func (x *MetricsSample) String() string

type MetricsSeries 

type MetricsSeries struct {

	// labelset is the set of key value pairs
	Labelset *v1alpha1.LabelSet `protobuf:"bytes,1,opt,name=labelset,proto3" json:"labelset,omitempty"`
	// samples is the set of top-level cumulative values of the corresponding profiles
	Samples []*MetricsSample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples,omitempty"`
	// contains filtered or unexported fields
}

MetricsSeries is a set of labels and corresponding sample values

func (*MetricsSeries) Descriptor deprecated 

func (*MetricsSeries) Descriptor() ([]byte, []int)

Deprecated: Use MetricsSeries.ProtoReflect.Descriptor instead.

func (*MetricsSeries) GetLabelset 

func (x *MetricsSeries) GetLabelset() *v1alpha1.LabelSet

func (*MetricsSeries) GetSamples 

func (x *MetricsSeries) GetSamples() []*MetricsSample

func (*MetricsSeries) ProtoMessage 

func (*MetricsSeries) ProtoMessage()

func (*MetricsSeries) ProtoReflect 

func (x *MetricsSeries) ProtoReflect() protoreflect.Message

func (*MetricsSeries) Reset 

func (x *MetricsSeries) Reset()

func (*MetricsSeries) String 

func (x *MetricsSeries) String() string

type ProfileDiffSelection 

type ProfileDiffSelection struct {

	// mode is the selection of the diff mode
	Mode ProfileDiffSelection_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=parca.query.v1alpha1.ProfileDiffSelection_Mode" json:"mode,omitempty"`
	// options are the available options for a diff selection
	//
	// Types that are assignable to Options:
	//	*ProfileDiffSelection_Merge
	//	*ProfileDiffSelection_Single
	Options isProfileDiffSelection_Options `protobuf_oneof:"options"`
	// contains filtered or unexported fields
}

ProfileDiffSelection contains the parameters of a diff selection

func (*ProfileDiffSelection) Descriptor deprecated 

func (*ProfileDiffSelection) Descriptor() ([]byte, []int)

Deprecated: Use ProfileDiffSelection.ProtoReflect.Descriptor instead.

func (*ProfileDiffSelection) GetMerge 

func (x *ProfileDiffSelection) GetMerge() *MergeProfile

func (*ProfileDiffSelection) GetMode 

func (x *ProfileDiffSelection) GetMode() ProfileDiffSelection_Mode

func (*ProfileDiffSelection) GetOptions 

func (m *ProfileDiffSelection) GetOptions() isProfileDiffSelection_Options

func (*ProfileDiffSelection) GetSingle 

func (x *ProfileDiffSelection) GetSingle() *SingleProfile

func (*ProfileDiffSelection) ProtoMessage 

func (*ProfileDiffSelection) ProtoMessage()

func (*ProfileDiffSelection) ProtoReflect 

func (x *ProfileDiffSelection) ProtoReflect() protoreflect.Message

func (*ProfileDiffSelection) Reset 

func (x *ProfileDiffSelection) Reset()

func (*ProfileDiffSelection) String 

func (x *ProfileDiffSelection) String() string

type ProfileDiffSelection_Merge 

type ProfileDiffSelection_Merge struct {
	// merge contains options for a merge request
	Merge *MergeProfile `protobuf:"bytes,2,opt,name=merge,proto3,oneof"`
}

type ProfileDiffSelection_Mode 

type ProfileDiffSelection_Mode int32

Mode specifies the type of diff 

const (
	// MODE_SINGLE_UNSPECIFIED default unspecified
	ProfileDiffSelection_MODE_SINGLE_UNSPECIFIED ProfileDiffSelection_Mode = 0
	// MODE_MERGE merge profile
	ProfileDiffSelection_MODE_MERGE ProfileDiffSelection_Mode = 1
)

func (ProfileDiffSelection_Mode) Descriptor 

func (ProfileDiffSelection_Mode) Descriptor() protoreflect.EnumDescriptor

func (ProfileDiffSelection_Mode) Enum 

func (x ProfileDiffSelection_Mode) Enum() *ProfileDiffSelection_Mode

func (ProfileDiffSelection_Mode) EnumDescriptor deprecated 

func (ProfileDiffSelection_Mode) EnumDescriptor() ([]byte, []int)

Deprecated: Use ProfileDiffSelection_Mode.Descriptor instead.

func (ProfileDiffSelection_Mode) Number 

func (x ProfileDiffSelection_Mode) Number() protoreflect.EnumNumber

func (ProfileDiffSelection_Mode) String 

func (x ProfileDiffSelection_Mode) String() string

func (ProfileDiffSelection_Mode) Type 

func (ProfileDiffSelection_Mode) Type() protoreflect.EnumType

type ProfileDiffSelection_Single 

type ProfileDiffSelection_Single struct {
	// single contains options for a single profile request
	Single *SingleProfile `protobuf:"bytes,3,opt,name=single,proto3,oneof"`
}

type ProfileOptionMatchesRule 

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

ProfileOptionMatchesRule ensure the options match the requested mode

func (ProfileOptionMatchesRule) Validate 

func (o ProfileOptionMatchesRule) Validate(v interface{}) error

Validate the option matches mode

type QueryModeRule 

type QueryModeRule struct{}

func (QueryModeRule) Validate 

func (r QueryModeRule) Validate(v interface{}) error

type QueryRangeRequest 

type QueryRangeRequest struct {

	// query is the query string to match profiles against
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// start is the start of the query time window
	Start *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	// end is the end of the query time window
	End *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"`
	// limit is the max number of profiles to include in the response
	Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

QueryRangeRequest is the request for a set of profiles matching a query over a time window

func (*QueryRangeRequest) Descriptor deprecated 

func (*QueryRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use QueryRangeRequest.ProtoReflect.Descriptor instead.

func (*QueryRangeRequest) GetEnd 

func (x *QueryRangeRequest) GetEnd() *timestamppb.Timestamp

func (*QueryRangeRequest) GetLimit 

func (x *QueryRangeRequest) GetLimit() uint32

func (*QueryRangeRequest) GetQuery 

func (x *QueryRangeRequest) GetQuery() string

func (*QueryRangeRequest) GetStart 

func (x *QueryRangeRequest) GetStart() *timestamppb.Timestamp

func (*QueryRangeRequest) ProtoMessage 

func (*QueryRangeRequest) ProtoMessage()

func (*QueryRangeRequest) ProtoReflect 

func (x *QueryRangeRequest) ProtoReflect() protoreflect.Message

func (*QueryRangeRequest) Reset 

func (x *QueryRangeRequest) Reset()

func (*QueryRangeRequest) String 

func (x *QueryRangeRequest) String() string

func (*QueryRangeRequest) Validate 

func (r *QueryRangeRequest) Validate() error

Validate the QueryRangeRequest

type QueryRangeResponse 

type QueryRangeResponse struct {

	// series is the set of metrics series that satisfy the query range request
	Series []*MetricsSeries `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"`
	// contains filtered or unexported fields
}

QueryRangeResponse is the set of matching profile values

func (*QueryRangeResponse) Descriptor deprecated 

func (*QueryRangeResponse) Descriptor() ([]byte, []int)

Deprecated: Use QueryRangeResponse.ProtoReflect.Descriptor instead.

func (*QueryRangeResponse) GetSeries 

func (x *QueryRangeResponse) GetSeries() []*MetricsSeries

func (*QueryRangeResponse) ProtoMessage 

func (*QueryRangeResponse) ProtoMessage()

func (*QueryRangeResponse) ProtoReflect 

func (x *QueryRangeResponse) ProtoReflect() protoreflect.Message

func (*QueryRangeResponse) Reset 

func (x *QueryRangeResponse) Reset()

func (*QueryRangeResponse) String 

func (x *QueryRangeResponse) String() string

type QueryRequest 

type QueryRequest struct {

	// mode indicates the type of query performed
	Mode QueryRequest_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=parca.query.v1alpha1.QueryRequest_Mode" json:"mode,omitempty"`
	// options are the options corresponding to the mode
	//
	// Types that are assignable to Options:
	//	*QueryRequest_Diff
	//	*QueryRequest_Merge
	//	*QueryRequest_Single
	Options isQueryRequest_Options `protobuf_oneof:"options"`
	// report_type is the type of report to return
	ReportType QueryRequest_ReportType `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

QueryRequest is a request for a profile query

func (*QueryRequest) Descriptor deprecated 

func (*QueryRequest) Descriptor() ([]byte, []int)

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetDiff 

func (x *QueryRequest) GetDiff() *DiffProfile

func (*QueryRequest) GetMerge 

func (x *QueryRequest) GetMerge() *MergeProfile

func (*QueryRequest) GetMode 

func (x *QueryRequest) GetMode() QueryRequest_Mode

func (*QueryRequest) GetOptions 

func (m *QueryRequest) GetOptions() isQueryRequest_Options

func (*QueryRequest) GetReportType 

func (x *QueryRequest) GetReportType() QueryRequest_ReportType

func (*QueryRequest) GetSingle 

func (x *QueryRequest) GetSingle() *SingleProfile

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

func (x *QueryRequest) ProtoReflect() protoreflect.Message

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

func (*QueryRequest) Validate 

func (r *QueryRequest) Validate() error

Validate the QueryRequest

type QueryRequest_Diff 

type QueryRequest_Diff struct {
	// diff contains the diff query options
	Diff *DiffProfile `protobuf:"bytes,2,opt,name=diff,proto3,oneof"`
}

type QueryRequest_Merge 

type QueryRequest_Merge struct {
	// merge contains the merge query options
	Merge *MergeProfile `protobuf:"bytes,3,opt,name=merge,proto3,oneof"`
}

type QueryRequest_Mode 

type QueryRequest_Mode int32

Mode is the type of query request 

const (
	// MODE_SINGLE_UNSPECIFIED query unspecified
	QueryRequest_MODE_SINGLE_UNSPECIFIED QueryRequest_Mode = 0
	// MODE_DIFF is a diff query
	QueryRequest_MODE_DIFF QueryRequest_Mode = 1
	// MODE_MERGE is a merge query
	QueryRequest_MODE_MERGE QueryRequest_Mode = 2
)

func (QueryRequest_Mode) Descriptor 

func (QueryRequest_Mode) Descriptor() protoreflect.EnumDescriptor

func (QueryRequest_Mode) Enum 

func (x QueryRequest_Mode) Enum() *QueryRequest_Mode

func (QueryRequest_Mode) EnumDescriptor deprecated 

func (QueryRequest_Mode) EnumDescriptor() ([]byte, []int)

Deprecated: Use QueryRequest_Mode.Descriptor instead.

func (QueryRequest_Mode) Number 

func (x QueryRequest_Mode) Number() protoreflect.EnumNumber

func (QueryRequest_Mode) String 

func (x QueryRequest_Mode) String() string

func (QueryRequest_Mode) Type 

func (QueryRequest_Mode) Type() protoreflect.EnumType

type QueryRequest_ReportType 

type QueryRequest_ReportType int32

ReportType is the type of report to return 

const (
	// REPORT_TYPE_FLAMEGRAPH_UNSPECIFIED unspecified
	QueryRequest_REPORT_TYPE_FLAMEGRAPH_UNSPECIFIED QueryRequest_ReportType = 0
)

func (QueryRequest_ReportType) Descriptor 

func (QueryRequest_ReportType) Descriptor() protoreflect.EnumDescriptor

func (QueryRequest_ReportType) Enum 

func (x QueryRequest_ReportType) Enum() *QueryRequest_ReportType

func (QueryRequest_ReportType) EnumDescriptor deprecated 

func (QueryRequest_ReportType) EnumDescriptor() ([]byte, []int)

Deprecated: Use QueryRequest_ReportType.Descriptor instead.

func (QueryRequest_ReportType) Number 

func (x QueryRequest_ReportType) Number() protoreflect.EnumNumber

func (QueryRequest_ReportType) String 

func (x QueryRequest_ReportType) String() string

func (QueryRequest_ReportType) Type 

func (QueryRequest_ReportType) Type() protoreflect.EnumType

type QueryRequest_Single 

type QueryRequest_Single struct {
	// single contains the single query options
	Single *SingleProfile `protobuf:"bytes,4,opt,name=single,proto3,oneof"`
}

type QueryResponse 

type QueryResponse struct {

	// report is the generated report
	//
	// Types that are assignable to Report:
	//	*QueryResponse_Flamegraph
	Report isQueryResponse_Report `protobuf_oneof:"report"`
	// contains filtered or unexported fields
}

QueryResponse is the returned report for the given query

func (*QueryResponse) Descriptor deprecated 

func (*QueryResponse) Descriptor() ([]byte, []int)

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetFlamegraph 

func (x *QueryResponse) GetFlamegraph() *Flamegraph

func (*QueryResponse) GetReport 

func (m *QueryResponse) GetReport() isQueryResponse_Report

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect 

func (x *QueryResponse) ProtoReflect() protoreflect.Message

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) String 

func (x *QueryResponse) String() string

type QueryResponse_Flamegraph 

type QueryResponse_Flamegraph struct {
	// flamegraph is a flamegraph representation of the report
	Flamegraph *Flamegraph `protobuf:"bytes,5,opt,name=flamegraph,proto3,oneof"`
}

type QueryServiceClient 

type QueryServiceClient interface {
	// QueryRange performs a profile query over a time range
	QueryRange(ctx context.Context, in *QueryRangeRequest, opts ...grpc.CallOption) (*QueryRangeResponse, error)
	// Query performs a profile query
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	// Series is unimplemented
	Series(ctx context.Context, in *SeriesRequest, opts ...grpc.CallOption) (*SeriesResponse, error)
	// Labels returns the set of label names against a given matching string and time frame
	Labels(ctx context.Context, in *LabelsRequest, opts ...grpc.CallOption) (*LabelsResponse, error)
	// Values returns the set of values that match a given label and time frame
	Values(ctx context.Context, in *ValuesRequest, opts ...grpc.CallOption) (*ValuesResponse, error)
}

QueryServiceClient is the client API for QueryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewQueryServiceClient 

func NewQueryServiceClient(cc grpc.ClientConnInterface) QueryServiceClient

type QueryServiceServer 

type QueryServiceServer interface {
	// QueryRange performs a profile query over a time range
	QueryRange(context.Context, *QueryRangeRequest) (*QueryRangeResponse, error)
	// Query performs a profile query
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	// Series is unimplemented
	Series(context.Context, *SeriesRequest) (*SeriesResponse, error)
	// Labels returns the set of label names against a given matching string and time frame
	Labels(context.Context, *LabelsRequest) (*LabelsResponse, error)
	// Values returns the set of values that match a given label and time frame
	Values(context.Context, *ValuesRequest) (*ValuesResponse, error)
}

QueryServiceServer is the server API for QueryService service. All implementations should embed UnimplementedQueryServiceServer for forward compatibility

type ReportTypeRule 

type ReportTypeRule struct{}

func (ReportTypeRule) Validate 

func (r ReportTypeRule) Validate(v interface{}) error

type SeriesRequest 

type SeriesRequest struct {

	// match ...
	Match []string `protobuf:"bytes,1,rep,name=match,proto3" json:"match,omitempty"`
	// start ...
	Start *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	// end ...
	End *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

SeriesRequest is unimplemented

func (*SeriesRequest) Descriptor deprecated 

func (*SeriesRequest) Descriptor() ([]byte, []int)

Deprecated: Use SeriesRequest.ProtoReflect.Descriptor instead.

func (*SeriesRequest) GetEnd 

func (x *SeriesRequest) GetEnd() *timestamppb.Timestamp

func (*SeriesRequest) GetMatch 

func (x *SeriesRequest) GetMatch() []string

func (*SeriesRequest) GetStart 

func (x *SeriesRequest) GetStart() *timestamppb.Timestamp

func (*SeriesRequest) ProtoMessage 

func (*SeriesRequest) ProtoMessage()

func (*SeriesRequest) ProtoReflect 

func (x *SeriesRequest) ProtoReflect() protoreflect.Message

func (*SeriesRequest) Reset 

func (x *SeriesRequest) Reset()

func (*SeriesRequest) String 

func (x *SeriesRequest) String() string

type SeriesResponse 

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

SeriesResponse is unimplemented

func (*SeriesResponse) Descriptor deprecated 

func (*SeriesResponse) Descriptor() ([]byte, []int)

Deprecated: Use SeriesResponse.ProtoReflect.Descriptor instead.

func (*SeriesResponse) ProtoMessage 

func (*SeriesResponse) ProtoMessage()

func (*SeriesResponse) ProtoReflect 

func (x *SeriesResponse) ProtoReflect() protoreflect.Message

func (*SeriesResponse) Reset 

func (x *SeriesResponse) Reset()

func (*SeriesResponse) String 

func (x *SeriesResponse) String() string

type SingleProfile 

type SingleProfile struct {

	// time is the point in time to perform the profile request
	Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// query is the query string to retrieve the profile
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

SingleProfile contains parameters for a single profile query request

func (*SingleProfile) Descriptor deprecated 

func (*SingleProfile) Descriptor() ([]byte, []int)

Deprecated: Use SingleProfile.ProtoReflect.Descriptor instead.

func (*SingleProfile) GetQuery 

func (x *SingleProfile) GetQuery() string

func (*SingleProfile) GetTime 

func (x *SingleProfile) GetTime() *timestamppb.Timestamp

func (*SingleProfile) ProtoMessage 

func (*SingleProfile) ProtoMessage()

func (*SingleProfile) ProtoReflect 

func (x *SingleProfile) ProtoReflect() protoreflect.Message

func (*SingleProfile) Reset 

func (x *SingleProfile) Reset()

func (*SingleProfile) String 

func (x *SingleProfile) String() string

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedQueryServiceServer) Labels 

func (UnimplementedQueryServiceServer) Labels(context.Context, *LabelsRequest) (*LabelsResponse, error)

func (UnimplementedQueryServiceServer) Query 

func (UnimplementedQueryServiceServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)

func (UnimplementedQueryServiceServer) QueryRange 

func (UnimplementedQueryServiceServer) QueryRange(context.Context, *QueryRangeRequest) (*QueryRangeResponse, error)

func (UnimplementedQueryServiceServer) Series 

func (UnimplementedQueryServiceServer) Series(context.Context, *SeriesRequest) (*SeriesResponse, error)

func (UnimplementedQueryServiceServer) Values 

func (UnimplementedQueryServiceServer) Values(context.Context, *ValuesRequest) (*ValuesResponse, error)

type UnsafeQueryServiceServer 

type UnsafeQueryServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeQueryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueryServiceServer will result in compilation errors.

type ValuesRequest 

type ValuesRequest struct {

	// label_name is the label name to match values against
	LabelName string `protobuf:"bytes,1,opt,name=label_name,json=labelName,proto3" json:"label_name,omitempty"`
	// match are the set of matching strings to match values against
	Match []string `protobuf:"bytes,2,rep,name=match,proto3" json:"match,omitempty"`
	// start is the start of the time window to perform the query
	Start *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start,proto3" json:"start,omitempty"`
	// end is the end of the time window to perform the query
	End *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

ValuesRequest are the request values for a values request

func (*ValuesRequest) Descriptor deprecated 

func (*ValuesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValuesRequest.ProtoReflect.Descriptor instead.

func (*ValuesRequest) GetEnd 

func (x *ValuesRequest) GetEnd() *timestamppb.Timestamp

func (*ValuesRequest) GetLabelName 

func (x *ValuesRequest) GetLabelName() string

func (*ValuesRequest) GetMatch 

func (x *ValuesRequest) GetMatch() []string

func (*ValuesRequest) GetStart 

func (x *ValuesRequest) GetStart() *timestamppb.Timestamp

func (*ValuesRequest) ProtoMessage 

func (*ValuesRequest) ProtoMessage()

func (*ValuesRequest) ProtoReflect 

func (x *ValuesRequest) ProtoReflect() protoreflect.Message

func (*ValuesRequest) Reset 

func (x *ValuesRequest) Reset()

func (*ValuesRequest) String 

func (x *ValuesRequest) String() string

type ValuesResponse 

type ValuesResponse struct {

	// label_values are the set of matching label values
	LabelValues []string `protobuf:"bytes,1,rep,name=label_values,json=labelValues,proto3" json:"label_values,omitempty"`
	// warnings is unimplemented
	Warnings []string `protobuf:"bytes,2,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

ValuesResponse are the set of matching values

func (*ValuesResponse) Descriptor deprecated 

func (*ValuesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ValuesResponse.ProtoReflect.Descriptor instead.

func (*ValuesResponse) GetLabelValues 

func (x *ValuesResponse) GetLabelValues() []string

func (*ValuesResponse) GetWarnings 

func (x *ValuesResponse) GetWarnings() []string

func (*ValuesResponse) ProtoMessage 

func (*ValuesResponse) ProtoMessage()

func (*ValuesResponse) ProtoReflect 

func (x *ValuesResponse) ProtoReflect() protoreflect.Message

func (*ValuesResponse) Reset 

func (x *ValuesResponse) Reset()

func (*ValuesResponse) String 

func (x *ValuesResponse) String() string

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.