batchdbpbdsl

Documentation

Index

• func BatchStored(m dsl.Module, destModule stdtypes.ModuleID, origin *types1.StoreBatchOrigin)
• func GarbageCollect(m dsl.Module, destModule stdtypes.ModuleID, ...)
• func LookupBatch[C any](m dsl.Module, destModule stdtypes.ModuleID, batchId types.BatchID, context *C)
• func LookupBatchResponse(m dsl.Module, destModule stdtypes.ModuleID, found bool, ...)
• func StoreBatch[C any](m dsl.Module, destModule stdtypes.ModuleID, batchId types.BatchID, ...)
• func UponBatchStored[C any](m dsl.Module, handler func(context *C) error)
• func UponEvent[W types.Event_TypeWrapper[Ev], Ev any](m dsl.Module, handler func(ev *Ev) error)
• func UponGarbageCollect(m dsl.Module, handler func(retentionIndex types4.RetentionIndex) error)
• func UponLookupBatch(m dsl.Module, ...)
• func UponLookupBatchResponse[C any](m dsl.Module, ...)
• func UponStoreBatch(m dsl.Module, ...)

Functions

func BatchStored

func BatchStored(m dsl.Module, destModule stdtypes.ModuleID, origin *types1.StoreBatchOrigin)

func GarbageCollect

func GarbageCollect(m dsl.Module, destModule stdtypes.ModuleID, retentionIndex types3.RetentionIndex)

func LookupBatch

func LookupBatch[C any](m dsl.Module, destModule stdtypes.ModuleID, batchId types.BatchID, context *C)

func LookupBatchResponse

func LookupBatchResponse(m dsl.Module, destModule stdtypes.ModuleID, found bool, txs []*types2.Transaction, origin *types1.LookupBatchOrigin)

func StoreBatch

func StoreBatch[C any](m dsl.Module, destModule stdtypes.ModuleID, batchId types.BatchID, txs []*types2.Transaction, retentionIndex types3.RetentionIndex, context *C)

func UponBatchStored

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

func UponEvent

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

func UponGarbageCollect

func UponGarbageCollect(m dsl.Module, handler func(retentionIndex types4.RetentionIndex) error)

func UponLookupBatch

func UponLookupBatch(m dsl.Module, handler func(batchId types2.BatchID, origin *types.LookupBatchOrigin) error)

func UponLookupBatchResponse

func UponLookupBatchResponse[C any](m dsl.Module, handler func(found bool, txs []*types3.Transaction, context *C) error)

func UponStoreBatch

func UponStoreBatch(m dsl.Module, handler func(batchId types2.BatchID, txs []*types3.Transaction, retentionIndex types4.RetentionIndex, origin *types.StoreBatchOrigin) error)