Merge pull request #120 from svix/jplatte/up-gcp

Update to new google cloud crates

Author: svix-jplatte

omniqueue/Cargo.toml

@@ -18,8 +18,8 @@ bb8 = { version = "0.9.0", optional = true }
 bb8-redis = { version = "0.23.0", optional = true }
 bytesize = "2.0.1"
 futures-util = { version = "0.3.28", default-features = false, features = ["async-await", "std"], optional = true }
-google-cloud-googleapis = { version = "0.16.0", optional = true }
-google-cloud-pubsub = { version = "0.30.0", optional = true }
+gcloud-googleapis = { version = "1.2.0", optional = true }
+gcloud-pubsub = { version = "1.3.0", optional = true }
 lapin = { version = "2", optional = true }
 redis = { version = "0.31.0", features = ["tokio-comp", "tokio-native-tls-comp", "streams"], optional = true }
 serde = "1.0.196"
@@ -43,7 +43,7 @@ tokio-reactor-trait = "1.1.0"
 [features]
 default = ["in_memory", "gcp_pubsub", "rabbitmq", "redis", "redis_cluster", "sqs"]
 in_memory = []
-gcp_pubsub = ["dep:futures-util", "dep:google-cloud-googleapis", "dep:google-cloud-pubsub"]
+gcp_pubsub = ["dep:futures-util", "dep:gcloud-googleapis", "dep:gcloud-pubsub"]
 rabbitmq = ["dep:futures-util", "dep:lapin"]
 # Generate message IDs for queue items. Likely not needed outside of Svix.
 rabbitmq-with-message-ids = ["rabbitmq", "dep:svix-ksuid"]

omniqueue/src/backends/gcp_pubsub.rs

@@ -5,8 +5,8 @@ use std::{
 };
 
 use futures_util::{future::try_join_all, StreamExt};
-use google_cloud_googleapis::pubsub::v1::PubsubMessage;
-use google_cloud_pubsub::{
+use gcloud_googleapis::pubsub::v1::PubsubMessage;
+use gcloud_pubsub::{
     client::{google_cloud_auth::credentials::CredentialsFile, Client, ClientConfig},
     publisher::Publisher,
     subscriber::ReceivedMessage,

omniqueue/tests/it/gcp_pubsub.rs

@@ -56,8 +56,8 @@
 
 use std::time::{Duration, Instant};
 
-use google_cloud_googleapis::pubsub::v1::DeadLetterPolicy;
-use google_cloud_pubsub::{
+use gcloud_googleapis::pubsub::v1::DeadLetterPolicy;
+use gcloud_pubsub::{
     client::{Client, ClientConfig},
     subscription::SubscriptionConfig,
 };