dbs

package
v1.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 7, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_lib_proto_dbs_db_proto protoreflect.FileDescriptor
View Source 
var FlyDBService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dbs.FlyDBService",
	HandlerType: (*FlyDBServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _FlyDBService_Get_Handler,
		},
		{
			MethodName: "Put",
			Handler:    _FlyDBService_Put_Handler,
		},
		{
			MethodName: "Del",
			Handler:    _FlyDBService_Del_Handler,
		},
		{
			MethodName: "Keys",
			Handler:    _FlyDBService_Keys_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "lib/proto/dbs/db.proto",
}

FlyDBService_ServiceDesc is the grpc.ServiceDesc for FlyDBService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterFlyDBServiceServer 

func RegisterFlyDBServiceServer(s grpc.ServiceRegistrar, srv FlyDBServiceServer)

Types

type DelRequest 

type DelRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DelRequest) Descriptor deprecated 

func (*DelRequest) Descriptor() ([]byte, []int)

Deprecated: Use DelRequest.ProtoReflect.Descriptor instead.

func (*DelRequest) GetKey 

func (x *DelRequest) GetKey() []byte

func (*DelRequest) ProtoMessage 

func (*DelRequest) ProtoMessage()

func (*DelRequest) ProtoReflect 

func (x *DelRequest) ProtoReflect() protoreflect.Message

func (*DelRequest) Reset 

func (x *DelRequest) Reset()

func (*DelRequest) String 

func (x *DelRequest) String() string

type DelResponse 

type DelResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*DelResponse) Descriptor deprecated 

func (*DelResponse) Descriptor() ([]byte, []int)

Deprecated: Use DelResponse.ProtoReflect.Descriptor instead.

func (*DelResponse) GetOk 

func (x *DelResponse) GetOk() bool

func (*DelResponse) ProtoMessage 

func (*DelResponse) ProtoMessage()

func (*DelResponse) ProtoReflect 

func (x *DelResponse) ProtoReflect() protoreflect.Message

func (*DelResponse) Reset 

func (x *DelResponse) Reset()

func (*DelResponse) String 

func (x *DelResponse) String() string

type FlyDBServiceClient 

type FlyDBServiceClient interface {
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	Del(ctx context.Context, in *DelRequest, opts ...grpc.CallOption) (*DelResponse, error)
	Keys(ctx context.Context, in *KeysRequest, opts ...grpc.CallOption) (*KeysResponse, error)
}

FlyDBServiceClient is the client API for FlyDBService 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 NewFlyDBServiceClient 

func NewFlyDBServiceClient(cc grpc.ClientConnInterface) FlyDBServiceClient

type FlyDBServiceServer 

type FlyDBServiceServer interface {
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Put(context.Context, *PutRequest) (*PutResponse, error)
	Del(context.Context, *DelRequest) (*DelResponse, error)
	Keys(context.Context, *KeysRequest) (*KeysResponse, error)
	// contains filtered or unexported methods
}

FlyDBServiceServer is the server API for FlyDBService service. All implementations must embed UnimplementedFlyDBServiceServer for forward compatibility

type GetRequest 

type GetRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

func (*GetRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetKey 

func (x *GetRequest) GetKey() []byte

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

func (*GetResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetValue 

func (x *GetResponse) GetValue() []byte

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

func (x *GetResponse) ProtoReflect() protoreflect.Message

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type KeysRequest 

type KeysRequest struct {
	Pattern []byte `protobuf:"bytes,1,opt,name=pattern,proto3" json:"pattern,omitempty"`
	// contains filtered or unexported fields
}

func (*KeysRequest) Descriptor deprecated 

func (*KeysRequest) Descriptor() ([]byte, []int)

Deprecated: Use KeysRequest.ProtoReflect.Descriptor instead.

func (*KeysRequest) GetPattern 

func (x *KeysRequest) GetPattern() []byte

func (*KeysRequest) ProtoMessage 

func (*KeysRequest) ProtoMessage()

func (*KeysRequest) ProtoReflect 

func (x *KeysRequest) ProtoReflect() protoreflect.Message

func (*KeysRequest) Reset 

func (x *KeysRequest) Reset()

func (*KeysRequest) String 

func (x *KeysRequest) String() string

type KeysResponse 

type KeysResponse struct {
	Keys [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*KeysResponse) Descriptor deprecated 

func (*KeysResponse) Descriptor() ([]byte, []int)

Deprecated: Use KeysResponse.ProtoReflect.Descriptor instead.

func (*KeysResponse) GetKeys 

func (x *KeysResponse) GetKeys() [][]byte

func (*KeysResponse) ProtoMessage 

func (*KeysResponse) ProtoMessage()

func (*KeysResponse) ProtoReflect 

func (x *KeysResponse) ProtoReflect() protoreflect.Message

func (*KeysResponse) Reset 

func (x *KeysResponse) Reset()

func (*KeysResponse) String 

func (x *KeysResponse) String() string

type PutRequest 

type PutRequest struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated 

func (*PutRequest) Descriptor() ([]byte, []int)

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetKey 

func (x *PutRequest) GetKey() []byte

func (*PutRequest) GetValue 

func (x *PutRequest) GetValue() []byte

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

func (x *PutRequest) ProtoReflect() protoreflect.Message

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) String 

func (x *PutRequest) String() string

type PutResponse 

type PutResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*PutResponse) Descriptor deprecated 

func (*PutResponse) Descriptor() ([]byte, []int)

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) GetOk 

func (x *PutResponse) GetOk() bool

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect 

func (x *PutResponse) ProtoReflect() protoreflect.Message

func (*PutResponse) Reset 

func (x *PutResponse) Reset()

func (*PutResponse) String 

func (x *PutResponse) String() string

type UnimplementedFlyDBServiceServer 

type UnimplementedFlyDBServiceServer struct {
}

UnimplementedFlyDBServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFlyDBServiceServer) Del 

func (UnimplementedFlyDBServiceServer) Del(context.Context, *DelRequest) (*DelResponse, error)

func (UnimplementedFlyDBServiceServer) Get 

func (UnimplementedFlyDBServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedFlyDBServiceServer) Keys 

func (UnimplementedFlyDBServiceServer) Keys(context.Context, *KeysRequest) (*KeysResponse, error)

func (UnimplementedFlyDBServiceServer) Put 

func (UnimplementedFlyDBServiceServer) Put(context.Context, *PutRequest) (*PutResponse, error)

type UnsafeFlyDBServiceServer 

type UnsafeFlyDBServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeFlyDBServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FlyDBServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.