Versions in this module Expand all Collapse all v1 v1.0.0 Jun 21, 2023 Changes in this version + const Profiling_Enable_FullMethodName + const Profiling_GetStreamStats_FullMethodName + var File_profiling_proto_service_proto protoreflect.FileDescriptor + var Profiling_ServiceDesc = grpc.ServiceDesc + func RegisterProfilingServer(s grpc.ServiceRegistrar, srv ProfilingServer) + type EnableRequest struct + Enabled bool + func (*EnableRequest) Descriptor() ([]byte, []int) + func (*EnableRequest) ProtoMessage() + func (x *EnableRequest) GetEnabled() bool + func (x *EnableRequest) ProtoReflect() protoreflect.Message + func (x *EnableRequest) Reset() + func (x *EnableRequest) String() string + type EnableResponse struct + func (*EnableResponse) Descriptor() ([]byte, []int) + func (*EnableResponse) ProtoMessage() + func (x *EnableResponse) ProtoReflect() protoreflect.Message + func (x *EnableResponse) Reset() + func (x *EnableResponse) String() string + type GetStreamStatsRequest struct + func (*GetStreamStatsRequest) Descriptor() ([]byte, []int) + func (*GetStreamStatsRequest) ProtoMessage() + func (x *GetStreamStatsRequest) ProtoReflect() protoreflect.Message + func (x *GetStreamStatsRequest) Reset() + func (x *GetStreamStatsRequest) String() string + type GetStreamStatsResponse struct + StreamStats []*Stat + func (*GetStreamStatsResponse) Descriptor() ([]byte, []int) + func (*GetStreamStatsResponse) ProtoMessage() + func (x *GetStreamStatsResponse) GetStreamStats() []*Stat + func (x *GetStreamStatsResponse) ProtoReflect() protoreflect.Message + func (x *GetStreamStatsResponse) Reset() + func (x *GetStreamStatsResponse) String() string + type ProfilingClient interface + Enable func(ctx context.Context, in *EnableRequest, opts ...grpc.CallOption) (*EnableResponse, error) + GetStreamStats func(ctx context.Context, in *GetStreamStatsRequest, opts ...grpc.CallOption) (*GetStreamStatsResponse, error) + func NewProfilingClient(cc grpc.ClientConnInterface) ProfilingClient + type ProfilingServer interface + Enable func(context.Context, *EnableRequest) (*EnableResponse, error) + GetStreamStats func(context.Context, *GetStreamStatsRequest) (*GetStreamStatsResponse, error) + type Stat struct + Metadata []byte + Tags string + Timers []*Timer + func (*Stat) Descriptor() ([]byte, []int) + func (*Stat) ProtoMessage() + func (x *Stat) GetMetadata() []byte + func (x *Stat) GetTags() string + func (x *Stat) GetTimers() []*Timer + func (x *Stat) ProtoReflect() protoreflect.Message + func (x *Stat) Reset() + func (x *Stat) String() string + type Timer struct + BeginNsec int32 + BeginSec int64 + EndNsec int32 + EndSec int64 + GoId int64 + Tags string + func (*Timer) Descriptor() ([]byte, []int) + func (*Timer) ProtoMessage() + func (x *Timer) GetBeginNsec() int32 + func (x *Timer) GetBeginSec() int64 + func (x *Timer) GetEndNsec() int32 + func (x *Timer) GetEndSec() int64 + func (x *Timer) GetGoId() int64 + func (x *Timer) GetTags() string + func (x *Timer) ProtoReflect() protoreflect.Message + func (x *Timer) Reset() + func (x *Timer) String() string + type UnimplementedProfilingServer struct + func (UnimplementedProfilingServer) Enable(context.Context, *EnableRequest) (*EnableResponse, error) + func (UnimplementedProfilingServer) GetStreamStats(context.Context, *GetStreamStatsRequest) (*GetStreamStatsResponse, error) + type UnsafeProfilingServer interface