queryv1alpha1

package
v0.10.0 Latest Latest
Warning

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

 Go to latest Published: Mar 31, 2022 License: Apache-2.0 Imports: 22 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",
		1: "REPORT_TYPE_PPROF",
		2: "REPORT_TYPE_TOP",
	}
	QueryRequest_ReportType_value = map[string]int32{
		"REPORT_TYPE_FLAMEGRAPH_UNSPECIFIED": 0,
		"REPORT_TYPE_PPROF":                  1,
		"REPORT_TYPE_TOP":                    2,
	}
)

Enum value maps for QueryRequest_ReportType.

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
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) MarshalToSizedBufferVT added in v0.5.0 

func (m *DiffProfile) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DiffProfile) MarshalToVT added in v0.5.0 

func (m *DiffProfile) MarshalToVT(dAtA []byte) (int, error)

func (*DiffProfile) MarshalVT added in v0.5.0 

func (m *DiffProfile) MarshalVT() (dAtA []byte, err error)

func (*DiffProfile) ProtoMessage 

func (*DiffProfile) ProtoMessage()

func (*DiffProfile) ProtoReflect 

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

func (*DiffProfile) Reset 

func (x *DiffProfile) Reset()

func (*DiffProfile) SizeVT added in v0.5.0 

func (m *DiffProfile) SizeVT() (n int)

func (*DiffProfile) String 

func (x *DiffProfile) String() string

func (*DiffProfile) UnmarshalVT added in v0.5.0 

func (m *DiffProfile) UnmarshalVT(dAtA []byte) error

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) MarshalToSizedBufferVT added in v0.5.0 

func (m *Flamegraph) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Flamegraph) MarshalToVT added in v0.5.0 

func (m *Flamegraph) MarshalToVT(dAtA []byte) (int, error)

func (*Flamegraph) MarshalVT added in v0.5.0 

func (m *Flamegraph) MarshalVT() (dAtA []byte, err error)

func (*Flamegraph) ProtoMessage 

func (*Flamegraph) ProtoMessage()

func (*Flamegraph) ProtoReflect 

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

func (*Flamegraph) Reset 

func (x *Flamegraph) Reset()

func (*Flamegraph) SizeVT added in v0.5.0 

func (m *Flamegraph) SizeVT() (n int)

func (*Flamegraph) String 

func (x *Flamegraph) String() string

func (*Flamegraph) UnmarshalVT added in v0.5.0 

func (m *Flamegraph) UnmarshalVT(dAtA []byte) error

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) MarshalToSizedBufferVT added in v0.5.0 

func (m *FlamegraphNode) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlamegraphNode) MarshalToVT added in v0.5.0 

func (m *FlamegraphNode) MarshalToVT(dAtA []byte) (int, error)

func (*FlamegraphNode) MarshalVT added in v0.5.0 

func (m *FlamegraphNode) MarshalVT() (dAtA []byte, err error)

func (*FlamegraphNode) ProtoMessage 

func (*FlamegraphNode) ProtoMessage()

func (*FlamegraphNode) ProtoReflect 

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

func (*FlamegraphNode) Reset 

func (x *FlamegraphNode) Reset()

func (*FlamegraphNode) SizeVT added in v0.5.0 

func (m *FlamegraphNode) SizeVT() (n int)

func (*FlamegraphNode) String 

func (x *FlamegraphNode) String() string

func (*FlamegraphNode) UnmarshalVT added in v0.5.0 

func (m *FlamegraphNode) UnmarshalVT(dAtA []byte) error

type FlamegraphNodeMeta 

