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
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) }
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) }
StatsServiceServer is the server API for StatsService service.
func NewStatsServer ¶
func NewStatsServer(manager core.StatManager) StatsServiceServer
Click to show internal directories.
Click to hide internal directories.