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
- datagram
- 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
Vecuntil the end. Therawcompressor is then used to compress the data and writes it to the provided writer. - socket_
bytes_ sink - statistic
- tcp
- udp
- unix
- uri
- zstd
Structs§
Traits§
- Element
Count - Marker trait for types that can hold a batch of events
- Stream
Sink
Functions§
- encode_
namespace - Joins namespace with name via delimiter if namespace is present.
- timezone_
to_ offset