Versions in this module Expand all Collapse all v0 v0.0.4 Jan 14, 2020 v0.0.2 Jan 14, 2020 Changes in this version + func RegisterStatsHandler(s server.Server, hdlr StatsHandler, opts ...server.HandlerOption) error + type Node struct + Address string + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Node) Descriptor() ([]byte, []int) + func (*Node) ProtoMessage() + func (m *Node) GetAddress() string + func (m *Node) GetId() string + func (m *Node) Reset() + func (m *Node) String() string + func (m *Node) XXX_DiscardUnknown() + func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Node) XXX_Merge(src proto.Message) + func (m *Node) XXX_Size() int + func (m *Node) XXX_Unmarshal(b []byte) error + type ReadRequest struct + Service *Service + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadRequest) Descriptor() ([]byte, []int) + func (*ReadRequest) ProtoMessage() + func (m *ReadRequest) GetService() *Service + func (m *ReadRequest) Reset() + func (m *ReadRequest) String() string + func (m *ReadRequest) XXX_DiscardUnknown() + func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadRequest) XXX_Merge(src proto.Message) + func (m *ReadRequest) XXX_Size() int + func (m *ReadRequest) XXX_Unmarshal(b []byte) error + type ReadResponse struct + Stats []*Snapshot + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadResponse) Descriptor() ([]byte, []int) + func (*ReadResponse) ProtoMessage() + func (m *ReadResponse) GetStats() []*Snapshot + func (m *ReadResponse) Reset() + func (m *ReadResponse) String() string + func (m *ReadResponse) XXX_DiscardUnknown() + func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadResponse) XXX_Merge(src proto.Message) + func (m *ReadResponse) XXX_Size() int + func (m *ReadResponse) XXX_Unmarshal(b []byte) error + type Service struct + Name string + Node *Node + Version string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Service) Descriptor() ([]byte, []int) + func (*Service) ProtoMessage() + func (m *Service) GetName() string + func (m *Service) GetNode() *Node + func (m *Service) GetVersion() string + func (m *Service) Reset() + func (m *Service) String() string + func (m *Service) XXX_DiscardUnknown() + func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Service) XXX_Merge(src proto.Message) + func (m *Service) XXX_Size() int + func (m *Service) XXX_Unmarshal(b []byte) error + type Snapshot struct + Errors uint64 + Gc uint64 + Memory uint64 + Requests uint64 + Service *Service + Started int64 + Threads uint64 + Uptime uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Snapshot) Descriptor() ([]byte, []int) + func (*Snapshot) ProtoMessage() + func (m *Snapshot) GetErrors() uint64 + func (m *Snapshot) GetGc() uint64 + func (m *Snapshot) GetMemory() uint64 + func (m *Snapshot) GetRequests() uint64 + func (m *Snapshot) GetService() *Service + func (m *Snapshot) GetStarted() int64 + func (m *Snapshot) GetThreads() uint64 + func (m *Snapshot) GetUptime() uint64 + func (m *Snapshot) Reset() + func (m *Snapshot) String() string + func (m *Snapshot) XXX_DiscardUnknown() + func (m *Snapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Snapshot) XXX_Merge(src proto.Message) + func (m *Snapshot) XXX_Size() int + func (m *Snapshot) XXX_Unmarshal(b []byte) error + type StatsHandler interface + Read func(context.Context, *ReadRequest, *ReadResponse) error + Stream func(context.Context, *StreamRequest, Stats_StreamStream) error + Write func(context.Context, *WriteRequest, *WriteResponse) error + type StatsService interface + Read func(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error) + Stream func(ctx context.Context, in *StreamRequest, opts ...client.CallOption) (Stats_StreamService, error) + Write func(ctx context.Context, in *WriteRequest, opts ...client.CallOption) (*WriteResponse, error) + func NewStatsService(name string, c client.Client) StatsService + type Stats_StreamService interface + Close func() error + Recv func() (*StreamResponse, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type Stats_StreamStream interface + Close func() error + RecvMsg func(interface{}) error + Send func(*StreamResponse) error + SendMsg func(interface{}) error + type StreamRequest struct + Namespace string + Service *Service + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamRequest) Descriptor() ([]byte, []int) + func (*StreamRequest) ProtoMessage() + func (m *StreamRequest) GetNamespace() string + func (m *StreamRequest) GetService() *Service + func (m *StreamRequest) Reset() + func (m *StreamRequest) String() string + func (m *StreamRequest) XXX_DiscardUnknown() + func (m *StreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamRequest) XXX_Merge(src proto.Message) + func (m *StreamRequest) XXX_Size() int + func (m *StreamRequest) XXX_Unmarshal(b []byte) error + type StreamResponse struct + Stats []*Snapshot + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamResponse) Descriptor() ([]byte, []int) + func (*StreamResponse) ProtoMessage() + func (m *StreamResponse) GetStats() []*Snapshot + func (m *StreamResponse) Reset() + func (m *StreamResponse) String() string + func (m *StreamResponse) XXX_DiscardUnknown() + func (m *StreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamResponse) XXX_Merge(src proto.Message) + func (m *StreamResponse) XXX_Size() int + func (m *StreamResponse) XXX_Unmarshal(b []byte) error + type WriteRequest struct + Service *Service + Stats *Snapshot + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteRequest) Descriptor() ([]byte, []int) + func (*WriteRequest) ProtoMessage() + func (m *WriteRequest) GetService() *Service + func (m *WriteRequest) GetStats() *Snapshot + func (m *WriteRequest) Reset() + func (m *WriteRequest) String() string + func (m *WriteRequest) XXX_DiscardUnknown() + func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteRequest) XXX_Merge(src proto.Message) + func (m *WriteRequest) XXX_Size() int + func (m *WriteRequest) XXX_Unmarshal(b []byte) error + type WriteResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteResponse) Descriptor() ([]byte, []int) + func (*WriteResponse) ProtoMessage() + func (m *WriteResponse) Reset() + func (m *WriteResponse) String() string + func (m *WriteResponse) XXX_DiscardUnknown() + func (m *WriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteResponse) XXX_Merge(src proto.Message) + func (m *WriteResponse) XXX_Size() int + func (m *WriteResponse) XXX_Unmarshal(b []byte) error
Go to main page