linera-core 0.15.17

The core Linera protocol, including client and server logic, node synchronization, etc.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

// Copyright (c) Zefchain Labs, Inc.
// SPDX-License-Identifier: Apache-2.0

//! This module manages communication with validator nodes, including
//! load balancing, request deduplication, caching, and performance tracking.

mod cache;
mod in_flight_tracker;
mod node_info;
mod request;
mod scheduler;
mod scoring;

pub use scheduler::RequestsScheduler;
pub use scoring::ScoringWeights;

// Module constants - default values for RequestsSchedulerConfig
pub const MAX_IN_FLIGHT_REQUESTS: usize = 100;
pub const MAX_ACCEPTED_LATENCY_MS: f64 = 5000.0;
pub const CACHE_TTL_MS: u64 = 2000;
pub const CACHE_MAX_SIZE: usize = 1000;
pub const MAX_REQUEST_TTL_MS: u64 = 200;
pub const ALPHA_SMOOTHING_FACTOR: f64 = 0.1;
pub const STAGGERED_DELAY_MS: u64 = 150;

/// Configuration for the `RequestsScheduler`.
#[derive(Debug, Clone)]
pub struct RequestsSchedulerConfig {
    /// Maximum expected latency in milliseconds for score normalization
    pub max_accepted_latency_ms: f64,
    /// Time-to-live for cached responses in milliseconds
    pub cache_ttl_ms: u64,
    /// Maximum number of entries in the cache
    pub cache_max_size: usize,
    /// Maximum latency for an in-flight request before we stop deduplicating it (in milliseconds)
    pub max_request_ttl_ms: u64,
    /// Smoothing factor for Exponential Moving Averages (0 < alpha < 1)
    pub alpha: f64,
    /// Delay in milliseconds between starting requests to different peers.
    pub retry_delay_ms: u64,
}

impl Default for RequestsSchedulerConfig {
    fn default() -> Self {
        Self {
            max_accepted_latency_ms: MAX_ACCEPTED_LATENCY_MS,
            cache_ttl_ms: CACHE_TTL_MS,
            cache_max_size: CACHE_MAX_SIZE,
            max_request_ttl_ms: MAX_REQUEST_TTL_MS,
            alpha: ALPHA_SMOOTHING_FACTOR,
            retry_delay_ms: STAGGERED_DELAY_MS,
        }
    }
}