Versions in this module Expand all Collapse all v1 v1.0.0 Jun 24, 2021 Changes in this version + func RegisterProfilingServer(s *grpc.Server, srv ProfilingServer) + type EnableRequest struct + Enabled bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EnableRequest) Descriptor() ([]byte, []int) + func (*EnableRequest) ProtoMessage() + func (m *EnableRequest) GetEnabled() bool + func (m *EnableRequest) Reset() + func (m *EnableRequest) String() string + func (m *EnableRequest) XXX_DiscardUnknown() + func (m *EnableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EnableRequest) XXX_Merge(src proto.Message) + func (m *EnableRequest) XXX_Size() int + func (m *EnableRequest) XXX_Unmarshal(b []byte) error + type EnableResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EnableResponse) Descriptor() ([]byte, []int) + func (*EnableResponse) ProtoMessage() + func (m *EnableResponse) Reset() + func (m *EnableResponse) String() string + func (m *EnableResponse) XXX_DiscardUnknown() + func (m *EnableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EnableResponse) XXX_Merge(src proto.Message) + func (m *EnableResponse) XXX_Size() int + func (m *EnableResponse) XXX_Unmarshal(b []byte) error + type GetStreamStatsRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetStreamStatsRequest) Descriptor() ([]byte, []int) + func (*GetStreamStatsRequest) ProtoMessage() + func (m *GetStreamStatsRequest) Reset() + func (m *GetStreamStatsRequest) String() string + func (m *GetStreamStatsRequest) XXX_DiscardUnknown() + func (m *GetStreamStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetStreamStatsRequest) XXX_Merge(src proto.Message) + func (m *GetStreamStatsRequest) XXX_Size() int + func (m *GetStreamStatsRequest) XXX_Unmarshal(b []byte) error + type GetStreamStatsResponse struct + StreamStats []*Stat + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetStreamStatsResponse) Descriptor() ([]byte, []int) + func (*GetStreamStatsResponse) ProtoMessage() + func (m *GetStreamStatsResponse) GetStreamStats() []*Stat + func (m *GetStreamStatsResponse) Reset() + func (m *GetStreamStatsResponse) String() string + func (m *GetStreamStatsResponse) XXX_DiscardUnknown() + func (m *GetStreamStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetStreamStatsResponse) XXX_Merge(src proto.Message) + func (m *GetStreamStatsResponse) XXX_Size() int + func (m *GetStreamStatsResponse) XXX_Unmarshal(b []byte) error + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Stat) Descriptor() ([]byte, []int) + func (*Stat) ProtoMessage() + func (m *Stat) GetMetadata() []byte + func (m *Stat) GetTags() string + func (m *Stat) GetTimers() []*Timer + func (m *Stat) Reset() + func (m *Stat) String() string + func (m *Stat) XXX_DiscardUnknown() + func (m *Stat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Stat) XXX_Merge(src proto.Message) + func (m *Stat) XXX_Size() int + func (m *Stat) XXX_Unmarshal(b []byte) error + type Timer struct + BeginNsec int32 + BeginSec int64 + EndNsec int32 + EndSec int64 + GoId int64 + Tags string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Timer) Descriptor() ([]byte, []int) + func (*Timer) ProtoMessage() + func (m *Timer) GetBeginNsec() int32 + func (m *Timer) GetBeginSec() int64 + func (m *Timer) GetEndNsec() int32 + func (m *Timer) GetEndSec() int64 + func (m *Timer) GetGoId() int64 + func (m *Timer) GetTags() string + func (m *Timer) Reset() + func (m *Timer) String() string + func (m *Timer) XXX_DiscardUnknown() + func (m *Timer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Timer) XXX_Merge(src proto.Message) + func (m *Timer) XXX_Size() int + func (m *Timer) XXX_Unmarshal(b []byte) error + type UnimplementedProfilingServer struct + func (*UnimplementedProfilingServer) Enable(ctx context.Context, req *EnableRequest) (*EnableResponse, error) + func (*UnimplementedProfilingServer) GetStreamStats(ctx context.Context, req *GetStreamStatsRequest) (*GetStreamStatsResponse, error)