sync

Documentation

Index

• type Synchronizer
  • func New(bc *blockchain.Blockchain, starkNetData starknetdata.StarknetData, ...) *Synchronizer
  • func (s *Synchronizer) Run(ctx context.Context) error

Types

type Synchronizer

type Synchronizer struct {
	Blockchain          *blockchain.Blockchain
	StarknetData        starknetdata.StarknetData
	StartingBlockNumber *uint64
	HighestBlockHeader  *core.Header
	// 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) Run

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

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