form

func Dispatch ¶

func Dispatch(path string, msg hermod.Message) error

Dispatch sends a message to the channel registered for the given path.

func Register ¶

func Register(path string) chan hermod.Message

Register creates a new channel for a form path, superseding any existing registration. The newest registration owns the path: when a workflow moves between workers, the one taking the lease over is the one that should receive.

It used to return the existing channel instead, which meant the worker taking over and the worker being replaced read from the same one — so the outgoing teardown closed the channel its successor was reading.

func Unregister ¶

func Unregister(path string, ch chan hermod.Message)

Unregister releases a path, but only if ch is still the channel registered for it.

The ownership check is what makes a handover safe. Nothing orders the outgoing worker's teardown against the incoming worker's registration, so deleting by path alone let a worker that had already lost the lease close and remove its successor's channel. The successor was then reading from a closed channel that no longer appeared in the registry: the workflow reported itself running and never received another message.