txmgr

Documentation

Index

• type ETHBackend
• type PreconfClient
• type PreconfTxMgr
  • func NewPreconfTxMgr(l log.Logger, backend ETHBackend, cfg *txmgr.Config, client PreconfClient, ...) *PreconfTxMgr
  • func (m *PreconfTxMgr) Send(ctx context.Context, candidate txmgr.TxCandidate) (*types.Receipt, error)

Types

type ETHBackend

type ETHBackend interface {
	txmgr.ETHBackend

	BlockByNumber(ctx context.Context, num *big.Int) (*types.Block, error)
}

type PreconfClient

type PreconfClient interface {
	GetSlots(ctx context.Context) ([]luban.SlotInfo, error)
	GetPreconfFee(ctx context.Context, slot uint64) (uint64, uint64, error)

	ReserveBlockspace(ctx context.Context, req luban.ReserveBlockSpaceRequest) (uuid.UUID, error)

	SubmitTransaction(ctx context.Context, reqId uuid.UUID, tx *types.Transaction) error
}

type PreconfTxMgr

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

func NewPreconfTxMgr

func NewPreconfTxMgr(l log.Logger, backend ETHBackend, cfg *txmgr.Config, client PreconfClient, beaconUrl string) *PreconfTxMgr

func (*PreconfTxMgr) Send

func (m *PreconfTxMgr) Send(ctx context.Context, candidate txmgr.TxCandidate) (*types.Receipt, error)

TODO: wrap in timeout?