database

Documentation

Index

• type DB
  • func NewDB(ctx context.Context, dbConfig config.Database) (*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 {
	CreateTable                     worker.CreateTableDB
	Blocks                          common.BlocksDB
	ContractEvents                  event.ContractEventsDB
	WithdrawProven                  event.WithdrawProvenDB
	WithdrawFinalized               event.WithdrawFinalizedDB
	StateRoots                      worker.StateRootDB
	L2ToL1                          worker.L2ToL1DB
	L1ToL2                          worker.L1ToL2DB
	MsgSentRelationD                relation.MsgSentRelationDB
	MsgHashRelationD                relation.MsgHashRelationDB
	RelayRelationD                  relation.RelayRelationDB
	RelayMessage                    event.RelayMessageDB
	StakeRecord                     relayer.StakingRecordDB
	BridgeRecord                    relayer.BridgeRecordDB
	BridgeMsgSent                   relayer.BridgeMsgSentDB
	BridgeMsgHash                   relayer.BridgeMsgHashDB
	BridgeClaim                     relayer.BridgeClaimDB
	BridgeFinalize                  relayer.BridgeFinalizeDB
	BridgeBlockListener             relayer.BridgeBlockListenerDB
	BridgeFundingPoolDB             relayer.BridgeFundingPoolUpdateDB
	AppChainLastBlock               appchain.AppChainLastBlockDB
	AppChainUnStake                 appchain.AppChainUnStakeDB
	AppChainStake                   appchain.AppChainStakeDB
	AppChainOperatorSharesIncreased appchain.AppChainOperatorSharesIncreasedDB
	AppChainIncreaseBatch           appchain.AppChainIncreaseBatchDB
	AppChainDappLinkBridge          appchain.AppChainDappLinkBridgeDB
	AppChainMigrateShares           appchain.AppChainMigrateSharesDB
	AppChainWithdraw                appchain.AppChainWithdrawDB
	AppChainDethShares              appchain.AppChainDethSharesDB
	AppChainDEthTransfer            appchain.AppChainDEthTransferDB
	// contains filtered or unexported fields
}

func NewDB

func NewDB(ctx context.Context, dbConfig config.Database) (*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