type FlamegraphNodeMeta struct {

	// location is the location for the code
	Location *v1alpha11.Location `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// mapping is the mapping into code
	Mapping *v1alpha11.Mapping `protobuf:"bytes,2,opt,name=mapping,proto3" json:"mapping,omitempty"`
	// function is the function information
	Function *v1alpha11.Function `protobuf:"bytes,3,opt,name=function,proto3" json:"function,omitempty"`
	// line is the line location
	Line *v1alpha11.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() *v1alpha11.Function

func (*FlamegraphNodeMeta) GetLine 

func (x *FlamegraphNodeMeta) GetLine() *v1alpha11.Line

func (*FlamegraphNodeMeta) GetLocation 

func (x *FlamegraphNodeMeta) GetLocation() *v1alpha11.Location

func (*FlamegraphNodeMeta) GetMapping 

func (x *FlamegraphNodeMeta) GetMapping() *v1alpha11.Mapping

func (*FlamegraphNodeMeta) MarshalToSizedBufferVT added in v0.5.0 

func (m *FlamegraphNodeMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlamegraphNodeMeta) MarshalToVT added in v0.5.0 

func (m *FlamegraphNodeMeta) MarshalToVT(dAtA []byte) (int, error)

func (*FlamegraphNodeMeta) MarshalVT added in v0.5.0 

func (m *FlamegraphNodeMeta) MarshalVT() (dAtA []byte, err error)

func (*FlamegraphNodeMeta) ProtoMessage 

func (*FlamegraphNodeMeta) ProtoMessage()

func (*FlamegraphNodeMeta) ProtoReflect 

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

func (*FlamegraphNodeMeta) Reset 

func (x *FlamegraphNodeMeta) Reset()

func (*FlamegraphNodeMeta) SizeVT added in v0.5.0 

func (m *FlamegraphNodeMeta) SizeVT() (n int)

func (*FlamegraphNodeMeta) String 

func (x *FlamegraphNodeMeta) String() string

func (*FlamegraphNodeMeta) UnmarshalVT added in v0.5.0 

func (m *FlamegraphNodeMeta) UnmarshalVT(dAtA []byte) error

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) MarshalToSizedBufferVT added in v0.5.0 

func (m *FlamegraphRootNode) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlamegraphRootNode) MarshalToVT added in v0.5.0 

func (m *FlamegraphRootNode) MarshalToVT(dAtA []byte) (int, error)

func (*FlamegraphRootNode) MarshalVT added in v0.5.0 

func (m *FlamegraphRootNode) MarshalVT() (dAtA []byte, err error)

func (*FlamegraphRootNode) ProtoMessage 

func (*FlamegraphRootNode) ProtoMessage()

func (*FlamegraphRootNode) ProtoReflect 

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

func (*FlamegraphRootNode) Reset 

func (x *FlamegraphRootNode) Reset()

func (*FlamegraphRootNode) SizeVT added in v0.5.0 

func (m *FlamegraphRootNode) SizeVT() (n int)

func (*FlamegraphRootNode) String 

func (x *FlamegraphRootNode) String() string

func (*FlamegraphRootNode) UnmarshalVT added in v0.5.0 

func (m *FlamegraphRootNode) UnmarshalVT(dAtA []byte) error

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) MarshalToSizedBufferVT added in v0.5.0 

func (m *LabelsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LabelsRequest) MarshalToVT added in v0.5.0 

func (m *LabelsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*LabelsRequest) MarshalVT added in v0.5.0 

func (m *LabelsRequest) MarshalVT() (dAtA []byte, err error)

func (*LabelsRequest) ProtoMessage 

func (*LabelsRequest) ProtoMessage()

func (*LabelsRequest) ProtoReflect 

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

func (*LabelsRequest) Reset 

func (x *LabelsRequest) Reset()

func (*LabelsRequest) SizeVT added in v0.5.0 

func (m *LabelsRequest) SizeVT() (n int)

func (*LabelsRequest) String 

func (x *LabelsRequest) String() string

func (*LabelsRequest) UnmarshalVT added in v0.5.0 

func (m *LabelsRequest) UnmarshalVT(dAtA []byte) error

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) MarshalToSizedBufferVT added in v0.5.0 

func (m *LabelsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LabelsResponse) MarshalToVT added in v0.5.0 

func (m *LabelsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*LabelsResponse) MarshalVT added in v0.5.0 

func (m *LabelsResponse) MarshalVT() (dAtA []byte, err error)

func (*LabelsResponse) ProtoMessage 

func (*LabelsResponse) ProtoMessage()

func (*LabelsResponse) ProtoReflect 

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

func (*LabelsResponse) Reset 

func (x *LabelsResponse) Reset()

func (*LabelsResponse) SizeVT added in v0.5.0 

func (m *LabelsResponse) SizeVT() (n int)

func (*LabelsResponse) String 

func (x *LabelsResponse) String() string

func (*LabelsResponse) UnmarshalVT added in v0.5.0 

func (m *LabelsResponse) UnmarshalVT(dAtA []byte) error

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) MarshalToSizedBufferVT added in v0.5.0 

func (m *MergeProfile) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MergeProfile) MarshalToVT added in v0.5.0 

func (m *MergeProfile) MarshalToVT(dAtA []byte) (int, error)

func (*MergeProfile) MarshalVT added in v0.5.0 

func (m *MergeProfile) MarshalVT() (dAtA []byte, err error)

func (*MergeProfile) ProtoMessage 

func (*MergeProfile) ProtoMessage()

func (*MergeProfile) ProtoReflect 

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

func (*MergeProfile) Reset 

func (x *MergeProfile) Reset()

func (*MergeProfile) SizeVT added in v0.5.0 

func (m *MergeProfile) SizeVT() (n int)

func (*MergeProfile) String 

func (x *MergeProfile) String() string

func (*MergeProfile) UnmarshalVT added in v0.5.0 

func (m *MergeProfile) UnmarshalVT(dAtA []byte) error

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) MarshalToSizedBufferVT added in v0.5.0 

func (m *MetricsSample) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MetricsSample) MarshalToVT added in v0.5.0 

func (m *MetricsSample) MarshalToVT(dAtA []byte) (int, error)

func (*MetricsSample) MarshalVT added in v0.5.0 

func (m *MetricsSample) MarshalVT() (dAtA []byte, err error)

func (*MetricsSample) ProtoMessage 

func (*MetricsSample) ProtoMessage()

func (*MetricsSample) ProtoReflect 

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

func (*MetricsSample) Reset 

func (x *MetricsSample) Reset()

func (*MetricsSample) SizeVT added in v0.5.0 

func (m *MetricsSample) SizeVT() (n int)

func (*MetricsSample) String 

func (x *MetricsSample) String() string

func (*MetricsSample) UnmarshalVT added in v0.5.0 

func (m *MetricsSample) UnmarshalVT(dAtA []byte) error

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"`
	// period_type is the value type of profile period
	PeriodType *ValueType `protobuf:"bytes,3,opt,name=period_type,json=periodType,proto3" json:"period_type,omitempty"`
	// sample_type is the value type of profile sample
	SampleType *ValueType `protobuf:"bytes,4,opt,name=sample_type,json=sampleType,proto3" json:"sample_type,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) GetPeriodType added in v0.4.0 

func (x *MetricsSeries) GetPeriodType() *ValueType

func (*MetricsSeries) GetSampleType added in v0.4.0 

func (x *MetricsSeries) GetSampleType() *ValueType

func (*MetricsSeries) GetSamples 

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

func (*MetricsSeries) MarshalToSizedBufferVT added in v0.5.0 

func (m *MetricsSeries) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MetricsSeries) MarshalToVT added in v0.5.0 

func (m *MetricsSeries) MarshalToVT(dAtA []byte) (int, error)

func (*MetricsSeries) MarshalVT added in v0.5.0 

func (m *MetricsSeries) MarshalVT() (dAtA []byte, err error)

func (*MetricsSeries) ProtoMessage 

func (*MetricsSeries) ProtoMessage()

func (*MetricsSeries) ProtoReflect 

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

func (*MetricsSeries) Reset 

func (x *MetricsSeries) Reset()

func (*MetricsSeries) SizeVT added in v0.5.0 

func (m *MetricsSeries) SizeVT() (n int)

func (*MetricsSeries) String 

func (x *MetricsSeries) String() string

func (*MetricsSeries) UnmarshalVT added in v0.5.0 

func (m *MetricsSeries) UnmarshalVT(dAtA []byte) error

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) MarshalToSizedBufferVT added in v0.5.0 

func (m *ProfileDiffSelection) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ProfileDiffSelection) MarshalToVT added in v0.5.0 

func (m *ProfileDiffSelection) MarshalToVT(dAtA []byte) (int, error)

func (*ProfileDiffSelection) MarshalVT added in v0.5.0 

func (m *ProfileDiffSelection) MarshalVT() (dAtA []byte, err error)

func (*ProfileDiffSelection) ProtoMessage 

func (*ProfileDiffSelection) ProtoMessage()

func (*ProfileDiffSelection) ProtoReflect 

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

func (*ProfileDiffSelection) Reset 

func (x *ProfileDiffSelection) Reset()

func (*ProfileDiffSelection) SizeVT added in v0.5.0 

func (m *ProfileDiffSelection) SizeVT() (n int)

func (*ProfileDiffSelection) String 

func (x *ProfileDiffSelection) String() string

func (*ProfileDiffSelection) UnmarshalVT added in v0.5.0 

func (m *ProfileDiffSelection) UnmarshalVT(dAtA []byte) error

type ProfileDiffSelection_Merge 

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

func (*ProfileDiffSelection_Merge) MarshalToSizedBufferVT added in v0.5.0 

func (m *ProfileDiffSelection_Merge) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ProfileDiffSelection_Merge) MarshalToVT added in v0.5.0 

func (m *ProfileDiffSelection_Merge) MarshalToVT(dAtA []byte) (int, error)

func (*ProfileDiffSelection_Merge) SizeVT added in v0.5.0 

func (m *ProfileDiffSelection_Merge) SizeVT() (n int)

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"`
}

