manager

type BookKeepersChangedEvent ¶

type BookKeepersChangedEvent struct {
	RawPeers []byte `json:"raw_peers"`
}

type CrossTransfer ¶

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

func (t *CrossTransfer) Deserialization(source *common.ZeroCopySource) error

func (t *CrossTransfer) Serialization(sink *common.ZeroCopySink)

type GenesisInitEvent ¶

type GenesisInitEvent struct {
	Height    uint32 `json:"height"`
	RawHeader []byte `json:"raw_header"`
}

type PolyManager ¶

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

func NewPolyManager(
	srvCfg *config.ServiceConfig,
	polyForceStartBlockHeight uint32,
	polySDK *sdk.PolySdk,
	quorumSDK *sccli.Client,
	boltDB *db.BoltDB,
) (*PolyManager, error)

func (m *PolyManager) MonitorChain()

func (m *PolyManager) Stop()

type QuorumManager ¶

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

QuorumManager quorum->poly: 1. record quorum height in poly 2. fetch quorum header and proof and send to poly chain 3. The synchronization process is often batch processing, rather than block-by-block synchronization or submitting events, etc., so two slices are required to record the header and crossTx. 4. To ensure that each block is not dropped, we need a currentHeight mark stored in the headerSync contract of the relay chain to record which block is currently processed. 5. A cross chain manager is required to obtain cross-chain events from the solidity contract on the quorum chain

func NewQuorumManager(
	cfg *config.ServiceConfig,
	startHeight,
	startForceHeight uint64,
	polySdk *polysdk.PolySdk,
	quorumClient *sccli.Client,
	boltDB *db.BoltDB,
) (*QuorumManager, error)

func (m *QuorumManager) CheckDeposit()

func (m *QuorumManager) MonitorChain()

func (m *QuorumManager) MonitorDeposit()

type QuorumSender ¶

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

type QuorumTxInfo ¶

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