all lists on lists.proxmox.com
 help / color / mirror / Atom feed
From: Maximiliano Sandoval <m.sandoval@proxmox.com>
To: Proxmox Datacenter Manager development discussion
	<pdm-devel@lists.proxmox.com>
Subject: Re: [pdm-devel] [PATCH proxmox-datacenter-manager 03/25] pdm-api-types: add CollectionSettings type
Date: Tue, 11 Feb 2025 15:18:39 +0100	[thread overview]
Message-ID: <s8or044lfwd.fsf@proxmox.com> (raw)
In-Reply-To: <20250211120541.163621-4-l.wagner@proxmox.com>


Lukas Wagner <l.wagner@proxmox.com> writes:

> This commit adds the CollectionSettings type which holds settings for
> the metric collection system. Included are collection interval, max
> concurrency and upper/lower bounds for the metric collection loop.
>
> Signed-off-by: Lukas Wagner <l.wagner@proxmox.com>
> ---
>  lib/pdm-api-types/src/lib.rs               |   3 +
>  lib/pdm-api-types/src/metric_collection.rs | 180 +++++++++++++++++++++
>  2 files changed, 183 insertions(+)
>  create mode 100644 lib/pdm-api-types/src/metric_collection.rs
>
> diff --git a/lib/pdm-api-types/src/lib.rs b/lib/pdm-api-types/src/lib.rs
> index 3844907..6115e41 100644
> --- a/lib/pdm-api-types/src/lib.rs
> +++ b/lib/pdm-api-types/src/lib.rs
> @@ -19,6 +19,9 @@ pub use acl::*;
>  mod node_config;
>  pub use node_config::*;
>
> +mod metric_collection;
> +pub use metric_collection::*;
> +
>  mod proxy;
>  pub use proxy::HTTP_PROXY_SCHEMA;
>
> diff --git a/lib/pdm-api-types/src/metric_collection.rs b/lib/pdm-api-types/src/metric_collection.rs
> new file mode 100644
> index 0000000..99dac9b
> --- /dev/null
> +++ b/lib/pdm-api-types/src/metric_collection.rs
> @@ -0,0 +1,180 @@
> +//! API types for metric collection settings.
> +
> +use serde::{Deserialize, Serialize};
> +
> +use proxmox_schema::{api, Updater};
> +
> +/// Default metric collection interval.
> +pub const DEFAULT_COLLECTION_INTERVAL: u64 = 600;
> +
> +/// Minimum metric collection interval.
> +pub const MIN_COLLECTION_INTERVAL: u64 = 10;
> +
> +/// Maximum metric collection interval.
> +/// PVE and PBS keep 30 minutes of metric history,
> +/// maximum is set to 25 minutes to leave some headroom.
> +pub const MAX_COLLECTION_INTERVAL: u64 = 1500;
> +
> +/// Default number of concurrent connections.
> +pub const DEFAULT_CONCURRENCY: usize = 10;
> +/// Maximum number of concurrent connections.
> +pub const MAX_CONCURRENCY: u64 = 50;
> +/// Minimum number of concurrent connections (no concurrency).
> +pub const MIN_CONCURRENCY: u64 = 1;
> +
> +/// Default upper bound for the random delay for the
> +/// main metric collection loop.
> +pub const DEFAULT_MAX_OFFSET: u64 = 10;
> +/// Default lower bound for the random delay for the
> +/// main metric collection loop.
> +pub const DEFAULT_MIN_OFFSET: u64 = 0;
> +
> +/// Highest configurable upper bound for the random interval offset for the main loop.
> +pub const MAX_INTERVAL_OFFSET: u64 = 300;
> +/// Lowest configureable lower bound for the random interval offset for the main loop.

There is a typo on configureable.