func (*ProfileDiffSelection_Single) MarshalToSizedBufferVT added in v0.5.0 

func (m *ProfileDiffSelection_Single) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ProfileDiffSelection_Single) MarshalToVT added in v0.5.0 

func (m *ProfileDiffSelection_Single) MarshalToVT(dAtA []byte) (int, error)

func (*ProfileDiffSelection_Single) SizeVT added in v0.5.0 

func (m *ProfileDiffSelection_Single) SizeVT() (n int)

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) MarshalToSizedBufferVT added in v0.5.0 

func (m *QueryRangeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryRangeRequest) MarshalToVT added in v0.5.0 

func (m *QueryRangeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*QueryRangeRequest) MarshalVT added in v0.5.0 

func (m *QueryRangeRequest) MarshalVT() (dAtA []byte, err error)

func (*QueryRangeRequest) ProtoMessage 

func (*QueryRangeRequest) ProtoMessage()

func (*QueryRangeRequest) ProtoReflect 

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

func (*QueryRangeRequest) Reset 

func (x *QueryRangeRequest) Reset()

func (*QueryRangeRequest) SizeVT added in v0.5.0 

func (m *QueryRangeRequest) SizeVT() (n int)

func (*QueryRangeRequest) String 

func (x *QueryRangeRequest) String() string

