pushv1

package
v0.1.3 Latest Latest
Warning

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

Go to latest
Published: Jan 12, 2023 License: Apache-2.0 Imports: 13 Imported by: 1

Documentation

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 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) Descriptor deprecated

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

Deprecated: Use PushRequest.ProtoReflect.Descriptor instead.

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) Descriptor deprecated

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

Deprecated: Use PushResponse.ProtoReflect.Descriptor instead.

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.

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) Descriptor deprecated

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

Deprecated: Use RawProfileSeries.ProtoReflect.Descriptor instead.

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) Descriptor deprecated

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

Deprecated: Use RawSample.ProtoReflect.Descriptor instead.

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

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.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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