Module vector::sinks::util

Re-exports

• pub use batch::Batch;
• pub use batch::BatchConfig;
• pub use batch::BatchSettings;
• pub use batch::BatchSize;
• pub use batch::BulkSizeBasedDefaultBatchSettings;
• pub use batch::Merged;
• pub use batch::NoDefaultsBatchSettings;
• pub use batch::PushResult;
• pub use batch::RealtimeEventBasedDefaultBatchSettings;
• pub use batch::RealtimeSizeBasedDefaultBatchSettings;
• pub use batch::SinkBatchSettings;
• pub use batch::Unmerged;
• pub use buffer::json::BoxedRawValue;
• pub use buffer::json::JsonArrayBuffer;
• pub use buffer::partition::Partition;
• pub use buffer::vec::EncodedLength;
• pub use buffer::vec::VecBuffer;
• pub use buffer::Buffer;
• pub use buffer::Compression;
• pub use buffer::PartitionBuffer;
• pub use buffer::PartitionInnerBuffer;
• pub use builder::SinkBuilderExt;
• pub use compressor::Compressor;
• pub use normalizer::Normalizer;
• pub use request_builder::IncrementalRequestBuilder;
• pub use request_builder::RequestBuilder;
• pub use service::Concurrency;
• pub use service::ServiceBuilderExt;
• pub use service::TowerBatchedSink;
• pub use service::TowerPartitionSink;
• pub use service::TowerRequestConfig;
• pub use service::TowerRequestLayer;
• pub use service::TowerRequestSettings;
• pub use sink::BatchSink;
• pub use sink::PartitionBatchSink;
• pub use uri::UriSerde;

Modules

• adaptive_concurrency
  Limit the max number of requests being concurrently processed.
• auth
• batch
• buffer
• builder
• compressor
• encoding
• http
• metadata
• normalizer
• partitioner
• processed_event
• request_builder
• retries
• service
• sink
  This module contains all our internal sink utilities
• snappy
  An encoder for Snappy compression. Whilst there does exist a Writer implementation for Snappy, this compresses using the Snappy frame format, which is not quite what we want. So instead this encoder buffers the data in a Vec until the end. The raw compressor is then used to compress the data and writes it to the provided writer.
• socket_bytes_sink
• statistic
• tcp
• udp
• unix
• uri
• zstd

Structs

• EncodedEvent

Traits

• ElementCount
  Marker trait for types that can hold a batch of events
• StreamSink

Functions

• encode_namespace
  Joins namespace with name via delimiter if namespace is present.
• timezone_to_offset