repositories

package

v0.0.14-rc.1 Latest Latest Go to latest Published: Mar 16, 2020 License: AGPL-3.0 Imports: 10 Imported by: 7

Details

This section is empty.

View Source

var ErrValidHeaderExists = errors.New("valid header already exists")

This section is empty.

type CheckedHeadersRepository struct {
	// contains filtered or unexported fields
}

func NewCheckedHeadersRepository(db *postgres.DB) CheckedHeadersRepository

func (repo CheckedHeadersRepository) MarkHeaderChecked(headerID int64) error

Increment check_count for header

func (repo CheckedHeadersRepository) MarkHeadersUncheckedSince(startingBlockNumber int64) error

Zero out check count for headers with block number >= startingBlockNumber

func (repo CheckedHeadersRepository) MarkSingleHeaderUnchecked(blockNumber int64) error

Zero out check count for header with the given block number

func (repo CheckedHeadersRepository) UncheckedHeaders(startingBlockNumber, endingBlockNumber, checkCount int64) ([]core.Header, error)

Return header if check_count < passed checkCount

type CheckedLogsRepository struct {
	// contains filtered or unexported fields
}

func NewCheckedLogsRepository(db *postgres.DB) CheckedLogsRepository

func (repository CheckedLogsRepository) AlreadyWatchingLog(addresses []string, topic0 string) (bool, error)

Return whether a given address + topic0 has been fetched on a previous run of vDB

func (repository CheckedLogsRepository) MarkLogWatched(addresses []string, topic0 string) error

Persist that a given address + topic0 has is being fetched on this run of vDB

type EventLogRepository struct {
	// contains filtered or unexported fields
}

func NewEventLogRepository(db *postgres.DB) EventLogRepository

func (repo EventLogRepository) CreateEventLogs(headerID int64, logs []types.Log) error

func (repo EventLogRepository) GetUntransformedEventLogs() ([]core.EventLog, error)

type HeaderRepository struct {
	// contains filtered or unexported fields
}

func NewHeaderRepository(database *postgres.DB) HeaderRepository

func (repository HeaderRepository) CreateOrUpdateHeader(header core.Header) (int64, error)

func (repository HeaderRepository) CreateTransactionInTx(tx *sqlx.Tx, headerID int64, transaction core.TransactionModel) (int64, error)

func (repository HeaderRepository) CreateTransactions(headerID int64, transactions []core.TransactionModel) error

func (repository HeaderRepository) GetHeader(blockNumber int64) (core.Header, error)

func (repository HeaderRepository) MissingBlockNumbers(startingBlockNumber, endingBlockNumber int64) ([]int64, error)

type ReceiptRepository struct{}

func (ReceiptRepository) CreateReceiptInTx(headerID, transactionID int64, receipt core.Receipt, tx *sqlx.Tx) (int64, error)