pub async fn start_grpc_server(
grpc_reader: Arc<GrpcReader>,
event_subscriber: Arc<dyn EventSubscriber>,
config: Config,
shutdown_token: CancellationToken,
) -> Result<GrpcServerHandle>
Expand description
Start a gRPC server with checkpoint and event services
This function creates and starts a gRPC server that hosts checkpoint-related and event streaming services. Currently includes the checkpoint streaming and event streaming services, but can be extended to host additional services in the future.