database

Documentation

Index

• type DB
  • func NewDB(ctx context.Context, dbConfig config.DBConfig) (*DB, error)
  • func (db *DB) Close() error
  • func (db *DB) ExecuteSQLMigration(migrationsFolder string) error
  • func (db *DB) Transaction(fn func(db *DB) error) error

Types

type DB

type DB struct {
	Blocks        common.BlocksDB
	ContractEvent event.ContractEventDB
	DepositTokens worker.DepositTokensDB
	// contains filtered or unexported fields
}

func NewDB

func NewDB(ctx context.Context, dbConfig config.DBConfig) (*DB, error)

func (*DB) Close

func (db *DB) Close() error

func (*DB) ExecuteSQLMigration

func (db *DB) ExecuteSQLMigration(migrationsFolder string) error

func (*DB) Transaction

func (db *DB) Transaction(fn func(db *DB) error) error