Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterDataServer(s grpc.ServiceRegistrar, srv DataServer)
- func RegisterDbServer(s grpc.ServiceRegistrar, srv DbServer)
- func RegisterSysServer(s grpc.ServiceRegistrar, srv SysServer)
- type CreateDbOpt
- type CreateDbReq
- func (*CreateDbReq) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDbReq) GetName() string
- func (x *CreateDbReq) GetOpt() *CreateDbOpt
- func (*CreateDbReq) ProtoMessage()
- func (x *CreateDbReq) ProtoReflect() protoreflect.Message
- func (x *CreateDbReq) Reset()
- func (x *CreateDbReq) String() string
- type DataClient
- type DataItem
- type DataServer
- type Data_CreateReadStreamClient
- type Data_CreateReadStreamServer
- type Data_CreateSendStreamClient
- type Data_CreateSendStreamServer
- type DbClient
- type DbServer
- type DropDbRequest
- type ExistsDbReq
- type ExistsDbRes
- type GetResult
- type KeyRequest
- type PingRequest
- type PingResult
- type PrefixRequest
- func (*PrefixRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PrefixRequest) GetDb() string
- func (x *PrefixRequest) GetPrefix() string
- func (*PrefixRequest) ProtoMessage()
- func (x *PrefixRequest) ProtoReflect() protoreflect.Message
- func (x *PrefixRequest) Reset()
- func (x *PrefixRequest) String() string
- type ReadStreamReq
- func (*ReadStreamReq) Descriptor() ([]byte, []int)deprecated
- func (x *ReadStreamReq) GetDb() string
- func (x *ReadStreamReq) GetPrefix() string
- func (*ReadStreamReq) ProtoMessage()
- func (x *ReadStreamReq) ProtoReflect() protoreflect.Message
- func (x *ReadStreamReq) Reset()
- func (x *ReadStreamReq) String() string
- type SendStreamReq
- func (*SendStreamReq) Descriptor() ([]byte, []int)deprecated
- func (x *SendStreamReq) GetDb() string
- func (x *SendStreamReq) GetItem() *DataItem
- func (*SendStreamReq) ProtoMessage()
- func (x *SendStreamReq) ProtoReflect() protoreflect.Message
- func (x *SendStreamReq) Reset()
- func (x *SendStreamReq) String() string
- type SetRequest
- func (*SetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetRequest) GetData() []byte
- func (x *SetRequest) GetDb() string
- func (x *SetRequest) GetKey() string
- func (x *SetRequest) GetTtl() int32
- func (*SetRequest) ProtoMessage()
- func (x *SetRequest) ProtoReflect() protoreflect.Message
- func (x *SetRequest) Reset()
- func (x *SetRequest) String() string
- type SysClient
- type SysServer
- type UnimplementedDataServer
- func (UnimplementedDataServer) CreateReadStream(*ReadStreamReq, Data_CreateReadStreamServer) error
- func (UnimplementedDataServer) CreateSendStream(Data_CreateSendStreamServer) error
- func (UnimplementedDataServer) Delete(context.Context, *KeyRequest) (*emptypb.Empty, error)
- func (UnimplementedDataServer) DeleteByPrefix(context.Context, *PrefixRequest) (*emptypb.Empty, error)
- func (UnimplementedDataServer) Get(context.Context, *KeyRequest) (*GetResult, error)
- func (UnimplementedDataServer) Set(context.Context, *SetRequest) (*emptypb.Empty, error)
- type UnimplementedDbServer
- func (UnimplementedDbServer) Create(context.Context, *CreateDbReq) (*emptypb.Empty, error)
- func (UnimplementedDbServer) Drop(context.Context, *DropDbRequest) (*emptypb.Empty, error)
- func (UnimplementedDbServer) EnsureDb(context.Context, *CreateDbReq) (*emptypb.Empty, error)
- func (UnimplementedDbServer) Exists(context.Context, *ExistsDbReq) (*ExistsDbRes, error)
- type UnimplementedSysServer
- type UnsafeDataServer
- type UnsafeDbServer
- type UnsafeSysServer
Constants ¶
const ( Data_Set_FullMethodName = "/hb.Data/Set" Data_Get_FullMethodName = "/hb.Data/Get" Data_Delete_FullMethodName = "/hb.Data/Delete" Data_DeleteByPrefix_FullMethodName = "/hb.Data/DeleteByPrefix" Data_CreateReadStream_FullMethodName = "/hb.Data/CreateReadStream" Data_CreateSendStream_FullMethodName = "/hb.Data/CreateSendStream" )
const ( Db_Create_FullMethodName = "/hb.Db/Create" Db_Drop_FullMethodName = "/hb.Db/Drop" Db_Exists_FullMethodName = "/hb.Db/Exists" Db_EnsureDb_FullMethodName = "/hb.Db/EnsureDb" )
const (
Sys_Ping_FullMethodName = "/hb.Sys/Ping"
)
Variables ¶
var Data_ServiceDesc = grpc.ServiceDesc{ ServiceName: "hb.Data", HandlerType: (*DataServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Set", Handler: _Data_Set_Handler, }, { MethodName: "Get", Handler: _Data_Get_Handler, }, { MethodName: "Delete", Handler: _Data_Delete_Handler, }, { MethodName: "DeleteByPrefix", Handler: _Data_DeleteByPrefix_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "CreateReadStream", Handler: _Data_CreateReadStream_Handler, ServerStreams: true, }, { StreamName: "CreateSendStream", Handler: _Data_CreateSendStream_Handler, ClientStreams: true, }, }, Metadata: "honey_badger.proto", }
Data_ServiceDesc is the grpc.ServiceDesc for Data service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Db_ServiceDesc = grpc.ServiceDesc{ ServiceName: "hb.Db", HandlerType: (*DbServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _Db_Create_Handler, }, { MethodName: "Drop", Handler: _Db_Drop_Handler, }, { MethodName: "Exists", Handler: _Db_Exists_Handler, }, { MethodName: "EnsureDb", Handler: _Db_EnsureDb_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "honey_badger.proto", }
Db_ServiceDesc is the grpc.ServiceDesc for Db service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_honey_badger_proto protoreflect.FileDescriptor
var Sys_ServiceDesc = grpc.ServiceDesc{ ServiceName: "hb.Sys", HandlerType: (*SysServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Ping", Handler: _Sys_Ping_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "honey_badger.proto", }
Sys_ServiceDesc is the grpc.ServiceDesc for Sys service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterDataServer ¶
func RegisterDataServer(s grpc.ServiceRegistrar, srv DataServer)
func RegisterDbServer ¶
func RegisterDbServer(s grpc.ServiceRegistrar, srv DbServer)
func RegisterSysServer ¶
func RegisterSysServer(s grpc.ServiceRegistrar, srv SysServer)
Types ¶
type CreateDbOpt ¶
type CreateDbOpt struct { InMemory bool `protobuf:"varint,1,opt,name=inMemory,proto3" json:"inMemory,omitempty"` // contains filtered or unexported fields }
func (*CreateDbOpt) Descriptor
deprecated
func (*CreateDbOpt) Descriptor() ([]byte, []int)
Deprecated: Use CreateDbOpt.ProtoReflect.Descriptor instead.
func (*CreateDbOpt) GetInMemory ¶
func (x *CreateDbOpt) GetInMemory() bool
func (*CreateDbOpt) ProtoMessage ¶
func (*CreateDbOpt) ProtoMessage()
func (*CreateDbOpt) ProtoReflect ¶
func (x *CreateDbOpt) ProtoReflect() protoreflect.Message
func (*CreateDbOpt) Reset ¶
func (x *CreateDbOpt) Reset()
func (*CreateDbOpt) String ¶
func (x *CreateDbOpt) String() string
type CreateDbReq ¶
type CreateDbReq struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Opt *CreateDbOpt `protobuf:"bytes,2,opt,name=opt,proto3" json:"opt,omitempty"` // contains filtered or unexported fields }
func (*CreateDbReq) Descriptor
deprecated
func (*CreateDbReq) Descriptor() ([]byte, []int)
Deprecated: Use CreateDbReq.ProtoReflect.Descriptor instead.
func (*CreateDbReq) GetName ¶
func (x *CreateDbReq) GetName() string
func (*CreateDbReq) GetOpt ¶
func (x *CreateDbReq) GetOpt() *CreateDbOpt
func (*CreateDbReq) ProtoMessage ¶
func (*CreateDbReq) ProtoMessage()
func (*CreateDbReq) ProtoReflect ¶
func (x *CreateDbReq) ProtoReflect() protoreflect.Message
func (*CreateDbReq) Reset ¶
func (x *CreateDbReq) Reset()
func (*CreateDbReq) String ¶
func (x *CreateDbReq) String() string
type DataClient ¶
type DataClient interface { Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) Get(ctx context.Context, in *KeyRequest, opts ...grpc.CallOption) (*GetResult, error) Delete(ctx context.Context, in *KeyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) DeleteByPrefix(ctx context.Context, in *PrefixRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) CreateReadStream(ctx context.Context, in *ReadStreamReq, opts ...grpc.CallOption) (Data_CreateReadStreamClient, error) CreateSendStream(ctx context.Context, opts ...grpc.CallOption) (Data_CreateSendStreamClient, error) }
DataClient is the client API for Data service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewDataClient ¶
func NewDataClient(cc grpc.ClientConnInterface) DataClient
type DataItem ¶
type DataItem struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*DataItem) Descriptor
deprecated
func (*DataItem) ProtoMessage ¶
func (*DataItem) ProtoMessage()
func (*DataItem) ProtoReflect ¶
func (x *DataItem) ProtoReflect() protoreflect.Message
type DataServer ¶
type DataServer interface { Set(context.Context, *SetRequest) (*emptypb.Empty, error) Get(context.Context, *KeyRequest) (*GetResult, error) Delete(context.Context, *KeyRequest) (*emptypb.Empty, error) DeleteByPrefix(context.Context, *PrefixRequest) (*emptypb.Empty, error) CreateReadStream(*ReadStreamReq, Data_CreateReadStreamServer) error CreateSendStream(Data_CreateSendStreamServer) error // contains filtered or unexported methods }
DataServer is the server API for Data service. All implementations must embed UnimplementedDataServer for forward compatibility
type Data_CreateReadStreamClient ¶
type Data_CreateReadStreamClient interface { Recv() (*DataItem, error) grpc.ClientStream }
type Data_CreateReadStreamServer ¶
type Data_CreateReadStreamServer interface { Send(*DataItem) error grpc.ServerStream }
type Data_CreateSendStreamClient ¶
type Data_CreateSendStreamClient interface { Send(*SendStreamReq) error CloseAndRecv() (*emptypb.Empty, error) grpc.ClientStream }
type Data_CreateSendStreamServer ¶
type Data_CreateSendStreamServer interface { SendAndClose(*emptypb.Empty) error Recv() (*SendStreamReq, error) grpc.ServerStream }
type DbClient ¶
type DbClient interface { Create(ctx context.Context, in *CreateDbReq, opts ...grpc.CallOption) (*emptypb.Empty, error) Drop(ctx context.Context, in *DropDbRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) Exists(ctx context.Context, in *ExistsDbReq, opts ...grpc.CallOption) (*ExistsDbRes, error) EnsureDb(ctx context.Context, in *CreateDbReq, opts ...grpc.CallOption) (*emptypb.Empty, error) }
DbClient is the client API for Db service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewDbClient ¶
func NewDbClient(cc grpc.ClientConnInterface) DbClient
type DbServer ¶
type DbServer interface { Create(context.Context, *CreateDbReq) (*emptypb.Empty, error) Drop(context.Context, *DropDbRequest) (*emptypb.Empty, error) Exists(context.Context, *ExistsDbReq) (*ExistsDbRes, error) EnsureDb(context.Context, *CreateDbReq) (*emptypb.Empty, error) // contains filtered or unexported methods }
DbServer is the server API for Db service. All implementations must embed UnimplementedDbServer for forward compatibility
type DropDbRequest ¶
type DropDbRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*DropDbRequest) Descriptor
deprecated
func (*DropDbRequest) Descriptor() ([]byte, []int)
Deprecated: Use DropDbRequest.ProtoReflect.Descriptor instead.
func (*DropDbRequest) GetName ¶
func (x *DropDbRequest) GetName() string
func (*DropDbRequest) ProtoMessage ¶
func (*DropDbRequest) ProtoMessage()
func (*DropDbRequest) ProtoReflect ¶
func (x *DropDbRequest) ProtoReflect() protoreflect.Message
func (*DropDbRequest) Reset ¶
func (x *DropDbRequest) Reset()
func (*DropDbRequest) String ¶
func (x *DropDbRequest) String() string
type ExistsDbReq ¶
type ExistsDbReq struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*ExistsDbReq) Descriptor
deprecated
func (*ExistsDbReq) Descriptor() ([]byte, []int)
Deprecated: Use ExistsDbReq.ProtoReflect.Descriptor instead.
func (*ExistsDbReq) GetName ¶
func (x *ExistsDbReq) GetName() string
func (*ExistsDbReq) ProtoMessage ¶
func (*ExistsDbReq) ProtoMessage()
func (*ExistsDbReq) ProtoReflect ¶
func (x *ExistsDbReq) ProtoReflect() protoreflect.Message
func (*ExistsDbReq) Reset ¶
func (x *ExistsDbReq) Reset()
func (*ExistsDbReq) String ¶
func (x *ExistsDbReq) String() string
type ExistsDbRes ¶
type ExistsDbRes struct { Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"` // contains filtered or unexported fields }
func (*ExistsDbRes) Descriptor
deprecated
func (*ExistsDbRes) Descriptor() ([]byte, []int)
Deprecated: Use ExistsDbRes.ProtoReflect.Descriptor instead.
func (*ExistsDbRes) GetExists ¶
func (x *ExistsDbRes) GetExists() bool
func (*ExistsDbRes) ProtoMessage ¶
func (*ExistsDbRes) ProtoMessage()
func (*ExistsDbRes) ProtoReflect ¶
func (x *ExistsDbRes) ProtoReflect() protoreflect.Message
func (*ExistsDbRes) Reset ¶
func (x *ExistsDbRes) Reset()
func (*ExistsDbRes) String ¶
func (x *ExistsDbRes) String() string
type GetResult ¶
type GetResult struct { Hit bool `protobuf:"varint,1,opt,name=hit,proto3" json:"hit,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*GetResult) Descriptor
deprecated
func (*GetResult) ProtoMessage ¶
func (*GetResult) ProtoMessage()
func (*GetResult) ProtoReflect ¶
func (x *GetResult) ProtoReflect() protoreflect.Message
type KeyRequest ¶
type KeyRequest struct { Db string `protobuf:"bytes,1,opt,name=db,proto3" json:"db,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*KeyRequest) Descriptor
deprecated
func (*KeyRequest) Descriptor() ([]byte, []int)
Deprecated: Use KeyRequest.ProtoReflect.Descriptor instead.
func (*KeyRequest) GetDb ¶
func (x *KeyRequest) GetDb() string
func (*KeyRequest) GetKey ¶
func (x *KeyRequest) GetKey() string
func (*KeyRequest) ProtoMessage ¶
func (*KeyRequest) ProtoMessage()
func (*KeyRequest) ProtoReflect ¶
func (x *KeyRequest) ProtoReflect() protoreflect.Message
func (*KeyRequest) Reset ¶
func (x *KeyRequest) Reset()
func (*KeyRequest) String ¶
func (x *KeyRequest) String() string
type PingRequest ¶
type PingRequest struct {
// contains filtered or unexported fields
}
func (*PingRequest) Descriptor
deprecated
func (*PingRequest) Descriptor() ([]byte, []int)
Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) ProtoReflect ¶
func (x *PingRequest) ProtoReflect() protoreflect.Message
func (*PingRequest) Reset ¶
func (x *PingRequest) Reset()
func (*PingRequest) String ¶
func (x *PingRequest) String() string
type PingResult ¶
type PingResult struct { Mesage string `protobuf:"bytes,1,opt,name=mesage,proto3" json:"mesage,omitempty"` // contains filtered or unexported fields }
func (*PingResult) Descriptor
deprecated
func (*PingResult) Descriptor() ([]byte, []int)
Deprecated: Use PingResult.ProtoReflect.Descriptor instead.
func (*PingResult) GetMesage ¶
func (x *PingResult) GetMesage() string
func (*PingResult) ProtoMessage ¶
func (*PingResult) ProtoMessage()
func (*PingResult) ProtoReflect ¶
func (x *PingResult) ProtoReflect() protoreflect.Message
func (*PingResult) Reset ¶
func (x *PingResult) Reset()
func (*PingResult) String ¶
func (x *PingResult) String() string
type PrefixRequest ¶
type PrefixRequest struct { Db string `protobuf:"bytes,1,opt,name=db,proto3" json:"db,omitempty"` Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"` // contains filtered or unexported fields }
func (*PrefixRequest) Descriptor
deprecated
func (*PrefixRequest) Descriptor() ([]byte, []int)
Deprecated: Use PrefixRequest.ProtoReflect.Descriptor instead.
func (*PrefixRequest) GetDb ¶
func (x *PrefixRequest) GetDb() string
func (*PrefixRequest) GetPrefix ¶
func (x *PrefixRequest) GetPrefix() string
func (*PrefixRequest) ProtoMessage ¶
func (*PrefixRequest) ProtoMessage()
func (*PrefixRequest) ProtoReflect ¶
func (x *PrefixRequest) ProtoReflect() protoreflect.Message
func (*PrefixRequest) Reset ¶
func (x *PrefixRequest) Reset()
func (*PrefixRequest) String ¶
func (x *PrefixRequest) String() string
type ReadStreamReq ¶
type ReadStreamReq struct { Db string `protobuf:"bytes,1,opt,name=db,proto3" json:"db,omitempty"` Prefix *string `protobuf:"bytes,2,opt,name=prefix,proto3,oneof" json:"prefix,omitempty"` // contains filtered or unexported fields }
func (*ReadStreamReq) Descriptor
deprecated
func (*ReadStreamReq) Descriptor() ([]byte, []int)
Deprecated: Use ReadStreamReq.ProtoReflect.Descriptor instead.
func (*ReadStreamReq) GetDb ¶
func (x *ReadStreamReq) GetDb() string
func (*ReadStreamReq) GetPrefix ¶
func (x *ReadStreamReq) GetPrefix() string
func (*ReadStreamReq) ProtoMessage ¶
func (*ReadStreamReq) ProtoMessage()
func (*ReadStreamReq) ProtoReflect ¶
func (x *ReadStreamReq) ProtoReflect() protoreflect.Message
func (*ReadStreamReq) Reset ¶
func (x *ReadStreamReq) Reset()
func (*ReadStreamReq) String ¶
func (x *ReadStreamReq) String() string
type SendStreamReq ¶
type SendStreamReq struct { Item *DataItem `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"` Db string `protobuf:"bytes,2,opt,name=db,proto3" json:"db,omitempty"` // contains filtered or unexported fields }
func (*SendStreamReq) Descriptor
deprecated
func (*SendStreamReq) Descriptor() ([]byte, []int)
Deprecated: Use SendStreamReq.ProtoReflect.Descriptor instead.
func (*SendStreamReq) GetDb ¶
func (x *SendStreamReq) GetDb() string
func (*SendStreamReq) GetItem ¶
func (x *SendStreamReq) GetItem() *DataItem
func (*SendStreamReq) ProtoMessage ¶
func (*SendStreamReq) ProtoMessage()
func (*SendStreamReq) ProtoReflect ¶
func (x *SendStreamReq) ProtoReflect() protoreflect.Message
func (*SendStreamReq) Reset ¶
func (x *SendStreamReq) Reset()
func (*SendStreamReq) String ¶
func (x *SendStreamReq) String() string
type SetRequest ¶
type SetRequest struct { Db string `protobuf:"bytes,1,opt,name=db,proto3" json:"db,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` Ttl *int32 `protobuf:"varint,4,opt,name=ttl,proto3,oneof" json:"ttl,omitempty"` // contains filtered or unexported fields }
func (*SetRequest) Descriptor
deprecated
func (*SetRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetRequest.ProtoReflect.Descriptor instead.
func (*SetRequest) GetData ¶
func (x *SetRequest) GetData() []byte
func (*SetRequest) GetDb ¶
func (x *SetRequest) GetDb() string
func (*SetRequest) GetKey ¶
func (x *SetRequest) GetKey() string
func (*SetRequest) GetTtl ¶
func (x *SetRequest) GetTtl() int32
func (*SetRequest) ProtoMessage ¶
func (*SetRequest) ProtoMessage()
func (*SetRequest) ProtoReflect ¶
func (x *SetRequest) ProtoReflect() protoreflect.Message
func (*SetRequest) Reset ¶
func (x *SetRequest) Reset()
func (*SetRequest) String ¶
func (x *SetRequest) String() string
type SysClient ¶
type SysClient interface {
Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResult, error)
}
SysClient is the client API for Sys service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSysClient ¶
func NewSysClient(cc grpc.ClientConnInterface) SysClient
type SysServer ¶
type SysServer interface { Ping(context.Context, *PingRequest) (*PingResult, error) // contains filtered or unexported methods }
SysServer is the server API for Sys service. All implementations must embed UnimplementedSysServer for forward compatibility
type UnimplementedDataServer ¶
type UnimplementedDataServer struct { }
UnimplementedDataServer must be embedded to have forward compatible implementations.
func (UnimplementedDataServer) CreateReadStream ¶
func (UnimplementedDataServer) CreateReadStream(*ReadStreamReq, Data_CreateReadStreamServer) error
func (UnimplementedDataServer) CreateSendStream ¶
func (UnimplementedDataServer) CreateSendStream(Data_CreateSendStreamServer) error
func (UnimplementedDataServer) Delete ¶
func (UnimplementedDataServer) Delete(context.Context, *KeyRequest) (*emptypb.Empty, error)
func (UnimplementedDataServer) DeleteByPrefix ¶
func (UnimplementedDataServer) DeleteByPrefix(context.Context, *PrefixRequest) (*emptypb.Empty, error)
func (UnimplementedDataServer) Get ¶
func (UnimplementedDataServer) Get(context.Context, *KeyRequest) (*GetResult, error)
func (UnimplementedDataServer) Set ¶
func (UnimplementedDataServer) Set(context.Context, *SetRequest) (*emptypb.Empty, error)
type UnimplementedDbServer ¶
type UnimplementedDbServer struct { }
UnimplementedDbServer must be embedded to have forward compatible implementations.
func (UnimplementedDbServer) Create ¶
func (UnimplementedDbServer) Create(context.Context, *CreateDbReq) (*emptypb.Empty, error)
func (UnimplementedDbServer) Drop ¶
func (UnimplementedDbServer) Drop(context.Context, *DropDbRequest) (*emptypb.Empty, error)
func (UnimplementedDbServer) EnsureDb ¶
func (UnimplementedDbServer) EnsureDb(context.Context, *CreateDbReq) (*emptypb.Empty, error)
func (UnimplementedDbServer) Exists ¶
func (UnimplementedDbServer) Exists(context.Context, *ExistsDbReq) (*ExistsDbRes, error)
type UnimplementedSysServer ¶
type UnimplementedSysServer struct { }
UnimplementedSysServer must be embedded to have forward compatible implementations.
func (UnimplementedSysServer) Ping ¶
func (UnimplementedSysServer) Ping(context.Context, *PingRequest) (*PingResult, error)
type UnsafeDataServer ¶
type UnsafeDataServer interface {
// contains filtered or unexported methods
}
UnsafeDataServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DataServer will result in compilation errors.
type UnsafeDbServer ¶
type UnsafeDbServer interface {
// contains filtered or unexported methods
}
UnsafeDbServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DbServer will result in compilation errors.
type UnsafeSysServer ¶
type UnsafeSysServer interface {
// contains filtered or unexported methods
}
UnsafeSysServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SysServer will result in compilation errors.