Documentation
¶
Overview ¶
Package database exposes the postgres database
Index ¶
- Variables
- func NewNullInt64(i int64) sql.NullInt64
- func NewNullString(s string) sql.NullString
- type BuilderBlockSubmissionEntry
- type DatabaseService
- func (s *DatabaseService) Close() error
- func (s *DatabaseService) GetBlockSubmissionEntry(slot uint64, proposerPubkey, blockHash string) (entry *BuilderBlockSubmissionEntry, err error)
- func (s *DatabaseService) GetExecutionPayloadEntryByID(executionPayloadID int64) (entry *ExecutionPayloadEntry, err error)
- func (s *DatabaseService) GetExecutionPayloadEntryBySlotPkHash(slot uint64, proposerPubkey, blockHash string) (entry *ExecutionPayloadEntry, err error)
- func (s *DatabaseService) GetNumDeliveredPayloads() (uint64, error)
- func (s *DatabaseService) GetRecentDeliveredPayloads(filters GetPayloadsFilters) ([]*DeliveredPayloadEntry, error)
- func (s *DatabaseService) SaveBuilderBlockSubmission(payload *types.BuilderSubmitBlockRequest, simError error) (id int64, err error)
- func (s *DatabaseService) SaveDeliveredPayload(slot uint64, proposerPubkey types.PubkeyHex, blockHash types.Hash, ...) error
- func (s *DatabaseService) SaveValidatorRegistration(registration types.SignedValidatorRegistration) error
- type DeliveredPayloadEntry
- type ExecutionPayloadEntry
- type GetPayloadsFilters
- type IDatabaseService
- type MockDB
- func (db MockDB) GetBlockSubmissionEntry(slot uint64, proposerPubkey, blockHash string) (entry *BuilderBlockSubmissionEntry, err error)
- func (db MockDB) GetExecutionPayloadEntryByID(executionPayloadID int64) (entry *ExecutionPayloadEntry, err error)
- func (db MockDB) GetExecutionPayloadEntryBySlotPkHash(slot uint64, proposerPubkey, blockHash string) (entry *ExecutionPayloadEntry, err error)
- func (db MockDB) GetNumDeliveredPayloads() (uint64, error)
- func (db MockDB) GetRecentDeliveredPayloads(filters GetPayloadsFilters) ([]*DeliveredPayloadEntry, error)
- func (db MockDB) SaveBuilderBlockSubmission(payload *types.BuilderSubmitBlockRequest, simError error) (id int64, err error)
- func (db MockDB) SaveDeliveredPayload(slot uint64, proposerPubkey types.PubkeyHex, blockHash types.Hash, ...) error
- func (db MockDB) SaveValidatorRegistration(registration types.SignedValidatorRegistration) error
- type ValidatorRegistrationEntry
Constants ¶
This section is empty.
Variables ¶
View Source
var ( TableValidatorRegistration = tableBase + "_validator_registration" TableExecutionPayload = tableBase + "_execution_payload" TableBuilderBlockSubmission = tableBase + "_builder_block_submission" TableDeliveredPayload = tableBase + "_payload_delivered" )
Functions ¶
func NewNullInt64 ¶
func NewNullString ¶
func NewNullString(s string) sql.NullString
Types ¶
type BuilderBlockSubmissionEntry ¶
type BuilderBlockSubmissionEntry struct {
ID int64 `db:"id"`
InsertedAt time.Time `db:"inserted_at"`
// Delivered ExecutionPayload
ExecutionPayloadID sql.NullInt64 `db:"execution_payload_id"`
// Sim Result
SimSuccess bool `db:"sim_success"`
SimError string `db:"sim_error"`
// BidTrace data
Signature string `db:"signature"`
Slot uint64 `db:"slot"`
ParentHash string `db:"parent_hash"`
BlockHash string `db:"block_hash"`
BuilderPubkey string `db:"builder_pubkey"`
ProposerPubkey string `db:"proposer_pubkey"`
ProposerFeeRecipient string `db:"proposer_fee_recipient"`
GasUsed uint64 `db:"gas_used"`
GasLimit uint64 `db:"gas_limit"`
NumTx int `db:"num_tx"`
Value string `db:"value"`
// Helpers
Epoch uint64 `db:"epoch"`
BlockNumber uint64 `db:"block_number"`
}
type DatabaseService ¶
func NewDatabaseService ¶
func NewDatabaseService(dsn string) (*DatabaseService, error)
func (*DatabaseService) Close ¶
func (s *DatabaseService) Close() error
func (*DatabaseService) GetBlockSubmissionEntry ¶
func (s *DatabaseService) GetBlockSubmissionEntry(slot uint64, proposerPubkey, blockHash string) (entry *BuilderBlockSubmissionEntry, err error)
func (*DatabaseService) GetExecutionPayloadEntryByID ¶
func (s *DatabaseService) GetExecutionPayloadEntryByID(executionPayloadID int64) (entry *ExecutionPayloadEntry, err error)
func (*DatabaseService) GetExecutionPayloadEntryBySlotPkHash ¶
func (s *DatabaseService) GetExecutionPayloadEntryBySlotPkHash(slot uint64, proposerPubkey, blockHash string) (entry *ExecutionPayloadEntry, err error)
func (*DatabaseService) GetNumDeliveredPayloads ¶
func (s *DatabaseService) GetNumDeliveredPayloads() (uint64, error)
func (*DatabaseService) GetRecentDeliveredPayloads ¶
func (s *DatabaseService) GetRecentDeliveredPayloads(filters GetPayloadsFilters) ([]*DeliveredPayloadEntry, error)
func (*DatabaseService) SaveBuilderBlockSubmission ¶
func (s *DatabaseService) SaveBuilderBlockSubmission(payload *types.BuilderSubmitBlockRequest, simError error) (id int64, err error)
func (*DatabaseService) SaveDeliveredPayload ¶
func (s *DatabaseService) SaveDeliveredPayload(slot uint64, proposerPubkey types.PubkeyHex, blockHash types.Hash, signedBlindedBeaconBlock *types.SignedBlindedBeaconBlock) error
func (*DatabaseService) SaveValidatorRegistration ¶
func (s *DatabaseService) SaveValidatorRegistration(registration types.SignedValidatorRegistration) error
type DeliveredPayloadEntry ¶
type DeliveredPayloadEntry struct {
ID int64 `db:"id"`
InsertedAt time.Time `db:"inserted_at"`
ExecutionPayloadID sql.NullInt64 `db:"execution_payload_id"`
SignedBlindedBeaconBlock sql.NullString `db:"signed_blinded_beacon_block"`
Slot uint64 `db:"slot"`
Epoch uint64 `db:"epoch"`
BuilderPubkey string `db:"builder_pubkey"`
ProposerPubkey string `db:"proposer_pubkey"`
ProposerFeeRecipient string `db:"proposer_fee_recipient"`
ParentHash string `db:"parent_hash"`
BlockHash string `db:"block_hash"`
BlockNumber uint64 `db:"block_number"`
GasUsed uint64 `db:"gas_used"`
GasLimit uint64 `db:"gas_limit"`
NumTx int `db:"num_tx"`
Value string `db:"value"`
}
type ExecutionPayloadEntry ¶
type ExecutionPayloadEntry struct {
ID int64 `db:"id"`
InsertedAt time.Time `db:"inserted_at"`
Slot uint64 `db:"slot"`
ProposerPubkey string `db:"proposer_pubkey"`
BlockHash string `db:"block_hash"`
Version string `db:"version"`
Payload string `db:"payload"`
}
func PayloadToExecPayloadEntry ¶
func PayloadToExecPayloadEntry(payload *types.BuilderSubmitBlockRequest) (*ExecutionPayloadEntry, error)
type GetPayloadsFilters ¶
type IDatabaseService ¶
type IDatabaseService interface {
SaveValidatorRegistration(registration types.SignedValidatorRegistration) error
SaveBuilderBlockSubmission(payload *types.BuilderSubmitBlockRequest, simError error) (id int64, err error)
SaveDeliveredPayload(slot uint64, proposerPubkey types.PubkeyHex, blockHash types.Hash, signedBlindedBeaconBlock *types.SignedBlindedBeaconBlock) error
GetBlockSubmissionEntry(slot uint64, proposerPubkey, blockHash string) (entry *BuilderBlockSubmissionEntry, err error)
GetExecutionPayloadEntryByID(executionPayloadID int64) (entry *ExecutionPayloadEntry, err error)
GetExecutionPayloadEntryBySlotPkHash(slot uint64, proposerPubkey, blockHash string) (entry *ExecutionPayloadEntry, err error)
GetRecentDeliveredPayloads(filters GetPayloadsFilters) ([]*DeliveredPayloadEntry, error)
GetNumDeliveredPayloads() (uint64, error)
}
type MockDB ¶
type MockDB struct{}
func (MockDB) GetBlockSubmissionEntry ¶
func (db MockDB) GetBlockSubmissionEntry(slot uint64, proposerPubkey, blockHash string) (entry *BuilderBlockSubmissionEntry, err error)
func (MockDB) GetExecutionPayloadEntryByID ¶
func (db MockDB) GetExecutionPayloadEntryByID(executionPayloadID int64) (entry *ExecutionPayloadEntry, err error)
func (MockDB) GetExecutionPayloadEntryBySlotPkHash ¶
func (db MockDB) GetExecutionPayloadEntryBySlotPkHash(slot uint64, proposerPubkey, blockHash string) (entry *ExecutionPayloadEntry, err error)
func (MockDB) GetNumDeliveredPayloads ¶
func (MockDB) GetRecentDeliveredPayloads ¶
func (db MockDB) GetRecentDeliveredPayloads(filters GetPayloadsFilters) ([]*DeliveredPayloadEntry, error)
func (MockDB) SaveBuilderBlockSubmission ¶
func (MockDB) SaveDeliveredPayload ¶
func (MockDB) SaveValidatorRegistration ¶
func (db MockDB) SaveValidatorRegistration(registration types.SignedValidatorRegistration) error
Click to show internal directories.
Click to hide internal directories.