profilestorev1alpha1

package
v0.21.0 Latest Latest
Warning

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

Go to latest
Published: Feb 27, 2024 License: Apache-2.0 Imports: 20 Imported by: 10

Documentation

Overview

Package profilestorev1alpha1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

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 AgentsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "parca.profilestore.v1alpha1.AgentsService",
	HandlerType: (*AgentsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Agents",
			Handler:    _AgentsService_Agents_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "parca/profilestore/v1alpha1/profilestore.proto",
}

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

View Source
var File_parca_profilestore_v1alpha1_profilestore_proto protoreflect.FileDescriptor
View Source
var ProfileStoreService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "parca.profilestore.v1alpha1.ProfileStoreService",
	HandlerType: (*ProfileStoreServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "WriteRaw",
			Handler:    _ProfileStoreService_WriteRaw_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "parca/profilestore/v1alpha1/profilestore.proto",
}

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

Functions

func RegisterAgentsServiceHandler added in v0.13.0

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

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

func RegisterAgentsServiceHandlerClient added in v0.13.0

func RegisterAgentsServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AgentsServiceClient) error

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

func RegisterAgentsServiceHandlerFromEndpoint added in v0.13.0

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

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

func RegisterAgentsServiceHandlerServer added in v0.13.0

func RegisterAgentsServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AgentsServiceServer) error

RegisterAgentsServiceHandlerServer registers the http handlers for service AgentsService to "mux". UnaryRPC :call AgentsServiceServer 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 RegisterAgentsServiceHandlerFromEndpoint instead.

func RegisterAgentsServiceServer added in v0.13.0

func RegisterAgentsServiceServer(s grpc.ServiceRegistrar, srv AgentsServiceServer)

func RegisterProfileStoreServiceHandler

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

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

func RegisterProfileStoreServiceHandlerClient

func RegisterProfileStoreServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ProfileStoreServiceClient) error

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

func RegisterProfileStoreServiceHandlerFromEndpoint

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

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

func RegisterProfileStoreServiceHandlerServer

func RegisterProfileStoreServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ProfileStoreServiceServer) error

RegisterProfileStoreServiceHandlerServer registers the http handlers for service ProfileStoreService to "mux". UnaryRPC :call ProfileStoreServiceServer 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 RegisterProfileStoreServiceHandlerFromEndpoint instead.

func RegisterProfileStoreServiceServer

func RegisterProfileStoreServiceServer(s grpc.ServiceRegistrar, srv ProfileStoreServiceServer)

Types

type Agent added in v0.13.0

type Agent struct {

	// id is the agent identity that either represent by the node name or the IP address.
	// When node name is not found, this will fallback to IP address.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// last_error is the error message most recently received from a push attempt
	LastError string `protobuf:"bytes,2,opt,name=last_error,json=lastError,proto3" json:"last_error,omitempty"`
	// last_push is the time stamp the last push request was performed
	LastPush *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_push,json=lastPush,proto3" json:"last_push,omitempty"`
	// last_push_duration is the duration of the last push request
	LastPushDuration *durationpb.Duration `protobuf:"bytes,4,opt,name=last_push_duration,json=lastPushDuration,proto3" json:"last_push_duration,omitempty"`
	// contains filtered or unexported fields
}

Agent is the agent representation

func (*Agent) Descriptor deprecated added in v0.13.0

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

Deprecated: Use Agent.ProtoReflect.Descriptor instead.

func (*Agent) GetId added in v0.13.0

func (x *Agent) GetId() string

func (*Agent) GetLastError added in v0.13.0

func (x *Agent) GetLastError() string

func (*Agent) GetLastPush added in v0.13.0

func (x *Agent) GetLastPush() *timestamppb.Timestamp

func (*Agent) GetLastPushDuration added in v0.13.0

func (x *Agent) GetLastPushDuration() *durationpb.Duration

func (*Agent) MarshalToSizedBufferVT added in v0.13.0

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

func (*Agent) MarshalToVT added in v0.13.0

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

func (*Agent) MarshalVT added in v0.13.0

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

