implementation

Documentation

Index

• type BtcLatestTransactionsIndex
  • func (i BtcLatestTransactionsIndex) ConnectBlock(tx pgx.Tx, block *core.AbstractMsgBlock, blockHeight int64, ...) error
  • func (i BtcLatestTransactionsIndex) DisconnectBlock(tx pgx.Tx, block *core.AbstractMsgBlock, _ int64, _ *core.AbstractRPCClient) error
  • func (i BtcLatestTransactionsIndex) FetchNextBlockFromNode(offset int64, checkPrevBlock bool, rpcClient *core.AbstractRPCClient, ...) (block *core.AbstractMsgBlock, prevBlockNumber, blockHeight int64, ...)
  • func (i BtcLatestTransactionsIndex) InitRPCClient() (*core.AbstractRPCClient, error)
• type JaxLatestTransactionsIndex
  • func (i JaxLatestTransactionsIndex) ConnectBlock(tx pgx.Tx, block *core.AbstractMsgBlock, blockHeight int64, ...) error
  • func (i JaxLatestTransactionsIndex) DisconnectBlock(tx pgx.Tx, block *core.AbstractMsgBlock, _ int64, _ *core.AbstractRPCClient) error
  • func (i JaxLatestTransactionsIndex) FetchNextBlockFromNode(offset int64, checkPrevBlock bool, rpcClient *core.AbstractRPCClient, ...) (block *core.AbstractMsgBlock, prevBlockNumber, blockHeight int64, ...)
  • func (i JaxLatestTransactionsIndex) InitRPCClient() (*core.AbstractRPCClient, error)
• type LatestTransactionsIndex
  • func (i LatestTransactionsIndex) DefaultFirstBlockForProcessing() (blockNumber int64)
  • func (i LatestTransactionsIndex) PrepareDatabase() error
  • func (i LatestTransactionsIndex) SetHttpHandlers(group *router.Group)

Types

type BtcLatestTransactionsIndex

type BtcLatestTransactionsIndex struct {
	LatestTransactionsIndex
}

func (BtcLatestTransactionsIndex) ConnectBlock

func (i BtcLatestTransactionsIndex) ConnectBlock(tx pgx.Tx, block *core.AbstractMsgBlock, blockHeight int64, rpcClient *core.AbstractRPCClient) error

func (BtcLatestTransactionsIndex) DisconnectBlock

func (i BtcLatestTransactionsIndex) DisconnectBlock(tx pgx.Tx, block *core.AbstractMsgBlock, _ int64, _ *core.AbstractRPCClient) error

func (BtcLatestTransactionsIndex) FetchNextBlockFromNode

func (i BtcLatestTransactionsIndex) FetchNextBlockFromNode(offset int64, checkPrevBlock bool,
	rpcClient *core.AbstractRPCClient, cacheHandler *blocks_cache.CacheHandler) (
	block *core.AbstractMsgBlock, prevBlockNumber, blockHeight int64, rebuildingChainBlockNumber int64, err error)

func (BtcLatestTransactionsIndex) InitRPCClient

func (i BtcLatestTransactionsIndex) InitRPCClient() (*core.AbstractRPCClient, error)

type JaxLatestTransactionsIndex

type JaxLatestTransactionsIndex struct {
	LatestTransactionsIndex
}

func (JaxLatestTransactionsIndex) ConnectBlock

func (i JaxLatestTransactionsIndex) ConnectBlock(tx pgx.Tx, block *core.AbstractMsgBlock, blockHeight int64, rpcClient *core.AbstractRPCClient) error

func (JaxLatestTransactionsIndex) DisconnectBlock

func (i JaxLatestTransactionsIndex) DisconnectBlock(tx pgx.Tx, block *core.AbstractMsgBlock, _ int64, _ *core.AbstractRPCClient) error

func (JaxLatestTransactionsIndex) FetchNextBlockFromNode

func (i JaxLatestTransactionsIndex) FetchNextBlockFromNode(offset int64, checkPrevBlock bool,
	rpcClient *core.AbstractRPCClient, cacheHandler *blocks_cache.CacheHandler) (
	block *core.AbstractMsgBlock, prevBlockNumber, blockHeight int64, rebuildingChainBlockNumber int64, err error)

func (JaxLatestTransactionsIndex) InitRPCClient

func (i JaxLatestTransactionsIndex) InitRPCClient() (*core.AbstractRPCClient, error)

type LatestTransactionsIndex

type LatestTransactionsIndex struct{}

func (LatestTransactionsIndex) DefaultFirstBlockForProcessing

func (i LatestTransactionsIndex) DefaultFirstBlockForProcessing() (blockNumber int64)

func (LatestTransactionsIndex) PrepareDatabase

func (i LatestTransactionsIndex) PrepareDatabase() error

func (LatestTransactionsIndex) SetHttpHandlers

func (i LatestTransactionsIndex) SetHttpHandlers(group *router.Group)