Struct DNSZoneStatusUpdater 

pub struct DNSZoneStatusUpdater { /* private fields */ }

Centralized status updater for DNSZone resources.

This struct collects all status changes during reconciliation and applies them atomically in a single Kubernetes API call. This prevents the tight reconciliation loop caused by multiple status updates triggering multiple “object updated” events.

Pattern aligns with kube-condition project for future migration.

Example

use bindy::reconcilers::status::DNSZoneStatusUpdater;

async fn reconcile(client: Client, zone: DNSZone) -> Result<()> {
    let mut status_updater = DNSZoneStatusUpdater::new(&zone);

    // Collect status changes in memory
    status_updater.set_condition("Progressing", "True", "Configuring", "Setting up zone");
    status_updater.set_records(vec![/* discovered records */]);

    // Single atomic update at the end
    status_updater.apply(&client).await?;
    Ok(())
}

Implementations

impl DNSZoneStatusUpdater

pub fn new(dnszone: &DNSZone) -> Self

Create a new status updater for a DNSZone.

Initializes with the current status from the zone, or creates a new empty status.

pub fn set_condition( &mut self, condition_type: &str, status: &str, reason: &str, message: &str, )

Update or add a condition (in-memory only, no API call).

Marks the status as changed if the condition differs from the current state.

pub fn set_records(&mut self, records: &[RecordReferenceWithTimestamp])

Set the discovered DNS records list (in-memory only, no API call).

pub fn set_observed_generation(&mut self, generation: Option<i64>)

Set the observed generation to match the current generation.

pub fn update_instance_status( &mut self, name: &str, namespace: &str, status: InstanceStatus, message: Option<String>, )

Update instance status (in-memory only, no API call).

Updates the status of a specific instance in the status.bind9Instances list. Creates a new entry if the instance doesn’t exist.

Arguments

• name - Instance name
• namespace - Instance namespace
• status - New status (Claimed, Configured, Failed, Unclaimed)
• message - Optional status message (error details, etc.)

pub fn remove_instance(&mut self, name: &str, namespace: &str)

Remove instance from the instances list (in-memory only, no API call).

Removes an instance from status.bind9Instances when it no longer claims the zone or has been deleted.

Arguments

• name - Instance name
• namespace - Instance namespace

pub fn has_changes(&self) -> bool

Check if the status has actually changed compared to the current status.

Returns true if there are semantic changes that warrant an API update.

CRITICAL: The comparison uses InstanceReferenceWithStatus::eq() which excludes last_reconciled_at timestamps. Without this, nanosecond precision differences would cause infinite reconciliation loops.

pub fn has_degraded_condition(&self) -> bool

Check if a Degraded condition was set during this reconciliation.

Returns true only if set_condition("Degraded", "True", ...) was called during this reconciliation, not if a Degraded condition existed from a previous reconciliation.

pub fn clear_degraded_condition(&mut self)

Clear any Degraded condition by setting it to False (in-memory only, no API call).

This method should be called when reconciliation succeeds to ensure stale Degraded conditions from previous failures are cleared.

If no Degraded condition exists, this method does nothing.

pub fn set_duplicate_zone_condition( &mut self, zone_name: &str, conflicting_zones: &[String], )

Set the Ready condition to False with DuplicateZone reason (in-memory only, no API call).

This method should be called when a duplicate zone is detected to signal that this zone cannot be reconciled because another zone already claims the same zone name.

Arguments

• zone_name - The zone name that has a conflict
• conflicting_zones - List of conflicting zone identifiers (namespace/name)

pub async fn apply(&self, client: &Client) -> Result<()>

Apply the collected status changes to Kubernetes (single atomic API call).

Only makes the API call if there are actual changes. Skips the update if the status is semantically unchanged, preventing unnecessary reconciliation loops.

Errors

Returns an error if the Kubernetes API call fails.