Darren Bolduc
Darren Bolduc
Googlers can see: go/cloud-rust:subscriber-api (not approved/final circa 2025-12-01) - [ ] Add message data type - [ ] Add handler and ack traits - [ ] Add `Session` - with...
We need to implement the internals for the subscriber. I may spin out these tasks into their own issues, with more details. - [x] Generate internals owned by sidekick -...
For example, in `LeaseState::shutdown()`, we ack messages, and we nack messages. This can take two different RPCs. We should spawn tasks for each of these actions, and await them concurrently....
Pub/Sub supports ordered delivery for subscriptions. In callback-based APIs, the client libraries guarantee that a callback for a message with a given ordering key completes before any subsequent callbacks on...
We are exposing builders with the tag `#[doc(hidden)]` to workaround doctest failures. We should fix this via a sidekick configuration, and remove these types from the public API (not just...
There is a size limit on requests for the `Acknowledge` and `ModifyAckDeadline` RPCs. https://cloud.google.com/pubsub/quotas#resource_limits We need to at least make sure that when we send these RPCs they are within...
Our initial implementation will not support exactly once subscribe. We will need to: - [ ] Add exactly once acking to the `Leaser` and `DefaultLeaser` - [ ] Add an...
The `google_cloud_storage::client::Storage` uses a `reqwest::Client` directly in its implementation instead of using `gaxi::http::ReqwestClient` like the GAPICs do. I think I missed the discussion on why we chose to do this,...
We should add a throughput benchmark for the subscriber client, similar to https://cloud.google.com/blog/products/data-analytics/testing-cloud-pubsub-clients-to-maximize-streaming-performance The benchmark should pull messages from a subscription and ack them, across N tasks. (At least) the...
https://pantheon.corp.google.com/cloud-build/builds;region=us-central1/9a17cdbe-a5cc-4739-a9d9-84bd32c8902d;step=1?project=rust-sdk-testing ``` Instance successfully deleted: Operation { client_operation_id: None, creation_timestamp: None, description: None, end_time: Some("2025-11-03T12:26:10.985-08:00"), error: None, http_error_message: None, http_error_status_code: None, id: Some(1792077791691583925), insert_time: Some("2025-11-03T12:23:54.990-08:00"), instances_bulk_insert_operation_metadata: None, kind: Some("compute#operation"), name:...