Documentation ¶
Overview ¶
Package kvs is a generated protocol buffer package.
It is generated from these files:
kvs/kvs.proto
It has these top-level messages:
Key Value Entry PutResponse DeleteResponse ListRequest
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterKvsServer ¶
Types ¶
type DeleteResponse ¶
type DeleteResponse struct { }
func (*DeleteResponse) Descriptor ¶
func (*DeleteResponse) Descriptor() ([]byte, []int)
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) Reset ¶
func (m *DeleteResponse) Reset()
func (*DeleteResponse) String ¶
func (m *DeleteResponse) String() string
type Entry ¶
type Entry struct { Key *Key `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` Value *Value `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"` }
Entry defines a pair of key and value as an entry in the KVS.
func (*Entry) Descriptor ¶
func (*Entry) ProtoMessage ¶
func (*Entry) ProtoMessage()
type Key ¶
type Key struct {
Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}
Key defines a simple key in the KVS.
func (*Key) Descriptor ¶
func (*Key) ProtoMessage ¶
func (*Key) ProtoMessage()
type KvsClient ¶
type KvsClient interface { Get(ctx context.Context, in *Key, opts ...grpc.CallOption) (*Value, error) Put(ctx context.Context, in *Entry, opts ...grpc.CallOption) (*PutResponse, error) Delete(ctx context.Context, in *Key, opts ...grpc.CallOption) (*DeleteResponse, error) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (Kvs_ListClient, error) }
func NewKvsClient ¶
func NewKvsClient(cc *grpc.ClientConn) KvsClient
type KvsServer ¶
type KvsServer interface { Get(context.Context, *Key) (*Value, error) Put(context.Context, *Entry) (*PutResponse, error) Delete(context.Context, *Key) (*DeleteResponse, error) List(*ListRequest, Kvs_ListServer) error }
type Kvs_ListClient ¶
type Kvs_ListClient interface { Recv() (*Key, error) grpc.ClientStream }
type Kvs_ListServer ¶
type Kvs_ListServer interface { Send(*Key) error grpc.ServerStream }
type ListRequest ¶
type ListRequest struct { }
func (*ListRequest) Descriptor ¶
func (*ListRequest) Descriptor() ([]byte, []int)
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) Reset ¶
func (m *ListRequest) Reset()
func (*ListRequest) String ¶
func (m *ListRequest) String() string
type PutResponse ¶
type PutResponse struct { }
Define empty requests/responses.
func (*PutResponse) Descriptor ¶
func (*PutResponse) Descriptor() ([]byte, []int)
func (*PutResponse) ProtoMessage ¶
func (*PutResponse) ProtoMessage()
func (*PutResponse) Reset ¶
func (m *PutResponse) Reset()
func (*PutResponse) String ¶
func (m *PutResponse) String() string
type Value ¶
type Value struct {
Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}
Value represents a share in SSS.
func (*Value) Descriptor ¶
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.