sync

Documentation

Index

• Constants
• type EventListener
• type Reader
• type SelectiveListener
  • func (l *SelectiveListener) OnReorg(blockNum uint64)
  • func (l *SelectiveListener) OnSyncStepDone(op string, blockNum uint64, took time.Duration)
• 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)
  • func (s *Synchronizer) WithListener(listener EventListener) *Synchronizer

Constants

const (
	OpVerify = "verify"
	OpStore  = "store"
	OpFetch  = "fetch"
)

Types

type EventListener

type EventListener interface {
	OnSyncStepDone(op string, blockNum uint64, took time.Duration)
	OnReorg(blockNum uint64)
}

type Reader

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

type SelectiveListener

type SelectiveListener struct {
	OnSyncStepDoneCb func(op string, blockNum uint64, took time.Duration)
	OnReorgCb        func(blockNum uint64)
}

func (*SelectiveListener) OnReorg

func (l *SelectiveListener) OnReorg(blockNum uint64)

func (*SelectiveListener) OnSyncStepDone

func (l *SelectiveListener) OnSyncStepDone(op string, blockNum uint64, took time.Duration)

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)

func (*Synchronizer) WithListener

func (s *Synchronizer) WithListener(listener EventListener) *Synchronizer

WithListener registers an EventListener