Struct MirroredRelay

server/internal/realtime/relay_lifecycle.go:26–29

MirroredRelay is a temporary rollout helper: it starts two relay backends, reads from both, and publishes every event to both with the same event id. Client-side dedup keeps loopback delivery idempotent.

// reads from both, and publishes every event to both with the same event id.
// Client-side dedup keeps loopback delivery idempotent.
type MirroredRelay struct {
	primary ManagedRelay
	mirror  ManagedRelay
}

func NewMirroredRelay(primary, mirror ManagedRelay) *MirroredRelay {
	return &MirroredRelay{primary: primary, mirror: mirror}