Documentation
      ¶
    
    
  
    
  
    Index ¶
- func RegisterRedisServer(s *grpc.Server, srv RedisServer)
 - type RedisClient
 - type RedisServer
 - type ReportRequest
 - func (*ReportRequest) Descriptor() ([]byte, []int)
 - func (m *ReportRequest) GetDelay() float32
 - func (m *ReportRequest) GetExpireTime() uint32
 - func (m *ReportRequest) GetKey() string
 - func (m *ReportRequest) GetLoss() float32
 - func (m *ReportRequest) GetTimestamp() uint32
 - func (*ReportRequest) ProtoMessage()
 - func (m *ReportRequest) Reset()
 - func (m *ReportRequest) String() string
 - func (m *ReportRequest) XXX_DiscardUnknown()
 - func (m *ReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (dst *ReportRequest) XXX_Merge(src proto.Message)
 - func (m *ReportRequest) XXX_Size() int
 - func (m *ReportRequest) XXX_Unmarshal(b []byte) error
 
- type ReportResponse
 - func (*ReportResponse) Descriptor() ([]byte, []int)
 - func (m *ReportResponse) GetInfo() string
 - func (*ReportResponse) ProtoMessage()
 - func (m *ReportResponse) Reset()
 - func (m *ReportResponse) String() string
 - func (m *ReportResponse) XXX_DiscardUnknown()
 - func (m *ReportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (dst *ReportResponse) XXX_Merge(src proto.Message)
 - func (m *ReportResponse) XXX_Size() int
 - func (m *ReportResponse) XXX_Unmarshal(b []byte) error
 
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterRedisServer ¶
func RegisterRedisServer(s *grpc.Server, srv RedisServer)
Types ¶
type RedisClient ¶
type RedisClient interface {
	Report(ctx context.Context, in *ReportRequest, opts ...grpc.CallOption) (*ReportResponse, error)
}
    RedisClient is the client API for Redis service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewRedisClient ¶
func NewRedisClient(cc *grpc.ClientConn) RedisClient
type RedisServer ¶
type RedisServer interface {
	Report(context.Context, *ReportRequest) (*ReportResponse, error)
}
    RedisServer is the server API for Redis service.
type ReportRequest ¶
type ReportRequest struct {
	Delay                float32  `protobuf:"fixed32,2,opt,name=delay,proto3" json:"delay,omitempty"`
	Timestamp            uint32   `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Loss                 float32  `protobuf:"fixed32,4,opt,name=loss,proto3" json:"loss,omitempty"`
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	ExpireTime           uint32   `protobuf:"varint,6,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    redis上报数据格式
func (*ReportRequest) Descriptor ¶
func (*ReportRequest) Descriptor() ([]byte, []int)
func (*ReportRequest) GetDelay ¶
func (m *ReportRequest) GetDelay() float32
func (*ReportRequest) GetExpireTime ¶
func (m *ReportRequest) GetExpireTime() uint32
func (*ReportRequest) GetKey ¶
func (m *ReportRequest) GetKey() string
func (*ReportRequest) GetLoss ¶
func (m *ReportRequest) GetLoss() float32
func (*ReportRequest) GetTimestamp ¶
func (m *ReportRequest) GetTimestamp() uint32
func (*ReportRequest) ProtoMessage ¶
func (*ReportRequest) ProtoMessage()
func (*ReportRequest) Reset ¶
func (m *ReportRequest) Reset()
func (*ReportRequest) String ¶
func (m *ReportRequest) String() string
func (*ReportRequest) XXX_DiscardUnknown ¶
func (m *ReportRequest) XXX_DiscardUnknown()
func (*ReportRequest) XXX_Marshal ¶
func (m *ReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReportRequest) XXX_Merge ¶
func (dst *ReportRequest) XXX_Merge(src proto.Message)
func (*ReportRequest) XXX_Size ¶
func (m *ReportRequest) XXX_Size() int
func (*ReportRequest) XXX_Unmarshal ¶
func (m *ReportRequest) XXX_Unmarshal(b []byte) error
type ReportResponse ¶
type ReportResponse struct {
	Info                 string   `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    返回数据格式
func (*ReportResponse) Descriptor ¶
func (*ReportResponse) Descriptor() ([]byte, []int)
func (*ReportResponse) GetInfo ¶
func (m *ReportResponse) GetInfo() string
func (*ReportResponse) ProtoMessage ¶
func (*ReportResponse) ProtoMessage()
func (*ReportResponse) Reset ¶
func (m *ReportResponse) Reset()
func (*ReportResponse) String ¶
func (m *ReportResponse) String() string
func (*ReportResponse) XXX_DiscardUnknown ¶
func (m *ReportResponse) XXX_DiscardUnknown()
func (*ReportResponse) XXX_Marshal ¶
func (m *ReportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReportResponse) XXX_Merge ¶
func (dst *ReportResponse) XXX_Merge(src proto.Message)
func (*ReportResponse) XXX_Size ¶
func (m *ReportResponse) XXX_Size() int
func (*ReportResponse) XXX_Unmarshal ¶
func (m *ReportResponse) XXX_Unmarshal(b []byte) error
 Click to show internal directories. 
   Click to hide internal directories.