func (*Agent) ProtoMessage added in v0.13.0

func (*Agent) ProtoMessage()

func (*Agent) ProtoReflect added in v0.13.0

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

func (*Agent) Reset added in v0.13.0

func (x *Agent) Reset()

func (*Agent) SizeVT added in v0.13.0

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

func (*Agent) String added in v0.13.0

func (x *Agent) String() string

func (*Agent) UnmarshalVT added in v0.13.0

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

type AgentsRequest added in v0.13.0

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

AgentsRequest is the request to retrieve a list of agents

func (*AgentsRequest) Descriptor deprecated added in v0.13.0

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

Deprecated: Use AgentsRequest.ProtoReflect.Descriptor instead.

func (*AgentsRequest) MarshalToSizedBufferVT added in v0.13.0

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

func (*AgentsRequest) MarshalToVT added in v0.13.0

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

func (*AgentsRequest) MarshalVT added in v0.13.0

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

func (*AgentsRequest) ProtoMessage added in v0.13.0

func (*AgentsRequest) ProtoMessage()

func (*AgentsRequest) ProtoReflect added in v0.13.0

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

func (*AgentsRequest) Reset added in v0.13.0

func (x *AgentsRequest) Reset()

func (*AgentsRequest) SizeVT added in v0.13.0

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

func (*AgentsRequest) String added in v0.13.0

func (x *AgentsRequest) String() string

func (*AgentsRequest) UnmarshalVT added in v0.13.0

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

type AgentsResponse added in v0.13.0

