txsubmitter

Documentation

Index

• type TxSubmission
  • func New(tx *types.TransactionOrder) (*TxSubmission, error)
  • func (s *TxSubmission) Confirmed() bool
  • func (s *TxSubmission) ToBatch(partitionClient sdktypes.PartitionClient, log *slog.Logger) *TxSubmissionBatch
• type TxSubmissionBatch
  • func NewBatch(partitionClient sdktypes.PartitionClient, 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 TxSubmission

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

func New

func New(tx *types.TransactionOrder) (*TxSubmission, error)

func (*TxSubmission) Confirmed

func (s *TxSubmission) Confirmed() bool

func (*TxSubmission) ToBatch

func (s *TxSubmission) ToBatch(partitionClient sdktypes.PartitionClient, log *slog.Logger) *TxSubmissionBatch

type TxSubmissionBatch

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

func NewBatch

func NewBatch(partitionClient sdktypes.PartitionClient, 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