sync

Documentation

Index

• type Reader
• type Synchronizer
  • func New(bc *blockchain.Blockchain, starkNetData starknetdata.StarknetData, ...) *Synchronizer
  • func (s *Synchronizer) HighestBlockHeader() *core.Header
  • func (s *Synchronizer) Run(ctx context.Context) error
  • func (s *Synchronizer) StartingBlockNumber() (uint64, error)

Types

type Reader

type Reader interface {
	StartingBlockNumber() (uint64, error)
	HighestBlockHeader() *core.Header
}

type Synchronizer

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

Synchronizer manages a list of StarknetData to fetch the latest blockchain updates

func New

func New(bc *blockchain.Blockchain, starkNetData starknetdata.StarknetData,
	log utils.SimpleLogger, pendingPollInterval time.Duration,
) *Synchronizer

func (*Synchronizer) HighestBlockHeader

func (s *Synchronizer) HighestBlockHeader() *core.Header

func (*Synchronizer) Run

func (s *Synchronizer) Run(ctx context.Context) error

Run starts the Synchronizer, returns an error if the loop is already running

func (*Synchronizer) StartingBlockNumber

func (s *Synchronizer) StartingBlockNumber() (uint64, error)