Documentation
¶
Index ¶
- func BatchStored(m dsl.Module, dest t.ModuleID, origin *batchdbpb.StoreBatchOrigin)
- func LookupBatch[C any](m dsl.Module, dest t.ModuleID, batchID t.BatchID, context *C)
- func LookupBatchResponse(m dsl.Module, dest t.ModuleID, found bool, txs []*requestpb.Request, ...)
- func StoreBatch[C any](m dsl.Module, dest t.ModuleID, batchID t.BatchID, txIDs []t.TxID, ...)
- func UponBatchStored[C any](m dsl.Module, handler func(context *C) error)
- func UponEvent[EvWrapper batchdbpb.Event_TypeWrapper[Ev], Ev any](m dsl.Module, handler func(ev *Ev) error)
- func UponLookupBatch(m dsl.Module, ...)
- func UponLookupBatchResponse[C any](m dsl.Module, ...)
- func UponStoreBatch(m dsl.Module, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BatchStored ¶
BatchStored is a response to a StoreBatch event.
func LookupBatch ¶
LookupBatch is used to pull a batch with its metadata from the local batch database.
func LookupBatchResponse ¶
func LookupBatchResponse(m dsl.Module, dest t.ModuleID, found bool, txs []*requestpb.Request, metadata []byte, origin *batchdbpb.LookupBatchOrigin)
LookupBatchResponse is a response to a LookupBatch event.
func StoreBatch ¶
func StoreBatch[C any](m dsl.Module, dest t.ModuleID, batchID t.BatchID, txIDs []t.TxID, txs []*requestpb.Request, metadata []byte, context *C)
StoreBatch is used to store a new batch in the local batch database.
func UponBatchStored ¶
UponBatchStored registers a handler for the BatchStored events.
func UponEvent ¶
func UponEvent[EvWrapper batchdbpb.Event_TypeWrapper[Ev], Ev any](m dsl.Module, handler func(ev *Ev) error)
UponEvent registers a handler for the given batchdb event type.
func UponLookupBatch ¶
func UponLookupBatch(m dsl.Module, handler func(batchID t.BatchID, origin *batchdbpb.LookupBatchOrigin) error)
UponLookupBatch registers a handler for the LookupBatch events.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.