submitting

Documentation

Index

• type DASubmitter
  • func NewDASubmitter(da coreda.DA, config config.Config, genesis genesis.Genesis, ...) *DASubmitter
  • func (s *DASubmitter) SubmitData(ctx context.Context, cache cache.Manager, signer signer.Signer, ...) error
  • func (s *DASubmitter) SubmitHeaders(ctx context.Context, cache cache.Manager) error
• type Submitter
  • func NewSubmitter(store store.Store, exec coreexecutor.Executor, cache cache.Manager, ...) *Submitter
  • func (s *Submitter) GetDAIncludedHeight() uint64
  • func (s *Submitter) IsHeightDAIncluded(height uint64, header *types.SignedHeader, data *types.Data) (bool, error)
  • func (s *Submitter) SetDAIncludedHeight(height uint64)
  • func (s *Submitter) Start(ctx context.Context) error
  • func (s *Submitter) Stop() error

Types

type DASubmitter

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

DASubmitter handles DA submission operations

func NewDASubmitter

func NewDASubmitter(
	da coreda.DA,
	config config.Config,
	genesis genesis.Genesis,
	options common.BlockOptions,
	metrics *common.Metrics,
	logger zerolog.Logger,
) *DASubmitter

NewDASubmitter creates a new DA submitter

func (*DASubmitter) SubmitData

func (s *DASubmitter) SubmitData(ctx context.Context, cache cache.Manager, signer signer.Signer, genesis genesis.Genesis) error

SubmitData submits pending data to DA layer

func (*DASubmitter) SubmitHeaders

func (s *DASubmitter) SubmitHeaders(ctx context.Context, cache cache.Manager) error

SubmitHeaders submits pending headers to DA layer

type Submitter

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

Submitter handles DA submission and inclusion processing for both sync and aggregator nodes

func NewSubmitter

func NewSubmitter(
	store store.Store,
	exec coreexecutor.Executor,
	cache cache.Manager,
	metrics *common.Metrics,
	config config.Config,
	genesis genesis.Genesis,
	daSubmitter daSubmitterAPI,
	signer signer.Signer,
	logger zerolog.Logger,
	errorCh chan<- error,
) *Submitter

NewSubmitter creates a new DA submitter component

func (*Submitter) GetDAIncludedHeight

func (s *Submitter) GetDAIncludedHeight() uint64

GetDAIncludedHeight returns the DA included height

func (*Submitter) IsHeightDAIncluded

func (s *Submitter) IsHeightDAIncluded(height uint64, header *types.SignedHeader, data *types.Data) (bool, error)

IsHeightDAIncluded checks if a height is included in DA

func (*Submitter) SetDAIncludedHeight

func (s *Submitter) SetDAIncludedHeight(height uint64)

SetDAIncludedHeight updates the DA included height

func (*Submitter) Start

func (s *Submitter) Start(ctx context.Context) error

Start begins the submitting component

func (*Submitter) Stop

func (s *Submitter) Stop() error

Stop shuts down the submitting component