Versions in this module Expand all Collapse all v0 v0.4.1 Dec 14, 2023 Changes in this version + const River_DelInBatch_FullMethodName + const River_Del_FullMethodName + const River_Exp_FullMethodName + const River_Get_FullMethodName + const River_PutInBatch_FullMethodName + const River_Put_FullMethodName + const River_Range_FullMethodName + const River_Stat_FullMethodName + const River_TTL_FullMethodName + var File_riverpb_river_proto protoreflect.FileDescriptor + var River_ServiceDesc = grpc.ServiceDesc + func RegisterRiverServer(s grpc.ServiceRegistrar, srv RiverServer) + type BatchDelOption struct + BatchSize int64 + Keys [][]byte + func (*BatchDelOption) Descriptor() ([]byte, []int) + func (*BatchDelOption) ProtoMessage() + func (x *BatchDelOption) GetBatchSize() int64 + func (x *BatchDelOption) GetKeys() [][]byte + func (x *BatchDelOption) ProtoReflect() protoreflect.Message + func (x *BatchDelOption) Reset() + func (x *BatchDelOption) String() string + type BatchPutOption struct + BatchSize int64 + Records []*Record + func (*BatchPutOption) Descriptor() ([]byte, []int) + func (*BatchPutOption) ProtoMessage() + func (x *BatchPutOption) GetBatchSize() int64 + func (x *BatchPutOption) GetRecords() []*Record + func (x *BatchPutOption) ProtoReflect() protoreflect.Message + func (x *BatchPutOption) Reset() + func (x *BatchPutOption) String() string + type BatchResult struct + Effected int64 + Ok bool + func (*BatchResult) Descriptor() ([]byte, []int) + func (*BatchResult) ProtoMessage() + func (x *BatchResult) GetEffected() int64 + func (x *BatchResult) GetOk() bool + func (x *BatchResult) ProtoReflect() protoreflect.Message + func (x *BatchResult) Reset() + func (x *BatchResult) String() string + type DataResult struct + Data []byte + Ok bool + func (*DataResult) Descriptor() ([]byte, []int) + func (*DataResult) ProtoMessage() + func (x *DataResult) GetData() []byte + func (x *DataResult) GetOk() bool + func (x *DataResult) ProtoReflect() protoreflect.Message + func (x *DataResult) Reset() + func (x *DataResult) String() string + type ExpRecord struct + Key []byte + Ttl int64 + func (*ExpRecord) Descriptor() ([]byte, []int) + func (*ExpRecord) ProtoMessage() + func (x *ExpRecord) GetKey() []byte + func (x *ExpRecord) GetTtl() int64 + func (x *ExpRecord) ProtoReflect() protoreflect.Message + func (x *ExpRecord) Reset() + func (x *ExpRecord) String() string + type InfoResult struct + Ok bool + func (*InfoResult) Descriptor() ([]byte, []int) + func (*InfoResult) ProtoMessage() + func (x *InfoResult) GetOk() bool + func (x *InfoResult) ProtoReflect() protoreflect.Message + func (x *InfoResult) Reset() + func (x *InfoResult) String() string + type RangeOption struct + Descend bool + MaxKey []byte + MinKey []byte + Pattern []byte + func (*RangeOption) Descriptor() ([]byte, []int) + func (*RangeOption) ProtoMessage() + func (x *RangeOption) GetDescend() bool + func (x *RangeOption) GetMaxKey() []byte + func (x *RangeOption) GetMinKey() []byte + func (x *RangeOption) GetPattern() []byte + func (x *RangeOption) ProtoReflect() protoreflect.Message + func (x *RangeOption) Reset() + func (x *RangeOption) String() string + type RangeResult struct + Count int64 + Keys [][]byte + func (*RangeResult) Descriptor() ([]byte, []int) + func (*RangeResult) ProtoMessage() + func (x *RangeResult) GetCount() int64 + func (x *RangeResult) GetKeys() [][]byte + func (x *RangeResult) ProtoReflect() protoreflect.Message + func (x *RangeResult) Reset() + func (x *RangeResult) String() string + type RawData struct + Data []byte + func (*RawData) Descriptor() ([]byte, []int) + func (*RawData) ProtoMessage() + func (x *RawData) GetData() []byte + func (x *RawData) ProtoReflect() protoreflect.Message + func (x *RawData) Reset() + func (x *RawData) String() string + type Record struct + Key []byte + Ttl int64 + Value []byte + func (*Record) Descriptor() ([]byte, []int) + func (*Record) ProtoMessage() + func (x *Record) GetKey() []byte + func (x *Record) GetTtl() int64 + func (x *Record) GetValue() []byte + func (x *Record) ProtoReflect() protoreflect.Message + func (x *Record) Reset() + func (x *Record) String() string + type RiverClient interface + Del func(ctx context.Context, in *RawData, opts ...grpc.CallOption) (*InfoResult, error) + DelInBatch func(ctx context.Context, in *BatchDelOption, opts ...grpc.CallOption) (*BatchResult, error) + Exp func(ctx context.Context, in *ExpRecord, opts ...grpc.CallOption) (*InfoResult, error) + Get func(ctx context.Context, in *RawData, opts ...grpc.CallOption) (*DataResult, error) + Put func(ctx context.Context, in *Record, opts ...grpc.CallOption) (*InfoResult, error) + PutInBatch func(ctx context.Context, in *BatchPutOption, opts ...grpc.CallOption) (*BatchResult, error) + Range func(ctx context.Context, in *RangeOption, opts ...grpc.CallOption) (*RangeResult, error) + Stat func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Status, error) + TTL func(ctx context.Context, in *RawData, opts ...grpc.CallOption) (*TTLResult, error) + func NewRiverClient(cc grpc.ClientConnInterface) RiverClient + type RiverServer interface + Del func(context.Context, *RawData) (*InfoResult, error) + DelInBatch func(context.Context, *BatchDelOption) (*BatchResult, error) + Exp func(context.Context, *ExpRecord) (*InfoResult, error) + Get func(context.Context, *RawData) (*DataResult, error) + Put func(context.Context, *Record) (*InfoResult, error) + PutInBatch func(context.Context, *BatchPutOption) (*BatchResult, error) + Range func(context.Context, *RangeOption) (*RangeResult, error) + Stat func(context.Context, *emptypb.Empty) (*Status, error) + TTL func(context.Context, *RawData) (*TTLResult, error) + type Status struct + Datasize int64 + Hintsize int64 + Keys int64 + Records int64 + func (*Status) Descriptor() ([]byte, []int) + func (*Status) ProtoMessage() + func (x *Status) GetDatasize() int64 + func (x *Status) GetHintsize() int64 + func (x *Status) GetKeys() int64 + func (x *Status) GetRecords() int64 + func (x *Status) ProtoReflect() protoreflect.Message + func (x *Status) Reset() + func (x *Status) String() string + type TTLResult struct + Ok bool + Ttl int64 + func (*TTLResult) Descriptor() ([]byte, []int) + func (*TTLResult) ProtoMessage() + func (x *TTLResult) GetOk() bool + func (x *TTLResult) GetTtl() int64 + func (x *TTLResult) ProtoReflect() protoreflect.Message + func (x *TTLResult) Reset() + func (x *TTLResult) String() string + type UnimplementedRiverServer struct + func (UnimplementedRiverServer) Del(context.Context, *RawData) (*InfoResult, error) + func (UnimplementedRiverServer) DelInBatch(context.Context, *BatchDelOption) (*BatchResult, error) + func (UnimplementedRiverServer) Exp(context.Context, *ExpRecord) (*InfoResult, error) + func (UnimplementedRiverServer) Get(context.Context, *RawData) (*DataResult, error) + func (UnimplementedRiverServer) Put(context.Context, *Record) (*InfoResult, error) + func (UnimplementedRiverServer) PutInBatch(context.Context, *BatchPutOption) (*BatchResult, error) + func (UnimplementedRiverServer) Range(context.Context, *RangeOption) (*RangeResult, error) + func (UnimplementedRiverServer) Stat(context.Context, *emptypb.Empty) (*Status, error) + func (UnimplementedRiverServer) TTL(context.Context, *RawData) (*TTLResult, error) + type UnsafeRiverServer interface