LinYushen 18524d80d0 Implement sharded Redis realtime relay (#1702) ...

* Implement sharded Redis realtime relay

* Isolate dual relay read pools

* Surface mirrored relay publish divergence

2026-04-26 12:03:06 +08:00

..

broadcaster.go

feat(realtime): phase 0 — extract Broadcaster interface + add metrics (MUL-1138) (#1429)

2026-04-23 13:36:55 +08:00

hub_test.go

feat(realtime): phase 0 — extract Broadcaster interface + add metrics (MUL-1138) (#1429)

2026-04-23 13:36:55 +08:00

hub.go

feat(realtime): phase 0 — extract Broadcaster interface + add metrics (MUL-1138) (#1429)

2026-04-23 13:36:55 +08:00

metrics_test.go

feat(realtime): phase 0 — extract Broadcaster interface + add metrics (MUL-1138) (#1429)

2026-04-23 13:36:55 +08:00

metrics.go

Implement sharded Redis realtime relay (#1702)

2026-04-26 12:03:06 +08:00

redis_relay_test.go

Implement sharded Redis realtime relay (#1702)

2026-04-26 12:03:06 +08:00

redis_relay.go

Implement sharded Redis realtime relay (#1702)

2026-04-26 12:03:06 +08:00

relay_lifecycle_test.go

Implement sharded Redis realtime relay (#1702)

2026-04-26 12:03:06 +08:00

relay_lifecycle.go

Implement sharded Redis realtime relay (#1702)

2026-04-26 12:03:06 +08:00

sharded_stream_relay_test.go

Implement sharded Redis realtime relay (#1702)

2026-04-26 12:03:06 +08:00

sharded_stream_relay.go

Implement sharded Redis realtime relay (#1702)

2026-04-26 12:03:06 +08:00