Struct KedaConfig 

pub struct KedaConfig {
    pub enabled: bool,
    pub min_replicas: u32,
    pub max_replicas: u32,
    pub polling_interval: u32,
    pub cooldown_period: u32,
    pub kafka_lag_threshold: u64,
    pub activation_lag_threshold: u64,
    pub cpu_enabled: bool,
    pub cpu_threshold: u32,
}

Available on crate feature deployment only.

KEDA autoscaling configuration for the app config cascade.

Include this in your app’s Config struct so KEDA thresholds participate in the figment cascade and are env-var overridable.

Fields

enabled: bool

Whether KEDA scaling is enabled.

min_replicas: u32

Minimum replica count (0 = scale-to-zero).

max_replicas: u32

Maximum replica count.

polling_interval: u32

Seconds between KEDA polling the scaler.

cooldown_period: u32

Seconds before scale-down after load drops.

kafka_lag_threshold: u64

Scale when consumer group lag exceeds this per partition.

activation_lag_threshold: u64

Wake from zero replicas when lag exceeds this.

cpu_enabled: bool

Enable CPU-based scaling trigger.

cpu_threshold: u32

CPU utilisation percentage threshold.

Trait Implementations

impl Clone for KedaConfig

fn clone(&self) -> KedaConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KedaConfig

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

Formats the value using the given formatter.

impl Default for KedaConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for KedaConfig

where KedaConfig: Default,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<&KedaConfig> for KedaContract

fn from(config: &KedaConfig) -> Self

Converts to this type from the input type.

impl Serialize for KedaConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.