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 */]);
    status_updater.set_secondary_ips(vec!["10.0.0.1".to_string()]);

    // 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: Vec<RecordReference>)

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

pub fn set_secondary_ips(&mut self, ips: Vec<String>)

Set the secondary server IPs (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 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.

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.