pushv1

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Jan 7, 2025 License: Apache-2.0 Imports: 13 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_push_v1_push_proto protoreflect.FileDescriptor
View Source 
var PusherService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "push.v1.PusherService",
	HandlerType: (*PusherServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Push",
			Handler:    _PusherService_Push_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "push/v1/push.proto",
}

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

Functions

func RegisterPusherServiceServer 

func RegisterPusherServiceServer(s grpc.ServiceRegistrar, srv PusherServiceServer)

Types

type PushRequest 

type PushRequest struct {

	// series is a set raw pprof profiles and accompanying labels
	Series []*RawProfileSeries `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"`
	// contains filtered or unexported fields
}

WriteRawRequest writes a pprof profile

func (*PushRequest) CloneMessageVT 

func (m *PushRequest) CloneMessageVT() proto.Message

func (*PushRequest) CloneVT 

func (m *PushRequest) CloneVT() *PushRequest

func (*PushRequest) Descriptor deprecated 

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

Deprecated: Use PushRequest.ProtoReflect.Descriptor instead.

func (*PushRequest) EqualMessageVT added in v0.4.0 

func (this *PushRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*PushRequest) EqualVT added in v0.4.0 

func (this *PushRequest) EqualVT(that *PushRequest) bool

func (*PushRequest) GetSeries 

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

func (*PushRequest) MarshalToSizedBufferVT 

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

func (*PushRequest) MarshalToVT 

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

func (*PushRequest) MarshalVT 

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

func (*PushRequest) ProtoMessage 

func (*PushRequest) ProtoMessage()

func (*PushRequest) ProtoReflect 

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

func (*PushRequest) Reset 

func (x *PushRequest) Reset()

func (*PushRequest) SizeVT 

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

func (*PushRequest) String 

func (x *PushRequest) String() string

func (*PushRequest) UnmarshalVT 

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

type PushResponse 

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

func (*PushResponse) CloneMessageVT 

func (m *PushResponse) CloneMessageVT() proto.Message

func (*PushResponse) CloneVT 

func (m *PushResponse) CloneVT() *PushResponse

func (*PushResponse) Descriptor deprecated 

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

Deprecated: Use PushResponse.ProtoReflect.Descriptor instead.

func (*PushResponse) EqualMessageVT added in v0.4.0 

func (this *PushResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*PushResponse) EqualVT added in v0.4.0 

func (this *PushResponse) EqualVT(that *PushResponse) bool

func (*PushResponse) MarshalToSizedBufferVT 

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

func (*PushResponse) MarshalToVT 

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

func (*PushResponse) MarshalVT 

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

func (*PushResponse) ProtoMessage 

func (*PushResponse) ProtoMessage()

func (*PushResponse) ProtoReflect 

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

func (*PushResponse) Reset 

func (x *PushResponse) Reset()

func (*PushResponse) SizeVT 

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

func (*PushResponse) String 

func (x *PushResponse) String() string

func (*PushResponse) UnmarshalVT 

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

type PusherServiceClient 

type PusherServiceClient interface {
	Push(ctx context.Context, in *PushRequest, opts ...grpc.CallOption) (*PushResponse, error)
}

PusherServiceClient is the client API for PusherService 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 NewPusherServiceClient 

func NewPusherServiceClient(cc grpc.ClientConnInterface) PusherServiceClient

type PusherServiceServer 

type PusherServiceServer interface {
	Push(context.Context, *PushRequest) (*PushResponse, error)
	// contains filtered or unexported methods
}

PusherServiceServer is the server API for PusherService service. All implementations must embed UnimplementedPusherServiceServer for forward compatibility

type RawProfileSeries 

type RawProfileSeries struct {

	// LabelPair is the key value pairs to identify the corresponding profile
	Labels []*v1.LabelPair `protobuf:"bytes,1,rep,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) CloneMessageVT 

func (m *RawProfileSeries) CloneMessageVT() proto.Message

func (*RawProfileSeries) CloneVT 

func (m *RawProfileSeries) CloneVT() *RawProfileSeries

func (*RawProfileSeries) Descriptor deprecated 

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

Deprecated: Use RawProfileSeries.ProtoReflect.Descriptor instead.

func (*RawProfileSeries) EqualMessageVT added in v0.4.0 

func (this *RawProfileSeries) EqualMessageVT(thatMsg proto.Message) bool

func (*RawProfileSeries) EqualVT added in v0.4.0 

func (this *RawProfileSeries) EqualVT(that *RawProfileSeries) bool

func (*RawProfileSeries) GetLabels 

func (x *RawProfileSeries) GetLabels() []*v1.LabelPair

func (*RawProfileSeries) GetSamples 

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

func (*RawProfileSeries) MarshalToSizedBufferVT 

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

func (*RawProfileSeries) MarshalToVT 

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

func (*RawProfileSeries) MarshalVT 

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 

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

func (*RawProfileSeries) String 

func (x *RawProfileSeries) String() string

func (*RawProfileSeries) UnmarshalVT 

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"`
	// unique ID of the profile
	ID string `protobuf:"bytes,2,opt,name=ID,proto3" json:"ID,omitempty"`
	// contains filtered or unexported fields
}

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

func (*RawSample) CloneMessageVT 

func (m *RawSample) CloneMessageVT() proto.Message

func (*RawSample) CloneVT 

func (m *RawSample) CloneVT() *RawSample

func (*RawSample) Descriptor deprecated 

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

Deprecated: Use RawSample.ProtoReflect.Descriptor instead.

func (*RawSample) EqualMessageVT added in v0.4.0 

func (this *RawSample) EqualMessageVT(thatMsg proto.Message) bool

func (*RawSample) EqualVT added in v0.4.0 

func (this *RawSample) EqualVT(that *RawSample) bool

func (*RawSample) GetID 

func (x *RawSample) GetID() string

func (*RawSample) GetRawProfile 

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

func (*RawSample) MarshalToSizedBufferVT 

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

func (*RawSample) MarshalToVT 

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

func (*RawSample) MarshalVT 

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 

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

func (*RawSample) String 

func (x *RawSample) String() string

func (*RawSample) UnmarshalVT 

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

type UnimplementedPusherServiceServer 

type UnimplementedPusherServiceServer struct {
}

UnimplementedPusherServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPusherServiceServer) Push 

func (UnimplementedPusherServiceServer) Push(context.Context, *PushRequest) (*PushResponse, error)

type UnsafePusherServiceServer 

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

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

Source Files

View all Source files

Directories

Path Synopsis

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.