Implement gRPC Subscribe endpoint for events_platform

Vitali Tatarintev
2026-04-29T23:59:04Z

Implement the gRPC Subscribe endpoint for the events_platform module.

Server-streaming Subscribe RPC - reads CloudEvents from Redis Streams via the pubsub.Subscriber iterator and pushes them to gRPC clients

ACKs messages after successful Send(), continues on ACK failure (at-least-once semantics, redelivery via XPENDING/XCLAIM after 30s)

Consumer name uniqueness: kas-{instanceID}-{randomSuffix} per call

Context lifecycle via grpcz.MaxConnectionAgeContextFromStreamContext

Implements gitlab-org/gitlab#594112

How to run tests

bazel test //internal/module/events_platform/server:server_test \
  --test_env=RUN_IT=true \
  --cache_test_results=no