Struct UpgradeMonitor 

pub struct UpgradeMonitor { /* private fields */ }

Monitors GitHub releases for new versions.

Implementations

impl UpgradeMonitor

pub fn new( repo: String, channel: UpgradeChannel, check_interval_hours: u64, ) -> Self

Create a new upgrade monitor.

Arguments

• repo - GitHub repository in “owner/repo” format
• channel - Release channel to track (Stable or Beta)
• check_interval_hours - How often to check for updates

pub fn with_release_cache(self, cache: ReleaseCache) -> Self

Configure a shared disk cache for release metadata.

When set, check_for_updates will consult the cache before hitting the GitHub API. Fresh results are written back so that other nodes on the same machine can reuse them.

pub fn with_staged_rollout(self, node_id: &[u8], max_delay_hours: u64) -> Self

Configure staged rollout for this monitor.

Arguments

• node_id - The node’s unique identifier for deterministic delay calculation
• max_delay_hours - Maximum rollout window (0 to disable)

pub fn check_interval(&self) -> Duration

Get the check interval.

pub fn current_version(&self) -> &Version

Get the current version.

pub fn repo(&self) -> &str

Get the tracked repository.

pub fn version_matches_channel(&self, version: &Version) -> bool

Check if version matches the configured channel.

• Stable channel: Only accepts versions without pre-release suffixes
• Beta channel: Accepts all versions (stable and pre-release)

pub async fn check_for_updates(&self) -> Result<Option<UpgradeInfo>>

Check GitHub for available updates.

This method only checks for available updates, it does not respect staged rollout delays. Use Self::check_for_ready_upgrade for staged rollout aware upgrade checking.

Errors

Returns an error if the GitHub API request fails.

pub async fn check_for_ready_upgrade(&mut self) -> Result<Option<UpgradeInfo>>

Check for available updates with staged rollout awareness.

This method:

1. Checks GitHub for available updates
2. If staged rollout is enabled and an upgrade is found:
   • Starts tracking the upgrade detection time
   • Returns None until the calculated delay has passed
   • Returns the upgrade info once the node is ready to apply it

Errors

Returns an error if the GitHub API request fails.

pub fn time_until_upgrade(&self) -> Option<Duration>

Get the remaining time until this node should upgrade.

Returns None if no upgrade is pending or staged rollout is disabled.

pub fn has_staged_rollout(&self) -> bool

Check if staged rollout is enabled.

pub fn pending_version(&self) -> Option<&Version>

Get the pending upgrade version, if any.