transportpbdsl

Documentation

Index

• func MessageReceived(m dsl.Module, destModule types.ModuleID, from types.NodeID, ...)
• func SendMessage(m dsl.Module, destModule types.ModuleID, msg *types1.Message, ...)
• func UponEvent[W types.Event_TypeWrapper[Ev], Ev any](m dsl.Module, handler func(ev *Ev) error)
• func UponMessageReceived(m dsl.Module, handler func(from types3.NodeID, msg *types2.Message) error)
• func UponSendMessage(m dsl.Module, ...)

Functions

func MessageReceived

func MessageReceived(m dsl.Module, destModule types.ModuleID, from types.NodeID, msg *types1.Message)

func SendMessage

func SendMessage(m dsl.Module, destModule types.ModuleID, msg *types1.Message, destinations []types.NodeID)

func UponEvent

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

func UponMessageReceived

func UponMessageReceived(m dsl.Module, handler func(from types3.NodeID, msg *types2.Message) error)

func UponSendMessage

func UponSendMessage(m dsl.Module, handler func(msg *types2.Message, destinations []types3.NodeID) error)