Documentation
¶
Index ¶
- Variables
- type Sequencer
- func (s *Sequencer) HighestBlockHeader() *core.Header
- func (s *Sequencer) Pending() (*sync.Pending, error)
- func (s *Sequencer) PendingBlock() *core.Block
- func (s *Sequencer) PendingState() (core.StateReader, func() error, error)
- func (s *Sequencer) Run(ctx context.Context) error
- func (s *Sequencer) RunOnce() (*core.Header, error)
- func (s *Sequencer) StartingBlockNumber() (uint64, error)
- func (s *Sequencer) SubscribeNewHeads() sync.NewHeadSubscription
- func (s *Sequencer) SubscribePending() sync.PendingSubscription
- func (s *Sequencer) SubscribeReorg() sync.ReorgSubscription
- func (s *Sequencer) WithPlugin(junoPlugin plugin.JunoPlugin) *Sequencer
Constants ¶
This section is empty.
Variables ¶
View Source
var (
NumTxnsToBatchExecute = 10
)
Functions ¶
This section is empty.
Types ¶
type Sequencer ¶
type Sequencer struct {
// contains filtered or unexported fields
}
func (*Sequencer) HighestBlockHeader ¶
func (*Sequencer) PendingBlock ¶
func (*Sequencer) PendingState ¶
func (s *Sequencer) PendingState() (core.StateReader, func() error, error)
func (*Sequencer) StartingBlockNumber ¶
func (*Sequencer) SubscribeNewHeads ¶
func (s *Sequencer) SubscribeNewHeads() sync.NewHeadSubscription
func (*Sequencer) SubscribePending ¶
func (s *Sequencer) SubscribePending() sync.PendingSubscription
func (*Sequencer) SubscribeReorg ¶
func (s *Sequencer) SubscribeReorg() sync.ReorgSubscription
The builder has no reorg logic (centralised sequencer that can't reorg)
func (*Sequencer) WithPlugin ¶
func (s *Sequencer) WithPlugin(junoPlugin plugin.JunoPlugin) *Sequencer
Click to show internal directories.
Click to hide internal directories.