Documentation
¶
Overview ¶
Package streamregistry provides a centralized registry for routing mutation events to their appropriate event streams. It implements mutation.Publisher to enable automatic event publishing after successful transaction commits.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶
Handler publishes a mutation event to the appropriate stream. Each handler has closure access to the concrete streamer it needs.
type Registry ¶
type Registry struct {
// contains filtered or unexported fields
}
Registry maps entity types to stream handlers. It implements mutation.Publisher for automatic publishing on commit.
func (*Registry) PublishAll ¶
PublishAll implements mutation.Publisher. Called automatically by mutation.Context.Commit() if configured.
Source Files
Click to show internal directories.
Click to hide internal directories.