func (*QueryRangeRequest) UnmarshalVT added in v0.5.0 

func (m *QueryRangeRequest) UnmarshalVT(dAtA []byte) error

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) MarshalToSizedBufferVT added in v0.5.0 

func (m *QueryRangeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryRangeResponse) MarshalToVT added in v0.5.0 

func (m *QueryRangeResponse) MarshalToVT(dAtA []byte) (int, error)

func (*QueryRangeResponse) MarshalVT added in v0.5.0 

func (m *QueryRangeResponse) MarshalVT() (dAtA []byte, err error)

func (*QueryRangeResponse) ProtoMessage 

func (*QueryRangeResponse) ProtoMessage()

func (*QueryRangeResponse) ProtoReflect 

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

func (*QueryRangeResponse) Reset 

func (x *QueryRangeResponse) Reset()

func (*QueryRangeResponse) SizeVT added in v0.5.0 

func (m *QueryRangeResponse) SizeVT() (n int)

func (*QueryRangeResponse) String 

func (x *QueryRangeResponse) String() string

func (*QueryRangeResponse) UnmarshalVT added in v0.5.0 

func (m *QueryRangeResponse) UnmarshalVT(dAtA []byte) error

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) MarshalToSizedBufferVT added in v0.5.0 

func (m *QueryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryRequest) MarshalToVT added in v0.5.0 

func (m *QueryRequest) MarshalToVT(dAtA []byte) (int, error)

func (*QueryRequest) MarshalVT added in v0.5.0 

func (m *QueryRequest) MarshalVT() (dAtA []byte, err error)

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

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

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) SizeVT added in v0.5.0 

