Versions in this module Expand all Collapse all v1 v1.0.8 Jul 13, 2023 Changes in this version + type AppendRequest struct + Expire int64 + Key string + Value string + func (*AppendRequest) Descriptor() ([]byte, []int) + func (*AppendRequest) ProtoMessage() + func (x *AppendRequest) GetExpire() int64 + func (x *AppendRequest) GetKey() string + func (x *AppendRequest) GetValue() string + func (x *AppendRequest) ProtoReflect() protoreflect.Message + func (x *AppendRequest) Reset() + func (x *AppendRequest) String() string + type AppendResponse struct + Ok bool + func (*AppendResponse) Descriptor() ([]byte, []int) + func (*AppendResponse) ProtoMessage() + func (x *AppendResponse) GetOk() bool + func (x *AppendResponse) ProtoReflect() protoreflect.Message + func (x *AppendResponse) Reset() + func (x *AppendResponse) String() string + type DecrByRequest struct + Amount int32 + Expire int64 + Key string + func (*DecrByRequest) Descriptor() ([]byte, []int) + func (*DecrByRequest) ProtoMessage() + func (x *DecrByRequest) GetAmount() int32 + func (x *DecrByRequest) GetExpire() int64 + func (x *DecrByRequest) GetKey() string + func (x *DecrByRequest) ProtoReflect() protoreflect.Message + func (x *DecrByRequest) Reset() + func (x *DecrByRequest) String() string + type DecrByResponse struct + Ok bool + func (*DecrByResponse) Descriptor() ([]byte, []int) + func (*DecrByResponse) ProtoMessage() + func (x *DecrByResponse) GetOk() bool + func (x *DecrByResponse) ProtoReflect() protoreflect.Message + func (x *DecrByResponse) Reset() + func (x *DecrByResponse) String() string + type DecrRequest struct + Expire int64 + Key string + func (*DecrRequest) Descriptor() ([]byte, []int) + func (*DecrRequest) ProtoMessage() + func (x *DecrRequest) GetExpire() int64 + func (x *DecrRequest) GetKey() string + func (x *DecrRequest) ProtoReflect() protoreflect.Message + func (x *DecrRequest) Reset() + func (x *DecrRequest) String() string + type DecrResponse struct + Ok bool + func (*DecrResponse) Descriptor() ([]byte, []int) + func (*DecrResponse) ProtoMessage() + func (x *DecrResponse) GetOk() bool + func (x *DecrResponse) ProtoReflect() protoreflect.Message + func (x *DecrResponse) Reset() + func (x *DecrResponse) String() string + type ExistsRequest struct + Key string + func (*ExistsRequest) Descriptor() ([]byte, []int) + func (*ExistsRequest) ProtoMessage() + func (x *ExistsRequest) GetKey() string + func (x *ExistsRequest) ProtoReflect() protoreflect.Message + func (x *ExistsRequest) Reset() + func (x *ExistsRequest) String() string + type ExistsResponse struct + Exists bool + func (*ExistsResponse) Descriptor() ([]byte, []int) + func (*ExistsResponse) ProtoMessage() + func (x *ExistsResponse) GetExists() bool + func (x *ExistsResponse) ProtoReflect() protoreflect.Message + func (x *ExistsResponse) Reset() + func (x *ExistsResponse) String() string + type ExpireRequest struct + Expire int64 + Key string + func (*ExpireRequest) Descriptor() ([]byte, []int) + func (*ExpireRequest) ProtoMessage() + func (x *ExpireRequest) GetExpire() int64 + func (x *ExpireRequest) GetKey() string + func (x *ExpireRequest) ProtoReflect() protoreflect.Message + func (x *ExpireRequest) Reset() + func (x *ExpireRequest) String() string + type ExpireResponse struct + Ok bool + func (*ExpireResponse) Descriptor() ([]byte, []int) + func (*ExpireResponse) ProtoMessage() + func (x *ExpireResponse) GetOk() bool + func (x *ExpireResponse) ProtoReflect() protoreflect.Message + func (x *ExpireResponse) Reset() + func (x *ExpireResponse) String() string type FlyDBServiceClient + Append func(ctx context.Context, in *AppendRequest, opts ...grpc.CallOption) (*AppendResponse, error) + Decr func(ctx context.Context, in *DecrRequest, opts ...grpc.CallOption) (*DecrResponse, error) + DecrBy func(ctx context.Context, in *DecrByRequest, opts ...grpc.CallOption) (*DecrByResponse, error) + Exists func(ctx context.Context, in *ExistsRequest, opts ...grpc.CallOption) (*ExistsResponse, error) + Expire func(ctx context.Context, in *ExpireRequest, opts ...grpc.CallOption) (*ExpireResponse, error) + GetSet func(ctx context.Context, in *GetSetRequest, opts ...grpc.CallOption) (*GetSetResponse, error) + Incr func(ctx context.Context, in *IncrRequest, opts ...grpc.CallOption) (*IncrResponse, error) + IncrBy func(ctx context.Context, in *IncrByRequest, opts ...grpc.CallOption) (*IncrByResponse, error) + IncrByFloat func(ctx context.Context, in *IncrByFloatRequest, opts ...grpc.CallOption) (*IncrByFloatResponse, error) + Persist func(ctx context.Context, in *PersistRequest, opts ...grpc.CallOption) (*PersistResponse, error) + StrLen func(ctx context.Context, in *StrLenRequest, opts ...grpc.CallOption) (*StrLenResponse, error) + Type func(ctx context.Context, in *TypeRequest, opts ...grpc.CallOption) (*TypeResponse, error) type FlyDBServiceServer + Append func(context.Context, *AppendRequest) (*AppendResponse, error) + Decr func(context.Context, *DecrRequest) (*DecrResponse, error) + DecrBy func(context.Context, *DecrByRequest) (*DecrByResponse, error) + Exists func(context.Context, *ExistsRequest) (*ExistsResponse, error) + Expire func(context.Context, *ExpireRequest) (*ExpireResponse, error) + GetSet func(context.Context, *GetSetRequest) (*GetSetResponse, error) + Incr func(context.Context, *IncrRequest) (*IncrResponse, error) + IncrBy func(context.Context, *IncrByRequest) (*IncrByResponse, error) + IncrByFloat func(context.Context, *IncrByFloatRequest) (*IncrByFloatResponse, error) + Persist func(context.Context, *PersistRequest) (*PersistResponse, error) + StrLen func(context.Context, *StrLenRequest) (*StrLenResponse, error) + Type func(context.Context, *TypeRequest) (*TypeResponse, error) + type GetSetRequest struct + Expire int64 + Key string + Value isGetSetRequest_Value + func (*GetSetRequest) Descriptor() ([]byte, []int) + func (*GetSetRequest) ProtoMessage() + func (m *GetSetRequest) GetValue() isGetSetRequest_Value + func (x *GetSetRequest) GetBoolValue() bool + func (x *GetSetRequest) GetBytesValue() []byte + func (x *GetSetRequest) GetExpire() int64 + func (x *GetSetRequest) GetFloat32Value() float32 + func (x *GetSetRequest) GetFloat64Value() float64 + func (x *GetSetRequest) GetInt32Value() int32 + func (x *GetSetRequest) GetInt64Value() int64 + func (x *GetSetRequest) GetKey() string + func (x *GetSetRequest) GetStringValue() string + func (x *GetSetRequest) ProtoReflect() protoreflect.Message + func (x *GetSetRequest) Reset() + func (x *GetSetRequest) String() string + type GetSetRequest_BoolValue struct + BoolValue bool + type GetSetRequest_BytesValue struct + BytesValue []byte + type GetSetRequest_Float32Value struct + Float32Value float32 + type GetSetRequest_Float64Value struct + Float64Value float64 + type GetSetRequest_Int32Value struct + Int32Value int32 + type GetSetRequest_Int64Value struct + Int64Value int64 + type GetSetRequest_StringValue struct + StringValue string + type GetSetResponse struct + Value isGetSetResponse_Value + func (*GetSetResponse) Descriptor() ([]byte, []int) + func (*GetSetResponse) ProtoMessage() + func (m *GetSetResponse) GetValue() isGetSetResponse_Value + func (x *GetSetResponse) GetBoolValue() bool + func (x *GetSetResponse) GetBytesValue() []byte + func (x *GetSetResponse) GetFloat32Value() float32 + func (x *GetSetResponse) GetFloat64Value() float64 + func (x *GetSetResponse) GetInt32Value() int32 + func (x *GetSetResponse) GetInt64Value() int64 + func (x *GetSetResponse) GetStringValue() string + func (x *GetSetResponse) ProtoReflect() protoreflect.Message + func (x *GetSetResponse) Reset() + func (x *GetSetResponse) String() string + type GetSetResponse_BoolValue struct + BoolValue bool + type GetSetResponse_BytesValue struct + BytesValue []byte + type GetSetResponse_Float32Value struct + Float32Value float32 + type GetSetResponse_Float64Value struct + Float64Value float64 + type GetSetResponse_Int32Value struct + Int32Value int32 + type GetSetResponse_Int64Value struct + Int64Value int64 + type GetSetResponse_StringValue struct + StringValue string + type IncrByFloatRequest struct + Amount float64 + Expire int64 + Key string + func (*IncrByFloatRequest) Descriptor() ([]byte, []int) + func (*IncrByFloatRequest) ProtoMessage() + func (x *IncrByFloatRequest) GetAmount() float64 + func (x *IncrByFloatRequest) GetExpire() int64 + func (x *IncrByFloatRequest) GetKey() string + func (x *IncrByFloatRequest) ProtoReflect() protoreflect.Message + func (x *IncrByFloatRequest) Reset() + func (x *IncrByFloatRequest) String() string + type IncrByFloatResponse struct + Ok bool + func (*IncrByFloatResponse) Descriptor() ([]byte, []int) + func (*IncrByFloatResponse) ProtoMessage() + func (x *IncrByFloatResponse) GetOk() bool + func (x *IncrByFloatResponse) ProtoReflect() protoreflect.Message + func (x *IncrByFloatResponse) Reset() + func (x *IncrByFloatResponse) String() string + type IncrByRequest struct + Amount int32 + Expire int64 + Key string + func (*IncrByRequest) Descriptor() ([]byte, []int) + func (*IncrByRequest) ProtoMessage() + func (x *IncrByRequest) GetAmount() int32 + func (x *IncrByRequest) GetExpire() int64 + func (x *IncrByRequest) GetKey() string + func (x *IncrByRequest) ProtoReflect() protoreflect.Message + func (x *IncrByRequest) Reset() + func (x *IncrByRequest) String() string + type IncrByResponse struct + Ok bool + func (*IncrByResponse) Descriptor() ([]byte, []int) + func (*IncrByResponse) ProtoMessage() + func (x *IncrByResponse) GetOk() bool + func (x *IncrByResponse) ProtoReflect() protoreflect.Message + func (x *IncrByResponse) Reset() + func (x *IncrByResponse) String() string + type IncrRequest struct + Expire int64 + Key string + func (*IncrRequest) Descriptor() ([]byte, []int) + func (*IncrRequest) ProtoMessage() + func (x *IncrRequest) GetExpire() int64 + func (x *IncrRequest) GetKey() string + func (x *IncrRequest) ProtoReflect() protoreflect.Message + func (x *IncrRequest) Reset() + func (x *IncrRequest) String() string + type IncrResponse struct + Ok bool + func (*IncrResponse) Descriptor() ([]byte, []int) + func (*IncrResponse) ProtoMessage() + func (x *IncrResponse) GetOk() bool + func (x *IncrResponse) ProtoReflect() protoreflect.Message + func (x *IncrResponse) Reset() + func (x *IncrResponse) String() string + type PersistRequest struct + Key string + func (*PersistRequest) Descriptor() ([]byte, []int) + func (*PersistRequest) ProtoMessage() + func (x *PersistRequest) GetKey() string + func (x *PersistRequest) ProtoReflect() protoreflect.Message + func (x *PersistRequest) Reset() + func (x *PersistRequest) String() string + type PersistResponse struct + Ok bool + func (*PersistResponse) Descriptor() ([]byte, []int) + func (*PersistResponse) ProtoMessage() + func (x *PersistResponse) GetOk() bool + func (x *PersistResponse) ProtoReflect() protoreflect.Message + func (x *PersistResponse) Reset() + func (x *PersistResponse) String() string + type StrLenRequest struct + Key string + func (*StrLenRequest) Descriptor() ([]byte, []int) + func (*StrLenRequest) ProtoMessage() + func (x *StrLenRequest) GetKey() string + func (x *StrLenRequest) ProtoReflect() protoreflect.Message + func (x *StrLenRequest) Reset() + func (x *StrLenRequest) String() string + type StrLenResponse struct + Length int32 + func (*StrLenResponse) Descriptor() ([]byte, []int) + func (*StrLenResponse) ProtoMessage() + func (x *StrLenResponse) GetLength() int32 + func (x *StrLenResponse) ProtoReflect() protoreflect.Message + func (x *StrLenResponse) Reset() + func (x *StrLenResponse) String() string + type TypeRequest struct + Key string + func (*TypeRequest) Descriptor() ([]byte, []int) + func (*TypeRequest) ProtoMessage() + func (x *TypeRequest) GetKey() string + func (x *TypeRequest) ProtoReflect() protoreflect.Message + func (x *TypeRequest) Reset() + func (x *TypeRequest) String() string + type TypeResponse struct + Type string + func (*TypeResponse) Descriptor() ([]byte, []int) + func (*TypeResponse) ProtoMessage() + func (x *TypeResponse) GetType() string + func (x *TypeResponse) ProtoReflect() protoreflect.Message + func (x *TypeResponse) Reset() + func (x *TypeResponse) String() string type UnimplementedFlyDBServiceServer + func (UnimplementedFlyDBServiceServer) Append(context.Context, *AppendRequest) (*AppendResponse, error) + func (UnimplementedFlyDBServiceServer) Decr(context.Context, *DecrRequest) (*DecrResponse, error) + func (UnimplementedFlyDBServiceServer) DecrBy(context.Context, *DecrByRequest) (*DecrByResponse, error) + func (UnimplementedFlyDBServiceServer) Exists(context.Context, *ExistsRequest) (*ExistsResponse, error) + func (UnimplementedFlyDBServiceServer) Expire(context.Context, *ExpireRequest) (*ExpireResponse, error) + func (UnimplementedFlyDBServiceServer) GetSet(context.Context, *GetSetRequest) (*GetSetResponse, error) + func (UnimplementedFlyDBServiceServer) Incr(context.Context, *IncrRequest) (*IncrResponse, error) + func (UnimplementedFlyDBServiceServer) IncrBy(context.Context, *IncrByRequest) (*IncrByResponse, error) + func (UnimplementedFlyDBServiceServer) IncrByFloat(context.Context, *IncrByFloatRequest) (*IncrByFloatResponse, error) + func (UnimplementedFlyDBServiceServer) Persist(context.Context, *PersistRequest) (*PersistResponse, error) + func (UnimplementedFlyDBServiceServer) StrLen(context.Context, *StrLenRequest) (*StrLenResponse, error) + func (UnimplementedFlyDBServiceServer) Type(context.Context, *TypeRequest) (*TypeResponse, error) v1.0.7 Jul 11, 2023 Changes in this version type GetResponse + func (x *GetResponse) GetBoolValue() bool + func (x *GetResponse) GetBytesValue() []byte + func (x *GetResponse) GetFloat32Value() float32 + func (x *GetResponse) GetFloat64Value() float64 + func (x *GetResponse) GetInt32Value() int32 + func (x *GetResponse) GetInt64Value() int64 + func (x *GetResponse) GetStringValue() string + type GetResponse_BoolValue struct + BoolValue bool + type GetResponse_BytesValue struct + BytesValue []byte + type GetResponse_Float32Value struct + Float32Value float32 + type GetResponse_Float64Value struct + Float64Value float64 + type GetResponse_Int32Value struct + Int32Value int32 + type GetResponse_Int64Value struct + Int64Value int64 + type GetResponse_StringValue struct + StringValue string + type SetRequest struct + Expire int64 + Key string + Value isSetRequest_Value + func (*SetRequest) Descriptor() ([]byte, []int) + func (*SetRequest) ProtoMessage() + func (m *SetRequest) GetValue() isSetRequest_Value + func (x *SetRequest) GetBoolValue() bool + func (x *SetRequest) GetBytesValue() []byte + func (x *SetRequest) GetExpire() int64 + func (x *SetRequest) GetFloat32Value() float32 + func (x *SetRequest) GetFloat64Value() float64 + func (x *SetRequest) GetInt32Value() int32 + func (x *SetRequest) GetInt64Value() int64 + func (x *SetRequest) GetKey() string + func (x *SetRequest) GetStringValue() string + func (x *SetRequest) ProtoReflect() protoreflect.Message + func (x *SetRequest) Reset() + func (x *SetRequest) String() string + type SetRequest_BoolValue struct + BoolValue bool + type SetRequest_BytesValue struct + BytesValue []byte + type SetRequest_Float32Value struct + Float32Value float32 + type SetRequest_Float64Value struct + Float64Value float64 + type SetRequest_Int32Value struct + Int32Value int32 + type SetRequest_Int64Value struct + Int64Value int64 + type SetRequest_StringValue struct + StringValue string + type SetResponse struct + Ok bool + func (*SetResponse) Descriptor() ([]byte, []int) + func (*SetResponse) ProtoMessage() + func (x *SetResponse) GetOk() bool + func (x *SetResponse) ProtoReflect() protoreflect.Message + func (x *SetResponse) Reset() + func (x *SetResponse) String() string v1.0.6 Jul 7, 2023 Changes in this version + var File_lib_proto_dbs_db_proto protoreflect.FileDescriptor + var FlyDBService_ServiceDesc = grpc.ServiceDesc + func RegisterFlyDBServiceServer(s grpc.ServiceRegistrar, srv FlyDBServiceServer) + type DelRequest struct + Key []byte + func (*DelRequest) Descriptor() ([]byte, []int) + func (*DelRequest) ProtoMessage() + func (x *DelRequest) GetKey() []byte + func (x *DelRequest) ProtoReflect() protoreflect.Message + func (x *DelRequest) Reset() + func (x *DelRequest) String() string + type DelResponse struct + Ok bool + func (*DelResponse) Descriptor() ([]byte, []int) + func (*DelResponse) ProtoMessage() + func (x *DelResponse) GetOk() bool + func (x *DelResponse) ProtoReflect() protoreflect.Message + func (x *DelResponse) Reset() + func (x *DelResponse) String() string + type FlyDBServiceClient interface + Del func(ctx context.Context, in *DelRequest, opts ...grpc.CallOption) (*DelResponse, error) + Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) + Keys func(ctx context.Context, in *KeysRequest, opts ...grpc.CallOption) (*KeysResponse, error) + Put func(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error) + func NewFlyDBServiceClient(cc grpc.ClientConnInterface) FlyDBServiceClient + type FlyDBServiceServer interface + Del func(context.Context, *DelRequest) (*DelResponse, error) + Get func(context.Context, *GetRequest) (*GetResponse, error) + Keys func(context.Context, *KeysRequest) (*KeysResponse, error) + Put func(context.Context, *PutRequest) (*PutResponse, error) + type GetRequest struct + Key []byte + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (x *GetRequest) GetKey() []byte + func (x *GetRequest) ProtoReflect() protoreflect.Message + func (x *GetRequest) Reset() + func (x *GetRequest) String() string + type GetResponse struct + Value []byte + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (x *GetResponse) GetValue() []byte + func (x *GetResponse) ProtoReflect() protoreflect.Message + func (x *GetResponse) Reset() + func (x *GetResponse) String() string + type KeysRequest struct + Pattern []byte + func (*KeysRequest) Descriptor() ([]byte, []int) + func (*KeysRequest) ProtoMessage() + func (x *KeysRequest) GetPattern() []byte + func (x *KeysRequest) ProtoReflect() protoreflect.Message + func (x *KeysRequest) Reset() + func (x *KeysRequest) String() string + type KeysResponse struct + Keys [][]byte + func (*KeysResponse) Descriptor() ([]byte, []int) + func (*KeysResponse) ProtoMessage() + func (x *KeysResponse) GetKeys() [][]byte + func (x *KeysResponse) ProtoReflect() protoreflect.Message + func (x *KeysResponse) Reset() + func (x *KeysResponse) String() string + type PutRequest struct + Key []byte + Value []byte + func (*PutRequest) Descriptor() ([]byte, []int) + func (*PutRequest) ProtoMessage() + func (x *PutRequest) GetKey() []byte + func (x *PutRequest) GetValue() []byte + func (x *PutRequest) ProtoReflect() protoreflect.Message + func (x *PutRequest) Reset() + func (x *PutRequest) String() string + type PutResponse struct + Ok bool + func (*PutResponse) Descriptor() ([]byte, []int) + func (*PutResponse) ProtoMessage() + func (x *PutResponse) GetOk() bool + func (x *PutResponse) ProtoReflect() protoreflect.Message + func (x *PutResponse) Reset() + func (x *PutResponse) String() string + type UnimplementedFlyDBServiceServer struct + func (UnimplementedFlyDBServiceServer) Del(context.Context, *DelRequest) (*DelResponse, error) + func (UnimplementedFlyDBServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error) + func (UnimplementedFlyDBServiceServer) Keys(context.Context, *KeysRequest) (*KeysResponse, error) + func (UnimplementedFlyDBServiceServer) Put(context.Context, *PutRequest) (*PutResponse, error) + type UnsafeFlyDBServiceServer interface