synchronizer

Documentation

Index

• type Synchronizer
  • func NewSynchronizer(ctx context.Context, cfg *config.Config, db *store.Storage, ...) (*Synchronizer, error)
  • func (syncer *Synchronizer) Close() error
  • func (syncer *Synchronizer) ProcessCommitPubRandList(txMessage store.TxMessage) error
  • func (syncer *Synchronizer) ProcessCreateBTCDelegation(txMessage store.TxMessage) error
  • func (syncer *Synchronizer) ProcessNewFinalityProvider(txMessage store.TxMessage) error
  • func (syncer *Synchronizer) Start() error

Types

type Synchronizer

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

func NewSynchronizer

func NewSynchronizer(ctx context.Context, cfg *config.Config, db *store.Storage, shutdown context.CancelCauseFunc, logger log.Logger, txMsgChan chan store.TxMessage) (*Synchronizer, error)

func (*Synchronizer) Close

func (syncer *Synchronizer) Close() error

func (*Synchronizer) ProcessCommitPubRandList

func (syncer *Synchronizer) ProcessCommitPubRandList(txMessage store.TxMessage) error

func (*Synchronizer) ProcessCreateBTCDelegation

func (syncer *Synchronizer) ProcessCreateBTCDelegation(txMessage store.TxMessage) error

func (*Synchronizer) ProcessNewFinalityProvider

func (syncer *Synchronizer) ProcessNewFinalityProvider(txMessage store.TxMessage) error

func (*Synchronizer) Start

func (syncer *Synchronizer) Start() error