checkpointpbdsl

Documentation

Index

• func EpochProgress(m dsl.Module, destModule types.ModuleID, nodeId types.NodeID, ...)
• func StableCheckpoint(m dsl.Module, destModule types.ModuleID, sn types1.SeqNr, ...)
• func UponCheckpointReceived(m dsl.Module, ...)
• func UponEpochProgress(m dsl.Module, handler func(nodeId types4.NodeID, epoch types2.EpochNr) error)
• func UponEvent[W types.Event_TypeWrapper[Ev], Ev any](m dsl.Module, handler func(ev *Ev) error)
• func UponMessageReceived[W types4.Message_TypeWrapper[M], M any](m dsl.Module, handler func(from types.NodeID, msg *M) error)
• func UponStableCheckpoint(m dsl.Module, ...)
• func UponStableCheckpointReceived(m dsl.Module, ...)

Functions

func EpochProgress

func EpochProgress(m dsl.Module, destModule types.ModuleID, nodeId types.NodeID, epoch types1.EpochNr)

func StableCheckpoint

func StableCheckpoint(m dsl.Module, destModule types.ModuleID, sn types1.SeqNr, snapshot *types2.StateSnapshot, cert map[types.NodeID][]uint8)

func UponCheckpointReceived

func UponCheckpointReceived(m dsl.Module, handler func(from types.NodeID, epoch types1.EpochNr, sn types1.SeqNr, snapshotHash []uint8, signature []uint8) error)

func UponEpochProgress

func UponEpochProgress(m dsl.Module, handler func(nodeId types4.NodeID, epoch types2.EpochNr) error)

func UponEvent

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

func UponMessageReceived

func UponMessageReceived[W types4.Message_TypeWrapper[M], M any](m dsl.Module, handler func(from types.NodeID, msg *M) error)

func UponStableCheckpoint

func UponStableCheckpoint(m dsl.Module, handler func(sn types2.SeqNr, snapshot *types3.StateSnapshot, cert map[types4.NodeID][]uint8) error)

func UponStableCheckpointReceived

func UponStableCheckpointReceived(m dsl.Module, handler func(from types.NodeID, sn types1.SeqNr, snapshot *types2.StateSnapshot, cert map[types.NodeID][]uint8) error)