Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

rpcdb

package

Go to main page

Versions in this module

v1

v1.10.10

Jul 12, 2024

v1.0.0-test

Jul 12, 2024

v0

v0.0.7

Jul 12, 2024

v0.0.6

Jul 12, 2024

v0.0.5

Jul 12, 2024

v0.0.1

Jun 26, 2024

Changes in this version

+ const Database_Close_FullMethodName

+ const Database_Compact_FullMethodName

+ const Database_Delete_FullMethodName

+ const Database_Get_FullMethodName

+ const Database_Has_FullMethodName

+ const Database_HealthCheck_FullMethodName

+ const Database_IteratorError_FullMethodName

+ const Database_IteratorNext_FullMethodName

+ const Database_IteratorRelease_FullMethodName

+ const Database_NewIteratorWithStartAndPrefix_FullMethodName

+ const Database_Put_FullMethodName

+ const Database_WriteBatch_FullMethodName

+ var Database_ServiceDesc = grpc.ServiceDesc

+ var Error_name = map[int32]string

+ var Error_value = map[string]int32

+ var File_rpcdb_rpcdb_proto protoreflect.FileDescriptor

+ func RegisterDatabaseServer(s grpc.ServiceRegistrar, srv DatabaseServer)

+ type CloseRequest struct

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

+ func (*CloseRequest) ProtoMessage()

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

+ func (x *CloseRequest) Reset()

+ func (x *CloseRequest) String() string

+ type CloseResponse struct

+ Err Error

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

+ func (*CloseResponse) ProtoMessage()

+ func (x *CloseResponse) GetErr() Error

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

+ func (x *CloseResponse) Reset()

+ func (x *CloseResponse) String() string

+ type CompactRequest struct

+ Limit []byte

+ Start []byte

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

+ func (*CompactRequest) ProtoMessage()

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

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

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

+ func (x *CompactRequest) Reset()

+ func (x *CompactRequest) String() string

+ type CompactResponse struct

+ Err Error

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

+ func (*CompactResponse) ProtoMessage()

+ func (x *CompactResponse) GetErr() Error

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

+ func (x *CompactResponse) Reset()

+ func (x *CompactResponse) String() string

+ type DatabaseClient interface

+ Close func(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)

+ Compact func(ctx context.Context, in *CompactRequest, opts ...grpc.CallOption) (*CompactResponse, error)

+ Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)

+ Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)

+ Has func(ctx context.Context, in *HasRequest, opts ...grpc.CallOption) (*HasResponse, error)

+ HealthCheck func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthCheckResponse, error)

+ IteratorError func(ctx context.Context, in *IteratorErrorRequest, opts ...grpc.CallOption) (*IteratorErrorResponse, error)

+ IteratorNext func(ctx context.Context, in *IteratorNextRequest, opts ...grpc.CallOption) (*IteratorNextResponse, error)

+ IteratorRelease func(ctx context.Context, in *IteratorReleaseRequest, opts ...grpc.CallOption) (*IteratorReleaseResponse, error)

+ NewIteratorWithStartAndPrefix func(ctx context.Context, in *NewIteratorWithStartAndPrefixRequest, ...) (*NewIteratorWithStartAndPrefixResponse, error)

+ Put func(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)

+ WriteBatch func(ctx context.Context, in *WriteBatchRequest, opts ...grpc.CallOption) (*WriteBatchResponse, error)

+ func NewDatabaseClient(cc grpc.ClientConnInterface) DatabaseClient

+ type DatabaseServer interface

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

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

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

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

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

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

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

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

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

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

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

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

+ type DeleteRequest struct

+ Key []byte

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

+ func (*DeleteRequest) ProtoMessage()

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

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

+ func (x *DeleteRequest) Reset()

+ func (x *DeleteRequest) String() string

+ type DeleteResponse struct

+ Err Error

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

+ func (*DeleteResponse) ProtoMessage()

+ func (x *DeleteResponse) GetErr() Error

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

+ func (x *DeleteResponse) Reset()

+ func (x *DeleteResponse) String() string

+ type Error int32

+ const Error_ERROR_CLOSED

+ const Error_ERROR_NOT_FOUND

+ const Error_ERROR_UNSPECIFIED

+ func (Error) Descriptor() protoreflect.EnumDescriptor

+ func (Error) EnumDescriptor() ([]byte, []int)

+ func (Error) Type() protoreflect.EnumType

+ func (x Error) Enum() *Error

+ func (x Error) Number() protoreflect.EnumNumber

+ func (x Error) String() string

+ 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

+ Err Error

+ Value []byte

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

+ func (*GetResponse) ProtoMessage()

