database

Documentation

Index

• func BlockSyncerDBBuilder(ctx *database.Context) (database.Database, error)
• type DB
  • func Cast(db database.Database) *DB
  • func (db *DB) CreatePrefixTree(ctx context.Context, prefixTree []*bsdb.SlashPrefixTreeNode) error
  • func (db *DB) DeletePrefixTree(ctx context.Context, prefixTree []*bsdb.SlashPrefixTreeNode) error
  • func (db *DB) GetMasterDB(ctx context.Context) (*bsdb.MasterDB, error)
  • func (db *DB) GetPrefixTree(ctx context.Context, fullName, bucketName string) (*bsdb.SlashPrefixTreeNode, error)
  • func (db *DB) GetPrefixTreeCount(ctx context.Context, pathName, bucketName string) (int64, error)
  • func (db *DB) GetPrefixTreeObject(ctx context.Context, objectID common.Hash) (*bsdb.SlashPrefixTreeNode, error)
  • func (db *DB) SetMasterDB(ctx context.Context, masterDB *bsdb.MasterDB) error

Functions

func BlockSyncerDBBuilder

func BlockSyncerDBBuilder(ctx *database.Context) (database.Database, error)

BlockSyncerDBBuilder allows to create a new DB instance implementing the db.Builder type

Types

type DB

type DB struct {
	*mysql.Database
}

DB represents a SQL database with expanded features. so that it can properly store custom BigDipper-related data.

func Cast

func Cast(db database.Database) *DB

Cast allows to cast the given db to a DB instance

func (*DB) CreatePrefixTree

func (db *DB) CreatePrefixTree(ctx context.Context, prefixTree []*bsdb.SlashPrefixTreeNode) error

CreatePrefixTree create prefix tree nodes by input slice

func (*DB) DeletePrefixTree

func (db *DB) DeletePrefixTree(ctx context.Context, prefixTree []*bsdb.SlashPrefixTreeNode) error

DeletePrefixTree delete prefix tree nodes by given conditions

func (*DB) GetMasterDB

func (db *DB) GetMasterDB(ctx context.Context) (*bsdb.MasterDB, error)

GetMasterDB get master db info

func (*DB) GetPrefixTree

func (db *DB) GetPrefixTree(ctx context.Context, fullName, bucketName string) (*bsdb.SlashPrefixTreeNode, error)

GetPrefixTree get prefix tree node by full name and bucket name

func (*DB) GetPrefixTreeCount

func (db *DB) GetPrefixTreeCount(ctx context.Context, pathName, bucketName string) (int64, error)

GetPrefixTreeCount get prefix tree nodes count by path and bucket name

func (*DB) GetPrefixTreeObject

func (db *DB) GetPrefixTreeObject(ctx context.Context, objectID common.Hash) (*bsdb.SlashPrefixTreeNode, error)

GetPrefixTreeObject get prefix tree node object by object id

func (*DB) SetMasterDB

func (db *DB) SetMasterDB(ctx context.Context, masterDB *bsdb.MasterDB) error

SetMasterDB set the master db