events

type Bus ¶

type Bus interface {
	Publish(evt Event)
	Subscribe(pattern string) (<-chan Event, func())
}

Bus is the publish/subscribe surface every R-layer codes against.

Publish is non-blocking. If a subscriber's channel is full, the event is dropped for THAT subscriber only; the publisher and other subscribers are unaffected. This keeps mutation-handler latency bounded regardless of subscriber speed.

Subscribe returns a buffered channel and an unsubscribe func. The pattern is matched against Event.Type. Patterns ending in ".*" match any Type beginning with the prefix (e.g. "membership.*" matches "membership.changed" and "membership.created" but not "membership"). A bare "*" matches every Type. Any other pattern matches Type exactly. Source is not part of pattern matching today.

The unsubscribe func removes the subscription and closes the channel. It is safe to call exactly once; further calls are no-ops.

func NewInProcessBus(bufSize int) Bus

type Event ¶

type Event struct {
	Source  string
	Type    string
	Payload map[string]any
}

Event is one item published to the Bus. Source is the publishing store ("directory", "membership", "trust", ...). Type is the dot-namespaced event name within that source ("node.deleted", "membership.changed", "key.rotated", ...). Payload keys/values are publisher-defined; subscribers parse them.