+ func (x *GetResponse) GetErr() Error

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

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

+ func (x *GetResponse) Reset()

+ func (x *GetResponse) String() string

+ type HasRequest struct

+ Key []byte

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

+ func (*HasRequest) ProtoMessage()

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

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

+ func (x *HasRequest) Reset()

+ func (x *HasRequest) String() string

+ type HasResponse struct

+ Err Error

+ Has bool

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

+ func (*HasResponse) ProtoMessage()

+ func (x *HasResponse) GetErr() Error

+ func (x *HasResponse) GetHas() bool

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

+ func (x *HasResponse) Reset()

+ func (x *HasResponse) String() string

+ type HealthCheckResponse struct

+ Details []byte

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

+ func (*HealthCheckResponse) ProtoMessage()

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

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

+ func (x *HealthCheckResponse) Reset()

+ func (x *HealthCheckResponse) String() string

+ type IteratorErrorRequest struct

+ Id uint64

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

+ func (*IteratorErrorRequest) ProtoMessage()

+ func (x *IteratorErrorRequest) GetId() uint64

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

+ func (x *IteratorErrorRequest) Reset()

+ func (x *IteratorErrorRequest) String() string

+ type IteratorErrorResponse struct

+ Err Error

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

+ func (*IteratorErrorResponse) ProtoMessage()

+ func (x *IteratorErrorResponse) GetErr() Error

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

+ func (x *IteratorErrorResponse) Reset()

+ func (x *IteratorErrorResponse) String() string

+ type IteratorNextRequest struct

+ Id uint64

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

+ func (*IteratorNextRequest) ProtoMessage()

+ func (x *IteratorNextRequest) GetId() uint64

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

+ func (x *IteratorNextRequest) Reset()

+ func (x *IteratorNextRequest) String() string

+ type IteratorNextResponse struct

+ Data []*PutRequest

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

+ func (*IteratorNextResponse) ProtoMessage()

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

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

+ func (x *IteratorNextResponse) Reset()

+ func (x *IteratorNextResponse) String() string

+ type IteratorReleaseRequest struct

+ Id uint64

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

+ func (*IteratorReleaseRequest) ProtoMessage()

+ func (x *IteratorReleaseRequest) GetId() uint64

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

+ func (x *IteratorReleaseRequest) Reset()

+ func (x *IteratorReleaseRequest) String() string

+ type IteratorReleaseResponse struct

+ Err Error

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

+ func (*IteratorReleaseResponse) ProtoMessage()

+ func (x *IteratorReleaseResponse) GetErr() Error

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

+ func (x *IteratorReleaseResponse) Reset()

+ func (x *IteratorReleaseResponse) String() string

+ type NewIteratorRequest struct

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

+ func (*NewIteratorRequest) ProtoMessage()

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

+ func (x *NewIteratorRequest) Reset()

+ func (x *NewIteratorRequest) String() string

+ type NewIteratorWithStartAndPrefixRequest struct

+ Prefix []byte

+ Start []byte

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

+ func (*NewIteratorWithStartAndPrefixRequest) ProtoMessage()

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

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

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

+ func (x *NewIteratorWithStartAndPrefixRequest) Reset()

+ func (x *NewIteratorWithStartAndPrefixRequest) String() string

+ type NewIteratorWithStartAndPrefixResponse struct

+ Id uint64

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

+ func (*NewIteratorWithStartAndPrefixResponse) ProtoMessage()

+ func (x *NewIteratorWithStartAndPrefixResponse) GetId() uint64

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

+ func (x *NewIteratorWithStartAndPrefixResponse) Reset()

+ func (x *NewIteratorWithStartAndPrefixResponse) 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

+ Err Error

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

+ func (*PutResponse) ProtoMessage()

+ func (x *PutResponse) GetErr() Error

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

+ func (x *PutResponse) Reset()

+ func (x *PutResponse) String() string

+ type UnimplementedDatabaseServer struct

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

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

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

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

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

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

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

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

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

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

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

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

+ type UnsafeDatabaseServer interface

+ type WriteBatchRequest struct

+ Deletes []*DeleteRequest

+ Puts []*PutRequest

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

+ func (*WriteBatchRequest) ProtoMessage()

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

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

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

+ func (x *WriteBatchRequest) Reset()

+ func (x *WriteBatchRequest) String() string

+ type WriteBatchResponse struct

+ Err Error

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

+ func (*WriteBatchResponse) ProtoMessage()

+ func (x *WriteBatchResponse) GetErr() Error

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

+ func (x *WriteBatchResponse) Reset()

+ func (x *WriteBatchResponse) String() string