fix: Accommodate partial features build (#333)

txpipe · Jun 21, 2022 · 5a946ac · 5a946ac
1 parent dbf2798
commit 5a946ac
Show file tree

Hide file tree

Showing 7 changed files with 9 additions and 6 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -64,11 +64,12 @@ cloud-pubsub = { version = "0.8.0", optional = true }
 
 [features]
 default = []
+web = ["reqwest"]
 logs = ["file-rotate"]
-webhook = ["reqwest"]
+webhook = ["web"]
 kafkasink = ["kafka", "openssl"]
 elasticsink = ["elasticsearch", "tokio"]
 fingerprint = ["murmur3"]
 aws = ["aws-config", "aws-sdk-sqs", "aws-sdk-lambda", "aws-sdk-s3", "tokio"]
 redissink = ["redis", "tokio"]
-gcp = ["cloud-pubsub", "tokio", "reqwest"]
+gcp = ["cloud-pubsub", "tokio", "web"]
diff --git a/src/sinks/common/mod.rs b/src/sinks/common/mod.rs
@@ -0,0 +1,2 @@
+#[cfg(feature = "web")]
+pub mod web;
diff --git a/src/sinks/common.rs → src/sinks/common/web.rs b/src/sinks/common.rs → src/sinks/common/web.rs
diff --git a/src/sinks/gcp_cloudfunction/setup.rs b/src/sinks/gcp_cloudfunction/setup.rs
@@ -4,7 +4,7 @@ use serde::Deserialize;
 
 use crate::{
     pipelining::{BootstrapResult, SinkProvider, StageReceiver},
-    sinks::{build_headers_map, request_loop, ErrorPolicy, APP_USER_AGENT},
+    sinks::common::web::{build_headers_map, request_loop, ErrorPolicy, APP_USER_AGENT},
     utils::{retry, WithUtils},
 };
 

diff --git a/src/sinks/gcp_pubsub/run.rs b/src/sinks/gcp_pubsub/run.rs
@@ -6,7 +6,7 @@ use serde_json::json;
 use crate::{
     model::Event,
     pipelining::StageReceiver,
-    sinks::ErrorPolicy,
+    sinks::common::web::ErrorPolicy,
     utils::{retry, Utils},
 };
 

diff --git a/src/sinks/gcp_pubsub/setup.rs b/src/sinks/gcp_pubsub/setup.rs
@@ -2,7 +2,7 @@ use serde::Deserialize;
 
 use crate::{
     pipelining::{BootstrapResult, SinkProvider, StageReceiver},
-    sinks::ErrorPolicy,
+    sinks::common::web::ErrorPolicy,
     utils::{retry, WithUtils},
 };
 

diff --git a/src/sinks/webhook/setup.rs b/src/sinks/webhook/setup.rs
@@ -4,7 +4,7 @@ use serde::Deserialize;
 
 use crate::{
     pipelining::{BootstrapResult, SinkProvider, StageReceiver},
-    sinks::{build_headers_map, request_loop, ErrorPolicy, APP_USER_AGENT},
+    sinks::common::web::{build_headers_map, request_loop, ErrorPolicy, APP_USER_AGENT},
     utils::{retry, WithUtils},
 };