Documentation ¶
Index ¶
- func RegisterStatsServiceServer(s *grpc.Server, srv StatsServiceServer)
- type Config
- func (*Config) Descriptor() ([]byte, []int)
- func (*Config) ProtoMessage()
- func (m *Config) Reset()
- func (m *Config) String() string
- func (m *Config) XXX_DiscardUnknown()
- func (m *Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Config) XXX_Merge(src proto.Message)
- func (m *Config) XXX_Size() int
- func (m *Config) XXX_Unmarshal(b []byte) error
- type GetStatsRequest
- func (*GetStatsRequest) Descriptor() ([]byte, []int)
- func (m *GetStatsRequest) GetName() string
- func (m *GetStatsRequest) GetReset_() bool
- func (*GetStatsRequest) ProtoMessage()
- func (m *GetStatsRequest) Reset()
- func (m *GetStatsRequest) String() string
- func (m *GetStatsRequest) XXX_DiscardUnknown()
- func (m *GetStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetStatsRequest) XXX_Merge(src proto.Message)
- func (m *GetStatsRequest) XXX_Size() int
- func (m *GetStatsRequest) XXX_Unmarshal(b []byte) error
- type GetStatsResponse
- func (*GetStatsResponse) Descriptor() ([]byte, []int)
- func (m *GetStatsResponse) GetStat() *Stat
- func (*GetStatsResponse) ProtoMessage()
- func (m *GetStatsResponse) Reset()
- func (m *GetStatsResponse) String() string
- func (m *GetStatsResponse) XXX_DiscardUnknown()
- func (m *GetStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetStatsResponse) XXX_Merge(src proto.Message)
- func (m *GetStatsResponse) XXX_Size() int
- func (m *GetStatsResponse) XXX_Unmarshal(b []byte) error
- type QueryStatsRequest
- func (*QueryStatsRequest) Descriptor() ([]byte, []int)
- func (m *QueryStatsRequest) GetPattern() string
- func (m *QueryStatsRequest) GetReset_() bool
- func (*QueryStatsRequest) ProtoMessage()
- func (m *QueryStatsRequest) Reset()
- func (m *QueryStatsRequest) String() string
- func (m *QueryStatsRequest) XXX_DiscardUnknown()
- func (m *QueryStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryStatsRequest) XXX_Merge(src proto.Message)
- func (m *QueryStatsRequest) XXX_Size() int
- func (m *QueryStatsRequest) XXX_Unmarshal(b []byte) error
- type QueryStatsResponse
- func (*QueryStatsResponse) Descriptor() ([]byte, []int)
- func (m *QueryStatsResponse) GetStat() []*Stat
- func (*QueryStatsResponse) ProtoMessage()
- func (m *QueryStatsResponse) Reset()
- func (m *QueryStatsResponse) String() string
- func (m *QueryStatsResponse) XXX_DiscardUnknown()
- func (m *QueryStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryStatsResponse) XXX_Merge(src proto.Message)
- func (m *QueryStatsResponse) XXX_Size() int
- func (m *QueryStatsResponse) XXX_Unmarshal(b []byte) error
- type Stat
- func (*Stat) Descriptor() ([]byte, []int)
- func (m *Stat) GetName() string
- func (m *Stat) GetValue() int64
- func (*Stat) ProtoMessage()
- 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 StatsServiceClient
- type StatsServiceServer
- type SysStatsRequest
- func (*SysStatsRequest) Descriptor() ([]byte, []int)
- func (*SysStatsRequest) ProtoMessage()
- func (m *SysStatsRequest) Reset()
- func (m *SysStatsRequest) String() string
- func (m *SysStatsRequest) XXX_DiscardUnknown()
- func (m *SysStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SysStatsRequest) XXX_Merge(src proto.Message)
- func (m *SysStatsRequest) XXX_Size() int
- func (m *SysStatsRequest) XXX_Unmarshal(b []byte) error
- type SysStatsResponse
- func (*SysStatsResponse) Descriptor() ([]byte, []int)
- func (m *SysStatsResponse) GetAlloc() uint64
- func (m *SysStatsResponse) GetFrees() uint64
- func (m *SysStatsResponse) GetLiveObjects() uint64
- func (m *SysStatsResponse) GetMallocs() uint64
- func (m *SysStatsResponse) GetNumGC() uint32
- func (m *SysStatsResponse) GetNumGoroutine() uint32
- func (m *SysStatsResponse) GetPauseTotalNs() uint64
- func (m *SysStatsResponse) GetSys() uint64
- func (m *SysStatsResponse) GetTotalAlloc() uint64
- func (m *SysStatsResponse) GetUptime() uint32
- func (*SysStatsResponse) ProtoMessage()
- func (m *SysStatsResponse) Reset()
- func (m *SysStatsResponse) String() string
- func (m *SysStatsResponse) XXX_DiscardUnknown()
- func (m *SysStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SysStatsResponse) XXX_Merge(src proto.Message)
- func (m *SysStatsResponse) XXX_Size() int
- func (m *SysStatsResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedStatsServiceServer
- func (*UnimplementedStatsServiceServer) GetStats(ctx context.Context, req *GetStatsRequest) (*GetStatsResponse, error)
- func (*UnimplementedStatsServiceServer) GetSysStats(ctx context.Context, req *SysStatsRequest) (*SysStatsResponse, error)
- func (*UnimplementedStatsServiceServer) QueryStats(ctx context.Context, req *QueryStatsRequest) (*QueryStatsResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterStatsServiceServer ¶
func RegisterStatsServiceServer(s *grpc.Server, srv StatsServiceServer)
Types ¶
type Config ¶
type Config struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Config) Descriptor ¶
func (*Config) ProtoMessage ¶
func (*Config) ProtoMessage()
func (*Config) XXX_DiscardUnknown ¶
func (m *Config) XXX_DiscardUnknown()
func (*Config) XXX_Marshal ¶
func (*Config) XXX_Unmarshal ¶
type GetStatsRequest ¶
type GetStatsRequest struct { // Name of the stat counter. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Whether or not to reset the counter to fetching its value. Reset_ bool `protobuf:"varint,2,opt,name=reset,proto3" json:"reset,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetStatsRequest) Descriptor ¶
func (*GetStatsRequest) Descriptor() ([]byte, []int)
func (*GetStatsRequest) GetName ¶
func (m *GetStatsRequest) GetName() string
func (*GetStatsRequest) GetReset_ ¶
func (m *GetStatsRequest) GetReset_() bool
func (*GetStatsRequest) ProtoMessage ¶
func (*GetStatsRequest) ProtoMessage()
func (*GetStatsRequest) Reset ¶
func (m *GetStatsRequest) Reset()
func (*GetStatsRequest) String ¶
func (m *GetStatsRequest) String() string
func (*GetStatsRequest) XXX_DiscardUnknown ¶
func (m *GetStatsRequest) XXX_DiscardUnknown()
func (*GetStatsRequest) XXX_Marshal ¶
func (m *GetStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetStatsRequest) XXX_Merge ¶
func (m *GetStatsRequest) XXX_Merge(src proto.Message)
func (*GetStatsRequest) XXX_Size ¶
func (m *GetStatsRequest) XXX_Size() int
func (*GetStatsRequest) XXX_Unmarshal ¶
func (m *GetStatsRequest) XXX_Unmarshal(b []byte) error
type GetStatsResponse ¶
type GetStatsResponse struct { Stat *Stat `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetStatsResponse) Descriptor ¶
func (*GetStatsResponse) Descriptor() ([]byte, []int)
func (*GetStatsResponse) GetStat ¶
func (m *GetStatsResponse) GetStat() *Stat
func (*GetStatsResponse) ProtoMessage ¶
func (*GetStatsResponse) ProtoMessage()
func (*GetStatsResponse) Reset ¶
func (m *GetStatsResponse) Reset()
func (*GetStatsResponse) String ¶
func (m *GetStatsResponse) String() string
func (*GetStatsResponse) XXX_DiscardUnknown ¶
func (m *GetStatsResponse) XXX_DiscardUnknown()
func (*GetStatsResponse) XXX_Marshal ¶
func (m *GetStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetStatsResponse) XXX_Merge ¶
func (m *GetStatsResponse) XXX_Merge(src proto.Message)
func (*GetStatsResponse) XXX_Size ¶
func (m *GetStatsResponse) XXX_Size() int
func (*GetStatsResponse) XXX_Unmarshal ¶
func (m *GetStatsResponse) XXX_Unmarshal(b []byte) error
type QueryStatsRequest ¶
type QueryStatsRequest struct { Pattern string `protobuf:"bytes,1,opt,name=pattern,proto3" json:"pattern,omitempty"` Reset_ bool `protobuf:"varint,2,opt,name=reset,proto3" json:"reset,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*QueryStatsRequest) Descriptor ¶
func (*QueryStatsRequest) Descriptor() ([]byte, []int)
func (*QueryStatsRequest) GetPattern ¶
func (m *QueryStatsRequest) GetPattern() string
func (*QueryStatsRequest) GetReset_ ¶
func (m *QueryStatsRequest) GetReset_() bool
func (*QueryStatsRequest) ProtoMessage ¶
func (*QueryStatsRequest) ProtoMessage()
func (*QueryStatsRequest) Reset ¶
func (m *QueryStatsRequest) Reset()
func (*QueryStatsRequest) String ¶
func (m *QueryStatsRequest) String() string
func (*QueryStatsRequest) XXX_DiscardUnknown ¶
func (m *QueryStatsRequest) XXX_DiscardUnknown()
func (*QueryStatsRequest) XXX_Marshal ¶
func (m *QueryStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryStatsRequest) XXX_Merge ¶
func (m *QueryStatsRequest) XXX_Merge(src proto.Message)
func (*QueryStatsRequest) XXX_Size ¶
func (m *QueryStatsRequest) XXX_Size() int
func (*QueryStatsRequest) XXX_Unmarshal ¶
func (m *QueryStatsRequest) XXX_Unmarshal(b []byte) error
type QueryStatsResponse ¶
type QueryStatsResponse struct { Stat []*Stat `protobuf:"bytes,1,rep,name=stat,proto3" json:"stat,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*QueryStatsResponse) Descriptor ¶
func (*QueryStatsResponse) Descriptor() ([]byte, []int)
func (*QueryStatsResponse) GetStat ¶
func (m *QueryStatsResponse) GetStat() []*Stat
func (*QueryStatsResponse) ProtoMessage ¶
func (*QueryStatsResponse) ProtoMessage()
func (*QueryStatsResponse) Reset ¶
func (m *QueryStatsResponse) Reset()
func (*QueryStatsResponse) String ¶
func (m *QueryStatsResponse) String() string
func (*QueryStatsResponse) XXX_DiscardUnknown ¶
func (m *QueryStatsResponse) XXX_DiscardUnknown()
func (*QueryStatsResponse) XXX_Marshal ¶
func (m *QueryStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryStatsResponse) XXX_Merge ¶
func (m *QueryStatsResponse) XXX_Merge(src proto.Message)
func (*QueryStatsResponse) XXX_Size ¶
func (m *QueryStatsResponse) XXX_Size() int
func (*QueryStatsResponse) XXX_Unmarshal ¶
func (m *QueryStatsResponse) XXX_Unmarshal(b []byte) error
type Stat ¶
type Stat struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Value int64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Stat) Descriptor ¶
func (*Stat) ProtoMessage ¶
func (*Stat) ProtoMessage()
func (*Stat) XXX_DiscardUnknown ¶
func (m *Stat) XXX_DiscardUnknown()
func (*Stat) XXX_Unmarshal ¶
type StatsServiceClient ¶
type StatsServiceClient interface { GetStats(ctx context.Context, in *GetStatsRequest, opts ...grpc.CallOption) (*GetStatsResponse, error) QueryStats(ctx context.Context, in *QueryStatsRequest, opts ...grpc.CallOption) (*QueryStatsResponse, error) GetSysStats(ctx context.Context, in *SysStatsRequest, opts ...grpc.CallOption) (*SysStatsResponse, error) }
StatsServiceClient is the client API for StatsService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewStatsServiceClient ¶
func NewStatsServiceClient(cc *grpc.ClientConn) StatsServiceClient
type StatsServiceServer ¶
type StatsServiceServer interface { GetStats(context.Context, *GetStatsRequest) (*GetStatsResponse, error) QueryStats(context.Context, *QueryStatsRequest) (*QueryStatsResponse, error) GetSysStats(context.Context, *SysStatsRequest) (*SysStatsResponse, error) }
StatsServiceServer is the server API for StatsService service.
func NewStatsServer ¶
func NewStatsServer(manager feature_stats.Manager) StatsServiceServer
type SysStatsRequest ¶
type SysStatsRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SysStatsRequest) Descriptor ¶
func (*SysStatsRequest) Descriptor() ([]byte, []int)
func (*SysStatsRequest) ProtoMessage ¶
func (*SysStatsRequest) ProtoMessage()
func (*SysStatsRequest) Reset ¶
func (m *SysStatsRequest) Reset()
func (*SysStatsRequest) String ¶
func (m *SysStatsRequest) String() string
func (*SysStatsRequest) XXX_DiscardUnknown ¶
func (m *SysStatsRequest) XXX_DiscardUnknown()
func (*SysStatsRequest) XXX_Marshal ¶
func (m *SysStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SysStatsRequest) XXX_Merge ¶
func (m *SysStatsRequest) XXX_Merge(src proto.Message)
func (*SysStatsRequest) XXX_Size ¶
func (m *SysStatsRequest) XXX_Size() int
func (*SysStatsRequest) XXX_Unmarshal ¶
func (m *SysStatsRequest) XXX_Unmarshal(b []byte) error
type SysStatsResponse ¶
type SysStatsResponse struct { NumGoroutine uint32 `protobuf:"varint,1,opt,name=NumGoroutine,proto3" json:"NumGoroutine,omitempty"` NumGC uint32 `protobuf:"varint,2,opt,name=NumGC,proto3" json:"NumGC,omitempty"` Alloc uint64 `protobuf:"varint,3,opt,name=Alloc,proto3" json:"Alloc,omitempty"` TotalAlloc uint64 `protobuf:"varint,4,opt,name=TotalAlloc,proto3" json:"TotalAlloc,omitempty"` Sys uint64 `protobuf:"varint,5,opt,name=Sys,proto3" json:"Sys,omitempty"` Mallocs uint64 `protobuf:"varint,6,opt,name=Mallocs,proto3" json:"Mallocs,omitempty"` Frees uint64 `protobuf:"varint,7,opt,name=Frees,proto3" json:"Frees,omitempty"` LiveObjects uint64 `protobuf:"varint,8,opt,name=LiveObjects,proto3" json:"LiveObjects,omitempty"` PauseTotalNs uint64 `protobuf:"varint,9,opt,name=PauseTotalNs,proto3" json:"PauseTotalNs,omitempty"` Uptime uint32 `protobuf:"varint,10,opt,name=Uptime,proto3" json:"Uptime,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SysStatsResponse) Descriptor ¶
func (*SysStatsResponse) Descriptor() ([]byte, []int)
func (*SysStatsResponse) GetAlloc ¶
func (m *SysStatsResponse) GetAlloc() uint64
func (*SysStatsResponse) GetFrees ¶
func (m *SysStatsResponse) GetFrees() uint64
func (*SysStatsResponse) GetLiveObjects ¶
func (m *SysStatsResponse) GetLiveObjects() uint64
func (*SysStatsResponse) GetMallocs ¶
func (m *SysStatsResponse) GetMallocs() uint64
func (*SysStatsResponse) GetNumGC ¶
func (m *SysStatsResponse) GetNumGC() uint32
func (*SysStatsResponse) GetNumGoroutine ¶
func (m *SysStatsResponse) GetNumGoroutine() uint32
func (*SysStatsResponse) GetPauseTotalNs ¶
func (m *SysStatsResponse) GetPauseTotalNs() uint64
func (*SysStatsResponse) GetSys ¶
func (m *SysStatsResponse) GetSys() uint64
func (*SysStatsResponse) GetTotalAlloc ¶
func (m *SysStatsResponse) GetTotalAlloc() uint64
func (*SysStatsResponse) GetUptime ¶
func (m *SysStatsResponse) GetUptime() uint32
func (*SysStatsResponse) ProtoMessage ¶
func (*SysStatsResponse) ProtoMessage()
func (*SysStatsResponse) Reset ¶
func (m *SysStatsResponse) Reset()
func (*SysStatsResponse) String ¶
func (m *SysStatsResponse) String() string
func (*SysStatsResponse) XXX_DiscardUnknown ¶
func (m *SysStatsResponse) XXX_DiscardUnknown()
func (*SysStatsResponse) XXX_Marshal ¶
func (m *SysStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SysStatsResponse) XXX_Merge ¶
func (m *SysStatsResponse) XXX_Merge(src proto.Message)
func (*SysStatsResponse) XXX_Size ¶
func (m *SysStatsResponse) XXX_Size() int
func (*SysStatsResponse) XXX_Unmarshal ¶
func (m *SysStatsResponse) XXX_Unmarshal(b []byte) error
type UnimplementedStatsServiceServer ¶
type UnimplementedStatsServiceServer struct { }
UnimplementedStatsServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedStatsServiceServer) GetStats ¶
func (*UnimplementedStatsServiceServer) GetStats(ctx context.Context, req *GetStatsRequest) (*GetStatsResponse, error)
func (*UnimplementedStatsServiceServer) GetSysStats ¶
func (*UnimplementedStatsServiceServer) GetSysStats(ctx context.Context, req *SysStatsRequest) (*SysStatsResponse, error)
func (*UnimplementedStatsServiceServer) QueryStats ¶
func (*UnimplementedStatsServiceServer) QueryStats(ctx context.Context, req *QueryStatsRequest) (*QueryStatsResponse, error)
Click to show internal directories.
Click to hide internal directories.