type AgentsResponse struct {

	// agents is a list of agents
	Agents []*Agent `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
	// contains filtered or unexported fields
}

AgentsResponse is the request to retrieve a list of agents

func (*AgentsResponse) Descriptor deprecated added in v0.13.0

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

Deprecated: Use AgentsResponse.ProtoReflect.Descriptor instead.

func (*AgentsResponse) GetAgents added in v0.13.0

func (x *AgentsResponse) GetAgents() []*Agent

func (*AgentsResponse) MarshalToSizedBufferVT added in v0.13.0

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

func (*AgentsResponse) MarshalToVT added in v0.13.0

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

func (*AgentsResponse) MarshalVT added in v0.13.0

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

func (*AgentsResponse) ProtoMessage added in v0.13.0

func (*AgentsResponse) ProtoMessage()

func (*AgentsResponse) ProtoReflect added in v0.13.0

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

func (*AgentsResponse) Reset added in v0.13.0

func (x *AgentsResponse) Reset()

func (*AgentsResponse) SizeVT added in v0.13.0

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

func (*AgentsResponse) String added in v0.13.0

func (x *AgentsResponse) String() string

func (*AgentsResponse) UnmarshalVT added in v0.13.0

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

type AgentsServiceClient added in v0.13.0

type AgentsServiceClient interface {
	// Agents return the agents that pushed data to the server
	Agents(ctx context.Context, in *AgentsRequest, opts ...grpc.CallOption) (*AgentsResponse, error)
}

AgentsServiceClient is the client API for AgentsService 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 NewAgentsServiceClient added in v0.13.0

func NewAgentsServiceClient(cc grpc.ClientConnInterface) AgentsServiceClient

type AgentsServiceServer added in v0.13.0

type AgentsServiceServer interface {
	// Agents return the agents that pushed data to the server
	Agents(context.Context, *AgentsRequest) (*AgentsResponse, error)
	// contains filtered or unexported methods
}

AgentsServiceServer is the server API for AgentsService service. All implementations must embed UnimplementedAgentsServiceServer for forward compatibility

type ExecutableInfo added in v0.19.0

type ExecutableInfo struct {

	// elf_type is the type of the elf executable. Technically the elf type is a
	// 16 bit integer, but protobuf's smallest unsigned integer is 32 bits.
	ElfType uint32 `protobuf:"varint,1,opt,name=elf_type,json=elfType,proto3" json:"elf_type,omitempty"`
	// load_segment is the load segment of the executable.
	LoadSegment *LoadSegment `protobuf:"bytes,2,opt,name=load_segment,json=loadSegment,proto3" json:"load_segment,omitempty"`
	// contains filtered or unexported fields
}

ExecutableInfo is the information about the executable and executable section for normalizaton purposes before symbolization.

func (*ExecutableInfo) Descriptor deprecated added in v0.19.0

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

Deprecated: Use ExecutableInfo.ProtoReflect.Descriptor instead.

func (*ExecutableInfo) GetElfType added in v0.19.0

func (x *ExecutableInfo) GetElfType() uint32

func (*ExecutableInfo) GetLoadSegment added in v0.19.0

func (x *ExecutableInfo) GetLoadSegment() *LoadSegment

func (*ExecutableInfo) MarshalToSizedBufferVT added in v0.19.0

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

func (*ExecutableInfo) MarshalToVT added in v0.19.0

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

func (*ExecutableInfo) MarshalVT added in v0.19.0

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

func (*ExecutableInfo) ProtoMessage added in v0.19.0

func (*ExecutableInfo) ProtoMessage()

func (*ExecutableInfo) ProtoReflect added in v0.19.0

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

func (*ExecutableInfo) Reset added in v0.19.0

func (x *ExecutableInfo) Reset()

func (*ExecutableInfo) SizeVT added in v0.19.0

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

func (*ExecutableInfo) String added in v0.19.0

func (x *ExecutableInfo) String() string

func (*ExecutableInfo) UnmarshalVT added in v0.19.0

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

type Label

type Label struct {

	// name is the label name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// value is the value for the label name
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Label is a key value pair of identifiers

func (*Label) Descriptor deprecated

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

Deprecated: Use Label.ProtoReflect.Descriptor instead.

func (*Label) GetName

func (x *Label) GetName() string

func (*Label) GetValue

func (x *Label) GetValue() string

func (*Label) MarshalToSizedBufferVT added in v0.5.0

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

func (*Label) MarshalToVT added in v0.5.0

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

func (*Label) MarshalVT added in v0.5.0

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

func (*Label) ProtoMessage

func (*Label) ProtoMessage()

func (*Label) ProtoReflect

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

func (*Label) Reset

func (x *Label) Reset()

func (*Label) SizeVT added in v0.5.0

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

func (*Label) String

func (x *Label) String() string

func (*Label) UnmarshalVT added in v0.5.0

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

type LabelSet

type LabelSet struct {

	// labels are the grouping of labels
	Labels []*Label `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

LabelSet is a group of labels

func (*LabelSet) Descriptor deprecated

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

Deprecated: Use LabelSet.ProtoReflect.Descriptor instead.

func (*LabelSet) GetLabels

func (x *LabelSet) GetLabels() []*Label

func (*LabelSet) MarshalToSizedBufferVT added in v0.5.0

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

func (*LabelSet) MarshalToVT added in v0.5.0

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

func (*LabelSet) MarshalVT added in v0.5.0

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

func (*LabelSet) ProtoMessage

func (*LabelSet) ProtoMessage()

func (*LabelSet) ProtoReflect

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

func (*LabelSet) Reset

func (x *LabelSet) Reset()

func (*LabelSet) SizeVT added in v0.5.0

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

func (*LabelSet) String

func (x *LabelSet) String() string

func (*LabelSet) UnmarshalVT added in v0.5.0

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

type LoadSegment added in v0.19.0

type LoadSegment struct {

	// The offset from the beginning of the file at which the first byte of the segment resides.
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// The virtual address at which the first byte of the segment resides in memory.
	Vaddr uint64 `protobuf:"varint,2,opt,name=vaddr,proto3" json:"vaddr,omitempty"`
	// contains filtered or unexported fields
}

LoadSegment is the load segment of the executable

func (*LoadSegment) Descriptor deprecated added in v0.19.0

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

Deprecated: Use LoadSegment.ProtoReflect.Descriptor instead.

func (*LoadSegment) GetOffset added in v0.19.0

func (x *LoadSegment) GetOffset() uint64

func (*LoadSegment) GetVaddr added in v0.19.0

func (x *LoadSegment) GetVaddr() uint64

func (*LoadSegment) MarshalToSizedBufferVT added in v0.19.0

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

func (*LoadSegment) MarshalToVT added in v0.19.0

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

func (*LoadSegment) MarshalVT added in v0.19.0

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

func (*LoadSegment) ProtoMessage added in v0.19.0

func (*LoadSegment) ProtoMessage()

func (*LoadSegment) ProtoReflect added in v0.19.0

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

func (*LoadSegment) Reset added in v0.19.0

func (x *LoadSegment) Reset()

func (*LoadSegment) SizeVT added in v0.19.0

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

func (*LoadSegment) String added in v0.19.0

func (x *LoadSegment) String() string

func (*LoadSegment) UnmarshalVT added in v0.19.0

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

type ProfileStoreServiceClient

type ProfileStoreServiceClient interface {
	// WriteRaw accepts a raw set of bytes of a pprof file
	WriteRaw(ctx context.Context, in *WriteRawRequest, opts ...grpc.CallOption) (*WriteRawResponse, error)
}

ProfileStoreServiceClient is the client API for ProfileStoreService 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.

type ProfileStoreServiceServer

type ProfileStoreServiceServer interface {
	// WriteRaw accepts a raw set of bytes of a pprof file
	WriteRaw(context.Context, *WriteRawRequest) (*WriteRawResponse, error)
	// contains filtered or unexported methods
}

ProfileStoreServiceServer is the server API for ProfileStoreService service. All implementations must embed UnimplementedProfileStoreServiceServer for forward compatibility

type RawProfileSeries

type RawProfileSeries struct {

	// LabelSet is the key value pairs to identify the corresponding profile
	Labels *LabelSet `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels,omitempty"`
	// samples are the set of profile bytes
	Samples []*RawSample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples,omitempty"`
	// contains filtered or unexported fields
}

RawProfileSeries represents the pprof profile and its associated labels

func (*RawProfileSeries) Descriptor deprecated

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

Deprecated: Use RawProfileSeries.ProtoReflect.Descriptor instead.

func (*RawProfileSeries) GetLabels

func (x *RawProfileSeries) GetLabels() *LabelSet

func (*RawProfileSeries) GetSamples

func (x *RawProfileSeries) GetSamples() []*RawSample

func (*RawProfileSeries) MarshalToSizedBufferVT added in v0.5.0

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

func (*RawProfileSeries) MarshalToVT added in v0.5.0

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

func (*RawProfileSeries) MarshalVT added in v0.5.0

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

func (*RawProfileSeries) ProtoMessage

func (*RawProfileSeries) ProtoMessage()

func (*RawProfileSeries) ProtoReflect

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

func (*RawProfileSeries) Reset

func (x *RawProfileSeries) Reset()

func (*RawProfileSeries) SizeVT added in v0.5.0

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

func (*RawProfileSeries) String

func (x *RawProfileSeries) String() string

func (*RawProfileSeries) UnmarshalVT added in v0.5.0

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

type RawSample

type RawSample struct {

	// raw_profile is the set of bytes of the pprof profile
	RawProfile []byte `protobuf:"bytes,1,opt,name=raw_profile,json=rawProfile,proto3" json:"raw_profile,omitempty"`
	// information about the executable and executable section for normalizaton
	// purposes.
	ExecutableInfo []*ExecutableInfo `protobuf:"bytes,2,rep,name=executable_info,json=executableInfo,proto3" json:"executable_info,omitempty"`
	// contains filtered or unexported fields
}

RawSample is the set of bytes that correspond to a pprof profile

func (*RawSample) Descriptor deprecated

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

Deprecated: Use RawSample.ProtoReflect.Descriptor instead.

func (*RawSample) GetExecutableInfo added in v0.19.0

func (x *RawSample) GetExecutableInfo() []*ExecutableInfo

func (*RawSample) GetRawProfile

func (x *RawSample) GetRawProfile() []byte

func (*RawSample) MarshalToSizedBufferVT added in v0.5.0

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

func (*RawSample) MarshalToVT added in v0.5.0

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

func (*RawSample) MarshalVT added in v0.5.0

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

func (*RawSample) ProtoMessage

func (*RawSample) ProtoMessage()

func (*RawSample) ProtoReflect

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

func (*RawSample) Reset

func (x *RawSample) Reset()

func (*RawSample) SizeVT added in v0.5.0

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

func (*RawSample) String

func (x *RawSample) String() string

func (*RawSample) UnmarshalVT added in v0.5.0

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

type UnimplementedAgentsServiceServer added in v0.13.0

type UnimplementedAgentsServiceServer struct {
}

UnimplementedAgentsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentsServiceServer) Agents added in v0.13.0

