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 ¶
- func RegisterKvsServer(s *grpc.Server, srv KvsServer)
- type DeleteResponse
- type Entry
- type Key
- type KvsClient
- type KvsServer
- type Kvs_ListClient
- type Kvs_ListServer
- type ListRequest
- type PutResponse
- type Value
- func (*Value) Descriptor() ([]byte, []int)
- func (m *Value) GetDataKey() string
- func (m *Value) GetDataShares() []string
- func (m *Value) GetField() string
- func (m *Value) GetGroupKey() string
- func (m *Value) GetGroupShares() []string
- func (*Value) ProtoMessage()
- func (m *Value) Reset()
- func (m *Value) String() string
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 { Field string `protobuf:"bytes,1,opt,name=field" json:"field,omitempty"` GroupKey string `protobuf:"bytes,2,opt,name=group_key,json=groupKey" json:"group_key,omitempty"` DataKey string `protobuf:"bytes,4,opt,name=data_key,json=dataKey" json:"data_key,omitempty"` }
Value represents a share in CGSS.
func (*Value) Descriptor ¶
func (*Value) GetDataKey ¶
func (*Value) GetDataShares ¶
func (*Value) GetGroupKey ¶
func (*Value) GetGroupShares ¶
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.