From 8a02b168d4904d0837028b1ef9fc9743d9dee345 Mon Sep 17 00:00:00 2001 From: Bruce Guenter Date: Thu, 26 Oct 2023 21:10:19 -0600 Subject: [PATCH] chore(dev): Wrap `vector-stream` in `vector-lib` (#18953) --- Cargo.lock | 2 +- Cargo.toml | 1 - lib/vector-lib/Cargo.toml | 1 + lib/vector-lib/src/lib.rs | 1 + src/sinks/appsignal/service.rs | 2 +- src/sinks/aws_cloudwatch_logs/service.rs | 2 +- src/sinks/aws_cloudwatch_logs/sink.rs | 2 +- src/sinks/aws_kinesis/config.rs | 2 +- src/sinks/aws_s_s/service.rs | 2 +- src/sinks/azure_common/config.rs | 2 +- src/sinks/databend/service.rs | 2 +- src/sinks/datadog/events/service.rs | 2 +- src/sinks/datadog/logs/service.rs | 2 +- src/sinks/datadog/metrics/service.rs | 2 +- src/sinks/datadog/metrics/sink.rs | 2 +- src/sinks/datadog/traces/service.rs | 2 +- src/sinks/datadog/traces/sink.rs | 2 +- src/sinks/elasticsearch/service.rs | 2 +- src/sinks/gcs_common/service.rs | 2 +- src/sinks/greptimedb/batch.rs | 2 +- src/sinks/http/batch.rs | 2 +- src/sinks/prelude.rs | 2 +- src/sinks/prometheus/remote_write/sink.rs | 2 +- src/sinks/s3_common/service.rs | 2 +- src/sinks/splunk_hec/common/response.rs | 2 +- src/sinks/statsd/batch.rs | 2 +- src/sinks/statsd/service.rs | 2 +- src/sinks/statsd/sink.rs | 2 +- src/sinks/util/batch.rs | 2 +- src/sinks/util/builder.rs | 8 ++++---- src/sinks/util/http.rs | 2 +- src/sinks/vector/service.rs | 2 +- src/sinks/vector/sink.rs | 2 +- src/sources/kubernetes_logs/partial_events_merger.rs | 2 +- src/transforms/reduce/mod.rs | 2 +- 35 files changed, 37 insertions(+), 36 deletions(-) diff --git a/Cargo.lock b/Cargo.lock index 41b95bd1c02be..a523be885a85b 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -9868,7 +9868,6 @@ dependencies = [ "vector-buffers", "vector-lib", "vector-lookup", - "vector-stream", "vector-vrl-functions", "vrl", "warp", @@ -10116,6 +10115,7 @@ dependencies = [ "vector-common", "vector-config", "vector-core", + "vector-stream", ] [[package]] diff --git a/Cargo.toml b/Cargo.toml index 4ee0a0abea4b6..bfffda55b751c 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -142,7 +142,6 @@ tracing-limit = { path = "lib/tracing-limit" } vector-api-client = { path = "lib/vector-api-client", optional = true } vector-buffers = { path = "lib/vector-buffers", default-features = false } vector-lib = { path = "lib/vector-lib", default-features = false, features = ["vrl"] } -vector-stream = { path = "lib/vector-stream" } vector-vrl-functions = { path = "lib/vector-vrl/functions" } loki-logproto = { path = "lib/loki-logproto", optional = true } diff --git a/lib/vector-lib/Cargo.toml b/lib/vector-lib/Cargo.toml index dcc4c585f6020..ce943c519d916 100644 --- a/lib/vector-lib/Cargo.toml +++ b/lib/vector-lib/Cargo.toml @@ -9,6 +9,7 @@ publish = false vector-common = { path = "../vector-common" } vector-config = { path = "../vector-config" } vector-core = { path = "../vector-core", default-features = false } +vector-stream = { path = "../vector-stream" } [features] api = ["vector-core/api"] diff --git a/lib/vector-lib/src/lib.rs b/lib/vector-lib/src/lib.rs index 0e81ca7cbb9bc..949d69d2f60ec 100644 --- a/lib/vector-lib/src/lib.rs +++ b/lib/vector-lib/src/lib.rs @@ -14,6 +14,7 @@ pub use vector_core::{ samples, schema, serde, sink, source, tcp, tls, transform, update_counter, EstimatedJsonEncodedSizeOf, }; +pub use vector_stream as stream; pub mod config { pub use vector_common::config::ComponentKey; diff --git a/src/sinks/appsignal/service.rs b/src/sinks/appsignal/service.rs index e505ab1569c7c..ce6aad1e688f3 100644 --- a/src/sinks/appsignal/service.rs +++ b/src/sinks/appsignal/service.rs @@ -9,11 +9,11 @@ use http::{header::AUTHORIZATION, Request, StatusCode, Uri}; use hyper::Body; use tower::{Service, ServiceExt}; +use vector_lib::stream::DriverResponse; use vector_lib::{ finalization::EventStatus, request_metadata::GroupedCountByteSize, request_metadata::MetaDescriptive, sensitive_string::SensitiveString, }; -use vector_stream::DriverResponse; use crate::{ http::HttpClient, diff --git a/src/sinks/aws_cloudwatch_logs/service.rs b/src/sinks/aws_cloudwatch_logs/service.rs index 5189563bac725..d3d6fcb4dc44b 100644 --- a/src/sinks/aws_cloudwatch_logs/service.rs +++ b/src/sinks/aws_cloudwatch_logs/service.rs @@ -22,11 +22,11 @@ use tower::{ timeout::Timeout, Service, ServiceBuilder, ServiceExt, }; +use vector_lib::stream::DriverResponse; use vector_lib::{ finalization::EventStatus, request_metadata::{GroupedCountByteSize, MetaDescriptive}, }; -use vector_stream::DriverResponse; use crate::sinks::{ aws_cloudwatch_logs::{ diff --git a/src/sinks/aws_cloudwatch_logs/sink.rs b/src/sinks/aws_cloudwatch_logs/sink.rs index 5d50294b08dc2..0624f9f204b17 100644 --- a/src/sinks/aws_cloudwatch_logs/sink.rs +++ b/src/sinks/aws_cloudwatch_logs/sink.rs @@ -5,8 +5,8 @@ use chrono::{Duration, Utc}; use futures::{future, stream::BoxStream, StreamExt}; use tower::Service; use vector_lib::request_metadata::{MetaDescriptive, RequestMetadata}; +use vector_lib::stream::{BatcherSettings, DriverResponse}; use vector_lib::{partition::Partitioner, sink::StreamSink}; -use vector_stream::{BatcherSettings, DriverResponse}; use crate::{ event::{Event, EventFinalizers, Finalizable}, diff --git a/src/sinks/aws_kinesis/config.rs b/src/sinks/aws_kinesis/config.rs index f294025b23d60..4fea310284a44 100644 --- a/src/sinks/aws_kinesis/config.rs +++ b/src/sinks/aws_kinesis/config.rs @@ -1,7 +1,7 @@ use lookup::lookup_v2::ConfigValuePath; use std::marker::PhantomData; -use vector_stream::BatcherSettings; +use vector_lib::stream::BatcherSettings; use crate::{ aws::{AwsAuthentication, RegionOrEndpoint}, diff --git a/src/sinks/aws_s_s/service.rs b/src/sinks/aws_s_s/service.rs index 0049a52ac4f96..4060fc6bab7ca 100644 --- a/src/sinks/aws_s_s/service.rs +++ b/src/sinks/aws_s_s/service.rs @@ -5,8 +5,8 @@ use aws_sdk_sqs::types::SdkError; use futures::future::BoxFuture; use tower::Service; use vector_lib::request_metadata::GroupedCountByteSize; +use vector_lib::stream::DriverResponse; use vector_lib::{event::EventStatus, ByteSizeOf}; -use vector_stream::DriverResponse; use super::{client::Client, request_builder::SendMessageEntry}; diff --git a/src/sinks/azure_common/config.rs b/src/sinks/azure_common/config.rs index 1d6fdf32e9258..5e10ea797c305 100644 --- a/src/sinks/azure_common/config.rs +++ b/src/sinks/azure_common/config.rs @@ -8,11 +8,11 @@ use bytes::Bytes; use futures::FutureExt; use http::StatusCode; use snafu::Snafu; +use vector_lib::stream::DriverResponse; use vector_lib::{ json_size::JsonSize, request_metadata::{GroupedCountByteSize, MetaDescriptive, RequestMetadata}, }; -use vector_stream::DriverResponse; use crate::{ event::{EventFinalizers, EventStatus, Finalizable}, diff --git a/src/sinks/databend/service.rs b/src/sinks/databend/service.rs index b76d366afd1ed..29767a1e9208e 100644 --- a/src/sinks/databend/service.rs +++ b/src/sinks/databend/service.rs @@ -10,7 +10,7 @@ use snafu::Snafu; use tower::Service; use vector_lib::finalization::{EventFinalizers, EventStatus, Finalizable}; use vector_lib::request_metadata::{GroupedCountByteSize, MetaDescriptive, RequestMetadata}; -use vector_stream::DriverResponse; +use vector_lib::stream::DriverResponse; use crate::{internal_events::EndpointBytesSent, sinks::util::retries::RetryLogic}; diff --git a/src/sinks/datadog/events/service.rs b/src/sinks/datadog/events/service.rs index a7254f20868b5..0d95981f95b15 100644 --- a/src/sinks/datadog/events/service.rs +++ b/src/sinks/datadog/events/service.rs @@ -9,7 +9,7 @@ use http::Request; use hyper::Body; use tower::{Service, ServiceExt}; use vector_lib::request_metadata::{GroupedCountByteSize, MetaDescriptive}; -use vector_stream::DriverResponse; +use vector_lib::stream::DriverResponse; use crate::{ event::EventStatus, diff --git a/src/sinks/datadog/logs/service.rs b/src/sinks/datadog/logs/service.rs index 4cc1f80fea69d..d0baffee6d631 100644 --- a/src/sinks/datadog/logs/service.rs +++ b/src/sinks/datadog/logs/service.rs @@ -16,7 +16,7 @@ use tower::Service; use tracing::Instrument; use vector_lib::event::{EventFinalizers, EventStatus, Finalizable}; use vector_lib::request_metadata::{GroupedCountByteSize, MetaDescriptive, RequestMetadata}; -use vector_stream::DriverResponse; +use vector_lib::stream::DriverResponse; use crate::{ http::HttpClient, diff --git a/src/sinks/datadog/metrics/service.rs b/src/sinks/datadog/metrics/service.rs index dd7eb7c69ffbe..85f5fdc47fb2e 100644 --- a/src/sinks/datadog/metrics/service.rs +++ b/src/sinks/datadog/metrics/service.rs @@ -12,7 +12,7 @@ use snafu::ResultExt; use tower::Service; use vector_lib::event::{EventFinalizers, EventStatus, Finalizable}; use vector_lib::request_metadata::{GroupedCountByteSize, MetaDescriptive, RequestMetadata}; -use vector_stream::DriverResponse; +use vector_lib::stream::DriverResponse; use crate::{ http::{BuildRequestSnafu, CallRequestSnafu, HttpClient}, diff --git a/src/sinks/datadog/metrics/sink.rs b/src/sinks/datadog/metrics/sink.rs index ebe925e752da4..b5f62d956b18b 100644 --- a/src/sinks/datadog/metrics/sink.rs +++ b/src/sinks/datadog/metrics/sink.rs @@ -8,12 +8,12 @@ use futures_util::{ StreamExt, }; use tower::Service; +use vector_lib::stream::{BatcherSettings, DriverResponse}; use vector_lib::{ event::{Event, Metric, MetricValue}, partition::Partitioner, sink::StreamSink, }; -use vector_stream::{BatcherSettings, DriverResponse}; use super::{ config::DatadogMetricsEndpoint, normalizer::DatadogMetricsNormalizer, diff --git a/src/sinks/datadog/traces/service.rs b/src/sinks/datadog/traces/service.rs index ecda3c93c23ce..7af9469d94883 100644 --- a/src/sinks/datadog/traces/service.rs +++ b/src/sinks/datadog/traces/service.rs @@ -11,7 +11,7 @@ use snafu::ResultExt; use tower::Service; use vector_lib::event::{EventFinalizers, EventStatus, Finalizable}; use vector_lib::request_metadata::{GroupedCountByteSize, MetaDescriptive, RequestMetadata}; -use vector_stream::DriverResponse; +use vector_lib::stream::DriverResponse; use crate::{ http::{BuildRequestSnafu, CallRequestSnafu, HttpClient, HttpError}, diff --git a/src/sinks/datadog/traces/sink.rs b/src/sinks/datadog/traces/sink.rs index b907759f5cd8d..0d62cdd9ce59f 100644 --- a/src/sinks/datadog/traces/sink.rs +++ b/src/sinks/datadog/traces/sink.rs @@ -7,8 +7,8 @@ use futures_util::{ }; use tokio::sync::oneshot::{channel, Sender}; use tower::Service; +use vector_lib::stream::{BatcherSettings, DriverResponse}; use vector_lib::{config::log_schema, event::Event, partition::Partitioner, sink::StreamSink}; -use vector_stream::{BatcherSettings, DriverResponse}; use vrl::event_path; use vrl::path::PathPrefix; diff --git a/src/sinks/elasticsearch/service.rs b/src/sinks/elasticsearch/service.rs index dad9c51c90f07..9824c0e38b177 100644 --- a/src/sinks/elasticsearch/service.rs +++ b/src/sinks/elasticsearch/service.rs @@ -9,12 +9,12 @@ use futures::future::BoxFuture; use http::{Response, Uri}; use hyper::{service::Service, Body, Request}; use tower::ServiceExt; +use vector_lib::stream::DriverResponse; use vector_lib::ByteSizeOf; use vector_lib::{ json_size::JsonSize, request_metadata::{GroupedCountByteSize, MetaDescriptive, RequestMetadata}, }; -use vector_stream::DriverResponse; use super::{ElasticsearchCommon, ElasticsearchConfig}; use crate::{ diff --git a/src/sinks/gcs_common/service.rs b/src/sinks/gcs_common/service.rs index 3271e28755161..eafd47fbe4285 100644 --- a/src/sinks/gcs_common/service.rs +++ b/src/sinks/gcs_common/service.rs @@ -9,7 +9,7 @@ use http::{ use hyper::Body; use tower::Service; use vector_lib::request_metadata::{GroupedCountByteSize, MetaDescriptive, RequestMetadata}; -use vector_stream::DriverResponse; +use vector_lib::stream::DriverResponse; use crate::{ event::{EventFinalizers, EventStatus, Finalizable}, diff --git a/src/sinks/greptimedb/batch.rs b/src/sinks/greptimedb/batch.rs index e69bc17157001..7bfd7bcce2863 100644 --- a/src/sinks/greptimedb/batch.rs +++ b/src/sinks/greptimedb/batch.rs @@ -1,5 +1,5 @@ use vector_lib::event::{Metric, MetricValue}; -use vector_stream::batcher::limiter::ItemBatchSize; +use vector_lib::stream::batcher::limiter::ItemBatchSize; use super::request_builder::{ DISTRIBUTION_QUANTILES, DISTRIBUTION_STAT_FIELD_COUNT, SUMMARY_STAT_FIELD_COUNT, diff --git a/src/sinks/http/batch.rs b/src/sinks/http/batch.rs index 19ee7230b39bd..c3d03a621088d 100644 --- a/src/sinks/http/batch.rs +++ b/src/sinks/http/batch.rs @@ -1,8 +1,8 @@ //! Batch settings for the `http` sink. use codecs::encoding::Framer; +use vector_lib::stream::batcher::limiter::ItemBatchSize; use vector_lib::{event::Event, ByteSizeOf, EstimatedJsonEncodedSizeOf}; -use vector_stream::batcher::limiter::ItemBatchSize; use crate::codecs::Encoder; diff --git a/src/sinks/prelude.rs b/src/sinks/prelude.rs index 44adc400cf72a..3bee1b9f73fa1 100644 --- a/src/sinks/prelude.rs +++ b/src/sinks/prelude.rs @@ -6,6 +6,7 @@ pub use futures::{future, future::BoxFuture, stream::BoxStream, FutureExt, Strea pub use tower::{Service, ServiceBuilder}; pub use vector_buffers::EventCount; pub use vector_lib::configurable::configurable_component; +pub use vector_lib::stream::{BatcherSettings, DriverResponse}; pub use vector_lib::{ config::{telemetry, AcknowledgementsConfig, Input}, event::Value, @@ -21,7 +22,6 @@ pub use vector_lib::{ json_size::JsonSize, request_metadata::{GetEventCountTags, GroupedCountByteSize, MetaDescriptive, RequestMetadata}, }; -pub use vector_stream::{BatcherSettings, DriverResponse}; pub use crate::{ codecs::{Encoder, EncodingConfig, Transformer}, diff --git a/src/sinks/prometheus/remote_write/sink.rs b/src/sinks/prometheus/remote_write/sink.rs index fdff3b605db9c..093cb7e0bc26b 100644 --- a/src/sinks/prometheus/remote_write/sink.rs +++ b/src/sinks/prometheus/remote_write/sink.rs @@ -2,7 +2,7 @@ use std::fmt; use vector_lib::byte_size_of::ByteSizeOf; use vector_lib::event::Metric; -use vector_stream::batcher::{data::BatchData, limiter::ByteSizeOfItemSize}; +use vector_lib::stream::batcher::{data::BatchData, limiter::ByteSizeOfItemSize}; use crate::sinks::{prelude::*, util::buffer::metrics::MetricSet}; diff --git a/src/sinks/s3_common/service.rs b/src/sinks/s3_common/service.rs index f734928dc7f64..2175005bfb61e 100644 --- a/src/sinks/s3_common/service.rs +++ b/src/sinks/s3_common/service.rs @@ -13,7 +13,7 @@ use tower::Service; use tracing::Instrument; use vector_lib::event::{EventFinalizers, EventStatus, Finalizable}; use vector_lib::request_metadata::{GroupedCountByteSize, MetaDescriptive, RequestMetadata}; -use vector_stream::DriverResponse; +use vector_lib::stream::DriverResponse; use super::config::S3Options; use super::partitioner::S3PartitionKey; diff --git a/src/sinks/splunk_hec/common/response.rs b/src/sinks/splunk_hec/common/response.rs index 745c45a9b882c..c3714eaae6861 100644 --- a/src/sinks/splunk_hec/common/response.rs +++ b/src/sinks/splunk_hec/common/response.rs @@ -1,6 +1,6 @@ use vector_lib::event::EventStatus; use vector_lib::request_metadata::GroupedCountByteSize; -use vector_stream::DriverResponse; +use vector_lib::stream::DriverResponse; pub struct HecResponse { pub event_status: EventStatus, diff --git a/src/sinks/statsd/batch.rs b/src/sinks/statsd/batch.rs index a3b73588f8133..245ec1e3ac81f 100644 --- a/src/sinks/statsd/batch.rs +++ b/src/sinks/statsd/batch.rs @@ -1,5 +1,5 @@ use vector_lib::event::Metric; -use vector_stream::batcher::limiter::ItemBatchSize; +use vector_lib::stream::batcher::limiter::ItemBatchSize; // This accounts for the separators, the metric type string, the length of the value itself. It can // never be too small, as the above values will always take at least 4 bytes. diff --git a/src/sinks/statsd/service.rs b/src/sinks/statsd/service.rs index fa555a441cc2f..8acd729685360 100644 --- a/src/sinks/statsd/service.rs +++ b/src/sinks/statsd/service.rs @@ -2,11 +2,11 @@ use std::task::{Context, Poll}; use futures_util::future::BoxFuture; use tower::Service; +use vector_lib::stream::DriverResponse; use vector_lib::{ finalization::{EventFinalizers, EventStatus, Finalizable}, request_metadata::{GroupedCountByteSize, MetaDescriptive, RequestMetadata}, }; -use vector_stream::DriverResponse; /// Generalized request for sending metrics to a StatsD endpoint. #[derive(Clone, Debug)] diff --git a/src/sinks/statsd/sink.rs b/src/sinks/statsd/sink.rs index 3c16d177458f0..dd78f203ef341 100644 --- a/src/sinks/statsd/sink.rs +++ b/src/sinks/statsd/sink.rs @@ -7,8 +7,8 @@ use futures_util::{ }; use tower::Service; use vector_lib::internal_event::Protocol; +use vector_lib::stream::{BatcherSettings, DriverResponse}; use vector_lib::{event::Event, sink::StreamSink}; -use vector_stream::{BatcherSettings, DriverResponse}; use crate::sinks::util::SinkBuilderExt; diff --git a/src/sinks/util/batch.rs b/src/sinks/util/batch.rs index 30dfdd4b181b8..0bf04de202ae4 100644 --- a/src/sinks/util/batch.rs +++ b/src/sinks/util/batch.rs @@ -5,7 +5,7 @@ use serde_with::serde_as; use snafu::Snafu; use vector_lib::configurable::configurable_component; use vector_lib::json_size::JsonSize; -use vector_stream::BatcherSettings; +use vector_lib::stream::BatcherSettings; use super::EncodedEvent; use crate::{event::EventFinalizers, internal_events::LargeEventDroppedError}; diff --git a/src/sinks/util/builder.rs b/src/sinks/util/builder.rs index 50056941d1cf1..bdf98a21df1f4 100644 --- a/src/sinks/util/builder.rs +++ b/src/sinks/util/builder.rs @@ -12,15 +12,15 @@ use std::{ use futures_util::{stream::Map, Stream, StreamExt}; use pin_project::pin_project; use tower::Service; +use vector_lib::stream::{ + batcher::{config::BatchConfig, Batcher}, + ConcurrentMap, Driver, DriverResponse, ExpirationQueue, PartitionedBatcher, +}; use vector_lib::{ event::{Finalizable, Metric}, partition::Partitioner, ByteSizeOf, }; -use vector_stream::{ - batcher::{config::BatchConfig, Batcher}, - ConcurrentMap, Driver, DriverResponse, ExpirationQueue, PartitionedBatcher, -}; use super::{ buffer::metrics::MetricNormalize, IncrementalRequestBuilder, Normalizer, RequestBuilder, diff --git a/src/sinks/util/http.rs b/src/sinks/util/http.rs index f4461633948ba..8508f18acdbb3 100644 --- a/src/sinks/util/http.rs +++ b/src/sinks/util/http.rs @@ -20,8 +20,8 @@ use snafu::{ResultExt, Snafu}; use tower::{Service, ServiceBuilder}; use tower_http::decompression::DecompressionLayer; use vector_lib::configurable::configurable_component; +use vector_lib::stream::batcher::limiter::ItemBatchSize; use vector_lib::{ByteSizeOf, EstimatedJsonEncodedSizeOf}; -use vector_stream::batcher::limiter::ItemBatchSize; use super::{ retries::{RetryAction, RetryLogic}, diff --git a/src/sinks/vector/service.rs b/src/sinks/vector/service.rs index 87cd11fea3ec4..1a0b240e4338d 100644 --- a/src/sinks/vector/service.rs +++ b/src/sinks/vector/service.rs @@ -9,7 +9,7 @@ use prost::Message; use tonic::{body::BoxBody, IntoRequest}; use tower::Service; use vector_lib::request_metadata::{GroupedCountByteSize, MetaDescriptive, RequestMetadata}; -use vector_stream::DriverResponse; +use vector_lib::stream::DriverResponse; use super::VectorSinkError; use crate::{ diff --git a/src/sinks/vector/sink.rs b/src/sinks/vector/sink.rs index ef965f413431a..b5d97541c74e7 100644 --- a/src/sinks/vector/sink.rs +++ b/src/sinks/vector/sink.rs @@ -5,8 +5,8 @@ use futures::{stream::BoxStream, StreamExt}; use prost::Message; use tower::Service; use vector_lib::request_metadata::GroupedCountByteSize; +use vector_lib::stream::{batcher::data::BatchReduce, BatcherSettings, DriverResponse}; use vector_lib::{config::telemetry, ByteSizeOf, EstimatedJsonEncodedSizeOf}; -use vector_stream::{batcher::data::BatchReduce, BatcherSettings, DriverResponse}; use super::service::VectorRequest; use crate::{ diff --git a/src/sources/kubernetes_logs/partial_events_merger.rs b/src/sources/kubernetes_logs/partial_events_merger.rs index d3effb22c1c62..4a0ac987f8eb8 100644 --- a/src/sources/kubernetes_logs/partial_events_merger.rs +++ b/src/sources/kubernetes_logs/partial_events_merger.rs @@ -6,7 +6,7 @@ use lookup::OwnedTargetPath; use std::collections::HashMap; use std::time::{Duration, Instant}; use vector_lib::config::LogNamespace; -use vector_stream::expiration_map::{map_with_expiration, Emitter}; +use vector_lib::stream::expiration_map::{map_with_expiration, Emitter}; use vrl::owned_value_path; use crate::event; diff --git a/src/transforms/reduce/mod.rs b/src/transforms/reduce/mod.rs index 4d99c5cd650f9..957983188a47e 100644 --- a/src/transforms/reduce/mod.rs +++ b/src/transforms/reduce/mod.rs @@ -28,7 +28,7 @@ use crate::config::schema::Definition; use crate::event::Value; pub use merge_strategy::*; use vector_lib::config::LogNamespace; -use vector_stream::expiration_map::{map_with_expiration, Emitter}; +use vector_lib::stream::expiration_map::{map_with_expiration, Emitter}; use vrl::value::kind::Collection; use vrl::value::Kind;