Documentation ¶
Index ¶
- func RegisterCacheServiceServer(s *grpc.Server, srv CacheServiceServer)
- type CacheServiceClient
- type CacheServiceServer
- type GetReq
- func (*GetReq) Descriptor() ([]byte, []int)
- func (m *GetReq) GetFast() bool
- func (m *GetReq) GetKey() string
- func (*GetReq) ProtoMessage()
- func (m *GetReq) Reset()
- func (m *GetReq) String() string
- func (m *GetReq) XXX_DiscardUnknown()
- func (m *GetReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetReq) XXX_Merge(src proto.Message)
- func (m *GetReq) XXX_Size() int
- func (m *GetReq) XXX_Unmarshal(b []byte) error
- type GetResp
- func (*GetResp) Descriptor() ([]byte, []int)
- func (m *GetResp) GetInMemory() bool
- func (m *GetResp) GetKv() *KV
- func (*GetResp) ProtoMessage()
- func (m *GetResp) Reset()
- func (m *GetResp) String() string
- func (m *GetResp) XXX_DiscardUnknown()
- func (m *GetResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetResp) XXX_Merge(src proto.Message)
- func (m *GetResp) XXX_Size() int
- func (m *GetResp) XXX_Unmarshal(b []byte) error
- type KV
- func (*KV) Descriptor() ([]byte, []int)
- func (m *KV) GetKey() string
- func (m *KV) GetValue() []byte
- func (*KV) ProtoMessage()
- func (m *KV) Reset()
- func (m *KV) String() string
- func (m *KV) XXX_DiscardUnknown()
- func (m *KV) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KV) XXX_Merge(src proto.Message)
- func (m *KV) XXX_Size() int
- func (m *KV) XXX_Unmarshal(b []byte) error
- type PutReq
- func (*PutReq) Descriptor() ([]byte, []int)
- func (m *PutReq) GetKv() *KV
- func (m *PutReq) GetWriteBack() bool
- func (*PutReq) ProtoMessage()
- func (m *PutReq) Reset()
- func (m *PutReq) String() string
- func (m *PutReq) XXX_DiscardUnknown()
- func (m *PutReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PutReq) XXX_Merge(src proto.Message)
- func (m *PutReq) XXX_Size() int
- func (m *PutReq) XXX_Unmarshal(b []byte) error
- type PutResp
- func (*PutResp) Descriptor() ([]byte, []int)
- func (*PutResp) ProtoMessage()
- func (m *PutResp) Reset()
- func (m *PutResp) String() string
- func (m *PutResp) XXX_DiscardUnknown()
- func (m *PutResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PutResp) XXX_Merge(src proto.Message)
- func (m *PutResp) XXX_Size() int
- func (m *PutResp) XXX_Unmarshal(b []byte) error
- type UnimplementedCacheServiceServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterCacheServiceServer ¶
func RegisterCacheServiceServer(s *grpc.Server, srv CacheServiceServer)
Types ¶
type CacheServiceClient ¶
type CacheServiceClient interface { Get(ctx context.Context, in *GetReq, opts ...grpc.CallOption) (*GetResp, error) Put(ctx context.Context, in *PutReq, opts ...grpc.CallOption) (*PutResp, error) }
CacheServiceClient is the client API for CacheService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewCacheServiceClient ¶
func NewCacheServiceClient(cc *grpc.ClientConn) CacheServiceClient
type CacheServiceServer ¶
type CacheServiceServer interface { Get(context.Context, *GetReq) (*GetResp, error) Put(context.Context, *PutReq) (*PutResp, error) }
CacheServiceServer is the server API for CacheService service.
type GetReq ¶
type GetReq struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Fast bool `protobuf:"varint,2,opt,name=fast,proto3" json:"fast,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetReq) Descriptor ¶
func (*GetReq) ProtoMessage ¶
func (*GetReq) ProtoMessage()
func (*GetReq) XXX_DiscardUnknown ¶
func (m *GetReq) XXX_DiscardUnknown()
func (*GetReq) XXX_Marshal ¶
func (*GetReq) XXX_Unmarshal ¶
type GetResp ¶
type GetResp struct { Kv *KV `protobuf:"bytes,1,opt,name=kv,proto3" json:"kv,omitempty"` InMemory bool `protobuf:"varint,2,opt,name=in_memory,json=inMemory,proto3" json:"in_memory,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetResp) Descriptor ¶
func (*GetResp) GetInMemory ¶
func (*GetResp) ProtoMessage ¶
func (*GetResp) ProtoMessage()
func (*GetResp) XXX_DiscardUnknown ¶
func (m *GetResp) XXX_DiscardUnknown()
func (*GetResp) XXX_Marshal ¶
func (*GetResp) XXX_Unmarshal ¶
type KV ¶
type KV struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*KV) Descriptor ¶
func (*KV) ProtoMessage ¶
func (*KV) ProtoMessage()
func (*KV) XXX_DiscardUnknown ¶
func (m *KV) XXX_DiscardUnknown()
func (*KV) XXX_Unmarshal ¶
type PutReq ¶
type PutReq struct { Kv *KV `protobuf:"bytes,1,opt,name=kv,proto3" json:"kv,omitempty"` WriteBack bool `protobuf:"varint,2,opt,name=write_back,json=writeBack,proto3" json:"write_back,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PutReq) Descriptor ¶
func (*PutReq) GetWriteBack ¶
func (*PutReq) ProtoMessage ¶
func (*PutReq) ProtoMessage()
func (*PutReq) XXX_DiscardUnknown ¶
func (m *PutReq) XXX_DiscardUnknown()
func (*PutReq) XXX_Marshal ¶
func (*PutReq) XXX_Unmarshal ¶
type PutResp ¶
type PutResp struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PutResp) Descriptor ¶
func (*PutResp) ProtoMessage ¶
func (*PutResp) ProtoMessage()
func (*PutResp) XXX_DiscardUnknown ¶
func (m *PutResp) XXX_DiscardUnknown()
func (*PutResp) XXX_Marshal ¶
func (*PutResp) XXX_Unmarshal ¶
type UnimplementedCacheServiceServer ¶ added in v0.0.5
type UnimplementedCacheServiceServer struct { }
UnimplementedCacheServiceServer can be embedded to have forward compatible implementations.
Click to show internal directories.
Click to hide internal directories.