debuginfov1alpha1

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Mar 25, 2022 License: Apache-2.0 Imports: 17 Imported by: 1

Documentation

Overview

Package debuginfov1alpha1 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 DebugInfoService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "parca.debuginfo.v1alpha1.DebugInfoService",
	HandlerType: (*DebugInfoServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Exists",
			Handler:    _DebugInfoService_Exists_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Upload",
			Handler:       _DebugInfoService_Upload_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "parca/debuginfo/v1alpha1/debuginfo.proto",
}

DebugInfoService_ServiceDesc is the grpc.ServiceDesc for DebugInfoService 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_debuginfo_v1alpha1_debuginfo_proto protoreflect.FileDescriptor

Functions

func RegisterDebugInfoServiceHandler 

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

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

func RegisterDebugInfoServiceHandlerClient 

func RegisterDebugInfoServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DebugInfoServiceClient) error

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

func RegisterDebugInfoServiceHandlerFromEndpoint 

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

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

func RegisterDebugInfoServiceHandlerServer 

func RegisterDebugInfoServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DebugInfoServiceServer) error

RegisterDebugInfoServiceHandlerServer registers the http handlers for service DebugInfoService to "mux". UnaryRPC :call DebugInfoServiceServer 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 RegisterDebugInfoServiceHandlerFromEndpoint instead.

func RegisterDebugInfoServiceServer 

func RegisterDebugInfoServiceServer(s grpc.ServiceRegistrar, srv DebugInfoServiceServer)

Types

type DebugInfoServiceClient 

type DebugInfoServiceClient interface {
	// Exists returns true if the given build_id has debug info uploaded for it.
	Exists(ctx context.Context, in *ExistsRequest, opts ...grpc.CallOption) (*ExistsResponse, error)
	// Upload ingests debug info for a given build_id
	Upload(ctx context.Context, opts ...grpc.CallOption) (DebugInfoService_UploadClient, error)
}

DebugInfoServiceClient is the client API for DebugInfoService 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 NewDebugInfoServiceClient 

func NewDebugInfoServiceClient(cc grpc.ClientConnInterface) DebugInfoServiceClient

type DebugInfoServiceServer 

type DebugInfoServiceServer interface {
	// Exists returns true if the given build_id has debug info uploaded for it.
	Exists(context.Context, *ExistsRequest) (*ExistsResponse, error)
	// Upload ingests debug info for a given build_id
	Upload(DebugInfoService_UploadServer) error
	// contains filtered or unexported methods
}

DebugInfoServiceServer is the server API for DebugInfoService service. All implementations must embed UnimplementedDebugInfoServiceServer for forward compatibility

type DebugInfoService_UploadClient 

type DebugInfoService_UploadClient interface {
	Send(*UploadRequest) error
	CloseAndRecv() (*UploadResponse, error)
	grpc.ClientStream
}

type DebugInfoService_UploadServer 

type DebugInfoService_UploadServer interface {
	SendAndClose(*UploadResponse) error
	Recv() (*UploadRequest, error)
	grpc.ServerStream
}

type ExistsRequest 

