repositories

Documentation

Index

• func NewHeaderRepository(database *postgres.DB) headerRepository
• type CheckedHeadersRepository
  • func NewCheckedHeadersRepository(db *postgres.DB, schemaName string) (*CheckedHeadersRepository, error)
  • func (repo CheckedHeadersRepository) MarkHeaderChecked(headerID 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(minID, limit int) ([]core.EventLog, error)
• type ReceiptRepository
  • func (ReceiptRepository) CreateReceiptInTx(headerID, transactionID int64, receipt core.Receipt, tx *sqlx.Tx) (int64, error)
• type SchemaQuery

Functions

func NewHeaderRepository

func NewHeaderRepository(database *postgres.DB) headerRepository

Types

type CheckedHeadersRepository

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

func NewCheckedHeadersRepository

func NewCheckedHeadersRepository(db *postgres.DB, schemaName string) (*CheckedHeadersRepository, error)

func (CheckedHeadersRepository) MarkHeaderChecked

func (repo CheckedHeadersRepository) MarkHeaderChecked(headerID int64) error

Increment check_count for header

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(minID, limit int) ([]core.EventLog, error)

type ReceiptRepository

type ReceiptRepository struct{}

func (ReceiptRepository) CreateReceiptInTx

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

type SchemaQuery

type SchemaQuery struct {
	SchemaName string `db:"schema_name"`
}