Module prelude

Expand description

Prelude module for sinks which will re-export the symbols that most stream based sinks are likely to use.

Re-exports§

pub use crate::codecs::Encoder;
pub use crate::codecs::EncodingConfig;
pub use crate::codecs::Transformer;
pub use crate::config::SinkConfig;
pub use crate::config::SinkContext;
pub use crate::internal_events::SinkRequestBuildError;
pub use crate::internal_events::TemplateRenderingError;
pub use crate::sinks::util::builder::SinkBuilderExt;
pub use crate::sinks::util::encoding;
pub use crate::sinks::util::encoding::write_all;
pub use crate::sinks::util::metadata::RequestMetadataBuilder;
pub use crate::sinks::util::request_builder::default_request_builder_concurrency_limit;
pub use crate::sinks::util::request_builder::EncodeResult;
pub use crate::sinks::util::retries::RetryAction;
pub use crate::sinks::util::retries::RetryLogic;
pub use crate::sinks::util::service::ServiceBuilderExt;
pub use crate::sinks::util::service::Svc;
pub use crate::sinks::util::BatchConfig;
pub use crate::sinks::util::Compression;
pub use crate::sinks::util::Concurrency;
pub use crate::sinks::util::NoDefaultsBatchSettings;
pub use crate::sinks::util::RequestBuilder;
pub use crate::sinks::util::SinkBatchSettings;
pub use crate::sinks::util::TowerRequestConfig;
pub use crate::sinks::Healthcheck;
pub use crate::sinks::HealthcheckError;
pub use crate::template::Template;
pub use crate::template::TemplateParseError;
pub use crate::template::UnsignedIntTemplate;

AcknowledgementsConfig: End-to-end acknowledgements configuration.
BatcherSettings: Controls the behavior of the batcher in terms of batch size and flush interval.
CountByteSize: Holds the tuple (count_of_events, estimated_json_size_of_events).
DataType
EventFinalizers: A collection of event finalizers.
Input
JsonSize: A newtype for the JSON size of an event. Used to emit the component_received_event_bytes_total and component_sent_event_bytes_total metrics.
LogEvent
RequestMetadata: Metadata for batch requests.
Requirement: The input schema for a given component.
ServiceBuilder: Declaratively construct Service values.
TaggedEventsSent
TlsConfig: TLS configuration.
TlsSettings: Directly usable settings for TLS connectors

Event
EventStatus: The status of an individual event.
GroupedCountByteSize: Keeps track of the estimated json size of a given batch of events by source and service.
Value: The main value type used in Vector events, and VRL.
VectorSink

ByteSizeOf
DriverResponse
EstimatedJsonEncodedSizeOf: Return the estimated size of a type in bytes when encoded as JSON.
EventCount
Finalizable: An object that can be finalized.
FutureExt: An extension trait for Futures that provides a variety of convenient adapters.
GenerateConfig: A component that can generate a default configuration for itself.
GetEventCountTags: Must be implemented by events to get the tags that will be attached to the component_sent_event_* emitted metrics.
MetaDescriptive: Objects implementing this trait have metadata that describes the request.
Partitioner: Calculate partitions for an item
Service: An asynchronous function from a Request to a Response.
StreamExt: An extension trait for Streams that provides a variety of convenient combinator functions.
StreamSink

BoxFuture: An owned dynamically typed Future for use in cases where you can’t statically type your result or need to add some indirection.
BoxStream: An owned dynamically typed [Stream] for use in cases where you can’t statically type your result or need to add some indirection.

async_trait
configurable_component: Designates a type as being part of a Vector configuration.