Versions in this module Expand all Collapse all v0 v0.2.1 Jul 14, 2022 Changes in this version + var Event_EventType_name = map[int32]string + var Event_EventType_value = map[string]int32 + var RangeFilter_Hash_name = map[int32]string + var RangeFilter_Hash_value = map[string]int32 + func RegisterReadServer(s *grpc.Server, srv ReadServer) + func RegisterWatchServer(s *grpc.Server, srv WatchServer) + func RegisterWriteServer(s *grpc.Server, srv WriteServer) + type CompactRequest struct + Physical bool + Revision uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CompactRequest) Descriptor() ([]byte, []int) + func (*CompactRequest) ProtoMessage() + func (*CompactRequest) XXX_MessageName() string + func (m *CompactRequest) GetPhysical() bool + func (m *CompactRequest) GetRevision() uint64 + func (m *CompactRequest) Reset() + func (m *CompactRequest) Size() (n int) + func (m *CompactRequest) String() string + func (m *CompactRequest) XXX_DiscardUnknown() + func (m *CompactRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CompactRequest) XXX_Merge(src proto.Message) + func (m *CompactRequest) XXX_Size() int + func (m *CompactRequest) XXX_Unmarshal(b []byte) error + type CompactResponse struct + Header *ResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CompactResponse) Descriptor() ([]byte, []int) + func (*CompactResponse) ProtoMessage() + func (*CompactResponse) XXX_MessageName() string + func (m *CompactResponse) GetHeader() *ResponseHeader + func (m *CompactResponse) Reset() + func (m *CompactResponse) Size() (n int) + func (m *CompactResponse) String() string + func (m *CompactResponse) XXX_DiscardUnknown() + func (m *CompactResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CompactResponse) XXX_Merge(src proto.Message) + func (m *CompactResponse) XXX_Size() int + func (m *CompactResponse) XXX_Unmarshal(b []byte) error + type CountRequest struct + End []byte + Filter *RangeFilter + Key []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CountRequest) Descriptor() ([]byte, []int) + func (*CountRequest) ProtoMessage() + func (*CountRequest) XXX_MessageName() string + func (m *CountRequest) GetEnd() []byte + func (m *CountRequest) GetFilter() *RangeFilter + func (m *CountRequest) GetKey() []byte + func (m *CountRequest) Reset() + func (m *CountRequest) Size() (n int) + func (m *CountRequest) String() string + func (m *CountRequest) XXX_DiscardUnknown() + func (m *CountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CountRequest) XXX_Merge(src proto.Message) + func (m *CountRequest) XXX_Size() int + func (m *CountRequest) XXX_Unmarshal(b []byte) error + type CountResponse struct + Count uint64 + Header *ResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CountResponse) Descriptor() ([]byte, []int) + func (*CountResponse) ProtoMessage() + func (*CountResponse) XXX_MessageName() string + func (m *CountResponse) GetCount() uint64 + func (m *CountResponse) GetHeader() *ResponseHeader + func (m *CountResponse) Reset() + func (m *CountResponse) Size() (n int) + func (m *CountResponse) String() string + func (m *CountResponse) XXX_DiscardUnknown() + func (m *CountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CountResponse) XXX_Merge(src proto.Message) + func (m *CountResponse) XXX_Size() int + func (m *CountResponse) XXX_Unmarshal(b []byte) error + type CreateRequest struct + Key []byte + Lease int64 + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateRequest) Descriptor() ([]byte, []int) + func (*CreateRequest) ProtoMessage() + func (*CreateRequest) XXX_MessageName() string + func (m *CreateRequest) GetKey() []byte + func (m *CreateRequest) GetLease() int64 + func (m *CreateRequest) GetValue() []byte + func (m *CreateRequest) Reset() + func (m *CreateRequest) Size() (n int) + func (m *CreateRequest) String() string + func (m *CreateRequest) XXX_DiscardUnknown() + func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateRequest) XXX_Merge(src proto.Message) + func (m *CreateRequest) XXX_Size() int + func (m *CreateRequest) XXX_Unmarshal(b []byte) error + type CreateResponse struct + Header *ResponseHeader + Succeeded bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateResponse) Descriptor() ([]byte, []int) + func (*CreateResponse) ProtoMessage() + func (*CreateResponse) XXX_MessageName() string + func (m *CreateResponse) GetHeader() *ResponseHeader + func (m *CreateResponse) GetSucceeded() bool + func (m *CreateResponse) Reset() + func (m *CreateResponse) Size() (n int) + func (m *CreateResponse) String() string + func (m *CreateResponse) XXX_DiscardUnknown() + func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateResponse) XXX_Merge(src proto.Message) + func (m *CreateResponse) XXX_Size() int + func (m *CreateResponse) XXX_Unmarshal(b []byte) error + type DeleteRequest struct + Key []byte + Revision uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) ProtoMessage() + func (*DeleteRequest) XXX_MessageName() string + func (m *DeleteRequest) GetKey() []byte + func (m *DeleteRequest) GetRevision() uint64 + func (m *DeleteRequest) Reset() + func (m *DeleteRequest) Size() (n int) + func (m *DeleteRequest) String() string + func (m *DeleteRequest) XXX_DiscardUnknown() + func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteRequest) XXX_Merge(src proto.Message) + func (m *DeleteRequest) XXX_Size() int + func (m *DeleteRequest) XXX_Unmarshal(b []byte) error + type DeleteResponse struct + Header *ResponseHeader + Kv *KeyValue + Succeeded bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteResponse) Descriptor() ([]byte, []int) + func (*DeleteResponse) ProtoMessage() + func (*DeleteResponse) XXX_MessageName() string + func (m *DeleteResponse) GetHeader() *ResponseHeader + func (m *DeleteResponse) GetKv() *KeyValue + func (m *DeleteResponse) GetSucceeded() bool + func (m *DeleteResponse) Reset() + func (m *DeleteResponse) Size() (n int) + func (m *DeleteResponse) String() string + func (m *DeleteResponse) XXX_DiscardUnknown() + func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteResponse) XXX_Merge(src proto.Message) + func (m *DeleteResponse) XXX_Size() int + func (m *DeleteResponse) XXX_Unmarshal(b []byte) error + type Event struct + Kv *KeyValue + Revision uint64 + Type Event_EventType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (*Event) XXX_MessageName() string + func (m *Event) GetKv() *KeyValue + func (m *Event) GetRevision() uint64 + func (m *Event) GetType() Event_EventType + func (m *Event) Reset() + func (m *Event) Size() (n int) + func (m *Event) String() string + func (m *Event) XXX_DiscardUnknown() + func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Event) XXX_Merge(src proto.Message) + func (m *Event) XXX_Size() int + func (m *Event) XXX_Unmarshal(b []byte) error + type Event_EventType int32 + const Event_CREATE + const Event_DELETE + const Event_PUT + func (Event_EventType) EnumDescriptor() ([]byte, []int) + func (x Event_EventType) String() string + type GetRequest struct + Key []byte + Revision uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (*GetRequest) XXX_MessageName() string + func (m *GetRequest) GetKey() []byte + func (m *GetRequest) GetRevision() uint64 + func (m *GetRequest) Reset() + func (m *GetRequest) Size() (n int) + func (m *GetRequest) String() string + func (m *GetRequest) XXX_DiscardUnknown() + func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetRequest) XXX_Merge(src proto.Message) + func (m *GetRequest) XXX_Size() int + func (m *GetRequest) XXX_Unmarshal(b []byte) error + type GetResponse struct + Header *ResponseHeader + Kv *KeyValue + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (*GetResponse) XXX_MessageName() string + func (m *GetResponse) GetHeader() *ResponseHeader + func (m *GetResponse) GetKv() *KeyValue + func (m *GetResponse) Reset() + func (m *GetResponse) Size() (n int) + func (m *GetResponse) String() string + func (m *GetResponse) XXX_DiscardUnknown() + func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetResponse) XXX_Merge(src proto.Message) + func (m *GetResponse) XXX_Size() int + func (m *GetResponse) XXX_Unmarshal(b []byte) error + type KeyValue struct + Key []byte + Revision uint64 + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KeyValue) Descriptor() ([]byte, []int) + func (*KeyValue) ProtoMessage() + func (*KeyValue) XXX_MessageName() string + func (m *KeyValue) GetKey() []byte + func (m *KeyValue) GetRevision() uint64 + func (m *KeyValue) GetValue() []byte + func (m *KeyValue) Reset() + func (m *KeyValue) Size() (n int) + func (m *KeyValue) String() string + func (m *KeyValue) XXX_DiscardUnknown() + func (m *KeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KeyValue) XXX_Merge(src proto.Message) + func (m *KeyValue) XXX_Size() int + func (m *KeyValue) XXX_Unmarshal(b []byte) error + type ListPartitionRequest struct + End []byte + Key []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListPartitionRequest) Descriptor() ([]byte, []int) + func (*ListPartitionRequest) ProtoMessage() + func (*ListPartitionRequest) XXX_MessageName() string + func (m *ListPartitionRequest) GetEnd() []byte + func (m *ListPartitionRequest) GetKey() []byte + func (m *ListPartitionRequest) Reset() + func (m *ListPartitionRequest) Size() (n int) + func (m *ListPartitionRequest) String() string + func (m *ListPartitionRequest) XXX_DiscardUnknown() + func (m *ListPartitionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListPartitionRequest) XXX_Merge(src proto.Message) + func (m *ListPartitionRequest) XXX_Size() int + func (m *ListPartitionRequest) XXX_Unmarshal(b []byte) error + type ListPartitionResponse struct + Header *ResponseHeader + PartitionKeys [][]byte + PartitionNum int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListPartitionResponse) Descriptor() ([]byte, []int) + func (*ListPartitionResponse) ProtoMessage() + func (*ListPartitionResponse) XXX_MessageName() string + func (m *ListPartitionResponse) GetHeader() *ResponseHeader + func (m *ListPartitionResponse) GetPartitionKeys() [][]byte + func (m *ListPartitionResponse) GetPartitionNum() int64 + func (m *ListPartitionResponse) Reset() + func (m *ListPartitionResponse) Size() (n int) + func (m *ListPartitionResponse) String() string + func (m *ListPartitionResponse) XXX_DiscardUnknown() + func (m *ListPartitionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListPartitionResponse) XXX_Merge(src proto.Message) + func (m *ListPartitionResponse) XXX_Size() int + func (m *ListPartitionResponse) XXX_Unmarshal(b []byte) error + type RangeFilter struct + Hash RangeFilter_Hash + ShardCount int64 + ShardIndex int64 + TrimPrefix []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RangeFilter) Descriptor() ([]byte, []int) + func (*RangeFilter) ProtoMessage() + func (*RangeFilter) XXX_MessageName() string + func (m *RangeFilter) GetHash() RangeFilter_Hash + func (m *RangeFilter) GetShardCount() int64 + func (m *RangeFilter) GetShardIndex() int64 + func (m *RangeFilter) GetTrimPrefix() []byte + func (m *RangeFilter) Reset() + func (m *RangeFilter) Size() (n int) + func (m *RangeFilter) String() string + func (m *RangeFilter) XXX_DiscardUnknown() + func (m *RangeFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RangeFilter) XXX_Merge(src proto.Message) + func (m *RangeFilter) XXX_Size() int + func (m *RangeFilter) XXX_Unmarshal(b []byte) error + type RangeFilter_Hash int32 + const RangeFilter_MD5 + const RangeFilter_SHA1 + func (RangeFilter_Hash) EnumDescriptor() ([]byte, []int) + func (x RangeFilter_Hash) String() string + type RangeRequest struct + End []byte + Filter *RangeFilter + Key []byte + Limit int64 + Revision uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RangeRequest) Descriptor() ([]byte, []int) + func (*RangeRequest) ProtoMessage() + func (*RangeRequest) XXX_MessageName() string + func (m *RangeRequest) GetEnd() []byte + func (m *RangeRequest) GetFilter() *RangeFilter + func (m *RangeRequest) GetKey() []byte + func (m *RangeRequest) GetLimit() int64 + func (m *RangeRequest) GetRevision() uint64 + func (m *RangeRequest) Reset() + func (m *RangeRequest) Size() (n int) + func (m *RangeRequest) String() string + func (m *RangeRequest) XXX_DiscardUnknown() + func (m *RangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RangeRequest) XXX_Merge(src proto.Message) + func (m *RangeRequest) XXX_Size() int + func (m *RangeRequest) XXX_Unmarshal(b []byte) error + type RangeResponse struct + Header *ResponseHeader + Kvs []*KeyValue + More bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RangeResponse) Descriptor() ([]byte, []int) + func (*RangeResponse) ProtoMessage() + func (*RangeResponse) XXX_MessageName() string + func (m *RangeResponse) GetHeader() *ResponseHeader + func (m *RangeResponse) GetKvs() []*KeyValue + func (m *RangeResponse) GetMore() bool + func (m *RangeResponse) Reset() + func (m *RangeResponse) Size() (n int) + func (m *RangeResponse) String() string + func (m *RangeResponse) XXX_DiscardUnknown() + func (m *RangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RangeResponse) XXX_Merge(src proto.Message) + func (m *RangeResponse) XXX_Size() int + func (m *RangeResponse) XXX_Unmarshal(b []byte) error + type ReadClient interface + Count func(ctx context.Context, in *CountRequest, opts ...grpc.CallOption) (*CountResponse, error) + Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) + ListPartition func(ctx context.Context, in *ListPartitionRequest, opts ...grpc.CallOption) (*ListPartitionResponse, error) + Range func(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (*RangeResponse, error) + RangeStream func(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (Read_RangeStreamClient, error) + func NewReadClient(cc *grpc.ClientConn) ReadClient + type ReadServer interface + Count func(context.Context, *CountRequest) (*CountResponse, error) + Get func(context.Context, *GetRequest) (*GetResponse, error) + ListPartition func(context.Context, *ListPartitionRequest) (*ListPartitionResponse, error) + Range func(context.Context, *RangeRequest) (*RangeResponse, error) + RangeStream func(*RangeRequest, Read_RangeStreamServer) error + type Read_RangeStreamClient interface + Recv func() (*StreamRangeResponse, error) + type Read_RangeStreamServer interface + Send func(*StreamRangeResponse) error + type ResponseHeader struct + Revision uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResponseHeader) Descriptor() ([]byte, []int) + func (*ResponseHeader) ProtoMessage() + func (*ResponseHeader) XXX_MessageName() string + func (m *ResponseHeader) GetRevision() uint64 + func (m *ResponseHeader) Reset() + func (m *ResponseHeader) Size() (n int) + func (m *ResponseHeader) String() string + func (m *ResponseHeader) XXX_DiscardUnknown() + func (m *ResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResponseHeader) XXX_Merge(src proto.Message) + func (m *ResponseHeader) XXX_Size() int + func (m *ResponseHeader) XXX_Unmarshal(b []byte) error + type StreamRangeResponse struct + Err string + RangeResponse *RangeResponse + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamRangeResponse) Descriptor() ([]byte, []int) + func (*StreamRangeResponse) ProtoMessage() + func (*StreamRangeResponse) XXX_MessageName() string + func (m *StreamRangeResponse) GetErr() string + func (m *StreamRangeResponse) GetRangeResponse() *RangeResponse + func (m *StreamRangeResponse) Reset() + func (m *StreamRangeResponse) Size() (n int) + func (m *StreamRangeResponse) String() string + func (m *StreamRangeResponse) XXX_DiscardUnknown() + func (m *StreamRangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamRangeResponse) XXX_Merge(src proto.Message) + func (m *StreamRangeResponse) XXX_Size() int + func (m *StreamRangeResponse) XXX_Unmarshal(b []byte) error + type UnimplementedReadServer struct + func (*UnimplementedReadServer) Count(ctx context.Context, req *CountRequest) (*CountResponse, error) + func (*UnimplementedReadServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error) + func (*UnimplementedReadServer) ListPartition(ctx context.Context, req *ListPartitionRequest) (*ListPartitionResponse, error) + func (*UnimplementedReadServer) Range(ctx context.Context, req *RangeRequest) (*RangeResponse, error) + func (*UnimplementedReadServer) RangeStream(req *RangeRequest, srv Read_RangeStreamServer) error + type UnimplementedWatchServer struct + func (*UnimplementedWatchServer) Watch(req *WatchRequest, srv Watch_WatchServer) error + type UnimplementedWriteServer struct + func (*UnimplementedWriteServer) Compact(ctx context.Context, req *CompactRequest) (*CompactResponse, error) + func (*UnimplementedWriteServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error) + func (*UnimplementedWriteServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error) + func (*UnimplementedWriteServer) Update(ctx context.Context, req *UpdateRequest) (*UpdateResponse, error) + type UpdateRequest struct + Kv *KeyValue + Lease int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateRequest) Descriptor() ([]byte, []int) + func (*UpdateRequest) ProtoMessage() + func (*UpdateRequest) XXX_MessageName() string + func (m *UpdateRequest) GetKv() *KeyValue + func (m *UpdateRequest) GetLease() int64 + func (m *UpdateRequest) Reset() + func (m *UpdateRequest) Size() (n int) + func (m *UpdateRequest) String() string + func (m *UpdateRequest) XXX_DiscardUnknown() + func (m *UpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateRequest) XXX_Merge(src proto.Message) + func (m *UpdateRequest) XXX_Size() int + func (m *UpdateRequest) XXX_Unmarshal(b []byte) error + type UpdateResponse struct + Header *ResponseHeader + Kv *KeyValue + Succeeded bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateResponse) Descriptor() ([]byte, []int) + func (*UpdateResponse) ProtoMessage() + func (*UpdateResponse) XXX_MessageName() string + func (m *UpdateResponse) GetHeader() *ResponseHeader + func (m *UpdateResponse) GetKv() *KeyValue + func (m *UpdateResponse) GetSucceeded() bool + func (m *UpdateResponse) Reset() + func (m *UpdateResponse) Size() (n int) + func (m *UpdateResponse) String() string + func (m *UpdateResponse) XXX_DiscardUnknown() + func (m *UpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateResponse) XXX_Merge(src proto.Message) + func (m *UpdateResponse) XXX_Size() int + func (m *UpdateResponse) XXX_Unmarshal(b []byte) error + type WatchClient interface + Watch func(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Watch_WatchClient, error) + func NewWatchClient(cc *grpc.ClientConn) WatchClient + type WatchRequest struct + End []byte + Filter *RangeFilter + Key []byte + Revision uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchRequest) Descriptor() ([]byte, []int) + func (*WatchRequest) ProtoMessage() + func (*WatchRequest) XXX_MessageName() string + func (m *WatchRequest) GetEnd() []byte + func (m *WatchRequest) GetFilter() *RangeFilter + func (m *WatchRequest) GetKey() []byte + func (m *WatchRequest) GetRevision() uint64 + func (m *WatchRequest) Reset() + func (m *WatchRequest) Size() (n int) + func (m *WatchRequest) String() string + func (m *WatchRequest) XXX_DiscardUnknown() + func (m *WatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WatchRequest) XXX_Merge(src proto.Message) + func (m *WatchRequest) XXX_Size() int + func (m *WatchRequest) XXX_Unmarshal(b []byte) error + type WatchResponse struct + Err string + Events []*Event + Header *ResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchResponse) Descriptor() ([]byte, []int) + func (*WatchResponse) ProtoMessage() + func (*WatchResponse) XXX_MessageName() string + func (m *WatchResponse) GetErr() string + func (m *WatchResponse) GetEvents() []*Event + func (m *WatchResponse) GetHeader() *ResponseHeader + func (m *WatchResponse) Reset() + func (m *WatchResponse) Size() (n int) + func (m *WatchResponse) String() string + func (m *WatchResponse) XXX_DiscardUnknown() + func (m *WatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WatchResponse) XXX_Merge(src proto.Message) + func (m *WatchResponse) XXX_Size() int + func (m *WatchResponse) XXX_Unmarshal(b []byte) error + type WatchServer interface + Watch func(*WatchRequest, Watch_WatchServer) error + type Watch_WatchClient interface + Recv func() (*WatchResponse, error) + type Watch_WatchServer interface + Send func(*WatchResponse) error + type WriteClient interface + Compact func(ctx context.Context, in *CompactRequest, opts ...grpc.CallOption) (*CompactResponse, error) + Create func(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) + Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) + Update func(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error) + func NewWriteClient(cc *grpc.ClientConn) WriteClient + type WriteServer interface + Compact func(context.Context, *CompactRequest) (*CompactResponse, error) + Create func(context.Context, *CreateRequest) (*CreateResponse, error) + Delete func(context.Context, *DeleteRequest) (*DeleteResponse, error) + Update func(context.Context, *UpdateRequest) (*UpdateResponse, error)