synchronizer

README

synchronizer

Package is responsible to pull data from a blockchain.

For the moment only Starknet is supported.

You can either choose to use feeder_gateway as a datasource or full node.

Documentation

Index

• func Run(ctx context.Context, opts *cli.IndexerOptions, ...)
• type BlockDatasource
• type FeederGateway
  • func NewFeederGatewaySynchronizer(client *starknet.FeederGatewayClient, storage storage.Storage) *FeederGateway
  • func (g *FeederGateway) Start(ctx context.Context)
  • func (g *FeederGateway) SyncBlock(ctx context.Context, block uint64) error
• type FullNode
  • func (n *FullNode) Start(ctx context.Context)
  • func (n *FullNode) SyncBlock(ctx context.Context, block uint64) error
• type Synchronizer
  • func NewSynchronizer(client *starknet.FeederGatewayClient, storage storage.Storage) *Synchronizer
  • func (s *Synchronizer) FetchBlock(blockNumber uint64) (*starknet.GetBlockResponse, error)
  • func (s *Synchronizer) Start(ctx context.Context)
  • func (s *Synchronizer) SyncBlock(ctx context.Context, block *starknet.GetBlockResponse)

Functions

func Run

func Run(ctx context.Context, opts *cli.IndexerOptions, client *starknet.FeederGatewayClient, storage storage.Storage)

Types

type BlockDatasource

type BlockDatasource interface {
	Start(context.Context)
	SyncBlock(context.Context, uint64) error
}

type FeederGateway

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

func NewFeederGatewaySynchronizer

func NewFeederGatewaySynchronizer(client *starknet.FeederGatewayClient, storage storage.Storage) *FeederGateway

func (*FeederGateway) Start

func (g *FeederGateway) Start(ctx context.Context)

func (*FeederGateway) SyncBlock

func (g *FeederGateway) SyncBlock(ctx context.Context, block uint64) error

type FullNode

type FullNode struct{}

func (*FullNode) Start

func (n *FullNode) Start(ctx context.Context)

func (*FullNode) SyncBlock

func (n *FullNode) SyncBlock(ctx context.Context, block uint64) error

type Synchronizer

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

func NewSynchronizer

func NewSynchronizer(client *starknet.FeederGatewayClient, storage storage.Storage) *Synchronizer

func (*Synchronizer) FetchBlock

func (s *Synchronizer) FetchBlock(blockNumber uint64) (*starknet.GetBlockResponse, error)

func (*Synchronizer) Start

func (s *Synchronizer) Start(ctx context.Context)

func (*Synchronizer) SyncBlock

func (s *Synchronizer) SyncBlock(ctx context.Context, block *starknet.GetBlockResponse)