txsubmitter

Documentation

Index

• type RpcClient
• type TxSubmission
  • func (s *TxSubmission) Confirmed() bool
  • func (s *TxSubmission) ToBatch(backend RpcClient, sender wallet.PubKey, log *slog.Logger) *TxSubmissionBatch
• type TxSubmissionBatch
  • func NewBatch(sender wallet.PubKey, rpcClient RpcClient, log *slog.Logger) *TxSubmissionBatch
  • func (t *TxSubmissionBatch) Add(sub *TxSubmission)
  • func (t *TxSubmissionBatch) SendTx(ctx context.Context, confirmTx bool) error
  • func (t *TxSubmissionBatch) Submissions() []*TxSubmission

Types

type RpcClient

type RpcClient interface {
	GetRoundNumber(ctx context.Context) (uint64, error)
	SendTransaction(ctx context.Context, tx *types.TransactionOrder) ([]byte, error)
	GetTransactionProof(ctx context.Context, txHash types.Bytes) (*types.TransactionRecord, *types.TxProof, error)
}

type TxSubmission

type TxSubmission struct {
	UnitID      types.UnitID
	TxHash      types.Bytes
	Transaction *types.TransactionOrder
	Proof       *wallet.Proof
}

func (*TxSubmission) Confirmed

func (s *TxSubmission) Confirmed() bool

func (*TxSubmission) ToBatch

func (s *TxSubmission) ToBatch(backend RpcClient, sender wallet.PubKey, log *slog.Logger) *TxSubmissionBatch

type TxSubmissionBatch

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

func NewBatch

func NewBatch(sender wallet.PubKey, rpcClient RpcClient, log *slog.Logger) *TxSubmissionBatch

func (*TxSubmissionBatch) Add

func (t *TxSubmissionBatch) Add(sub *TxSubmission)

func (*TxSubmissionBatch) SendTx

func (t *TxSubmissionBatch) SendTx(ctx context.Context, confirmTx bool) error

func (*TxSubmissionBatch) Submissions

func (t *TxSubmissionBatch) Submissions() []*TxSubmission