> +pub const MIN_INTERVAL_OFFSET: u64 = 0;
> +
> +/// Default upper bound for the random individual connection delay.
> +pub const DEFAULT_MAX_CONNECTION_DELAY: u64 = 100;
> +/// Default lower bound for the random individual connection delay.
> +pub const DEFAULT_MIN_CONNECTION_DELAY: u64 = 0;
> +
> +/// Highest configurable upper bound for the random individual connection delay.
> +pub const MAX_CONNECTION_DELAY: u64 = 1000;
> +/// Lowest configurable lower bound for the random individual connection delay.
> +pub const MIN_CONNECTION_DELAY: u64 = 0;
> +
> +#[api(
> +    properties: {
> +        "collection-interval" : {
> +            optional: true,
> +            default: DEFAULT_COLLECTION_INTERVAL as isize,
> +            minimum: MIN_COLLECTION_INTERVAL as isize,
> +            maximum: MAX_COLLECTION_INTERVAL as isize,
> +        },
> +        "max-concurrent-connections" : {
> +            optional: true,
> +            default: DEFAULT_CONCURRENCY as isize,
> +            minimum: MIN_CONCURRENCY as isize,
> +            maximum: MAX_CONCURRENCY as isize,
> +        },
> +        "max-interval-offset" : {
> +            optional: true,
> +            default: DEFAULT_MAX_OFFSET as isize,
> +            minimum: MIN_INTERVAL_OFFSET as isize,
> +            maximum: MAX_INTERVAL_OFFSET as isize,
> +        },
> +        "min-interval-offset" : {
> +            optional: true,
> +            default: DEFAULT_MIN_OFFSET as isize,
> +            minimum: MIN_INTERVAL_OFFSET as isize,
> +            maximum: MAX_INTERVAL_OFFSET as isize,
> +        },
> +        "max-connection-delay" : {
> +            optional: true,
> +            default: DEFAULT_MAX_CONNECTION_DELAY as isize,
> +            minimum: MIN_CONNECTION_DELAY as isize,
> +            maximum: MAX_CONNECTION_DELAY as isize,
> +        },
> +        "min-connection-delay" : {
> +            optional: true,
> +            default: DEFAULT_MIN_CONNECTION_DELAY as isize,
> +            minimum: MIN_CONNECTION_DELAY as isize,
> +            maximum: MAX_CONNECTION_DELAY as isize,
> +        },
> +    },
> +)]
> +#[derive(Clone, Default, Deserialize, Serialize, Updater)]
> +#[serde(rename_all = "kebab-case")]
> +/// Settings for the metric collection system.
> +pub struct CollectionSettings {
> +    /// Collection settings ID
> +    #[updater(skip)]
> +    pub id: String,
> +
> +    /// Interval in seconds at which to collect metrics.
> +    /// The point in time at which metrics are collected
> +    /// are aligned based on the collection interval. For instance,
> +    /// a collection interval of 300 (5 minutes) would schedule metric collection
> +    /// at 11:00:00, 11:05:00 (without accounting for the random offset).
> +    ///
> +    /// To avoid load spikes, metric collection runs are offeset by

There is a typo on offeset.

> +    /// a random number of seconds between min_interval_offset and max_interval_offset.
> +    #[serde(skip_serializing_if = "Option::is_none")]
> +    pub collection_interval: Option<u64>,
> +
> +    /// Maximum number of concurrent connections while collecting metrics.
> +    #[serde(skip_serializing_if = "Option::is_none")]
> +    pub max_concurrent_connections: Option<usize>,
> +
> +    /// Maximum offset in seconds for the metric collection interval.
> +    #[serde(skip_serializing_if = "Option::is_none")]
> +    pub max_interval_offset: Option<u64>,
> +
> +    /// Minimum offset in seconds for the metric collection interval.
> +    #[serde(skip_serializing_if = "Option::is_none")]
> +    pub min_interval_offset: Option<u64>,
> +
> +    /// Maximum random delay in milliseconds for each outgoing connection.
> +    #[serde(skip_serializing_if = "Option::is_none")]
> +    pub max_connection_delay: Option<u64>,
> +
> +    /// Minimum random delay in milliseconds for each outgoing connection.
> +    #[serde(skip_serializing_if = "Option::is_none")]
> +    pub min_connection_delay: Option<u64>,
> +}
> +
> +#[api]
> +#[derive(Copy, Clone, Deserialize, Serialize)]
> +#[serde(rename_all = "kebab-case")]
> +/// Deletable property for [`CollectionSettings`].
> +pub enum DeletableCollectionSettingsProperty {
> +    /// Delete 'collection-interval'.
> +    CollectionInterval,
> +    /// Delete 'max-concurrent-connections'.
> +    MaxConcurrentConnections,
> +    /// Delete 'max-interval-offset'.
> +    MaxIntervalOffset,
> +    /// Delete 'min-interval-offset'.
> +    MinIntervalOffset,
> +    /// Delete 'min-connection-delay'.
> +    MaxConnectionDelay,
> +    /// Delete 'min-connection-delay'.
> +    MinConnectionDelay,
> +}
> +
> +impl CollectionSettings {
> +    /// Return the collection interval or the default if not configured.
> +    pub fn collection_interval_or_default(&self) -> u64 {
> +        self.collection_interval
> +            .unwrap_or(DEFAULT_COLLECTION_INTERVAL)
> +    }
> +
> +    /// Return the number of allowed concurrent connections or the default if not configured.
> +    pub fn max_concurrent_connections_or_default(&self) -> usize {
> +        self.max_concurrent_connections
> +            .unwrap_or(DEFAULT_CONCURRENCY)
> +    }
> +
> +    /// Return the upper bound for the main loop delay or the default if not configured.
> +    pub fn max_interval_offset_or_default(&self) -> u64 {
> +        self.max_interval_offset.unwrap_or(DEFAULT_MAX_OFFSET)
> +    }
> +
> +    /// Return the lower bound for the main loop delay or the default if not configured.
> +    pub fn min_interval_offset_or_default(&self) -> u64 {
> +        self.min_interval_offset.unwrap_or(DEFAULT_MIN_OFFSET)
> +    }
> +
> +    /// Return the upper bound for the connection delay or the default if not configured.
> +    pub fn max_connection_delay_or_default(&self) -> u64 {
> +        self.max_connection_delay
> +            .unwrap_or(DEFAULT_MAX_CONNECTION_DELAY)
> +    }
> +
> +    /// Return the lower bound for the connection delay or the default if not configured.
> +    pub fn min_connection_delay_or_default(&self) -> u64 {
> +        self.min_connection_delay
> +            .unwrap_or(DEFAULT_MIN_CONNECTION_DELAY)
> +    }
> +}



