rpcdb

package
v1.8.10 Latest Latest
Warning

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

 Go to latest Published: Dec 14, 2022 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Database_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpcdb.Database",
	HandlerType: (*DatabaseServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Has",
			Handler:    _Database_Has_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _Database_Get_Handler,
		},
		{
			MethodName: "Put",
			Handler:    _Database_Put_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Database_Delete_Handler,
		},
		{
			MethodName: "Compact",
			Handler:    _Database_Compact_Handler,
		},
		{
			MethodName: "Close",
			Handler:    _Database_Close_Handler,
		},
		{
			MethodName: "HealthCheck",
			Handler:    _Database_HealthCheck_Handler,
		},
		{
			MethodName: "WriteBatch",
			Handler:    _Database_WriteBatch_Handler,
		},
		{
			MethodName: "NewIteratorWithStartAndPrefix",
			Handler:    _Database_NewIteratorWithStartAndPrefix_Handler,
		},
		{
			MethodName: "IteratorNext",
			Handler:    _Database_IteratorNext_Handler,
		},
		{
			MethodName: "IteratorError",
			Handler:    _Database_IteratorError_Handler,
		},
		{
			MethodName: "IteratorRelease",
			Handler:    _Database_IteratorRelease_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpcdb/rpcdb.proto",
}

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

View Source 
var File_rpcdb_rpcdb_proto protoreflect.FileDescriptor

Functions

func RegisterDatabaseServer 

func RegisterDatabaseServer(s grpc.ServiceRegistrar, srv DatabaseServer)

Types

type CloseRequest 

type CloseRequest struct {
	// contains filtered or unexported fields
}

func (*CloseRequest) Descriptor deprecated 

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

Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) ProtoReflect 

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

func (*CloseRequest) Reset 

func (x *CloseRequest) Reset()

func (*CloseRequest) String 

func (x *CloseRequest) String() string

type CloseResponse 

type CloseResponse struct {
	Err uint32 `protobuf:"varint,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseResponse) Descriptor deprecated 

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

Deprecated: Use CloseResponse.ProtoReflect.Descriptor instead.

func (*CloseResponse) GetErr 

func (x *CloseResponse) GetErr() uint32

func (*CloseResponse) ProtoMessage 

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) ProtoReflect 

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

func (*CloseResponse) Reset 

func (x *CloseResponse) Reset()

func (*CloseResponse) String 

func (x *CloseResponse) String() string

type CompactRequest 

type CompactRequest struct {
	Start []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Limit []byte `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactRequest) Descriptor deprecated 

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

Deprecated: Use CompactRequest.ProtoReflect.Descriptor instead.

func (*CompactRequest) GetLimit 

func (x *CompactRequest) GetLimit() []byte

func (*CompactRequest) GetStart 

func (x *CompactRequest) GetStart() []byte

func (*CompactRequest) ProtoMessage 

func (*CompactRequest) ProtoMessage()

func (*CompactRequest) ProtoReflect 

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

func (*CompactRequest) Reset 

func (x *CompactRequest) Reset()

func (*CompactRequest) String 

func (x *CompactRequest) String() string

type CompactResponse 

