trackooor

Documentation

Index

• Variables
• func GetPastBlocks()
• func GetPastEventsSingle()
• func HandleHeader(header *types.Header)
• func ListenToBlocks()
• func ListenToEventsSingle()
• func ListenToPendingBlocks()
• func ProcessHistoricalBlocks(fromBlock *big.Int, toBlock *big.Int)
• func ProcessHistoricalEventsSingle(fromBlock *big.Int, toBlock *big.Int, eventTopics [][]common.Hash)
• func SetupHistorical()
• func SetupListener(options shared.TrackooorOptions)
• type SubscriptionLogs

Variables

var MaxRequestsPerSecond = 30 // max rpc requests per second

Functions

func GetPastBlocks

func GetPastBlocks()

func GetPastEventsSingle

func GetPastEventsSingle()

func HandleHeader

func HandleHeader(header *types.Header)

func ListenToBlocks

func ListenToBlocks()

func ListenToEventsSingle

func ListenToEventsSingle()

listens to events of multiple contracts, but instead of creating an event subscription log for each contract, it uses a single channel for all of them. downside is that event sigs cannot be filtered for each contract individually aka cannot filter only event X for contract A, and event Y for contract B

func ListenToPendingBlocks

func ListenToPendingBlocks()

func ProcessHistoricalBlocks

func ProcessHistoricalBlocks(fromBlock *big.Int, toBlock *big.Int)

func ProcessHistoricalEventsSingle

func ProcessHistoricalEventsSingle(fromBlock *big.Int, toBlock *big.Int, eventTopics [][]common.Hash)

func SetupHistorical

func SetupHistorical()

function called just before starting a historical processor

func SetupListener

func SetupListener(options shared.TrackooorOptions)

Types

type SubscriptionLogs

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