rpc

Documentation

Index

• func FetchBlock(ctx context.Context, ...) (*starknetRPC.BlockWithReceipts, error)
• func FetchStateUpdate(ctx context.Context, ...) (*starknetRPC.StateUpdateOutput, error)
• type Fetcher
  • func NewFetcher(starknetClients *firecoreRPC.Clients[*starknetRPC.Provider], ...) *Fetcher
  • func (f *Fetcher) Fetch(ctx context.Context, requestBlockNum uint64) (b *pbbstream.Block, skipped bool, err error)
  • func (f *Fetcher) IsBlockAvailable(blockNum uint64) bool

Functions

func FetchBlock

func FetchBlock(ctx context.Context, starknetClients *firecoreRPC.Clients[*starknetRPC.Provider], requestBlockNum uint64) (*starknetRPC.BlockWithReceipts, error)

func FetchStateUpdate

func FetchStateUpdate(ctx context.Context, starknetClients *firecoreRPC.Clients[*starknetRPC.Provider], blockNum uint64) (*starknetRPC.StateUpdateOutput, error)

Types

type Fetcher

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

func NewFetcher

func NewFetcher(
	starknetClients *firecoreRPC.Clients[*starknetRPC.Provider],
	ethClient *firecoreRPC.Clients[*ethRPC.Client],
	fetchLIBContractAddress string,
	fetchInterval time.Duration,
	latestBlockRetryInterval time.Duration,
	logger *zap.Logger) *Fetcher

func (*Fetcher) Fetch

func (f *Fetcher) Fetch(ctx context.Context, requestBlockNum uint64) (b *pbbstream.Block, skipped bool, err error)

func (*Fetcher) IsBlockAvailable

func (f *Fetcher) IsBlockAvailable(blockNum uint64) bool