The highest tagged major version is v2.

rpcdb

package

v1.18.1-qos Latest Latest Go to latest Published: Sep 26, 2025 License: BSD-3-Clause Imports: 5 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/luxfi/node

Links

Open Source Insights

Documentation ¶

Overview ¶

Package rpcdb provides database RPC functionality

Index ¶

type DatabaseClient
- func NewClient(client rpcdbpb.DatabaseClient) *DatabaseClient
type DatabaseServer
- func NewServer(db database.Database) *DatabaseServer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DatabaseClient ¶

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

DatabaseClient is a database client

func NewClient ¶

func NewClient(client rpcdbpb.DatabaseClient) *DatabaseClient

NewClient returns a new database client

func (*DatabaseClient) Close ¶

func (db *DatabaseClient) Close() error

func (*DatabaseClient) Compact ¶

func (db *DatabaseClient) Compact(start []byte, limit []byte) error

func (*DatabaseClient) Delete ¶

func (db *DatabaseClient) Delete(key []byte) error

func (*DatabaseClient) Get ¶

func (db *DatabaseClient) Get(key []byte) ([]byte, error)

func (*DatabaseClient) Has ¶

func (db *DatabaseClient) Has(key []byte) (bool, error)

func (*DatabaseClient) HealthCheck ¶

func (db *DatabaseClient) HealthCheck(ctx context.Context) (interface{}, error)

func (*DatabaseClient) NewBatch ¶

func (db *DatabaseClient) NewBatch() database.Batch

func (*DatabaseClient) NewIterator ¶

func (db *DatabaseClient) NewIterator() database.Iterator

func (*DatabaseClient) NewIteratorWithPrefix ¶

func (db *DatabaseClient) NewIteratorWithPrefix(prefix []byte) database.Iterator

func (*DatabaseClient) NewIteratorWithStart ¶

func (db *DatabaseClient) NewIteratorWithStart(start []byte) database.Iterator

func (*DatabaseClient) NewIteratorWithStartAndPrefix ¶

func (db *DatabaseClient) NewIteratorWithStartAndPrefix(start []byte, prefix []byte) database.Iterator

func (*DatabaseClient) Put ¶

func (db *DatabaseClient) Put(key []byte, value []byte) error

type DatabaseServer ¶

type DatabaseServer struct {
	rpcdbpb.UnimplementedDatabaseServer
	// contains filtered or unexported fields
}

DatabaseServer is a database server that listens over RPC.

func NewServer ¶

func NewServer(db database.Database) *DatabaseServer

NewServer returns a new database server

func (*DatabaseServer) Close ¶

func (db *DatabaseServer) Close(ctx context.Context, req *rpcdbpb.CloseRequest) (*rpcdbpb.CloseResponse, error)

func (*DatabaseServer) Compact ¶

func (db *DatabaseServer) Compact(ctx context.Context, req *rpcdbpb.CompactRequest) (*rpcdbpb.CompactResponse, error)

func (*DatabaseServer) Delete ¶

func (db *DatabaseServer) Delete(ctx context.Context, req *rpcdbpb.DeleteRequest) (*rpcdbpb.DeleteResponse, error)

func (*DatabaseServer) Get ¶

func (db *DatabaseServer) Get(ctx context.Context, req *rpcdbpb.GetRequest) (*rpcdbpb.GetResponse, error)

func (*DatabaseServer) Has ¶

func (db *DatabaseServer) Has(ctx context.Context, req *rpcdbpb.HasRequest) (*rpcdbpb.HasResponse, error)

func (*DatabaseServer) HealthCheck ¶

func (db *DatabaseServer) HealthCheck(ctx context.Context, req *emptypb.Empty) (*rpcdbpb.HealthCheckResponse, error)

func (*DatabaseServer) IteratorError ¶

func (db *DatabaseServer) IteratorError(ctx context.Context, req *rpcdbpb.IteratorErrorRequest) (*rpcdbpb.IteratorErrorResponse, error)

func (*DatabaseServer) IteratorNext ¶

func (db *DatabaseServer) IteratorNext(ctx context.Context, req *rpcdbpb.IteratorNextRequest) (*rpcdbpb.IteratorNextResponse, error)

func (*DatabaseServer) IteratorRelease ¶

func (db *DatabaseServer) IteratorRelease(ctx context.Context, req *rpcdbpb.IteratorReleaseRequest) (*rpcdbpb.IteratorReleaseResponse, error)

func (*DatabaseServer) NewIteratorWithStartAndPrefix ¶

func (db *DatabaseServer) NewIteratorWithStartAndPrefix(ctx context.Context, req *rpcdbpb.NewIteratorWithStartAndPrefixRequest) (*rpcdbpb.NewIteratorWithStartAndPrefixResponse, error)

func (*DatabaseServer) Put ¶

func (db *DatabaseServer) Put(ctx context.Context, req *rpcdbpb.PutRequest) (*rpcdbpb.PutResponse, error)

func (*DatabaseServer) WriteBatch ¶

func (db *DatabaseServer) WriteBatch(ctx context.Context, req *rpcdbpb.WriteBatchRequest) (*rpcdbpb.WriteBatchResponse, error)

Source Files ¶

View all Source files

rpcdb.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL