block

Documentation

Index

• type Manager
  • func NewManager(proposerKey crypto.PrivKey, conf config.BlockManagerConfig, ...) (*Manager, error)
  • func (m *Manager) EventListener(ctx context.Context)
  • func (m *Manager) ProduceBlockLoop(ctx context.Context)
  • func (m *Manager) RetrieveLoop(ctx context.Context)
  • func (m *Manager) SetDALC(dalc da.DataAvailabilityLayerClient)
  • func (m *Manager) Start(ctx context.Context, isAggregator bool) error
  • func (m *Manager) SubmitLoop(ctx context.Context)
  • func (m *Manager) SyncTargetLoop(ctx context.Context)

Types

type Manager

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

Manager is responsible for aggregating transactions into blocks.

func NewManager

func NewManager(
	proposerKey crypto.PrivKey,
	conf config.BlockManagerConfig,
	genesis *tmtypes.GenesisDoc,
	store store.Store,
	mempool mempool.Mempool,
	proxyApp proxy.AppConns,
	dalc da.DataAvailabilityLayerClient,
	settlementClient settlement.LayerI,
	eventBus *tmtypes.EventBus,
	pubsub *pubsub.Server,
	p2pClient *p2p.Client,
	logger log.Logger,
) (*Manager, error)

NewManager creates new block Manager.

func (*Manager) EventListener

func (m *Manager) EventListener(ctx context.Context)

EventListener registers events to callbacks.

func (*Manager) ProduceBlockLoop

func (m *Manager) ProduceBlockLoop(ctx context.Context)

ProduceBlockLoop is calling publishBlock in a loop as long as wer'e synced.

func (*Manager) RetrieveLoop

func (m *Manager) RetrieveLoop(ctx context.Context)

RetriveLoop listens for new sync messages written to a ring buffer and in turn runs syncUntilTarget on the latest message in the ring buffer.

func (*Manager) SetDALC

func (m *Manager) SetDALC(dalc da.DataAvailabilityLayerClient)

SetDALC is used to set DataAvailabilityLayerClient used by Manager. TODO(omritoptix): Remove this from here as it's only being used for tests.

func (*Manager) Start

func (m *Manager) Start(ctx context.Context, isAggregator bool) error

Start starts the block manager.

func (*Manager) SubmitLoop

func (m *Manager) SubmitLoop(ctx context.Context)

func (*Manager) SyncTargetLoop

func (m *Manager) SyncTargetLoop(ctx context.Context)

SyncTargetLoop is responsible for getting real time updates about batches submission. for non aggregator: updating the sync target which will be used by retrieveLoop to sync until this target. for aggregator: get notification that batch has been accepted so can send next batch.