blockfetcher

package
v0.0.0-...-0e6aee3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 16, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const CONFIRMS uint64 = 20

Variables

This section is empty.

Functions

This section is empty.

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.