Struct ObjectstoreServiceConfig 

pub struct ObjectstoreServiceConfig {
    pub objectstore_url: Option<String>,
    pub max_concurrent_requests: usize,
    pub max_backlog: usize,
    pub timeout: u64,
    pub stream_timeout: u64,
    pub retry_delay: f64,
    pub max_attempts: NonZeroU16,
    pub fallback_to_kafka: bool,
    pub auth: Option<ObjectstoreAuthConfig>,
}

Configuration values for the objectstore service.

Fields

objectstore_url: Option<String>

The base URL for the objectstore service.

This defaults to None, which means that the service will be disabled, unless a proper configuration is provided.

max_concurrent_requests: usize

Maximum concurrency of uploads.

max_backlog: usize

Maximum size of the service input queue when max_concurrent_requests is saturated.

The service will loadshed if this threshold is reached.

timeout: u64

Maximum duration of an attachment upload in seconds. Uploads that take longer are discarded.

NOTE: This timeout applies to attachments that are already in-memory. Streaming uploads might take longer and are restricted independently by Self::stream_timeout.

stream_timeout: u64

Maximum duration of an upload stream.

Streams get a larger default timeout because their duration depends on the client as well as the server.

retry_delay: f64

Time between upload attempts.

max_attempts: NonZeroU16

Maximum number of attempts made to upload.

fallback_to_kafka: bool

Whether event attachment payloads may be sent through Kafka if objectstore upload fails.

When disabled, failed event attachments are dropped with an upload_failed outcome instead of falling back to Store’s Kafka attachment path.

auth: Option<ObjectstoreAuthConfig>

Configuration values for objectstore’s auth scheme.

Trait Implementations

impl Debug for ObjectstoreServiceConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ObjectstoreServiceConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ObjectstoreServiceConfig

where ObjectstoreServiceConfig: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ObjectstoreServiceConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.