profilestorev1alpha1

package
v0.18.0 Latest Latest
Warning

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

 Go to latest Published: Jun 14, 2023 License: Apache-2.0 Imports: 20 Imported by: 3

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 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 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.

func NewProfileStoreServiceClient 

func NewProfileStoreServiceClient(cc grpc.ClientConnInterface) ProfileStoreServiceClient

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"`
	// 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) 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 

func (UnimplementedAgentsServiceServer) Agents(context.Context, *AgentsRequest) (*AgentsResponse, error)

type UnimplementedProfileStoreServiceServer 

type UnimplementedProfileStoreServiceServer struct {
}

UnimplementedProfileStoreServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProfileStoreServiceServer) WriteRaw 

func (UnimplementedProfileStoreServiceServer) WriteRaw(context.Context, *WriteRawRequest) (*WriteRawResponse, error)

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

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.