repositories

Documentation

Index

• Variables
• type CheckedHeadersRepository
  • func NewCheckedHeadersRepository(db *postgres.DB) CheckedHeadersRepository
  • func (repo CheckedHeadersRepository) MarkHeaderChecked(headerID int64) error
  • func (repo CheckedHeadersRepository) MarkHeadersUncheckedSince(startingBlockNumber int64) error
  • func (repo CheckedHeadersRepository) MarkSingleHeaderUnchecked(blockNumber int64) error
  • func (repo CheckedHeadersRepository) UncheckedHeaders(startingBlockNumber, endingBlockNumber, checkCount int64) ([]core.Header, error)
• type CheckedLogsRepository
  • func NewCheckedLogsRepository(db *postgres.DB) CheckedLogsRepository
  • func (repository CheckedLogsRepository) AlreadyWatchingLog(addresses []string, topic0 string) (bool, error)
  • func (repository CheckedLogsRepository) MarkLogWatched(addresses []string, topic0 string) error
• type EventLogRepository
  • 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
  • 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) InternalInsertHeader(header core.Header) (int64, error)
  • func (repository HeaderRepository) MissingBlockNumbers(startingBlockNumber, endingBlockNumber int64) ([]int64, error)
• type ReceiptRepository
  • func (ReceiptRepository) CreateReceiptInTx(headerID, transactionID int64, receipt core.Receipt, tx *sqlx.Tx) (int64, error)

Variables

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

Types

type CheckedHeadersRepository

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

func NewCheckedHeadersRepository

func NewCheckedHeadersRepository(db *postgres.DB) CheckedHeadersRepository

func (CheckedHeadersRepository) MarkHeaderChecked

func (repo CheckedHeadersRepository) MarkHeaderChecked(headerID int64) error

Increment check_count for header

func (CheckedHeadersRepository) MarkHeadersUncheckedSince

func (repo CheckedHeadersRepository) MarkHeadersUncheckedSince(startingBlockNumber int64) error

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

func (CheckedHeadersRepository) MarkSingleHeaderUnchecked

func (repo CheckedHeadersRepository) MarkSingleHeaderUnchecked(blockNumber int64) error

Zero out check count for header with the given block number

func (CheckedHeadersRepository) UncheckedHeaders

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

Return header if check_count < passed checkCount

type CheckedLogsRepository

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

func NewCheckedLogsRepository

func NewCheckedLogsRepository(db *postgres.DB) CheckedLogsRepository

func (CheckedLogsRepository) AlreadyWatchingLog

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 (CheckedLogsRepository) MarkLogWatched

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

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

func NewEventLogRepository

func NewEventLogRepository(db *postgres.DB) EventLogRepository

func (EventLogRepository) CreateEventLogs

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

func (EventLogRepository) GetUntransformedEventLogs

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

type HeaderRepository

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

func NewHeaderRepository

func NewHeaderRepository(database *postgres.DB) HeaderRepository

func (HeaderRepository) CreateOrUpdateHeader

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

func (HeaderRepository) CreateTransactionInTx

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

func (HeaderRepository) CreateTransactions

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

func (HeaderRepository) GetHeader

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

func (HeaderRepository) InternalInsertHeader

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

Function is public so we can test insert being called for the same header Can happen when concurrent processes are inserting headers Otherwise should not occur since only called in CreateOrUpdateHeader

func (HeaderRepository) MissingBlockNumbers

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

type ReceiptRepository

type ReceiptRepository struct{}

func (ReceiptRepository) CreateReceiptInTx

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