func (m *QueryRequest) SizeVT() (n int)

func (*QueryRequest) String 

func (x *QueryRequest) String() string

func (*QueryRequest) UnmarshalVT added in v0.5.0 

func (m *QueryRequest) UnmarshalVT(dAtA []byte) error

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"`
}

func (*QueryRequest_Diff) MarshalToSizedBufferVT added in v0.5.0 

func (m *QueryRequest_Diff) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryRequest_Diff) MarshalToVT added in v0.5.0 

func (m *QueryRequest_Diff) MarshalToVT(dAtA []byte) (int, error)

func (*QueryRequest_Diff) SizeVT added in v0.5.0 

func (m *QueryRequest_Diff) SizeVT() (n int)

type QueryRequest_Merge 

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

func (*QueryRequest_Merge) MarshalToSizedBufferVT added in v0.5.0 

func (m *QueryRequest_Merge) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryRequest_Merge) MarshalToVT added in v0.5.0 

func (m *QueryRequest_Merge) MarshalToVT(dAtA []byte) (int, error)

func (*QueryRequest_Merge) SizeVT added in v0.5.0 

func (m *QueryRequest_Merge) SizeVT() (n int)

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
	// REPORT_TYPE_PPROF unspecified
	QueryRequest_REPORT_TYPE_PPROF QueryRequest_ReportType = 1
	// REPORT_TYPE_TOP unspecified
	QueryRequest_REPORT_TYPE_TOP QueryRequest_ReportType = 2
)

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"`
}

func (*QueryRequest_Single) MarshalToSizedBufferVT added in v0.5.0 

func (m *QueryRequest_Single) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryRequest_Single) MarshalToVT added in v0.5.0 

func (m *QueryRequest_Single) MarshalToVT(dAtA []byte) (int, error)

func (*QueryRequest_Single) SizeVT added in v0.5.0 

func (m *QueryRequest_Single) SizeVT() (n int)

type QueryResponse 

type QueryResponse struct {

	// report is the generated report
	//
	// Types that are assignable to Report:
	//	*QueryResponse_Flamegraph
	//	*QueryResponse_Pprof
	//	*QueryResponse_Top
	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) GetPprof added in v0.4.0 

func (x *QueryResponse) GetPprof() []byte

func (*QueryResponse) GetReport 

func (m *QueryResponse) GetReport() isQueryResponse_Report

func (*QueryResponse) GetTop added in v0.8.0 

func (x *QueryResponse) GetTop() *Top

func (*QueryResponse) MarshalToSizedBufferVT added in v0.5.0 

func (m *QueryResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryResponse) MarshalToVT added in v0.5.0 

func (m *QueryResponse) MarshalToVT(dAtA []byte) (int, error)

func (*QueryResponse) MarshalVT added in v0.5.0 

func (m *QueryResponse) MarshalVT() (dAtA []byte, err error)

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect 

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

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) SizeVT added in v0.5.0 

func (m *QueryResponse) SizeVT() (n int)

func (*QueryResponse) String 

func (x *QueryResponse) String() string

func (*QueryResponse) UnmarshalVT added in v0.5.0 

func (m *QueryResponse) UnmarshalVT(dAtA []byte) error

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"`
}

func (*QueryResponse_Flamegraph) MarshalToSizedBufferVT added in v0.5.0 

func (m *QueryResponse_Flamegraph) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryResponse_Flamegraph) MarshalToVT added in v0.5.0 

func (m *QueryResponse_Flamegraph) MarshalToVT(dAtA []byte) (int, error)

func (*QueryResponse_Flamegraph) SizeVT added in v0.5.0 

func (m *QueryResponse_Flamegraph) SizeVT() (n int)

type QueryResponse_Pprof added in v0.4.0 

type QueryResponse_Pprof struct {
	// pprof is a pprof profile as compressed bytes
	Pprof []byte `protobuf:"bytes,6,opt,name=pprof,proto3,oneof"`
}

func (*QueryResponse_Pprof) MarshalToSizedBufferVT added in v0.5.0 

func (m *QueryResponse_Pprof) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryResponse_Pprof) MarshalToVT added in v0.5.0 

