indexer

package

Go to main page

Versions in this module

v0

v0.3.15

Nov 25, 2024

v0.3.14

Nov 25, 2024

Changes in this version

type PostgreSQLpgx

+ func (p *PostgreSQLpgx) RetrievePathsAndBlockBounds(blockchain string, blockNumber uint64, minBlocksToSync int) ([]string, uint64, uint64, error)

v0.3.5

Oct 10, 2024

Changes in this version

+ func GetJobIds(abiJobs []AbiJob, isSilent bool) []string

type CustomerUpdates

+ func ConvertToCustomerUpdatedAndDeployBlockDicts(abiJobs []AbiJob) ([]CustomerUpdates, map[string]AbiJobsDeployInfo, error)

type PostgreSQLpgx

+ func (p *PostgreSQLpgx) CopyAbiJobs(sourceCustomerId, destCustomerId string, abiJobs []AbiJob) error

+ func (p *PostgreSQLpgx) DeleteJobs(jobIds []string) error

v0.3.2

Oct 9, 2024

v0.3.1

Oct 8, 2024

v0.3.0

Oct 8, 2024

Changes in this version

+ var InsertBatchSize = 1000

+ var InsertMaxParametersPerBatch = 65535

+ var MOONSTREAM_DB_V3_INDEXES_URI string

+ var SeerCrawlerLabel string

+ var SeerCrawlerRawLabel string

+ func BlocksTableName(blockchain string) string

+ func CheckVariablesForIndexer() error

+ func InitDBConnection()

+ func IsBlockchainWithL1Chain(blockchain string) bool

+ func LabelsTableName(blockchain string) string

+ func PrintContractSignatures(abiString string) (interface{}, error)

+ func ReadIndicesFromFile(filePath string) ([]interface{}, error)

+ func TransactionsTableName(blockchain string) string

+ func WriteIndicesToDatabase(blockchain string, blocks []BlockIndex) error

+ func WriteIndicesToFile(indices []interface{}, filePath string) error

+ type AbiEntry struct

+ Abi *abi.ABI

+ AbiJSON string

+ AbiName string

+ AbiType string

+ Once sync.Once

+ type AbiJob struct

+ Abi string

+ AbiName string

+ AbiSelector string

+ AbiType string

+ Address []byte

+ Chain string

+ CreatedAt time.Time

+ CustomerID string

+ DeploymentBlockNumber *uint64

+ HistoricalCrawlStatus string

+ ID string

+ MoonwormTaskPickedup bool

+ Progress int

+ Status string

+ UpdatedAt time.Time

+ UserID string

+ func FilterABIJobs(abiJobs []AbiJob, ids []string) []AbiJob

+ type AbiJobsDeployInfo struct

+ DeployedBlockNumber uint64

+ IDs []string

+ type BlockCache struct

+ BlockHash string

+ BlockNumber uint64

+ BlockTimestamp uint64

+ type BlockIndex struct

+ BlockHash string

+ BlockNumber uint64

+ BlockTimestamp uint64

+ L1BlockNumber uint64

+ ParentHash string

+ Path string

+ RowID uint64

+ func NewBlockIndex(chain string, blockNumber uint64, blockHash string, blockTimestamp uint64, ...) BlockIndex

+ func (b *BlockIndex) SetChain(chain string)

+ type CustomerUpdates struct

+ Abis map[string]map[string]*AbiEntry

+ CustomerID string

+ LastBlock uint64

+ Path string

+ type EventLabel struct

+ Address string

+ BlockHash string

+ BlockNumber uint64

+ BlockTimestamp uint64

+ CallerAddress string

+ Label string

+ LabelData string

+ LabelName string

+ LabelType string

+ LogIndex uint64

+ OriginAddress string

+ TransactionHash string

+ type IndexType string

+ const BlockIndexType

+ const LogIndexType

+ const TransactionIndexType

+ type PostgreSQLpgx struct

+ var DBConnection *PostgreSQLpgx

+ func NewPostgreSQLpgx() (*PostgreSQLpgx, error)

+ func NewPostgreSQLpgxWithCustomURI(uri string) (*PostgreSQLpgx, error)

+ func (p *PostgreSQLpgx) CleanIndexes(blockchain string, batchLimit uint64, sleepTime int) error

+ func (p *PostgreSQLpgx) Close()

+ func (p *PostgreSQLpgx) CreateJobsFromAbi(chain string, address string, abiFile string, customerID string, userID string, ...) error

+ func (p *PostgreSQLpgx) EnsureCorrectSelectors(blockchain string, WriteToDB bool, outputFilePath string, ids []string) error

+ func (p *PostgreSQLpgx) FindBatchPath(blockchain string, blockNumber uint64) (string, uint64, uint64, error)

+ func (p *PostgreSQLpgx) GetAbiJobsWithoutDeployBlocks(blockchain string) (map[string]map[string][]string, error)

+ func (p *PostgreSQLpgx) GetCustomersIDs(blockchain string) ([]string, error)

+ func (p *PostgreSQLpgx) GetEdgeDBBlock(ctx context.Context, blockchain, side string) (BlockIndex, error)

+ func (p *PostgreSQLpgx) GetLatestDBBlockNumber(blockchain string) (uint64, error)

+ func (p *PostgreSQLpgx) GetPool() *pgxpool.Pool

+ func (p *PostgreSQLpgx) ReadABIJobs(blockchain string) ([]AbiJob, error)

+ func (p *PostgreSQLpgx) ReadBlockIndex(ctx context.Context, startBlock uint64, endBlock uint64) ([]BlockIndex, error)

+ func (p *PostgreSQLpgx) ReadIndexOnRange(tableName string, startBlock uint64, endBlock uint64) ([]interface{}, error)

+ func (p *PostgreSQLpgx) ReadLastLabel(blockchain string) (uint64, error)

+ func (p *PostgreSQLpgx) ReadUpdates(blockchain string, fromBlock uint64, customerIds []string) (uint64, uint64, string, []CustomerUpdates, error)

+ func (p *PostgreSQLpgx) SelectAbiJobs(blockchain string, addresses []string, customersIds []string, autoJobs bool) ([]CustomerUpdates, map[string]AbiJobsDeployInfo, error)

+ func (p *PostgreSQLpgx) UpdateAbiJobsDeployBlock(blockNumber uint64, ids []string) error

+ func (p *PostgreSQLpgx) UpdateAbiJobsStatus(blockchain string) error

+ func (p *PostgreSQLpgx) UpdateAbisAsDone(ids []string) error

+ func (p *PostgreSQLpgx) UpdateAbisProgress(ids []string, process int) error

+ func (p *PostgreSQLpgx) WriteEvents(tx pgx.Tx, blockchain string, events []EventLabel) error

+ func (p *PostgreSQLpgx) WriteIndexes(blockchain string, blocksIndexPack []BlockIndex) error

+ func (p *PostgreSQLpgx) WriteLabes(blockchain string, transactions []TransactionLabel, events []EventLabel) error

+ func (p *PostgreSQLpgx) WriteTransactions(tx pgx.Tx, blockchain string, transactions []TransactionLabel) error

+ type TaskForLog struct

+ ABI string

+ Address string

+ Selector string

+ type TaskForTransaction struct

+ ABI string

+ Address string

+ Selector string

+ type TransactionLabel struct

+ Address string

+ BlockHash string

+ BlockNumber uint64

+ BlockTimestamp uint64

+ CallerAddress string

+ Label string

+ LabelData string

+ LabelName string

+ LabelType string

+ OriginAddress string

+ TransactionHash string

+ type UnnestInsertValueStruct struct

+ Type string

+ Values []interface{}

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL