google_cloud_pubsub/apiv1/
mod.rs

1use google_cloud_gax::grpc::Code;
2use google_cloud_gax::retry::RetrySetting;
3
4pub mod conn_pool;
5pub mod publisher_client;
6pub mod schema_client;
7pub mod subscriber_client;
8
9const PUBSUB_MESSAGE_LIMIT: usize = 10 * 1024 * 1024; // 10MB
10
11pub fn default_retry_setting() -> RetrySetting {
12    let mut setting = RetrySetting::default();
13    setting.codes.push(Code::DeadlineExceeded);
14    setting.codes.push(Code::Internal);
15    setting.codes.push(Code::ResourceExhausted);
16    setting
17}