synchronizer

Documentation

Index

• type BabylonSynchronizer
  • func NewBabylonSynchronizer(ctx context.Context, cfg *config.Config, db *store.Storage, ...) (*BabylonSynchronizer, error)
  • func (syncer *BabylonSynchronizer) Close() error
  • func (syncer *BabylonSynchronizer) ProcessBTCUndelegate(txMessage store.TxMessage) error
  • func (syncer *BabylonSynchronizer) ProcessCommitPubRandList(txMessage store.TxMessage) error
  • func (syncer *BabylonSynchronizer) ProcessCreateBTCDelegation(txMessage store.TxMessage) error
  • func (syncer *BabylonSynchronizer) ProcessNewFinalityProvider(txMessage store.TxMessage) error
  • func (syncer *BabylonSynchronizer) ProcessSelectiveSlashingEvidence(txMessage store.TxMessage) error
  • func (syncer *BabylonSynchronizer) Start() error
• type EthEventProcess
  • func NewEthEventProcess(db *store.Storage, logger log.Logger, ...) (*EthEventProcess, error)
  • func (e *EthEventProcess) Start() error
• type EthSynchronizer
  • func NewEthSynchronizer(cfg *config.Config, db *store.Storage, client node.EthClient, ...) (*EthSynchronizer, error)
  • func (syncer *EthSynchronizer) Close() error
  • func (syncer *EthSynchronizer) Start() error

Types

type BabylonSynchronizer

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

func NewBabylonSynchronizer

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

func (*BabylonSynchronizer) Close

func (syncer *BabylonSynchronizer) Close() error

func (*BabylonSynchronizer) ProcessBTCUndelegate

func (syncer *BabylonSynchronizer) ProcessBTCUndelegate(txMessage store.TxMessage) error

func (*BabylonSynchronizer) ProcessCommitPubRandList

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

func (*BabylonSynchronizer) ProcessCreateBTCDelegation

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

func (*BabylonSynchronizer) ProcessNewFinalityProvider

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

func (*BabylonSynchronizer) ProcessSelectiveSlashingEvidence

func (syncer *BabylonSynchronizer) ProcessSelectiveSlashingEvidence(txMessage store.TxMessage) error

func (*BabylonSynchronizer) Start

func (syncer *BabylonSynchronizer) Start() error

type EthEventProcess

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

func NewEthEventProcess

func NewEthEventProcess(db *store.Storage, logger log.Logger, contractEventChan chan store.ContractEvent) (*EthEventProcess, error)

func (*EthEventProcess) Start

func (e *EthEventProcess) Start() error

type EthSynchronizer

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

func NewEthSynchronizer

func NewEthSynchronizer(cfg *config.Config, db *store.Storage, client node.EthClient, logger log.Logger, shutdown context.CancelCauseFunc, contractEventChan chan store.ContractEvent) (*EthSynchronizer, error)

func (*EthSynchronizer) Close

func (syncer *EthSynchronizer) Close() error

func (*EthSynchronizer) Start

func (syncer *EthSynchronizer) Start() error