diff --git a/src/sinks/gcp/bigquery/config.rs b/src/sinks/gcp/bigquery/config.rs index d8c03dc6cfc44e..dce2fd59b3ea71 100644 --- 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 index bfb4208f657290..350d82046fede6 100644 --- 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 for BigqueryRequestBuilderError { - fn from(error: vector_common::Error) -> Self { +impl From 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 index a1ffebbce91597..63f2abe79fcfa5 100644 --- 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;