vector/sinks/
prelude.rs

1//! Prelude module for sinks which will re-export the symbols that most
2//! stream based sinks are likely to use.
3
4pub use async_trait::async_trait;
5pub use futures::{FutureExt, StreamExt, future, future::BoxFuture, stream::BoxStream};
6pub use tower::{Service, ServiceBuilder};
7pub use vector_lib::{
8    ByteSizeOf, EstimatedJsonEncodedSizeOf,
9    buffers::EventCount,
10    config::{AcknowledgementsConfig, Input, telemetry},
11    configurable::configurable_component,
12    event::Value,
13    finalization::{EventFinalizers, EventStatus, Finalizable},
14    internal_event::{CountByteSize, TaggedEventsSent},
15    json_size::JsonSize,
16    partition::Partitioner,
17    request_metadata::{GetEventCountTags, GroupedCountByteSize, MetaDescriptive, RequestMetadata},
18    schema::Requirement,
19    sink::{StreamSink, VectorSink},
20    stream::{BatcherSettings, DriverResponse},
21    tls::TlsSettings,
22};
23
24pub use crate::{
25    codecs::{Encoder, EncodingConfig, Transformer},
26    config::{DataType, GenerateConfig, SinkConfig, SinkContext},
27    event::{Event, LogEvent},
28    internal_events::{SinkRequestBuildError, TemplateRenderingError},
29    sinks::{
30        Healthcheck, HealthcheckError,
31        util::{
32            BatchConfig, Compression, Concurrency, NoDefaultsBatchSettings, RequestBuilder,
33            SinkBatchSettings, TowerRequestConfig,
34            builder::SinkBuilderExt,
35            encoding::{self, write_all},
36            metadata::RequestMetadataBuilder,
37            request_builder::{EncodeResult, default_request_builder_concurrency_limit},
38            retries::{RetryAction, RetryLogic},
39            service::{ServiceBuilderExt, Svc},
40        },
41    },
42    template::{Template, TemplateParseError, UnsignedIntTemplate},
43    tls::TlsConfig,
44};
vector/sinks/prelude.rs

vector/sinks/
prelude.rs