func (m *QueryResponse_Pprof) MarshalToVT(dAtA []byte) (int, error)

func (*QueryResponse_Pprof) SizeVT added in v0.5.0 

func (m *QueryResponse_Pprof) SizeVT() (n int)

type QueryResponse_Top added in v0.8.0 

type QueryResponse_Top struct {
	// top is a top list representation of the report
	Top *Top `protobuf:"bytes,7,opt,name=top,proto3,oneof"`
}

func (*QueryResponse_Top) MarshalToSizedBufferVT added in v0.8.0 

func (m *QueryResponse_Top) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryResponse_Top) MarshalToVT added in v0.8.0 

func (m *QueryResponse_Top) MarshalToVT(dAtA []byte) (int, error)

func (*QueryResponse_Top) SizeVT added in v0.8.0 

func (m *QueryResponse_Top) SizeVT() (n int)

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)
	// contains filtered or unexported methods
}

QueryServiceServer is the server API for QueryService service. All implementations must 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) MarshalToSizedBufferVT added in v0.5.0 

func (m *SeriesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SeriesRequest) MarshalToVT added in v0.5.0 

func (m *SeriesRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SeriesRequest) MarshalVT added in v0.5.0 

func (m *SeriesRequest) MarshalVT() (dAtA []byte, err error)

func (*SeriesRequest) ProtoMessage 

func (*SeriesRequest) ProtoMessage()

func (*SeriesRequest) ProtoReflect 

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

func (*SeriesRequest) Reset 

func (x *SeriesRequest) Reset()

func (*SeriesRequest) SizeVT added in v0.5.0 

func (m *SeriesRequest) SizeVT() (n int)

func (*SeriesRequest) String 

func (x *SeriesRequest) String() string

func (*SeriesRequest) UnmarshalVT added in v0.5.0 

func (m *SeriesRequest) UnmarshalVT(dAtA []byte) error

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) MarshalToSizedBufferVT added in v0.5.0 

func (m *SeriesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SeriesResponse) MarshalToVT added in v0.5.0 

func (m *SeriesResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SeriesResponse) MarshalVT added in v0.5.0 

func (m *SeriesResponse) MarshalVT() (dAtA []byte, err error)

func (*SeriesResponse) ProtoMessage 

func (*SeriesResponse) ProtoMessage()

func (*SeriesResponse) ProtoReflect 

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

func (*SeriesResponse) Reset 

func (x *SeriesResponse) Reset()

func (*SeriesResponse) SizeVT added in v0.5.0 

func (m *SeriesResponse) SizeVT() (n int)

func (*SeriesResponse) String 

func (x *SeriesResponse) String() string

func (*SeriesResponse) UnmarshalVT added in v0.5.0 

func (m *SeriesResponse) UnmarshalVT(dAtA []byte) error

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) MarshalToSizedBufferVT added in v0.5.0 

func (m *SingleProfile) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SingleProfile) MarshalToVT added in v0.5.0 

func (m *SingleProfile) MarshalToVT(dAtA []byte) (int, error)

func (*SingleProfile) MarshalVT added in v0.5.0 

func (m *SingleProfile) MarshalVT() (dAtA []byte, err error)

func (*SingleProfile) ProtoMessage 

func (*SingleProfile) ProtoMessage()

func (*SingleProfile) ProtoReflect 

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

func (*SingleProfile) Reset 

func (x *SingleProfile) Reset()

func (*SingleProfile) SizeVT added in v0.5.0 

func (m *SingleProfile) SizeVT() (n int)

func (*SingleProfile) String 

func (x *SingleProfile) String() string

func (*SingleProfile) UnmarshalVT added in v0.5.0 

func (m *SingleProfile) UnmarshalVT(dAtA []byte) error

type Top added in v0.8.0 

