redis

Documentation

Index

• func RegisterRedisServer(s *grpc.Server, srv RedisServer)
• type RedisClient
  • func NewRedisClient(cc *grpc.ClientConn) 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

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