Documentation
¶
Index ¶
- type BlockCache
- type Manager
- func (m *Manager) AggregationLoop(ctx context.Context, lazy bool)
- func (m *Manager) BlockStoreRetrieveLoop(ctx context.Context)
- func (m *Manager) BlockSubmissionLoop(ctx context.Context)
- func (m *Manager) GetStoreHeight() uint64
- func (m *Manager) IsProposer() (bool, error)
- func (m *Manager) RetrieveLoop(ctx context.Context)
- func (m *Manager) SetDALC(dalc da.DataAvailabilityLayerClient)
- func (m *Manager) SyncLoop(ctx context.Context, cancel context.CancelFunc)
- type PendingBlocks
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlockCache ¶ added in v0.10.2
type BlockCache struct {
// contains filtered or unexported fields
}
func NewBlockCache ¶ added in v0.10.2
func NewBlockCache() *BlockCache
type Manager ¶
type Manager struct {
HeaderCh chan *types.SignedHeader
BlockCh chan *types.Block
// contains filtered or unexported fields
}
Manager is responsible for aggregating transactions into blocks.
func NewManager ¶
func NewManager( proposerKey crypto.PrivKey, conf config.BlockManagerConfig, genesis *cmtypes.GenesisDoc, store store.Store, mempool mempool.Mempool, proxyApp proxy.AppConnConsensus, dalc da.DataAvailabilityLayerClient, eventBus *cmtypes.EventBus, logger log.Logger, doneBuildingCh chan struct{}, blockStore *goheaderstore.Store[*types.Block], ) (*Manager, error)
NewManager creates new block Manager.
func (*Manager) AggregationLoop ¶
AggregationLoop is responsible for aggregating transactions into rollup-blocks.
func (*Manager) BlockStoreRetrieveLoop ¶ added in v0.10.2
BlockStoreRetrieveLoop is responsible for retrieving blocks from the Block Store.
func (*Manager) BlockSubmissionLoop ¶ added in v0.10.2
BlockSubmissionLoop is responsible for submitting blocks to the DA layer.
func (*Manager) GetStoreHeight ¶ added in v0.10.2
GetStoreHeight returns the manager's store height
func (*Manager) IsProposer ¶ added in v0.7.3
func (*Manager) RetrieveLoop ¶
RetrieveLoop is responsible for interacting with DA layer.
func (*Manager) SetDALC ¶
func (m *Manager) SetDALC(dalc da.DataAvailabilityLayerClient)
SetDALC is used to set DataAvailabilityLayerClient used by Manager.
type PendingBlocks ¶ added in v0.10.3
type PendingBlocks struct {
// contains filtered or unexported fields
}
Maintains blocks that need to be published to DA layer
func NewPendingBlocks ¶ added in v0.10.3
func NewPendingBlocks() *PendingBlocks
Source Files
Click to show internal directories.
Click to hide internal directories.