type Top struct {

	// list are the list of ordered elements of the table
	List []*TopNode `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	// reported is the number of lines reported
	Reported int32 `protobuf:"varint,2,opt,name=reported,proto3" json:"reported,omitempty"`
	// total is the number of lines that exist in the report
	Total int32 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	// unit is the unit represented by top table
	Unit string `protobuf:"bytes,4,opt,name=unit,proto3" json:"unit,omitempty"`
	// contains filtered or unexported fields
}

Top is the top report type

func (*Top) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use Top.ProtoReflect.Descriptor instead.

func (*Top) GetList added in v0.8.0 

func (x *Top) GetList() []*TopNode

func (*Top) GetReported added in v0.8.0 

func (x *Top) GetReported() int32

func (*Top) GetTotal added in v0.8.0 

func (x *Top) GetTotal() int32

func (*Top) GetUnit added in v0.8.0 

func (x *Top) GetUnit() string

func (*Top) MarshalToSizedBufferVT added in v0.8.0 

func (m *Top) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Top) MarshalToVT added in v0.8.0 

func (m *Top) MarshalToVT(dAtA []byte) (int, error)

func (*Top) MarshalVT added in v0.8.0 

func (m *Top) MarshalVT() (dAtA []byte, err error)

func (*Top) ProtoMessage added in v0.8.0 

func (*Top) ProtoMessage()

func (*Top) ProtoReflect added in v0.8.0 

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

func (*Top) Reset added in v0.8.0 

func (x *Top) Reset()

func (*Top) SizeVT added in v0.8.0 

func (m *Top) SizeVT() (n int)

func (*Top) String added in v0.8.0 

func (x *Top) String() string

func (*Top) UnmarshalVT added in v0.8.0 

func (m *Top) UnmarshalVT(dAtA []byte) error

type TopNode added in v0.8.0 

type TopNode struct {

	// meta is the metadata about the node
	Meta *TopNodeMeta `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"`
	// flat is the flat value of the node
	Flat int64 `protobuf:"varint,3,opt,name=flat,proto3" json:"flat,omitempty"`
	// contains filtered or unexported fields
}

TopNode is a node entry in a top list

func (*TopNode) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use TopNode.ProtoReflect.Descriptor instead.

func (*TopNode) GetCumulative added in v0.8.0 

func (x *TopNode) GetCumulative() int64

func (*TopNode) GetFlat added in v0.8.0 

func (x *TopNode) GetFlat() int64

func (*TopNode) GetMeta added in v0.8.0 

func (x *TopNode) GetMeta() *TopNodeMeta

func (*TopNode) MarshalToSizedBufferVT added in v0.8.0 

func (m *TopNode) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TopNode) MarshalToVT added in v0.8.0 

func (m *TopNode) MarshalToVT(dAtA []byte) (int, error)

func (*TopNode) MarshalVT added in v0.8.0 

func (m *TopNode) MarshalVT() (dAtA []byte, err error)

func (*TopNode) ProtoMessage added in v0.8.0 

func (*TopNode) ProtoMessage()

func (*TopNode) ProtoReflect added in v0.8.0 

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

func (*TopNode) Reset added in v0.8.0 

func (x *TopNode) Reset()

func (*TopNode) SizeVT added in v0.8.0 

func (m *TopNode) SizeVT() (n int)

func (*TopNode) String added in v0.8.0 

func (x *TopNode) String() string

func (*TopNode) UnmarshalVT added in v0.8.0 

func (m *TopNode) UnmarshalVT(dAtA []byte) error

type TopNodeMeta added in v0.8.0 

