Documentation
¶
Index ¶
- Variables
- func RegisterSegmentWriterServiceServer(s grpc.ServiceRegistrar, srv SegmentWriterServiceServer)
- type PushRequest
- func (m *PushRequest) CloneMessageVT() proto.Message
- func (m *PushRequest) CloneVT() *PushRequest
- func (*PushRequest) Descriptor() ([]byte, []int)deprecated
- func (this *PushRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *PushRequest) EqualVT(that *PushRequest) bool
- func (x *PushRequest) GetLabels() []*v1.LabelPair
- func (x *PushRequest) GetProfile() []byte
- func (x *PushRequest) GetProfileId() []byte
- func (x *PushRequest) GetShard() uint32
- func (x *PushRequest) GetTenantId() string
- func (m *PushRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PushRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *PushRequest) MarshalVT() (dAtA []byte, err error)
- func (*PushRequest) ProtoMessage()
- func (x *PushRequest) ProtoReflect() protoreflect.Message
- func (x *PushRequest) Reset()
- func (m *PushRequest) SizeVT() (n int)
- func (x *PushRequest) String() string
- func (m *PushRequest) UnmarshalVT(dAtA []byte) error
- type PushResponse
- func (m *PushResponse) CloneMessageVT() proto.Message
- func (m *PushResponse) CloneVT() *PushResponse
- func (*PushResponse) Descriptor() ([]byte, []int)deprecated
- func (this *PushResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *PushResponse) EqualVT(that *PushResponse) bool
- func (m *PushResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PushResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *PushResponse) MarshalVT() (dAtA []byte, err error)
- func (*PushResponse) ProtoMessage()
- func (x *PushResponse) ProtoReflect() protoreflect.Message
- func (x *PushResponse) Reset()
- func (m *PushResponse) SizeVT() (n int)
- func (x *PushResponse) String() string
- func (m *PushResponse) UnmarshalVT(dAtA []byte) error
- type SegmentWriterServiceClient
- type SegmentWriterServiceServer
- type UnimplementedSegmentWriterServiceServer
- type UnsafeSegmentWriterServiceServer
Constants ¶
This section is empty.
Variables ¶
var File_segmentwriter_v1_push_proto protoreflect.FileDescriptor
var SegmentWriterService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "segmentwriter.v1.SegmentWriterService", HandlerType: (*SegmentWriterServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Push", Handler: _SegmentWriterService_Push_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "segmentwriter/v1/push.proto", }
SegmentWriterService_ServiceDesc is the grpc.ServiceDesc for SegmentWriterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSegmentWriterServiceServer ¶
func RegisterSegmentWriterServiceServer(s grpc.ServiceRegistrar, srv SegmentWriterServiceServer)
Types ¶
type PushRequest ¶
type PushRequest struct { // Unique identifier for the tenant submitting the request. TenantId string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"` // Label KV pairs of the series the profile belongs to. Labels []*v1.LabelPair `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"` // Profile data in binary format. Default format is pprof. Profile []byte `protobuf:"bytes,4,opt,name=profile,proto3" json:"profile,omitempty"` // Unique identifier of the profile. ProfileId []byte `protobuf:"bytes,5,opt,name=profile_id,json=profileId,proto3" json:"profile_id,omitempty"` // Shard identifier the profile belongs to. Shard uint32 `protobuf:"varint,6,opt,name=shard,proto3" json:"shard,omitempty"` // contains filtered or unexported fields }
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 ¶
func (this *PushRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*PushRequest) EqualVT ¶
func (this *PushRequest) EqualVT(that *PushRequest) bool
func (*PushRequest) GetLabels ¶
func (x *PushRequest) GetLabels() []*v1.LabelPair
func (*PushRequest) GetProfile ¶
func (x *PushRequest) GetProfile() []byte
func (*PushRequest) GetProfileId ¶
func (x *PushRequest) GetProfileId() []byte
func (*PushRequest) GetShard ¶
func (x *PushRequest) GetShard() uint32
func (*PushRequest) GetTenantId ¶
func (x *PushRequest) GetTenantId() string
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 ¶
func (this *PushResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*PushResponse) EqualVT ¶
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 SegmentWriterServiceClient ¶
type SegmentWriterServiceClient interface {
Push(ctx context.Context, in *PushRequest, opts ...grpc.CallOption) (*PushResponse, error)
}
SegmentWriterServiceClient is the client API for SegmentWriterService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkgo.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSegmentWriterServiceClient ¶
func NewSegmentWriterServiceClient(cc grpc.ClientConnInterface) SegmentWriterServiceClient
type SegmentWriterServiceServer ¶
type SegmentWriterServiceServer interface { Push(context.Context, *PushRequest) (*PushResponse, error) // contains filtered or unexported methods }
SegmentWriterServiceServer is the server API for SegmentWriterService service. All implementations must embed UnimplementedSegmentWriterServiceServer for forward compatibility
type UnimplementedSegmentWriterServiceServer ¶
type UnimplementedSegmentWriterServiceServer struct { }
UnimplementedSegmentWriterServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedSegmentWriterServiceServer) Push ¶
func (UnimplementedSegmentWriterServiceServer) Push(context.Context, *PushRequest) (*PushResponse, error)
type UnsafeSegmentWriterServiceServer ¶
type UnsafeSegmentWriterServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSegmentWriterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SegmentWriterServiceServer will result in compilation errors.