type CompactResponse struct {
	Err uint32 `protobuf:"varint,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactResponse) Descriptor deprecated 

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

Deprecated: Use CompactResponse.ProtoReflect.Descriptor instead.

func (*CompactResponse) GetErr 

func (x *CompactResponse) GetErr() uint32

func (*CompactResponse) ProtoMessage 

func (*CompactResponse) ProtoMessage()

func (*CompactResponse) ProtoReflect 

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

func (*CompactResponse) Reset 

func (x *CompactResponse) Reset()

func (*CompactResponse) String 

func (x *CompactResponse) String() string

type DatabaseClient 

type DatabaseClient interface {
	Has(ctx context.Context, in *HasRequest, opts ...grpc.CallOption) (*HasResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Compact(ctx context.Context, in *CompactRequest, opts ...grpc.CallOption) (*CompactResponse, error)
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)
	HealthCheck(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	WriteBatch(ctx context.Context, in *WriteBatchRequest, opts ...grpc.CallOption) (*WriteBatchResponse, error)
	NewIteratorWithStartAndPrefix(ctx context.Context, in *NewIteratorWithStartAndPrefixRequest, opts ...grpc.CallOption) (*NewIteratorWithStartAndPrefixResponse, error)
	IteratorNext(ctx context.Context, in *IteratorNextRequest, opts ...grpc.CallOption) (*IteratorNextResponse, error)
	IteratorError(ctx context.Context, in *IteratorErrorRequest, opts ...grpc.CallOption) (*IteratorErrorResponse, error)
	IteratorRelease(ctx context.Context, in *IteratorReleaseRequest, opts ...grpc.CallOption) (*IteratorReleaseResponse, error)
}

DatabaseClient is the client API for Database 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 NewDatabaseClient 

func NewDatabaseClient(cc grpc.ClientConnInterface) DatabaseClient

type DatabaseServer 

type DatabaseServer interface {
	Has(context.Context, *HasRequest) (*HasResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Put(context.Context, *PutRequest) (*PutResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Compact(context.Context, *CompactRequest) (*CompactResponse, error)
	Close(context.Context, *CloseRequest) (*CloseResponse, error)
	HealthCheck(context.Context, *emptypb.Empty) (*HealthCheckResponse, error)
	WriteBatch(context.Context, *WriteBatchRequest) (*WriteBatchResponse, error)
	NewIteratorWithStartAndPrefix(context.Context, *NewIteratorWithStartAndPrefixRequest) (*NewIteratorWithStartAndPrefixResponse, error)
	IteratorNext(context.Context, *IteratorNextRequest) (*IteratorNextResponse, error)
	IteratorError(context.Context, *IteratorErrorRequest) (*IteratorErrorResponse, error)
	IteratorRelease(context.Context, *IteratorReleaseRequest) (*IteratorReleaseResponse, error)
	// contains filtered or unexported methods
}

DatabaseServer is the server API for Database service. All implementations must embed UnimplementedDatabaseServer for forward compatibility

type DeleteRequest 

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

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetKey 

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

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

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

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	Err uint32 `protobuf:"varint,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetErr 

func (x *DeleteResponse) GetErr() uint32

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

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

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

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"`
	Err   uint32 `protobuf:"varint,2,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetErr 

func (x *GetResponse) GetErr() uint32

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 HasRequest 

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

func (*HasRequest) Descriptor deprecated 

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

Deprecated: Use HasRequest.ProtoReflect.Descriptor instead.

func (*HasRequest) GetKey 

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

func (*HasRequest) ProtoMessage 

func (*HasRequest) ProtoMessage()

func (*HasRequest) ProtoReflect 

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

func (*HasRequest) Reset 

func (x *HasRequest) Reset()

func (*HasRequest) String 

func (x *HasRequest) String() string

type HasResponse 

type HasResponse struct {
	Has bool   `protobuf:"varint,1,opt,name=has,proto3" json:"has,omitempty"`
	Err uint32 `protobuf:"varint,2,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*HasResponse) Descriptor deprecated 

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

Deprecated: Use HasResponse.ProtoReflect.Descriptor instead.

func (*HasResponse) GetErr 

func (x *HasResponse) GetErr() uint32

func (*HasResponse) GetHas 

func (x *HasResponse) GetHas() bool

func (*HasResponse) ProtoMessage 

func (*HasResponse) ProtoMessage()

func (*HasResponse) ProtoReflect 

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

func (*HasResponse) Reset 

func (x *HasResponse) Reset()

func (*HasResponse) String 

func (x *HasResponse) String() string

type HealthCheckResponse 

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

func (*HealthCheckResponse) Descriptor deprecated 

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

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) GetDetails 