type TopNodeMeta struct {

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

TopNodeMeta is the metadata for a given node

func (*TopNodeMeta) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use TopNodeMeta.ProtoReflect.Descriptor instead.

func (*TopNodeMeta) GetFunction added in v0.8.0 

func (x *TopNodeMeta) GetFunction() *v1alpha11.Function

func (*TopNodeMeta) GetLine added in v0.8.0 

func (x *TopNodeMeta) GetLine() *v1alpha11.Line

func (*TopNodeMeta) GetLocation added in v0.8.0 

func (x *TopNodeMeta) GetLocation() *v1alpha11.Location

func (*TopNodeMeta) GetMapping added in v0.8.0 

func (x *TopNodeMeta) GetMapping() *v1alpha11.Mapping

func (*TopNodeMeta) MarshalToSizedBufferVT added in v0.8.0 

func (m *TopNodeMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TopNodeMeta) MarshalToVT added in v0.8.0 

func (m *TopNodeMeta) MarshalToVT(dAtA []byte) (int, error)

func (*TopNodeMeta) MarshalVT added in v0.8.0 

func (m *TopNodeMeta) MarshalVT() (dAtA []byte, err error)

func (*TopNodeMeta) ProtoMessage added in v0.8.0 

func (*TopNodeMeta) ProtoMessage()

func (*TopNodeMeta) ProtoReflect added in v0.8.0 

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

func (*TopNodeMeta) Reset added in v0.8.0 

func (x *TopNodeMeta) Reset()

func (*TopNodeMeta) SizeVT added in v0.8.0 

func (m *TopNodeMeta) SizeVT() (n int)

func (*TopNodeMeta) String added in v0.8.0 

func (x *TopNodeMeta) String() string

func (*TopNodeMeta) UnmarshalVT added in v0.8.0 

func (m *TopNodeMeta) UnmarshalVT(dAtA []byte) error

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer must 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 ValueType added in v0.4.0 

type ValueType struct {

	// type is the type of the value
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// unit is the unit of the value
	Unit string `protobuf:"bytes,2,opt,name=unit,proto3" json:"unit,omitempty"`
	// contains filtered or unexported fields
}

ValueType represents a value, including its type and unit

func (*ValueType) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use ValueType.ProtoReflect.Descriptor instead.

func (*ValueType) GetType added in v0.4.0 

func (x *ValueType) GetType() string

func (*ValueType) GetUnit added in v0.4.0 

func (x *ValueType) GetUnit() string

func (*ValueType) MarshalToSizedBufferVT added in v0.5.0 

func (m *ValueType) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValueType) MarshalToVT added in v0.5.0 

func (m *ValueType) MarshalToVT(dAtA []byte) (int, error)

func (*ValueType) MarshalVT added in v0.5.0 

func (m *ValueType) MarshalVT() (dAtA []byte, err error)

func (*ValueType) ProtoMessage added in v0.4.0 

func (*ValueType) ProtoMessage()

func (*ValueType) ProtoReflect added in v0.4.0 

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

func (*ValueType) Reset added in v0.4.0 

func (x *ValueType) Reset()

func (*ValueType) SizeVT added in v0.5.0 

func (m *ValueType) SizeVT() (n int)

func (*ValueType) String added in v0.4.0 

func (x *ValueType) String() string

func (*ValueType) UnmarshalVT added in v0.5.0 

func (m *ValueType) UnmarshalVT(dAtA []byte) error

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) MarshalToSizedBufferVT added in v0.5.0 

func (m *ValuesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValuesRequest) MarshalToVT added in v0.5.0 

func (m *ValuesRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ValuesRequest) MarshalVT added in v0.5.0 

func (m *ValuesRequest) MarshalVT() (dAtA []byte, err error)

func (*ValuesRequest) ProtoMessage 

func (*ValuesRequest) ProtoMessage()

func (*ValuesRequest) ProtoReflect 

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

func (*ValuesRequest) Reset 

func (x *ValuesRequest) Reset()

func (*ValuesRequest) SizeVT added in v0.5.0 

func (m *ValuesRequest) SizeVT() (n int)

func (*ValuesRequest) String 

func (x *ValuesRequest) String() string

func (*ValuesRequest) UnmarshalVT added in v0.5.0 

func (m *ValuesRequest) UnmarshalVT(dAtA []byte) error

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) MarshalToSizedBufferVT added in v0.5.0 

func (m *ValuesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValuesResponse) MarshalToVT added in v0.5.0 

func (m *ValuesResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ValuesResponse) MarshalVT added in v0.5.0 

func (m *ValuesResponse) MarshalVT() (dAtA []byte, err error)

func (*ValuesResponse) ProtoMessage 

func (*ValuesResponse) ProtoMessage()

func (*ValuesResponse) ProtoReflect 

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

func (*ValuesResponse) Reset 

func (x *ValuesResponse) Reset()

func (*ValuesResponse) SizeVT added in v0.5.0 

func (m *ValuesResponse) SizeVT() (n int)

func (*ValuesResponse) String 

func (x *ValuesResponse) String() string

func (*ValuesResponse) UnmarshalVT added in v0.5.0 

func (m *ValuesResponse) UnmarshalVT(dAtA []byte) 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.