type UnimplementedProfileStoreServiceServer

type UnimplementedProfileStoreServiceServer struct {
}

UnimplementedProfileStoreServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProfileStoreServiceServer) WriteRaw

type UnsafeAgentsServiceServer added in v0.13.0

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

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

type UnsafeProfileStoreServiceServer

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

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

type WriteRawRequest

type WriteRawRequest struct {

	// tenant is the given tenant to store the pprof profile under
	//
	// Deprecated: Marked as deprecated in parca/profilestore/v1alpha1/profilestore.proto.
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// series is a set raw pprof profiles and accompanying labels
	Series []*RawProfileSeries `protobuf:"bytes,2,rep,name=series,proto3" json:"series,omitempty"`
	// normalized is a flag indicating if the addresses in the profile is normalized for position independent code
	Normalized bool `protobuf:"varint,3,opt,name=normalized,proto3" json:"normalized,omitempty"`
	// contains filtered or unexported fields
}

WriteRawRequest writes a pprof profile for a given tenant

func (*WriteRawRequest) Descriptor deprecated

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

Deprecated: Use WriteRawRequest.ProtoReflect.Descriptor instead.

func (*WriteRawRequest) GetNormalized added in v0.9.0

func (x *WriteRawRequest) GetNormalized() bool

func (*WriteRawRequest) GetSeries

