datastore

Aug 24, 2021

Changes in this version

type HeaderRepository

+ DeleteHeader func(blockNumber int64) error

Oct 7, 2020

Changes in this version

type CheckedHeadersRepository

+ MarkSingleHeaderUnchecked func(blockNumber int64) error

+ type EventLogRepository interface

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

+ GetUntransformedEventLogs func(minID, limit int) ([]core.EventLog, error)

type HeaderRepository

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

+ GetHeaderByBlockNumber func(blockNumber int64) (core.Header, error)

+ GetHeaderByID func(id int64) (core.Header, error)

+ GetHeadersInRange func(startingBlock, endingBlock int64) ([]core.Header, error)

+ GetMostRecentHeaderBlockNumber func() (int64, error)

Nov 20, 2019

Changes in this version

+ type AddressRepository interface

+ GetOrCreateAddress func(address string) (int, error)

+ type CheckedHeadersRepository interface

+ MarkHeaderChecked func(headerID int64) error

+ MarkHeadersUnchecked func(startingBlockNumber int64) error

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

+ type CheckedLogsRepository interface

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

+ MarkLogWatched func(addresses []string, topic0 string) error

+ type FullSyncLogRepository interface

+ CreateLogs func(logs []core.FullSyncLog, receiptId int64) error

+ GetLogs func(address string, blockNumber int64) ([]core.FullSyncLog, error)

+ type FullSyncReceiptRepository interface

+ CreateFullSyncReceiptInTx func(blockId int64, receipt core.Receipt, tx *sqlx.Tx) (int64, error)

+ CreateReceiptsAndLogs func(blockId int64, receipts []core.Receipt) error

+ GetFullSyncReceipt func(txHash string) (core.Receipt, error)

+ type HeaderSyncLogRepository interface

+ CreateHeaderSyncLogs func(headerID int64, logs []types.Log) error

+ GetUntransformedHeaderSyncLogs func() ([]core.HeaderSyncLog, error)

+ type HeaderSyncReceiptRepository interface

+ CreateFullSyncReceiptInTx func(blockId int64, receipt core.Receipt, tx *sqlx.Tx) (int64, error)

Apr 9, 2019

Changes in this version

+ func ErrBlockDoesNotExist(blockNumber int64) error

+ func ErrContractDoesNotExist(contractHash string) error

+ func ErrFilterDoesNotExist(name string) error

+ func ErrReceiptDoesNotExist(txHash string) error

+ type BlockRepository interface

+ CreateOrUpdateBlock func(block core.Block) (int64, error)

+ GetBlock func(blockNumber int64) (core.Block, error)

+ MissingBlockNumbers func(startingBlockNumber, endingBlockNumber int64, nodeID string) []int64

+ SetBlocksStatus func(chainHead int64) error

+ type ContractRepository interface

+ ContractExists func(contractHash string) (bool, error)

+ CreateContract func(contract core.Contract) error

+ GetContract func(contractHash string) (core.Contract, error)

+ type FilterRepository interface

+ CreateFilter func(filter filters.LogFilter) error

+ GetFilter func(name string) (filters.LogFilter, error)

+ type HeaderRepository interface

+ CreateOrUpdateHeader func(header core.Header) (int64, error)

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

+ GetHeader func(blockNumber int64) (core.Header, error)

+ MissingBlockNumbers func(startingBlockNumber, endingBlockNumber int64, nodeID string) ([]int64, error)

+ type LogRepository interface

+ CreateLogs func(logs []core.Log, receiptId int64) error

+ GetLogs func(address string, blockNumber int64) ([]core.Log, error)

+ type ReceiptRepository interface

+ CreateReceipt func(blockId int64, receipt core.Receipt) (int64, error)

+ CreateReceiptsAndLogs func(blockId int64, receipts []core.Receipt) error

+ GetReceipt func(txHash string) (core.Receipt, error)

+ type WatchedEventRepository interface

+ GetWatchedEvents func(name string) ([]*core.WatchedEvent, error)