type ExistsRequest struct {

	// build_id is a unique identifier for the debug data
	BuildId string `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// hash is the hash of the debug information file
	Hash string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

ExistsRequest request to determine if debug info exists for a given build_id

func (*ExistsRequest) Descriptor deprecated 

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

Deprecated: Use ExistsRequest.ProtoReflect.Descriptor instead.

func (*ExistsRequest) GetBuildId 

func (x *ExistsRequest) GetBuildId() string

func (*ExistsRequest) GetHash added in v0.9.0 

func (x *ExistsRequest) GetHash() string

func (*ExistsRequest) MarshalToSizedBufferVT added in v0.5.0 

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

func (*ExistsRequest) MarshalToVT added in v0.5.0 

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

func (*ExistsRequest) MarshalVT added in v0.5.0 

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

func (*ExistsRequest) ProtoMessage 

func (*ExistsRequest) ProtoMessage()

func (*ExistsRequest) ProtoReflect 

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

func (*ExistsRequest) Reset 

func (x *ExistsRequest) Reset()

func (*ExistsRequest) SizeVT added in v0.5.0 

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

func (*ExistsRequest) String 

func (x *ExistsRequest) String() string

func (*ExistsRequest) UnmarshalVT added in v0.5.0 

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

type ExistsResponse 

type ExistsResponse struct {

	// exists indicates if there is debug data present for the given build_id
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

ExistsResponse returns whether the given build_id has debug info

func (*ExistsResponse) Descriptor deprecated 

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

Deprecated: Use ExistsResponse.ProtoReflect.Descriptor instead.

func (*ExistsResponse) GetExists 

func (x *ExistsResponse) GetExists() bool

func (*ExistsResponse) MarshalToSizedBufferVT added in v0.5.0 

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

func (*ExistsResponse) MarshalToVT added in v0.5.0 

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

func (*ExistsResponse) MarshalVT added in v0.5.0 

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

func (*ExistsResponse) ProtoMessage 

func (*ExistsResponse) ProtoMessage()

func (*ExistsResponse) ProtoReflect 

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

func (*ExistsResponse) Reset 

func (x *ExistsResponse) Reset()

func (*ExistsResponse) SizeVT added in v0.5.0 

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

func (*ExistsResponse) String 

func (x *ExistsResponse) String() string

func (*ExistsResponse) UnmarshalVT added in v0.5.0 

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

type UnimplementedDebugInfoServiceServer 

type UnimplementedDebugInfoServiceServer struct {
}

UnimplementedDebugInfoServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDebugInfoServiceServer) Exists 

func (UnimplementedDebugInfoServiceServer) Exists(context.Context, *ExistsRequest) (*ExistsResponse, error)

func (UnimplementedDebugInfoServiceServer) Upload 

func (UnimplementedDebugInfoServiceServer) Upload(DebugInfoService_UploadServer) error

type UnsafeDebugInfoServiceServer 

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

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

type UploadInfo 

type UploadInfo struct {

	// build_id is a unique identifier for the debug data
	BuildId string `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// hash is the hash of the debug information file
	Hash string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

UploadInfo contains the build_id and other metadata for the debug data

func (*UploadInfo) Descriptor deprecated 

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

Deprecated: Use UploadInfo.ProtoReflect.Descriptor instead.

func (*UploadInfo) GetBuildId 

func (x *UploadInfo) GetBuildId() string

func (*UploadInfo) GetHash added in v0.9.0 

func (x *UploadInfo) GetHash() string

func (*UploadInfo) MarshalToSizedBufferVT added in v0.5.0 

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

func (*UploadInfo) MarshalToVT added in v0.5.0 

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

func (*UploadInfo) MarshalVT added in v0.5.0 

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

func (*UploadInfo) ProtoMessage 

func (*UploadInfo) ProtoMessage()

func (*UploadInfo) ProtoReflect 

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

func (*UploadInfo) Reset 

func (x *UploadInfo) Reset()

func (*UploadInfo) SizeVT added in v0.5.0 

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

func (*UploadInfo) String 

func (x *UploadInfo) String() string

func (*UploadInfo) UnmarshalVT added in v0.5.0 

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

type UploadRequest 

type UploadRequest struct {

	// data contains either the upload info metadata or the debug info
	//
	// Types that are assignable to Data:
	//	*UploadRequest_Info
	//	*UploadRequest_ChunkData
	Data isUploadRequest_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

UploadRequest upload debug info

func (*UploadRequest) Descriptor deprecated 

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

Deprecated: Use UploadRequest.ProtoReflect.Descriptor instead.

func (*UploadRequest) GetChunkData 

func (x *UploadRequest) GetChunkData() []byte

func (*UploadRequest) GetData 

func (m *UploadRequest) GetData() isUploadRequest_Data

func (*UploadRequest) GetInfo 

func (x *UploadRequest) GetInfo() *UploadInfo

func (*UploadRequest) MarshalToSizedBufferVT added in v0.5.0 

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

func (*UploadRequest) MarshalToVT added in v0.5.0 

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

func (*UploadRequest) MarshalVT added in v0.5.0 

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

func (*UploadRequest) ProtoMessage 

func (*UploadRequest) ProtoMessage()

func (*UploadRequest) ProtoReflect 

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

func (*UploadRequest) Reset 

func (x *UploadRequest) Reset()

func (*UploadRequest) SizeVT added in v0.5.0 

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

func (*UploadRequest) String 

func (x *UploadRequest) String() string

func (*UploadRequest) UnmarshalVT added in v0.5.0 

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

type UploadRequest_ChunkData 

type UploadRequest_ChunkData struct {
	// chunk_data is the raw bytes of the debug info
	ChunkData []byte `protobuf:"bytes,2,opt,name=chunk_data,json=chunkData,proto3,oneof"`
}

func (*UploadRequest_ChunkData) MarshalToSizedBufferVT added in v0.5.0 

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

func (*UploadRequest_ChunkData) MarshalToVT added in v0.5.0 

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

func (*UploadRequest_ChunkData) SizeVT added in v0.5.0 

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

type UploadRequest_Info 

type UploadRequest_Info struct {
	// info is the metadata for the debug info
	Info *UploadInfo `protobuf:"bytes,1,opt,name=info,proto3,oneof"`
}

func (*UploadRequest_Info) MarshalToSizedBufferVT added in v0.5.0 

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

func (*UploadRequest_Info) MarshalToVT added in v0.5.0 

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

func (*UploadRequest_Info) SizeVT added in v0.5.0 

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

type UploadResponse 

type UploadResponse struct {

	// build_id is a unique identifier for the debug data
	BuildId string `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// size is the number of bytes of the debug info
	Size uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

UploadResponse returns the build_id and the size of the uploaded debug info

func (*UploadResponse) Descriptor deprecated 

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

Deprecated: Use UploadResponse.ProtoReflect.Descriptor instead.

func (*UploadResponse) GetBuildId 

func (x *UploadResponse) GetBuildId() string

func (*UploadResponse) GetSize 

func (x *UploadResponse) GetSize() uint64

func (*UploadResponse) MarshalToSizedBufferVT added in v0.5.0 

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

func (*UploadResponse) MarshalToVT added in v0.5.0 

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

func (*UploadResponse) MarshalVT added in v0.5.0 

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

func (*UploadResponse) ProtoMessage 

func (*UploadResponse) ProtoMessage()

func (*UploadResponse) ProtoReflect 

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

func (*UploadResponse) Reset 

func (x *UploadResponse) Reset()

func (*UploadResponse) SizeVT added in v0.5.0 

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

func (*UploadResponse) String 

func (x *UploadResponse) String() string

func (*UploadResponse) UnmarshalVT added in v0.5.0 

func (m *UploadResponse) 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.