adapter

Documentation

Index

• type BlockPersistence
• type CursorFunc

Types

type BlockPersistence

type BlockPersistence interface {
	WriteNextBlock(blockPair *protocol.BlockPairContainer) (bool, primitives.BlockHeight, error)
	ScanBlocks(from primitives.BlockHeight, pageSize uint8, f CursorFunc) error
	GetLastBlockHeight() (primitives.BlockHeight, error)
	GetLastBlock() (*protocol.BlockPairContainer, error)
	GetBlock(height primitives.BlockHeight) (*protocol.BlockPairContainer, error)
	GetSyncState() internodesync.SyncState
	GetTransactionsBlock(height primitives.BlockHeight) (*protocol.TransactionsBlockContainer, error)
	GetResultsBlock(height primitives.BlockHeight) (*protocol.ResultsBlockContainer, error)
	GetBlockByTx(txHash primitives.Sha256, minBlockTs primitives.TimestampNano, maxBlockTs primitives.TimestampNano) (block *protocol.BlockPairContainer, txIndexInBlock int, err error)
	GetBlockTracker() *synchronization.BlockTracker
}

type CursorFunc

type CursorFunc func(first primitives.BlockHeight, page []*protocol.BlockPairContainer) (wantsMore bool)

A Callback function provided by consumers of blocks from storage. Each invocation receives a single blocks page of the requested size. Methods receiving this type will call this function repeatedly until it returns false to signal no more pages are required or until there are no more blocks to fetch.