Documentation
¶
Index ¶
- func BatchIDResponse(m dsl.Module, dest t.ModuleID, batchID t.BatchID, ...)
- func NewBatch(m dsl.Module, dest t.ModuleID, txIDs []t.TxID, txs []*requestpb.Request, ...)
- func RequestBatch[C any](m dsl.Module, dest t.ModuleID, context *C)
- func RequestBatchID[C any](m dsl.Module, dest t.ModuleID, txIDs []t.TxID, context *C)
- func RequestTransactionIDs[C any](m dsl.Module, dest t.ModuleID, txs []*requestpb.Request, context *C)
- func RequestTransactions[C any](m dsl.Module, dest t.ModuleID, txIDs []t.TxID, context *C)
- func TransactionIDsResponse(m dsl.Module, dest t.ModuleID, txIDs []t.TxID, ...)
- func TransactionsResponse(m dsl.Module, dest t.ModuleID, present []bool, txs []*requestpb.Request, ...)
- func UponBatchIDResponse[C any](m dsl.Module, handler func(batchID t.BatchID, context *C) error)
- func UponEvent[EvWrapper mppb.Event_TypeWrapper[Ev], Ev any](m dsl.Module, handler func(ev *Ev) error)
- func UponNewBatch[C any](m dsl.Module, ...)
- func UponRequestBatch(m dsl.Module, handler func(origin *mppb.RequestBatchOrigin) error)
- 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 []t.TxID, context *C) error)
- func UponTransactionsResponse[C any](m dsl.Module, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BatchIDResponse ¶
func BatchIDResponse(m dsl.Module, dest t.ModuleID, batchID t.BatchID, origin *mppb.RequestBatchIDOrigin)
BatchIDResponse is a response to a RequestBatchID event.
func NewBatch ¶
func NewBatch(m dsl.Module, dest t.ModuleID, txIDs []t.TxID, txs []*requestpb.Request, origin *mppb.RequestBatchOrigin)
NewBatch is a response to a RequestBatch event.
func RequestBatch ¶
RequestBatch is used by the availability layer to request a new batch of transactions from the mempool.
func RequestBatchID ¶
RequestBatchID allows other modules to request the mempool module to compute the ID of a batch. It is possible that some transactions in the batch are not present in the mempool.
func RequestTransactionIDs ¶
func RequestTransactionIDs[C any](m dsl.Module, dest t.ModuleID, txs []*requestpb.Request, context *C)
RequestTransactionIDs allows other modules to request the mempool module to compute IDs for the given transactions. It is possible that some of these transactions are not present in the mempool.
func RequestTransactions ¶
RequestTransactions allows the availability layer to request transactions from the mempool by their IDs. It is possible that some of these transactions are not present in the mempool.
func TransactionIDsResponse ¶
func TransactionIDsResponse(m dsl.Module, dest t.ModuleID, txIDs []t.TxID, origin *mppb.RequestTransactionIDsOrigin)
TransactionIDsResponse is a response to a RequestTransactionIDs event.
func TransactionsResponse ¶
func TransactionsResponse(m dsl.Module, dest t.ModuleID, present []bool, txs []*requestpb.Request, origin *mppb.RequestTransactionsOrigin)
TransactionsResponse is a response to a RequestTransactions event.
func UponBatchIDResponse ¶
UponBatchIDResponse registers a handler for the BatchIDResponse events.
func UponEvent ¶
func UponEvent[EvWrapper mppb.Event_TypeWrapper[Ev], Ev any](m dsl.Module, handler func(ev *Ev) error)
UponEvent registers a handler for the given mempool event type.
func UponNewBatch ¶
func UponNewBatch[C any](m dsl.Module, handler func(txIDs []t.TxID, txs []*requestpb.Request, context *C) error)
UponNewBatch registers a handler for the NewBatch events.
func UponRequestBatch ¶
func UponRequestBatch(m dsl.Module, handler func(origin *mppb.RequestBatchOrigin) error)
UponRequestBatch registers a handler for the RequestBatch events.
func UponRequestBatchID ¶
func UponRequestBatchID(m dsl.Module, handler func(txIDs []t.TxID, origin *mppb.RequestBatchIDOrigin) error)
UponRequestBatchID registers a handler for the RequestBatchID events.
func UponRequestTransactionIDs ¶
func UponRequestTransactionIDs(m dsl.Module, handler func(txs []*requestpb.Request, origin *mppb.RequestTransactionIDsOrigin) error)
UponRequestTransactionIDs registers a handler for the RequestTransactionIDs events.
func UponRequestTransactions ¶
func UponRequestTransactions(m dsl.Module, handler func(txIDs []t.TxID, origin *mppb.RequestTransactionsOrigin) error)
UponRequestTransactions registers a handler for the RequestTransactions events.
Types ¶
This section is empty.
Source Files