datastore

Documentation

Index

• func ErrBlockDoesNotExist(blockNumber int64) error
• func ErrContractDoesNotExist(contractHash string) error
• func ErrFilterDoesNotExist(name string) error
• func ErrReceiptDoesNotExist(txHash string) error
• type AddressRepository
• type BlockRepository
• type CheckedHeadersRepository
• type CheckedLogsRepository
• type ContractRepository
• type FilterRepository
• type FullSyncLogRepository
• type FullSyncReceiptRepository
• type HeaderRepository
• type HeaderSyncLogRepository
• type HeaderSyncReceiptRepository
• type WatchedEventRepository

Functions

func ErrBlockDoesNotExist

func ErrBlockDoesNotExist(blockNumber int64) error

func ErrContractDoesNotExist

func ErrContractDoesNotExist(contractHash string) error

func ErrFilterDoesNotExist

func ErrFilterDoesNotExist(name string) error

func ErrReceiptDoesNotExist

func ErrReceiptDoesNotExist(txHash string) error

Types

type AddressRepository

type AddressRepository interface {
	GetOrCreateAddress(address string) (int, error)
}

type BlockRepository

type BlockRepository interface {
	CreateOrUpdateBlock(block core.Block) (int64, error)
	GetBlock(blockNumber int64) (core.Block, error)
	MissingBlockNumbers(startingBlockNumber, endingBlockNumber int64, nodeID string) []int64
	SetBlocksStatus(chainHead int64) error
}

type CheckedHeadersRepository

type CheckedHeadersRepository interface {
	MarkHeaderChecked(headerID int64) error
	MarkHeadersUnchecked(startingBlockNumber int64) error
	UncheckedHeaders(startingBlockNumber, endingBlockNumber, checkCount int64) ([]core.Header, error)
}

type CheckedLogsRepository

type CheckedLogsRepository interface {
	AlreadyWatchingLog(addresses []string, topic0 string) (bool, error)
	MarkLogWatched(addresses []string, topic0 string) error
}

type ContractRepository

type ContractRepository interface {
	CreateContract(contract core.Contract) error
	GetContract(contractHash string) (core.Contract, error)
	ContractExists(contractHash string) (bool, error)
}

type FilterRepository

type FilterRepository interface {
	CreateFilter(filter filters.LogFilter) error
	GetFilter(name string) (filters.LogFilter, error)
}

type FullSyncLogRepository

type FullSyncLogRepository interface {
	CreateLogs(logs []core.FullSyncLog, receiptId int64) error
	GetLogs(address string, blockNumber int64) ([]core.FullSyncLog, error)
}

type FullSyncReceiptRepository

type FullSyncReceiptRepository interface {
	CreateReceiptsAndLogs(blockId int64, receipts []core.Receipt) error
	CreateFullSyncReceiptInTx(blockId int64, receipt core.Receipt, tx *sqlx.Tx) (int64, error)
	GetFullSyncReceipt(txHash string) (core.Receipt, error)
}

type HeaderRepository

type HeaderRepository interface {
	CreateOrUpdateHeader(header core.Header) (int64, error)
	CreateTransactions(headerID int64, transactions []core.TransactionModel) error
	GetHeader(blockNumber int64) (core.Header, error)
	MissingBlockNumbers(startingBlockNumber, endingBlockNumber int64, nodeID string) ([]int64, error)
}

type HeaderSyncLogRepository

type HeaderSyncLogRepository interface {
	GetUntransformedHeaderSyncLogs() ([]core.HeaderSyncLog, error)
	CreateHeaderSyncLogs(headerID int64, logs []types.Log) error
}

type HeaderSyncReceiptRepository

type HeaderSyncReceiptRepository interface {
	CreateFullSyncReceiptInTx(blockId int64, receipt core.Receipt, tx *sqlx.Tx) (int64, error)
}

type WatchedEventRepository

type WatchedEventRepository interface {
	GetWatchedEvents(name string) ([]*core.WatchedEvent, error)
}