blockchain

Documentation

Index

• Variables
• func CheckVariablesForBlockchains() error
• func CrawlEntireBlocks(client BlockchainClient, startBlock *big.Int, endBlock *big.Int, debug bool, ...) ([]proto.Message, []indexer.BlockIndex, uint64, error)
• func DecodeTransactionInputData(contractABI *abi.ABI, data []byte)
• func DeployBlocksLookUpAndUpdate(blockchain string) error
• func FindDeployedBlock(client BlockchainClient, address string) (uint64, error)
• func GetLatestBlockNumberWithRetry(client BlockchainClient, retryAttempts int, retryWaitTime time.Duration) (*big.Int, error)
• type BlockData
• type BlockchainClient
  • func NewClient(chain, url string, timeout int) (BlockchainClient, error)

Variables

var BlockchainURLs map[string]string

Functions

func CheckVariablesForBlockchains

func CheckVariablesForBlockchains() error

func CrawlEntireBlocks

func CrawlEntireBlocks(client BlockchainClient, startBlock *big.Int, endBlock *big.Int, debug bool, maxRequests int) ([]proto.Message, []indexer.BlockIndex, uint64, error)

func DecodeTransactionInputData

func DecodeTransactionInputData(contractABI *abi.ABI, data []byte)

func DeployBlocksLookUpAndUpdate

func DeployBlocksLookUpAndUpdate(blockchain string) error

func FindDeployedBlock

func FindDeployedBlock(client BlockchainClient, address string) (uint64, error)

func GetLatestBlockNumberWithRetry

func GetLatestBlockNumberWithRetry(client BlockchainClient, retryAttempts int, retryWaitTime time.Duration) (*big.Int, error)

Types

type BlockData

type BlockData struct {
	BlockNumber    uint64
	BlockHash      string
	BlockTimestamp int64
	ChainID        string
	Data           map[string]interface{}
}

type BlockchainClient

type BlockchainClient interface {
	GetLatestBlockNumber() (*big.Int, error)
	FetchAsProtoBlocksWithEvents(*big.Int, *big.Int, bool, int) ([]proto.Message, []indexer.BlockIndex, uint64, error)
	ProcessBlocksToBatch([]proto.Message) (proto.Message, error)
	DecodeProtoEntireBlockToJson(*bytes.Buffer) (*seer_common.BlocksBatchJson, error)
	DecodeProtoEntireBlockToLabels(*bytes.Buffer, map[string]map[string]*indexer.AbiEntry, int) ([]indexer.EventLabel, []indexer.TransactionLabel, error)
	DecodeProtoTransactionsToLabels([]string, map[uint64]uint64, map[string]map[string]*indexer.AbiEntry) ([]indexer.TransactionLabel, error)
	ChainType() string
	GetCode(context.Context, common.Address, uint64) ([]byte, error)
	GetTransactionsLabels(uint64, uint64, map[string]map[string]*indexer.AbiEntry, int) ([]indexer.TransactionLabel, map[uint64]seer_common.BlockWithTransactions, error)
	GetEventsLabels(uint64, uint64, map[string]map[string]*indexer.AbiEntry, map[uint64]seer_common.BlockWithTransactions) ([]indexer.EventLabel, error)
}

func NewClient

func NewClient(chain, url string, timeout int) (BlockchainClient, error)