Documentation ¶
Overview ¶
Package database exposes the postgres database
Index ¶
- type DatabaseInterface
- func (database *DatabaseInterface) DBMigrate() error
- func (database *DatabaseInterface) GetBuilderBlocksReporter(ctx context.Context, slotFrom uint64, slotTo uint64) (*[]databaseTypes.BuilderBlockDatabase, error)
- func (database *DatabaseInterface) GetValidatorDeliveredHeaderReporter(ctx context.Context, slotFrom uint64, slotTo uint64) (*[]databaseTypes.ValidatorDeliveredHeaderDatabase, error)
- func (database *DatabaseInterface) GetValidatorDeliveredPayloadReporter(ctx context.Context, slotFrom uint64, slotTo uint64) (*[]databaseTypes.ValidatorReturnedBlockDatabase, error)
- func (database *DatabaseInterface) GetValidatorReturnedBlocksReporter(ctx context.Context, slotFrom uint64, slotTo uint64) (*[]databaseTypes.ValidatorReturnedBlockDatabase, error)
- func (database *DatabaseInterface) NewDatabaseOpts()
- func (database *DatabaseInterface) PutBuilderBlockSubmission(ctx context.Context, builderSubmission databaseTypes.BuilderBlockDatabase) error
- func (database *DatabaseInterface) PutBuilderOpenBlockSubmission(ctx context.Context, builderSubmission databaseTypes.BuilderBlockDatabase) error
- func (database *DatabaseInterface) PutBuilders(builders []ponPoolTypes.BuilderInterface) error
- func (database *DatabaseInterface) PutReporters(reporters []ponPoolTypes.Reporter) error
- func (database *DatabaseInterface) PutValidatorDeliveredHeader(ctx context.Context, ...) error
- func (database *DatabaseInterface) PutValidatorDeliveredPayload(ctx context.Context, ...) error
- func (database *DatabaseInterface) PutValidatorReturnedBlock(ctx context.Context, ...) (err error)
- func (database *DatabaseInterface) PutValidators(validators []ponPoolTypes.Validator) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DatabaseInterface ¶
type DatabaseInterface struct { DB *sql.DB // Function so we have functions on top of it Opts databaseTypes.DatabaseOpts Driver databaseTypes.DatabaseDriver Log logrus.Entry URL string }
func NewDatabase ¶
func NewDatabase(url string, parameters databaseTypes.DatabaseOpts, dbDriver databaseTypes.DatabaseDriver, deleteTables bool, openRelay bool) (*DatabaseInterface, error)
func (*DatabaseInterface) DBMigrate ¶
func (database *DatabaseInterface) DBMigrate() error
func (*DatabaseInterface) GetBuilderBlocksReporter ¶
func (database *DatabaseInterface) GetBuilderBlocksReporter(ctx context.Context, slotFrom uint64, slotTo uint64) (*[]databaseTypes.BuilderBlockDatabase, error)
func (*DatabaseInterface) GetValidatorDeliveredHeaderReporter ¶
func (database *DatabaseInterface) GetValidatorDeliveredHeaderReporter(ctx context.Context, slotFrom uint64, slotTo uint64) (*[]databaseTypes.ValidatorDeliveredHeaderDatabase, error)
func (*DatabaseInterface) GetValidatorDeliveredPayloadReporter ¶
func (database *DatabaseInterface) GetValidatorDeliveredPayloadReporter(ctx context.Context, slotFrom uint64, slotTo uint64) (*[]databaseTypes.ValidatorReturnedBlockDatabase, error)
func (*DatabaseInterface) GetValidatorReturnedBlocksReporter ¶
func (database *DatabaseInterface) GetValidatorReturnedBlocksReporter(ctx context.Context, slotFrom uint64, slotTo uint64) (*[]databaseTypes.ValidatorReturnedBlockDatabase, error)
func (*DatabaseInterface) NewDatabaseOpts ¶
func (database *DatabaseInterface) NewDatabaseOpts()
func (*DatabaseInterface) PutBuilderBlockSubmission ¶
func (database *DatabaseInterface) PutBuilderBlockSubmission(ctx context.Context, builderSubmission databaseTypes.BuilderBlockDatabase) error
func (*DatabaseInterface) PutBuilderOpenBlockSubmission ¶
func (database *DatabaseInterface) PutBuilderOpenBlockSubmission(ctx context.Context, builderSubmission databaseTypes.BuilderBlockDatabase) error
func (*DatabaseInterface) PutBuilders ¶
func (database *DatabaseInterface) PutBuilders(builders []ponPoolTypes.BuilderInterface) error
func (*DatabaseInterface) PutReporters ¶
func (database *DatabaseInterface) PutReporters(reporters []ponPoolTypes.Reporter) error
func (*DatabaseInterface) PutValidatorDeliveredHeader ¶
func (database *DatabaseInterface) PutValidatorDeliveredHeader(ctx context.Context, validatorDeliveredHeader databaseTypes.ValidatorDeliveredHeaderDatabase) error
func (*DatabaseInterface) PutValidatorDeliveredPayload ¶
func (database *DatabaseInterface) PutValidatorDeliveredPayload(ctx context.Context, validatorPayload databaseTypes.ValidatorDeliveredPayloadDatabase) error
func (*DatabaseInterface) PutValidatorReturnedBlock ¶
func (database *DatabaseInterface) PutValidatorReturnedBlock(ctx context.Context, returnedBlock databaseTypes.ValidatorReturnedBlockDatabase) (err error)
func (*DatabaseInterface) PutValidators ¶
func (database *DatabaseInterface) PutValidators(validators []ponPoolTypes.Validator) error
Click to show internal directories.
Click to hide internal directories.