mempoolpbdsl

Documentation

Index

• func BatchIDResponse(m dsl.Module, destModule types.ModuleID, batchId []uint8, ...)
• func NewBatch(m dsl.Module, destModule types.ModuleID, txIds [][]uint8, ...)
• func RequestBatch[C any](m dsl.Module, destModule types.ModuleID, context *C)
• func RequestBatchID[C any](m dsl.Module, destModule types.ModuleID, txIds [][]uint8, context *C)
• func RequestTransactionIDs[C any](m dsl.Module, destModule types.ModuleID, txs []*requestpb.Request, context *C)
• func RequestTransactions[C any](m dsl.Module, destModule types.ModuleID, txIds [][]uint8, context *C)
• func TransactionIDsResponse(m dsl.Module, destModule types.ModuleID, txIds [][]uint8, ...)
• func TransactionsResponse(m dsl.Module, destModule types.ModuleID, present []bool, ...)
• func UponBatchIDResponse[C any](m dsl.Module, handler func(batchId []uint8, context *C) 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 UponRequestBatch(m dsl.Module, handler func(origin *types.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 [][]uint8, context *C) error)
• func UponTransactionsResponse[C any](m dsl.Module, ...)

Functions

func BatchIDResponse

func BatchIDResponse(m dsl.Module, destModule types.ModuleID, batchId []uint8, origin *types1.RequestBatchIDOrigin)

func NewBatch

func NewBatch(m dsl.Module, destModule types.ModuleID, txIds [][]uint8, txs []*requestpb.Request, origin *types1.RequestBatchOrigin)

func RequestBatch

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

func RequestBatchID

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

func RequestTransactionIDs

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

func RequestTransactions

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

func TransactionIDsResponse

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

func TransactionsResponse

func TransactionsResponse(m dsl.Module, destModule types.ModuleID, present []bool, txs []*requestpb.Request, origin *types1.RequestTransactionsOrigin)

func UponBatchIDResponse

func UponBatchIDResponse[C any](m dsl.Module, handler func(batchId []uint8, context *C) 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 [][]uint8, txs []*requestpb.Request, context *C) error)

func UponRequestBatch

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

func UponRequestBatchID

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

func UponRequestTransactionIDs

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

func UponRequestTransactions

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

func UponTransactionIDsResponse

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

func UponTransactionsResponse

func UponTransactionsResponse[C any](m dsl.Module, handler func(present []bool, txs []*requestpb.Request, context *C) error)