Versions in this module Expand all Collapse all v0 v0.2.1 Sep 17, 2021 Changes in this version + const EXPIRED + const NEVER_EXPIRED + var Change_Op_name = map[int32]string + var Change_Op_value = map[string]int32 + var EntityType_name = map[int32]string + var EntityType_value = map[string]int32 + var LogEntry_Action_name = map[int32]string + var LogEntry_Action_value = map[string]int32 + func DialWithMode(endpoints []string, mode Mode) (*grpc.ClientConn, error) + func Marshal(m proto.Message) ([]byte, error) + func Must(d []byte, err error) []byte + func MustUnmarshal(data []byte, m proto.Message) + func RegisterKVServer(s *grpc.Server, srv KVServer) + func Unmarshal(data []byte, m proto.Message) error + func WithLock(kv KVClient, lockKey string, ttl int, f func()) + type Change struct + Current *Entity + Key string + Last *Entity + Op Change_Op + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Change) Descriptor() ([]byte, []int) + func (*Change) ProtoMessage() + func (*Change) Type() watcher.ChangeType + func (m *Change) GetCurrent() *Entity + func (m *Change) GetKey() string + func (m *Change) GetLast() *Entity + func (m *Change) GetOp() Change_Op + func (m *Change) Reset() + func (m *Change) String() string + func (m *Change) Topic() string + func (m *Change) Validate() error + func (m *Change) XXX_DiscardUnknown() + func (m *Change) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Change) XXX_Merge(src proto.Message) + func (m *Change) XXX_Size() int + func (m *Change) XXX_Unmarshal(b []byte) error + type ChangeCommand struct + Change *Change + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChangeCommand) Action() LogEntry_Action + func (*ChangeCommand) Descriptor() ([]byte, []int) + func (*ChangeCommand) ProtoMessage() + func (m *ChangeCommand) GetChange() *Change + func (m *ChangeCommand) Reset() + func (m *ChangeCommand) String() string + func (m *ChangeCommand) Validate() error + func (m *ChangeCommand) XXX_DiscardUnknown() + func (m *ChangeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChangeCommand) XXX_Merge(src proto.Message) + func (m *ChangeCommand) XXX_Size() int + func (m *ChangeCommand) XXX_Unmarshal(b []byte) error + type ChangeCommandValidationError struct + func (e ChangeCommandValidationError) Cause() error + func (e ChangeCommandValidationError) Error() string + func (e ChangeCommandValidationError) ErrorName() string + func (e ChangeCommandValidationError) Field() string + func (e ChangeCommandValidationError) Key() bool + func (e ChangeCommandValidationError) Reason() string + type ChangeValidationError struct + func (e ChangeValidationError) Cause() error + func (e ChangeValidationError) Error() string + func (e ChangeValidationError) ErrorName() string + func (e ChangeValidationError) Field() string + func (e ChangeValidationError) Key() bool + func (e ChangeValidationError) Reason() string + type Change_Op int32 + const Change_Invalid + const Change_Set + const Change_Unset + func (Change_Op) EnumDescriptor() ([]byte, []int) + func (x Change_Op) String() string + type Empty struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (m *Empty) Reset() + func (m *Empty) String() string + func (m *Empty) Validate() error + func (m *Empty) XXX_DiscardUnknown() + func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Empty) XXX_Merge(src proto.Message) + func (m *Empty) XXX_Size() int + func (m *Empty) XXX_Unmarshal(b []byte) error + type EmptyValidationError struct + func (e EmptyValidationError) Cause() error + func (e EmptyValidationError) Error() string + func (e EmptyValidationError) ErrorName() string + func (e EmptyValidationError) Field() string + func (e EmptyValidationError) Key() bool + func (e EmptyValidationError) Reason() string + type Entity struct + CreatedAt int64 + Fingerprint string + Key string + Size int32 + Ttl int32 + Typ EntityType + UpdatedAt int64 + Val []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewEntityWithCreated(key string, val []byte, ttl int32, created int64) *Entity + func (*Entity) Descriptor() ([]byte, []int) + func (*Entity) ProtoMessage() + func (m *Entity) Expired() bool + func (m *Entity) GetCreatedAt() int64 + func (m *Entity) GetFingerprint() string + func (m *Entity) GetKey() string + func (m *Entity) GetSize() int32 + func (m *Entity) GetTtl() int32 + func (m *Entity) GetTyp() EntityType + func (m *Entity) GetUpdatedAt() int64 + func (m *Entity) GetVal() []byte + func (m *Entity) Reset() + func (m *Entity) String() string + func (m *Entity) Validate() error + func (m *Entity) XXX_DiscardUnknown() + func (m *Entity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Entity) XXX_Merge(src proto.Message) + func (m *Entity) XXX_Size() int + func (m *Entity) XXX_Unmarshal(b []byte) error + func (m Entity) Type() EntityType + type EntityType int32 + const EntityType_DIR + const EntityType_ELT + const EntityType_UNKNOWN + func (EntityType) EnumDescriptor() ([]byte, []int) + func (x EntityType) String() string + type EntityValidationError struct + func (e EntityValidationError) Cause() error + func (e EntityValidationError) Error() string + func (e EntityValidationError) ErrorName() string + func (e EntityValidationError) Field() string + func (e EntityValidationError) Key() bool + func (e EntityValidationError) Reason() string + type ExpireReq struct + Key string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExpireReq) Descriptor() ([]byte, []int) + func (*ExpireReq) ProtoMessage() + func (m *ExpireReq) GetKey() string + func (m *ExpireReq) Reset() + func (m *ExpireReq) String() string + func (m *ExpireReq) Validate() error + func (m *ExpireReq) XXX_DiscardUnknown() + func (m *ExpireReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExpireReq) XXX_Merge(src proto.Message) + func (m *ExpireReq) XXX_Size() int + func (m *ExpireReq) XXX_Unmarshal(b []byte) error + type ExpireReqValidationError struct + func (e ExpireReqValidationError) Cause() error + func (e ExpireReqValidationError) Error() string + func (e ExpireReqValidationError) ErrorName() string + func (e ExpireReqValidationError) Field() string + func (e ExpireReqValidationError) Key() bool + func (e ExpireReqValidationError) Reason() string + type GetKVReq struct + Key string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetKVReq) Descriptor() ([]byte, []int) + func (*GetKVReq) ProtoMessage() + func (m *GetKVReq) GetKey() string + func (m *GetKVReq) Reset() + func (m *GetKVReq) String() string + func (m *GetKVReq) Validate() error + func (m *GetKVReq) XXX_DiscardUnknown() + func (m *GetKVReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetKVReq) XXX_Merge(src proto.Message) + func (m *GetKVReq) XXX_Size() int + func (m *GetKVReq) XXX_Unmarshal(b []byte) error + type GetKVReqValidationError struct + func (e GetKVReqValidationError) Cause() error + func (e GetKVReqValidationError) Error() string + func (e GetKVReqValidationError) ErrorName() string + func (e GetKVReqValidationError) Field() string + func (e GetKVReqValidationError) Key() bool + func (e GetKVReqValidationError) Reason() string + type GetKVResp struct + Entity *Entity + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetKVResp) Descriptor() ([]byte, []int) + func (*GetKVResp) ProtoMessage() + func (m *GetKVResp) GetEntity() *Entity + func (m *GetKVResp) Reset() + func (m *GetKVResp) String() string + func (m *GetKVResp) Validate() error + func (m *GetKVResp) XXX_DiscardUnknown() + func (m *GetKVResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetKVResp) XXX_Merge(src proto.Message) + func (m *GetKVResp) XXX_Size() int + func (m *GetKVResp) XXX_Unmarshal(b []byte) error + type GetKVRespValidationError struct + func (e GetKVRespValidationError) Cause() error + func (e GetKVRespValidationError) Error() string + func (e GetKVRespValidationError) ErrorName() string + func (e GetKVRespValidationError) Field() string + func (e GetKVRespValidationError) Key() bool + func (e GetKVRespValidationError) Reason() string + type GetKVsReq struct + Keys []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetKVsReq) Descriptor() ([]byte, []int) + func (*GetKVsReq) ProtoMessage() + func (m *GetKVsReq) GetKeys() []string + func (m *GetKVsReq) Reset() + func (m *GetKVsReq) String() string + func (m *GetKVsReq) Validate() error + func (m *GetKVsReq) XXX_DiscardUnknown() + func (m *GetKVsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetKVsReq) XXX_Merge(src proto.Message) + func (m *GetKVsReq) XXX_Size() int + func (m *GetKVsReq) XXX_Unmarshal(b []byte) error + type GetKVsReqValidationError struct + func (e GetKVsReqValidationError) Cause() error + func (e GetKVsReqValidationError) Error() string + func (e GetKVsReqValidationError) ErrorName() string + func (e GetKVsReqValidationError) Field() string + func (e GetKVsReqValidationError) Key() bool + func (e GetKVsReqValidationError) Reason() string + type GetKVsResp struct + Entities []*Entity + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetKVsResp) Descriptor() ([]byte, []int) + func (*GetKVsResp) ProtoMessage() + func (m *GetKVsResp) GetEntities() []*Entity + func (m *GetKVsResp) Reset() + func (m *GetKVsResp) String() string + func (m *GetKVsResp) Validate() error + func (m *GetKVsResp) XXX_DiscardUnknown() + func (m *GetKVsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetKVsResp) XXX_Merge(src proto.Message) + func (m *GetKVsResp) XXX_Size() int + func (m *GetKVsResp) XXX_Unmarshal(b []byte) error + type GetKVsRespValidationError struct + func (e GetKVsRespValidationError) Cause() error + func (e GetKVsRespValidationError) Error() string + func (e GetKVsRespValidationError) ErrorName() string + func (e GetKVsRespValidationError) Field() string + func (e GetKVsRespValidationError) Key() bool + func (e GetKVsRespValidationError) Reason() string + type KVClient interface + Expire func(ctx context.Context, in *ExpireReq, opts ...grpc.CallOption) (*Empty, error) + GetKV func(ctx context.Context, in *GetKVReq, opts ...grpc.CallOption) (*GetKVResp, error) + GetKVs func(ctx context.Context, in *GetKVsReq, opts ...grpc.CallOption) (*GetKVsResp, error) + Range func(ctx context.Context, in *RangeReq, opts ...grpc.CallOption) (*RangeResp, error) + SetKV func(ctx context.Context, in *SetKVReq, opts ...grpc.CallOption) (*Empty, error) + TTL func(ctx context.Context, in *TtlReq, opts ...grpc.CallOption) (*TtlResp, error) + UnsetKV func(ctx context.Context, in *UnsetKVReq, opts ...grpc.CallOption) (*Empty, error) + Watch func(ctx context.Context, in *WatchReq, opts ...grpc.CallOption) (KV_WatchClient, error) + func NewKVClient(cc *grpc.ClientConn) KVClient + type KVServer interface + Expire func(context.Context, *ExpireReq) (*Empty, error) + GetKV func(context.Context, *GetKVReq) (*GetKVResp, error) + GetKVs func(context.Context, *GetKVsReq) (*GetKVsResp, error) + Range func(context.Context, *RangeReq) (*RangeResp, error) + SetKV func(context.Context, *SetKVReq) (*Empty, error) + TTL func(context.Context, *TtlReq) (*TtlResp, error) + UnsetKV func(context.Context, *UnsetKVReq) (*Empty, error) + Watch func(*WatchReq, KV_WatchServer) error + type KV_WatchClient interface + Recv func() (*Change, error) + type KV_WatchServer interface + Send func(*Change) error + type LogEntry struct + Action LogEntry_Action + Command []byte + CreatedAt int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LogEntry) Descriptor() ([]byte, []int) + func (*LogEntry) ProtoMessage() + func (m *LogEntry) Expired() bool + func (m *LogEntry) GetAction() LogEntry_Action + func (m *LogEntry) GetCommand() []byte + func (m *LogEntry) GetCreatedAt() int64 + func (m *LogEntry) Reset() + func (m *LogEntry) String() string + func (m *LogEntry) Validate() error + func (m *LogEntry) XXX_DiscardUnknown() + func (m *LogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LogEntry) XXX_Merge(src proto.Message) + func (m *LogEntry) XXX_Size() int + func (m *LogEntry) XXX_Unmarshal(b []byte) error + type LogEntryValidationError struct + func (e LogEntryValidationError) Cause() error + func (e LogEntryValidationError) Error() string + func (e LogEntryValidationError) ErrorName() string + func (e LogEntryValidationError) Field() string + func (e LogEntryValidationError) Key() bool + func (e LogEntryValidationError) Reason() string + type LogEntry_Action int32 + const LogEntry_ChangeSpread + const LogEntry_Set + const LogEntry_UNKNOWN + func (LogEntry_Action) EnumDescriptor() ([]byte, []int) + func (x LogEntry_Action) String() string + type Mode uint8 + const Mode_R + const Mode_X + type ParentDirectoryChange struct + Change *Change + SpecificTopic string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ParentDirectoryChange) Descriptor() ([]byte, []int) + func (*ParentDirectoryChange) ProtoMessage() + func (*ParentDirectoryChange) Type() watcher.ChangeType + func (m *ParentDirectoryChange) GetChange() *Change + func (m *ParentDirectoryChange) GetSpecificTopic() string + func (m *ParentDirectoryChange) Reset() + func (m *ParentDirectoryChange) String() string + func (m *ParentDirectoryChange) Topic() string + func (m *ParentDirectoryChange) Validate() error + func (m *ParentDirectoryChange) XXX_DiscardUnknown() + func (m *ParentDirectoryChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ParentDirectoryChange) XXX_Merge(src proto.Message) + func (m *ParentDirectoryChange) XXX_Size() int + func (m *ParentDirectoryChange) XXX_Unmarshal(b []byte) error + type ParentDirectoryChangeValidationError struct + func (e ParentDirectoryChangeValidationError) Cause() error + func (e ParentDirectoryChangeValidationError) Error() string + func (e ParentDirectoryChangeValidationError) ErrorName() string + func (e ParentDirectoryChangeValidationError) Field() string + func (e ParentDirectoryChangeValidationError) Key() bool + func (e ParentDirectoryChangeValidationError) Reason() string + type Propose struct + Entry *LogEntry + ErrC chan<- error + func NewPropose(entry *LogEntry, errC chan<- error) *Propose + type RangeReq struct + Key string + Limit int32 + Seek string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RangeReq) Descriptor() ([]byte, []int) + func (*RangeReq) ProtoMessage() + func (m *RangeReq) GetKey() string + func (m *RangeReq) GetLimit() int32 + func (m *RangeReq) GetSeek() string + func (m *RangeReq) Reset() + func (m *RangeReq) String() string + func (m *RangeReq) Validate() error + func (m *RangeReq) XXX_DiscardUnknown() + func (m *RangeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RangeReq) XXX_Merge(src proto.Message) + func (m *RangeReq) XXX_Size() int + func (m *RangeReq) XXX_Unmarshal(b []byte) error + type RangeReqValidationError struct + func (e RangeReqValidationError) Cause() error + func (e RangeReqValidationError) Error() string + func (e RangeReqValidationError) ErrorName() string + func (e RangeReqValidationError) Field() string + func (e RangeReqValidationError) Key() bool + func (e RangeReqValidationError) Reason() string + type RangeResp struct + Entities []*Entity + HasMore bool + NextSeekKey string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RangeResp) Descriptor() ([]byte, []int) + func (*RangeResp) ProtoMessage() + func (m *RangeResp) GetEntities() []*Entity + func (m *RangeResp) GetHasMore() bool + func (m *RangeResp) GetNextSeekKey() string + func (m *RangeResp) Reset() + func (m *RangeResp) String() string + func (m *RangeResp) Validate() error + func (m *RangeResp) XXX_DiscardUnknown() + func (m *RangeResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RangeResp) XXX_Merge(src proto.Message) + func (m *RangeResp) XXX_Size() int + func (m *RangeResp) XXX_Unmarshal(b []byte) error + type RangeRespValidationError struct + func (e RangeRespValidationError) Cause() error + func (e RangeRespValidationError) Error() string + func (e RangeRespValidationError) ErrorName() string + func (e RangeRespValidationError) Field() string + func (e RangeRespValidationError) Key() bool + func (e RangeRespValidationError) Reason() string + type SetCommand struct + DeleteKey string + IsDir bool + SetKey string + Value *Entity + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetCommand) Action() LogEntry_Action + func (*SetCommand) Descriptor() ([]byte, []int) + func (*SetCommand) ProtoMessage() + func (m *SetCommand) GetDeleteKey() string + func (m *SetCommand) GetIsDir() bool + func (m *SetCommand) GetSetKey() string + func (m *SetCommand) GetValue() *Entity + func (m *SetCommand) Reset() + func (m *SetCommand) String() string + func (m *SetCommand) Validate() error + func (m *SetCommand) XXX_DiscardUnknown() + func (m *SetCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetCommand) XXX_Merge(src proto.Message) + func (m *SetCommand) XXX_Size() int + func (m *SetCommand) XXX_Unmarshal(b []byte) error + type SetCommandValidationError struct + func (e SetCommandValidationError) Cause() error + func (e SetCommandValidationError) Error() string + func (e SetCommandValidationError) ErrorName() string + func (e SetCommandValidationError) Field() string + func (e SetCommandValidationError) Key() bool + func (e SetCommandValidationError) Reason() string + type SetKVReq struct + IsDir bool + Key string + Overwrite bool + Ttl int32 + Val []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetKVReq) Descriptor() ([]byte, []int) + func (*SetKVReq) ProtoMessage() + func (m *SetKVReq) GetIsDir() bool + func (m *SetKVReq) GetKey() string + func (m *SetKVReq) GetOverwrite() bool + func (m *SetKVReq) GetTtl() int32 + func (m *SetKVReq) GetVal() []byte + func (m *SetKVReq) Reset() + func (m *SetKVReq) String() string + func (m *SetKVReq) Validate() error + func (m *SetKVReq) XXX_DiscardUnknown() + func (m *SetKVReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetKVReq) XXX_Merge(src proto.Message) + func (m *SetKVReq) XXX_Size() int + func (m *SetKVReq) XXX_Unmarshal(b []byte) error + type SetKVReqValidationError struct + func (e SetKVReqValidationError) Cause() error + func (e SetKVReqValidationError) Error() string + func (e SetKVReqValidationError) ErrorName() string + func (e SetKVReqValidationError) Field() string + func (e SetKVReqValidationError) Key() bool + func (e SetKVReqValidationError) Reason() string + type TtlReq struct + Key string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TtlReq) Descriptor() ([]byte, []int) + func (*TtlReq) ProtoMessage() + func (m *TtlReq) GetKey() string + func (m *TtlReq) Reset() + func (m *TtlReq) String() string + func (m *TtlReq) Validate() error + func (m *TtlReq) XXX_DiscardUnknown() + func (m *TtlReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TtlReq) XXX_Merge(src proto.Message) + func (m *TtlReq) XXX_Size() int + func (m *TtlReq) XXX_Unmarshal(b []byte) error + type TtlReqValidationError struct + func (e TtlReqValidationError) Cause() error + func (e TtlReqValidationError) Error() string + func (e TtlReqValidationError) ErrorName() string + func (e TtlReqValidationError) Field() string + func (e TtlReqValidationError) Key() bool + func (e TtlReqValidationError) Reason() string + type TtlResp struct + Ttl int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TtlResp) Descriptor() ([]byte, []int) + func (*TtlResp) ProtoMessage() + func (m *TtlResp) GetTtl() int32 + func (m *TtlResp) Reset() + func (m *TtlResp) String() string + func (m *TtlResp) Validate() error + func (m *TtlResp) XXX_DiscardUnknown() + func (m *TtlResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TtlResp) XXX_Merge(src proto.Message) + func (m *TtlResp) XXX_Size() int + func (m *TtlResp) XXX_Unmarshal(b []byte) error + type TtlRespValidationError struct + func (e TtlRespValidationError) Cause() error + func (e TtlRespValidationError) Error() string + func (e TtlRespValidationError) ErrorName() string + func (e TtlRespValidationError) Field() string + func (e TtlRespValidationError) Key() bool + func (e TtlRespValidationError) Reason() string + type UnimplementedKVServer struct + func (*UnimplementedKVServer) Expire(ctx context.Context, req *ExpireReq) (*Empty, error) + func (*UnimplementedKVServer) GetKV(ctx context.Context, req *GetKVReq) (*GetKVResp, error) + func (*UnimplementedKVServer) GetKVs(ctx context.Context, req *GetKVsReq) (*GetKVsResp, error) + func (*UnimplementedKVServer) Range(ctx context.Context, req *RangeReq) (*RangeResp, error) + func (*UnimplementedKVServer) SetKV(ctx context.Context, req *SetKVReq) (*Empty, error) + func (*UnimplementedKVServer) TTL(ctx context.Context, req *TtlReq) (*TtlResp, error) + func (*UnimplementedKVServer) UnsetKV(ctx context.Context, req *UnsetKVReq) (*Empty, error) + func (*UnimplementedKVServer) Watch(req *WatchReq, srv KV_WatchServer) error + type UnsetKVReq struct + IsDir bool + Key string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UnsetKVReq) Descriptor() ([]byte, []int) + func (*UnsetKVReq) ProtoMessage() + func (m *UnsetKVReq) GetIsDir() bool + func (m *UnsetKVReq) GetKey() string + func (m *UnsetKVReq) Reset() + func (m *UnsetKVReq) String() string + func (m *UnsetKVReq) Validate() error + func (m *UnsetKVReq) XXX_DiscardUnknown() + func (m *UnsetKVReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UnsetKVReq) XXX_Merge(src proto.Message) + func (m *UnsetKVReq) XXX_Size() int + func (m *UnsetKVReq) XXX_Unmarshal(b []byte) error + type UnsetKVReqValidationError struct + func (e UnsetKVReqValidationError) Cause() error + func (e UnsetKVReqValidationError) Error() string + func (e UnsetKVReqValidationError) ErrorName() string + func (e UnsetKVReqValidationError) Field() string + func (e UnsetKVReqValidationError) Key() bool + func (e UnsetKVReqValidationError) Reason() string + type WatchReq struct + Keys []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchReq) Descriptor() ([]byte, []int) + func (*WatchReq) ProtoMessage() + func (m *WatchReq) GetKeys() []string + func (m *WatchReq) Reset() + func (m *WatchReq) String() string + func (m *WatchReq) Validate() error + func (m *WatchReq) XXX_DiscardUnknown() + func (m *WatchReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WatchReq) XXX_Merge(src proto.Message) + func (m *WatchReq) XXX_Size() int + func (m *WatchReq) XXX_Unmarshal(b []byte) error + type WatchReqValidationError struct + func (e WatchReqValidationError) Cause() error + func (e WatchReqValidationError) Error() string + func (e WatchReqValidationError) ErrorName() string + func (e WatchReqValidationError) Field() string + func (e WatchReqValidationError) Key() bool + func (e WatchReqValidationError) Reason() string v0.2.0-rc2 Aug 30, 2021
Go to main page