sender

Documentation

Index

• type Config
• type Sender
  • func NewSender(cfg Config, poolDB poolDBInterface, monitor monitorInterface) *Sender
  • func (s *Sender) SendL2Transaction(l2Tx *types.L2Transaction) error
  • func (s *Sender) Start()

Types

type Config

type Config struct {
	// SequencerURL defines the URL for the sequencer RPC where the sender will send the pending txs
	SequencerURL string `mapstructure:"SequencerURL"`

	// ResendTxsCheckInterval is the time the sender waits to check in there are new txs in the pool
	ResendTxsCheckInterval types.Duration `mapstructure:"ResendTxsCheckInterval"`

	// Workers is the number of sender workers to send txs to the sequencer
	Workers uint16 `mapstructure:"Workers"`

	// QueueSize is the size of the queue for L2 txs that need to be sent to the sequencer
	QueueSize uint16 `mapstructure:"QueueSize"`
}

Config for pool-manager sender

type Sender

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

func NewSender

func NewSender(cfg Config, poolDB poolDBInterface, monitor monitorInterface) *Sender

func (*Sender) SendL2Transaction

func (s *Sender) SendL2Transaction(l2Tx *types.L2Transaction) error

func (*Sender) Start

func (s *Sender) Start()