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

vector/sinks/
prelude.rs