func (x *WriteRawRequest) GetSeries() []*RawProfileSeries

func (*WriteRawRequest) GetTenant deprecated

func (x *WriteRawRequest) GetTenant() string

Deprecated: Marked as deprecated in parca/profilestore/v1alpha1/profilestore.proto.

func (*WriteRawRequest) MarshalToSizedBufferVT added in v0.5.0

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

func (*WriteRawRequest) MarshalToVT added in v0.5.0

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

func (*WriteRawRequest) MarshalVT added in v0.5.0

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

func (*WriteRawRequest) ProtoMessage

func (*WriteRawRequest) ProtoMessage()

func (*WriteRawRequest) ProtoReflect

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

func (*WriteRawRequest) Reset

func (x *WriteRawRequest) Reset()

func (*WriteRawRequest) SizeVT added in v0.5.0

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

func (*WriteRawRequest) String

func (x *WriteRawRequest) String() string

func (*WriteRawRequest) UnmarshalVT added in v0.5.0

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

type WriteRawResponse

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

WriteRawResponse is the empty response

func (*WriteRawResponse) Descriptor deprecated

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

Deprecated: Use WriteRawResponse.ProtoReflect.Descriptor instead.

func (*WriteRawResponse) MarshalToSizedBufferVT added in v0.5.0

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

func (*WriteRawResponse) MarshalToVT added in v0.5.0

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

func (*WriteRawResponse) MarshalVT added in v0.5.0

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

func (*WriteRawResponse) ProtoMessage

func (*WriteRawResponse) ProtoMessage()

func (*WriteRawResponse) ProtoReflect

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

func (*WriteRawResponse) Reset

func (x *WriteRawResponse) Reset()

func (*WriteRawResponse) SizeVT added in v0.5.0

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

func (*WriteRawResponse) String

func (x *WriteRawResponse) String() string

func (*WriteRawResponse) UnmarshalVT added in v0.5.0

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

Jump to

Keyboard shortcuts

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