blockfetcher

Documentation

Index

• Constants
• type BlockFetcher
  • func NewBlockFetcher(rpcClient *thegarii.Client, ...) *BlockFetcher
  • func (f *BlockFetcher) Fetch(ctx context.Context, blockNum uint64) (block *pbbstream.Block, err error)
• type ThegariiBlockFetcher
  • func NewThegariiBlockFetcher(rpcClient *thegarii.Client, intervalBetweenFetch time.Duration, ...) *ThegariiBlockFetcher
  • func (f *ThegariiBlockFetcher) Fetch(ctx context.Context, blockNum uint64) (*pbbstream.Block, error)
  • func (f *ThegariiBlockFetcher) PollingInterval() time.Duration
• type ToArwBlock

Constants

const CONFIRMS uint64 = 20

Types

type BlockFetcher

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

func NewBlockFetcher

func NewBlockFetcher(rpcClient *thegarii.Client, intervalBetweenFetch, latestBlockRetryInterval time.Duration, toArwBlock ToArwBlock, logger *zap.Logger) *BlockFetcher

func (*BlockFetcher) Fetch

func (f *BlockFetcher) Fetch(ctx context.Context, blockNum uint64) (block *pbbstream.Block, err error)

type ThegariiBlockFetcher

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

func NewThegariiBlockFetcher

func NewThegariiBlockFetcher(rpcClient *thegarii.Client, intervalBetweenFetch time.Duration, latestBlockRetryInterval time.Duration, logger *zap.Logger) *ThegariiBlockFetcher

func (*ThegariiBlockFetcher) Fetch

func (f *ThegariiBlockFetcher) Fetch(ctx context.Context, blockNum uint64) (*pbbstream.Block, error)

func (*ThegariiBlockFetcher) PollingInterval

func (f *ThegariiBlockFetcher) PollingInterval() time.Duration

type ToArwBlock

type ToArwBlock func(in *rpc.Block, receipts map[string]*rpc.TransactionReceipt) (*pbarweave.Block, map[string]bool)