Module vector::sinks::prelude

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;

Modules

• future
  Asynchronous values.

Structs

• 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

Enums

• 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

Traits

• 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

Functions

• telemetry
  Returns the telemetry configuration options.

Type Aliases

• 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.

Attribute Macros

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