database

package

v0.2.3-kustomize.1 Latest Latest Go to latest Published: Jul 27, 2023 License: GPL-3.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/bnb-chain/greenfield-storage-provider

Documentation ¶

Index ¶

func BlockSyncerDBBuilder(ctx *database.Context) (database.Database, error)
type DB
- func Cast(db database.Database) *DB

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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 ¶ added in v0.2.3

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

func (*DB) BatchSaveObject ¶

func (db *DB) BatchSaveObject(ctx context.Context, objects map[string][]*models.Object) error

func (*DB) CreateObjectIDMap ¶ added in v0.2.3

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 ¶ added in v0.2.3

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 ¶ added in v0.2.3

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

func (*DB) GetObjectList ¶

func (db *DB) GetObjectList(ctx context.Context, objects map[string][]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 ¶ added in v0.2.3

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

func (*DB) SaveEventCancelMigrationBucket ¶ added in v0.2.3

func (db *DB) SaveEventCancelMigrationBucket(ctx context.Context, eventCancelMigrationBucket *bsdb.EventCancelMigrationBucket) error

func (*DB) SaveEventCancelSwapOut ¶ added in v0.2.3

func (db *DB) SaveEventCancelSwapOut(ctx context.Context, eventCancelSwapOut *bsdb.EventCancelSwapOut) error

func (*DB) SaveEventCompleteMigrationBucket ¶ added in v0.2.3

func (db *DB) SaveEventCompleteMigrationBucket(ctx context.Context, eventCompleteMigrationBucket *bsdb.EventCompleteMigrationBucket) error

func (*DB) SaveEventCompleteSwapOut ¶ added in v0.2.3

func (db *DB) SaveEventCompleteSwapOut(ctx context.Context, eventCompleteSwapOut *bsdb.EventCompleteSwapOut) error

func (*DB) SaveEventMigrationBucket ¶ added in v0.2.3

func (db *DB) SaveEventMigrationBucket(ctx context.Context, eventMigrationBucket *bsdb.EventMigrationBucket) error

func (*DB) SaveEventSPCompleteExit ¶ added in v0.2.3

func (db *DB) SaveEventSPCompleteExit(ctx context.Context, eventSpCompleteExit *bsdb.EventCompleteStorageProviderExit) error

func (*DB) SaveEventSPExit ¶ added in v0.2.3

func (db *DB) SaveEventSPExit(ctx context.Context, eventSPExit *bsdb.EventStorageProviderExit) error

func (*DB) SaveEventSwapOut ¶ added in v0.2.3

func (db *DB) SaveEventSwapOut(ctx context.Context, eventSwapOut *bsdb.EventSwapOut) error

func (*DB) SaveObject ¶ added in v0.2.3

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 ¶ added in v0.2.3

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

Source Files ¶

View all Source files

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