mempoolpbdsl

Documentation

Index

• func BatchIDResponse(m dsl.Module, destModule types.ModuleID, batchId types4.BatchID, ...)
• func BatchTimeout(m dsl.Module, destModule types.ModuleID, batchReqID uint64)
• func NewBatch(m dsl.Module, destModule types.ModuleID, txIds []types1.TxID, ...)
• func NewEpoch(m dsl.Module, destModule types.ModuleID, epochNr types1.EpochNr, ...)
• func NewTransactions(m dsl.Module, destModule types.ModuleID, transactions []*types3.Transaction)
• func RequestBatch[C any](m dsl.Module, destModule types.ModuleID, epoch types1.EpochNr, context *C)
• func RequestBatchID[C any](m dsl.Module, destModule types.ModuleID, txIds []types1.TxID, context *C)
• func RequestTransactionIDs[C any](m dsl.Module, destModule types.ModuleID, txs []*types3.Transaction, context *C)
• func RequestTransactions[C any](m dsl.Module, destModule types.ModuleID, txIds []types1.TxID, context *C)
• func TransactionIDsResponse(m dsl.Module, destModule types.ModuleID, txIds []types1.TxID, ...)
• func TransactionsResponse(m dsl.Module, destModule types.ModuleID, foundIds []types1.TxID, ...)
• func UponBatchIDResponse[C any](m dsl.Module, handler func(batchId types4.BatchID, context *C) error)
• func UponBatchTimeout(m dsl.Module, handler func(batchReqID uint64) error)
• func UponEvent[W types.Event_TypeWrapper[Ev], Ev any](m dsl.Module, handler func(ev *Ev) error)
• func UponNewBatch[C any](m dsl.Module, ...)
• func UponNewEpoch(m dsl.Module, ...)
• func UponNewTransactions(m dsl.Module, handler func(transactions []*types3.Transaction) error)
• func UponRequestBatch(m dsl.Module, ...)
• func UponRequestBatchID(m dsl.Module, ...)
• func UponRequestTransactionIDs(m dsl.Module, ...)
• func UponRequestTransactions(m dsl.Module, ...)
• func UponTransactionIDsResponse[C any](m dsl.Module, handler func(txIds []types2.TxID, context *C) error)
• func UponTransactionsResponse[C any](m dsl.Module, ...)

Functions

func BatchIDResponse

func BatchIDResponse(m dsl.Module, destModule types.ModuleID, batchId types4.BatchID, origin *types2.RequestBatchIDOrigin)

func BatchTimeout

func BatchTimeout(m dsl.Module, destModule types.ModuleID, batchReqID uint64)

func NewBatch

func NewBatch(m dsl.Module, destModule types.ModuleID, txIds []types1.TxID, txs []*types3.Transaction, origin *types2.RequestBatchOrigin)

func NewEpoch

func NewEpoch(m dsl.Module, destModule types.ModuleID, epochNr types1.EpochNr, clientProgress *types3.ClientProgress)

func NewTransactions

func NewTransactions(m dsl.Module, destModule types.ModuleID, transactions []*types3.Transaction)

func RequestBatch

func RequestBatch[C any](m dsl.Module, destModule types.ModuleID, epoch types1.EpochNr, context *C)

func RequestBatchID

func RequestBatchID[C any](m dsl.Module, destModule types.ModuleID, txIds []types1.TxID, context *C)

func RequestTransactionIDs

func RequestTransactionIDs[C any](m dsl.Module, destModule types.ModuleID, txs []*types3.Transaction, context *C)

func RequestTransactions

func RequestTransactions[C any](m dsl.Module, destModule types.ModuleID, txIds []types1.TxID, context *C)

func TransactionIDsResponse

func TransactionIDsResponse(m dsl.Module, destModule types.ModuleID, txIds []types1.TxID, origin *types2.RequestTransactionIDsOrigin)

func TransactionsResponse

func TransactionsResponse(m dsl.Module, destModule types.ModuleID, foundIds []types1.TxID, foundTxs []*types3.Transaction, missingIds []types1.TxID, origin *types2.RequestTransactionsOrigin)

func UponBatchIDResponse

func UponBatchIDResponse[C any](m dsl.Module, handler func(batchId types4.BatchID, context *C) error)

func UponBatchTimeout

func UponBatchTimeout(m dsl.Module, handler func(batchReqID uint64) error)

func UponEvent

func UponEvent[W types.Event_TypeWrapper[Ev], Ev any](m dsl.Module, handler func(ev *Ev) error)

func UponNewBatch

func UponNewBatch[C any](m dsl.Module, handler func(txIds []types2.TxID, txs []*types3.Transaction, context *C) error)

func UponNewEpoch

func UponNewEpoch(m dsl.Module, handler func(epochNr types2.EpochNr, clientProgress *types3.ClientProgress) error)

func UponNewTransactions

func UponNewTransactions(m dsl.Module, handler func(transactions []*types3.Transaction) error)

func UponRequestBatch

func UponRequestBatch(m dsl.Module, handler func(epoch types2.EpochNr, origin *types.RequestBatchOrigin) error)

func UponRequestBatchID

func UponRequestBatchID(m dsl.Module, handler func(txIds []types2.TxID, origin *types.RequestBatchIDOrigin) error)

func UponRequestTransactionIDs

func UponRequestTransactionIDs(m dsl.Module, handler func(txs []*types3.Transaction, origin *types.RequestTransactionIDsOrigin) error)

func UponRequestTransactions

func UponRequestTransactions(m dsl.Module, handler func(txIds []types2.TxID, origin *types.RequestTransactionsOrigin) error)

func UponTransactionIDsResponse

func UponTransactionIDsResponse[C any](m dsl.Module, handler func(txIds []types2.TxID, context *C) error)

func UponTransactionsResponse

func UponTransactionsResponse[C any](m dsl.Module, handler func(foundIds []types2.TxID, foundTxs []*types3.Transaction, missingIds []types2.TxID, context *C) error)