more fixes

discord · Sep 28, 2024 · af77824 · af77824
1 parent 8896c4b
commit af77824
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 9 deletions.
diff --git a/src/sinks/gcp/bigquery/config.rs b/src/sinks/gcp/bigquery/config.rs
@@ -1,9 +1,10 @@
-use codecs::encoding::ProtobufSerializerConfig;
+use vector_lib::codecs::encoding::ProtobufSerializerConfig;
 use futures::FutureExt;
 use http::Uri;
 use indoc::indoc;
 use tonic::transport::Channel;
-use vector_config::configurable_component;
+// use vector_lib::vector_config::configurable_component;
+use vector_lib::configurable::configurable_component;
 
 use super::proto::third_party::google::cloud::bigquery::storage::v1 as proto;
 use super::request_builder::{BigqueryRequestBuilder, MAX_BATCH_PAYLOAD_SIZE};

diff --git a/src/sinks/gcp/bigquery/request_builder.rs b/src/sinks/gcp/bigquery/request_builder.rs
@@ -1,5 +1,5 @@
 use bytes::BytesMut;
-use codecs::encoding::ProtobufSerializer;
+use vector_lib::codecs::encoding::ProtobufSerializer;
 use prost::Message;
 use std::num::NonZeroUsize;
 use tokio_util::codec::Encoder;
@@ -22,8 +22,8 @@ pub enum BigqueryRequestBuilderError {
     ProtobufEncoding { message: String }, // `error` needs to be some concrete type
 }
 
-impl From<vector_common::Error> for BigqueryRequestBuilderError {
-    fn from(error: vector_common::Error) -> Self {
+impl From<vector_lib::Error> for BigqueryRequestBuilderError {
+    fn from(error: vector_lib::Error) -> Self {
         BigqueryRequestBuilderError::ProtobufEncoding {
             message: format!("{:?}", error),
         }
@@ -142,7 +142,7 @@ mod test {
     use codecs::encoding::{ProtobufSerializerConfig, ProtobufSerializerOptions};
     use std::collections::BTreeMap;
     use std::path::PathBuf;
-    use vector_core::event::{Event, EventMetadata, LogEvent, Value};
+    use vector_lib::event::{Event, EventMetadata, LogEvent, Value};
 
     use super::BigqueryRequestBuilder;
     use crate::sinks::util::IncrementalRequestBuilder;

diff --git a/src/sinks/gcp/bigquery/sink.rs b/src/sinks/gcp/bigquery/sink.rs
@@ -2,9 +2,9 @@ use futures_util::{
     stream::{self, BoxStream},
     StreamExt,
 };
-use vector_core::event::Event;
-use vector_core::sink::StreamSink;
-use vector_core::stream::BatcherSettings;
+use vector_lib::event::Event;
+use vector_lib::sink::StreamSink;
+use vector_lib::stream::BatcherSettings;
 
 use super::request_builder::BigqueryRequestBuilder;
 use super::service::BigqueryService;