func (x *HealthCheckResponse) GetDetails() []byte

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect 

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

func (*HealthCheckResponse) Reset 

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (x *HealthCheckResponse) String() string

type IteratorErrorRequest 

type IteratorErrorRequest struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*IteratorErrorRequest) Descriptor deprecated 

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

Deprecated: Use IteratorErrorRequest.ProtoReflect.Descriptor instead.

func (*IteratorErrorRequest) GetId 

func (x *IteratorErrorRequest) GetId() uint64

func (*IteratorErrorRequest) ProtoMessage 

func (*IteratorErrorRequest) ProtoMessage()

func (*IteratorErrorRequest) ProtoReflect 

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

func (*IteratorErrorRequest) Reset 

func (x *IteratorErrorRequest) Reset()

func (*IteratorErrorRequest) String 

func (x *IteratorErrorRequest) String() string

type IteratorErrorResponse 

type IteratorErrorResponse struct {
	Err uint32 `protobuf:"varint,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*IteratorErrorResponse) Descriptor deprecated 

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

Deprecated: Use IteratorErrorResponse.ProtoReflect.Descriptor instead.

func (*IteratorErrorResponse) GetErr 

func (x *IteratorErrorResponse) GetErr() uint32

func (*IteratorErrorResponse) ProtoMessage 

func (*IteratorErrorResponse) ProtoMessage()

func (*IteratorErrorResponse) ProtoReflect 

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

func (*IteratorErrorResponse) Reset 

func (x *IteratorErrorResponse) Reset()

func (*IteratorErrorResponse) String 

func (x *IteratorErrorResponse) String() string

type IteratorNextRequest 

type IteratorNextRequest struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*IteratorNextRequest) Descriptor deprecated 

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

Deprecated: Use IteratorNextRequest.ProtoReflect.Descriptor instead.

func (*IteratorNextRequest) GetId 

func (x *IteratorNextRequest) GetId() uint64

func (*IteratorNextRequest) ProtoMessage 

func (*IteratorNextRequest) ProtoMessage()

func (*IteratorNextRequest) ProtoReflect 

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

func (*IteratorNextRequest) Reset 

func (x *IteratorNextRequest) Reset()

func (*IteratorNextRequest) String 

func (x *IteratorNextRequest) String() string

type IteratorNextResponse 

type IteratorNextResponse struct {
	Data []*PutRequest `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*IteratorNextResponse) Descriptor deprecated 

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

Deprecated: Use IteratorNextResponse.ProtoReflect.Descriptor instead.

func (*IteratorNextResponse) GetData 

func (x *IteratorNextResponse) GetData() []*PutRequest

func (*IteratorNextResponse) ProtoMessage 

func (*IteratorNextResponse) ProtoMessage()

func (*IteratorNextResponse) ProtoReflect 

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

func (*IteratorNextResponse) Reset 

func (x *IteratorNextResponse) Reset()

func (*IteratorNextResponse) String 

func (x *IteratorNextResponse) String() string

type IteratorReleaseRequest 

type IteratorReleaseRequest struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*IteratorReleaseRequest) Descriptor deprecated 

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

Deprecated: Use IteratorReleaseRequest.ProtoReflect.Descriptor instead.

func (*IteratorReleaseRequest) GetId 

func (x *IteratorReleaseRequest) GetId() uint64

func (*IteratorReleaseRequest) ProtoMessage 

func (*IteratorReleaseRequest) ProtoMessage()

func (*IteratorReleaseRequest) ProtoReflect 

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

func (*IteratorReleaseRequest) Reset 

func (x *IteratorReleaseRequest) Reset()

func (*IteratorReleaseRequest) String 

func (x *IteratorReleaseRequest) String() string

type IteratorReleaseResponse 

