Struct EmbeddingBulkheadConfig 

pub struct EmbeddingBulkheadConfig {
    pub max_concurrent: usize,
    pub acquire_timeout_ms: u64,
    pub fail_fast: bool,
}

Configuration for the embedding bulkhead pattern.

Fields

max_concurrent: usize

Maximum concurrent embedding operations allowed.

Default: 2 (conservative due to CPU/memory intensity).

acquire_timeout_ms: u64

Timeout for acquiring a permit in milliseconds (0 = no timeout).

Default: 30000ms (30 seconds - embeddings can be slow).

fail_fast: bool

Whether to fail fast when bulkhead is full (vs. waiting).

Default: false (wait for permit).

Implementations

impl EmbeddingBulkheadConfig

pub const fn new() -> Self

Creates a new embedding bulkhead configuration.

pub fn from_env() -> Self

Loads configuration from environment variables.

Variable	Description	Default
SUBCOG_EMBEDDING_BULKHEAD_MAX_CONCURRENT	Max concurrent ops	2
SUBCOG_EMBEDDING_BULKHEAD_ACQUIRE_TIMEOUT_MS	Permit timeout	30000
SUBCOG_EMBEDDING_BULKHEAD_FAIL_FAST	Fail when full	false

pub fn with_env_overrides(self) -> Self

Applies environment variable overrides.

pub const fn with_max_concurrent(self, max: usize) -> Self

Sets the maximum concurrent operations.

pub const fn with_acquire_timeout_ms(self, timeout_ms: u64) -> Self

Sets the acquire timeout in milliseconds.

pub const fn with_fail_fast(self, fail_fast: bool) -> Self

Sets whether to fail fast when the bulkhead is full.

Trait Implementations

impl Clone for EmbeddingBulkheadConfig

fn clone(&self) -> EmbeddingBulkheadConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EmbeddingBulkheadConfig

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

Formats the value using the given formatter.

impl Default for EmbeddingBulkheadConfig

fn default() -> Self

Returns the “default value” for a type.