database

Documentation

Index

• func BlockSyncerDBBuilder(ctx *database.Context) (database.Database, error)
• type DB
  • func Cast(db database.Database) *DB
  • func (db *DB) AutoMigrate(ctx context.Context, tables []schema.Tabler) error
  • func (db *DB) CreateObjectIDMap(ctx context.Context, objectIDMap *bsdb.ObjectIDMap) error
  • func (db *DB) CreatePrefixTree(ctx context.Context, prefixTree []*bsdb.SlashPrefixTreeNode) error
  • func (db *DB) DeletePrefixTree(ctx context.Context, prefixTree []*bsdb.SlashPrefixTreeNode) error
  • func (b *DB) GetBucketNameByObjectID(objectID common.Hash) (string, error)
  • func (db *DB) GetMasterDB(ctx context.Context) (*bsdb.MasterDB, error)
  • func (db *DB) GetObject(ctx context.Context, objectId common.Hash) (*models.Object, 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, bucketName string) (*bsdb.SlashPrefixTreeNode, error)
  • func (db *DB) PrepareTables(ctx context.Context, tables []schema.Tabler) error
  • func (db *DB) SaveObject(ctx context.Context, object *models.Object) error
  • func (db *DB) SetMasterDB(ctx context.Context, masterDB *bsdb.MasterDB) error
  • func (db *DB) UpdateObject(ctx context.Context, object *models.Object) 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) AutoMigrate

func (db *DB) AutoMigrate(ctx context.Context, tables []schema.Tabler) error

func (*DB) CreateObjectIDMap

func (db *DB) CreateObjectIDMap(ctx context.Context, objectIDMap *bsdb.ObjectIDMap) error

CreateObjectIDMap create object id map table entry

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) GetBucketNameByObjectID

func (b *DB) GetBucketNameByObjectID(objectID common.Hash) (string, error)

GetBucketNameByObjectID get bucket name info by an object id

func (*DB) GetMasterDB

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

GetMasterDB get master db info

func (*DB) GetObject

func (db *DB) GetObject(ctx context.Context, objectId common.Hash) (*models.Object, error)

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, bucketName string) (*bsdb.SlashPrefixTreeNode, error)

GetPrefixTreeObject get prefix tree node object by object id

func (*DB) PrepareTables

func (db *DB) PrepareTables(ctx context.Context, tables []schema.Tabler) error

func (*DB) SaveObject

func (db *DB) SaveObject(ctx context.Context, object *models.Object) error

func (*DB) SetMasterDB

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

SetMasterDB set the master db

func (*DB) UpdateObject

func (db *DB) UpdateObject(ctx context.Context, object *models.Object) error