type IteratorReleaseResponse struct {
	Err uint32 `protobuf:"varint,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*IteratorReleaseResponse) Descriptor deprecated 

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

Deprecated: Use IteratorReleaseResponse.ProtoReflect.Descriptor instead.

func (*IteratorReleaseResponse) GetErr 

func (x *IteratorReleaseResponse) GetErr() uint32

func (*IteratorReleaseResponse) ProtoMessage 

func (*IteratorReleaseResponse) ProtoMessage()

func (*IteratorReleaseResponse) ProtoReflect 

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

func (*IteratorReleaseResponse) Reset 

func (x *IteratorReleaseResponse) Reset()

func (*IteratorReleaseResponse) String 

func (x *IteratorReleaseResponse) String() string

type NewIteratorRequest 

type NewIteratorRequest struct {
	// contains filtered or unexported fields
}

func (*NewIteratorRequest) Descriptor deprecated 

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

Deprecated: Use NewIteratorRequest.ProtoReflect.Descriptor instead.

func (*NewIteratorRequest) ProtoMessage 

func (*NewIteratorRequest) ProtoMessage()

func (*NewIteratorRequest) ProtoReflect 

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

func (*NewIteratorRequest) Reset 

func (x *NewIteratorRequest) Reset()

func (*NewIteratorRequest) String 

func (x *NewIteratorRequest) String() string

type NewIteratorWithStartAndPrefixRequest 

type NewIteratorWithStartAndPrefixRequest struct {
	Start  []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Prefix []byte `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*NewIteratorWithStartAndPrefixRequest) Descriptor deprecated 

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

Deprecated: Use NewIteratorWithStartAndPrefixRequest.ProtoReflect.Descriptor instead.

func (*NewIteratorWithStartAndPrefixRequest) GetPrefix 

func (x *NewIteratorWithStartAndPrefixRequest) GetPrefix() []byte

func (*NewIteratorWithStartAndPrefixRequest) GetStart 

func (x *NewIteratorWithStartAndPrefixRequest) GetStart() []byte

func (*NewIteratorWithStartAndPrefixRequest) ProtoMessage 

func (*NewIteratorWithStartAndPrefixRequest) ProtoMessage()

func (*NewIteratorWithStartAndPrefixRequest) ProtoReflect 

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

func (*NewIteratorWithStartAndPrefixRequest) Reset 

func (x *NewIteratorWithStartAndPrefixRequest) Reset()

func (*NewIteratorWithStartAndPrefixRequest) String 

func (x *NewIteratorWithStartAndPrefixRequest) String() string

type NewIteratorWithStartAndPrefixResponse 

type NewIteratorWithStartAndPrefixResponse struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*NewIteratorWithStartAndPrefixResponse) Descriptor deprecated 

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

Deprecated: Use NewIteratorWithStartAndPrefixResponse.ProtoReflect.Descriptor instead.

func (*NewIteratorWithStartAndPrefixResponse) GetId 

func (x *NewIteratorWithStartAndPrefixResponse) GetId() uint64

func (*NewIteratorWithStartAndPrefixResponse) ProtoMessage 

func (*NewIteratorWithStartAndPrefixResponse) ProtoMessage()

func (*NewIteratorWithStartAndPrefixResponse) ProtoReflect 

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

func (*NewIteratorWithStartAndPrefixResponse) Reset 

func (x *NewIteratorWithStartAndPrefixResponse) Reset()

func (*NewIteratorWithStartAndPrefixResponse) String 