_______________________________________________
pdm-devel mailing list
pdm-devel@lists.proxmox.com
https://lists.proxmox.com/cgi-bin/mailman/listinfo/pdm-devel


  reply	other threads:[~2025-02-11 14:23 UTC|newest]

Thread overview: 49+ messages / expand[flat|nested]  mbox.gz  Atom feed  top
2025-02-11 12:05 [pdm-devel] [PATCH proxmox-datacenter-manager 00/25] metric collection improvements (concurrency, config, API, CLI) Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 01/25] test support: add NamedTempFile helper Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 02/25] test support: add NamedTempDir helper Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 03/25] pdm-api-types: add CollectionSettings type Lukas Wagner
2025-02-11 14:18   ` Maximiliano Sandoval [this message]
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 04/25] pdm-config: add functions for reading/writing metric collection settings Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 05/25] metric collection: split top_entities split into separate module Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 06/25] metric collection: save metric data to RRD in separate task Lukas Wagner
2025-02-12 13:59   ` Wolfgang Bumiller
2025-02-12 14:32     ` Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 07/25] metric collection: rework metric poll task Lukas Wagner
2025-02-11 12:58   ` Lukas Wagner
2025-02-12 15:57   ` Wolfgang Bumiller
2025-02-13 12:31     ` Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 08/25] metric collection: persist state after metric collection Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 09/25] metric collection: skip if last_collection < MIN_COLLECTION_INTERVAL Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 10/25] metric collection: collect overdue metrics on startup/timer change Lukas Wagner
2025-02-13  8:55   ` Wolfgang Bumiller
2025-02-13 13:50     ` Lukas Wagner
2025-02-13 14:19       ` Wolfgang Bumiller
2025-02-13 15:21         ` Lukas Wagner
2025-02-13 15:34           ` Wolfgang Bumiller
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 11/25] metric collection: add tests for the fetch_remotes function Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 12/25] metric collection: add test for fetch_overdue Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 13/25] metric collection: pass rrd cache instance as function parameter Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 14/25] metric collection: add test for rrd task Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 15/25] metric collection: wrap rrd_cache::Cache in a struct Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 16/25] metric collection: record remote response time in metric database Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 17/25] metric collection: save time needed for collection run to RRD Lukas Wagner
2025-02-13 11:53   ` Wolfgang Bumiller
2025-02-13 12:12     ` Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 18/25] metric collection: periodically clean removed remotes from statefile Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 19/25] api: add endpoint for updating metric collection settings Lukas Wagner
2025-02-13 12:09   ` Wolfgang Bumiller
2025-02-13 12:15     ` Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 20/25] api: add endpoint to trigger metric collection Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 21/25] api: remotes: trigger immediate metric collection for newly added nodes Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 22/25] api: add api for querying metric collection RRD data Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 23/25] api: metric-collection: add status endpoint Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 24/25] pdm-client: add metric collection API methods Lukas Wagner
2025-02-13 12:10   ` Wolfgang Bumiller
2025-02-13 13:52     ` Lukas Wagner
2025-02-11 12:05 ` [pdm-devel] [PATCH proxmox-datacenter-manager 25/25] cli: add commands for metric-collection settings, trigger, status Lukas Wagner
2025-02-13 12:14   ` Wolfgang Bumiller
2025-02-13 14:17     ` Lukas Wagner
2025-02-13 14:56       ` Wolfgang Bumiller
2025-02-13 14:58         ` Lukas Wagner
2025-02-13 15:11           ` Lukas Wagner
2025-02-14 13:08 ` [pdm-devel] [PATCH proxmox-datacenter-manager 00/25] metric collection improvements (concurrency, config, API, CLI) Lukas Wagner

Reply instructions:

You may reply publicly to this message via plain-text email
using any one of the following methods:

* Save the following mbox file, import it into your mail client,
  and reply-to-all from there: mbox

  Avoid top-posting and favor interleaved quoting:
  https://en.wikipedia.org/wiki/Posting_style#Interleaved_style

* Reply using the --to, --cc, and --in-reply-to
  switches of git-send-email(1):

  git send-email \
    --in-reply-to=s8or044lfwd.fsf@proxmox.com \
    --to=m.sandoval@proxmox.com \
    --cc=pdm-devel@lists.proxmox.com \
    /path/to/YOUR_REPLY

  https://kernel.org/pub/software/scm/git/docs/git-send-email.html

* If your mail client supports setting the In-Reply-To header
  via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line before the message body.
This is an external index of several public inboxes,
see mirroring instructions on how to clone and mirror
all data and code used by this external index.
Service provided by Proxmox Server Solutions GmbH | Privacy | Legal