func (x *NewIteratorWithStartAndPrefixResponse) 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 {
	Err uint32 `protobuf:"varint,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*PutResponse) Descriptor deprecated 

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) GetErr 

func (x *PutResponse) GetErr() uint32

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 UnimplementedDatabaseServer 

type UnimplementedDatabaseServer struct {
}

UnimplementedDatabaseServer must be embedded to have forward compatible implementations.

func (UnimplementedDatabaseServer) Close 

func (UnimplementedDatabaseServer) Close(context.Context, *CloseRequest) (*CloseResponse, error)

func (UnimplementedDatabaseServer) Compact 

func (UnimplementedDatabaseServer) Compact(context.Context, *CompactRequest) (*CompactResponse, error)

func (UnimplementedDatabaseServer) Delete 

func (UnimplementedDatabaseServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedDatabaseServer) Get 

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

func (UnimplementedDatabaseServer) Has 

func (UnimplementedDatabaseServer) Has(context.Context, *HasRequest) (*HasResponse, error)

func (UnimplementedDatabaseServer) HealthCheck 

func (UnimplementedDatabaseServer) HealthCheck(context.Context, *emptypb.Empty) (*HealthCheckResponse, error)

func (UnimplementedDatabaseServer) IteratorError 

func (UnimplementedDatabaseServer) IteratorError(context.Context, *IteratorErrorRequest) (*IteratorErrorResponse, error)

func (UnimplementedDatabaseServer) IteratorNext 

func (UnimplementedDatabaseServer) IteratorNext(context.Context, *IteratorNextRequest) (*IteratorNextResponse, error)

func (UnimplementedDatabaseServer) IteratorRelease 

func (UnimplementedDatabaseServer) IteratorRelease(context.Context, *IteratorReleaseRequest) (*IteratorReleaseResponse, error)

func (UnimplementedDatabaseServer) NewIteratorWithStartAndPrefix 

func (UnimplementedDatabaseServer) NewIteratorWithStartAndPrefix(context.Context, *NewIteratorWithStartAndPrefixRequest) (*NewIteratorWithStartAndPrefixResponse, error)

func (UnimplementedDatabaseServer) Put 

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

func (UnimplementedDatabaseServer) WriteBatch 

func (UnimplementedDatabaseServer) WriteBatch(context.Context, *WriteBatchRequest) (*WriteBatchResponse, error)

type UnsafeDatabaseServer 

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

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

type WriteBatchRequest 

type WriteBatchRequest struct {
	Puts      []*PutRequest    `protobuf:"bytes,1,rep,name=puts,proto3" json:"puts,omitempty"`
	Deletes   []*DeleteRequest `protobuf:"bytes,2,rep,name=deletes,proto3" json:"deletes,omitempty"`
	Id        int64            `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	Continues bool             `protobuf:"varint,4,opt,name=continues,proto3" json:"continues,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteBatchRequest) Descriptor deprecated 

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

Deprecated: Use WriteBatchRequest.ProtoReflect.Descriptor instead.

func (*WriteBatchRequest) GetContinues 

func (x *WriteBatchRequest) GetContinues() bool

func (*WriteBatchRequest) GetDeletes 

func (x *WriteBatchRequest) GetDeletes() []*DeleteRequest

func (*WriteBatchRequest) GetId 

func (x *WriteBatchRequest) GetId() int64

func (*WriteBatchRequest) GetPuts 

func (x *WriteBatchRequest) GetPuts() []*PutRequest

func (*WriteBatchRequest) ProtoMessage 

func (*WriteBatchRequest) ProtoMessage()

func (*WriteBatchRequest) ProtoReflect 

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

func (*WriteBatchRequest) Reset 

func (x *WriteBatchRequest) Reset()

func (*WriteBatchRequest) String 

func (x *WriteBatchRequest) String() string

type WriteBatchResponse 

type WriteBatchResponse struct {
	Err uint32 `protobuf:"varint,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteBatchResponse) Descriptor deprecated 

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

Deprecated: Use WriteBatchResponse.ProtoReflect.Descriptor instead.

func (*WriteBatchResponse) GetErr 

func (x *WriteBatchResponse) GetErr() uint32

func (*WriteBatchResponse) ProtoMessage 

func (*WriteBatchResponse) ProtoMessage()

func (*WriteBatchResponse) ProtoReflect 

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

func (*WriteBatchResponse) Reset 

func (x *WriteBatchResponse) Reset()

func (*WriteBatchResponse) String 

func (x *WriteBatchResponse) String() string

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.