Source
pub async fn admin_ha_offline( &self, offline: bool, ) -> Result<AdminHaOfflineResponse, KineticaError>
Pauses consumption of messages from other HA clusters
Pauses consumption of messages from other HA clusters to support data repair/recovery scenarios. In-flight queries may fail to replicate to other clusters in the ring when going offline.
offline- Set to true if desired state is offline.
Source
pub async fn admin_ha_offline_with_opts( &self, offline: bool, options: AdminHaOfflineRequestOptions, ) -> Result<AdminHaOfflineResponse, KineticaError>
Pauses consumption of messages from other HA clusters
Pauses consumption of messages from other HA clusters to support data repair/recovery scenarios. In-flight queries may fail to replicate to other clusters in the ring when going offline.
offline- Set to true if desired state is offline.options- The optional parameters; any left unset take the server’s defaults.
Source
pub async fn admin_ha_offline_raw( &self, request: &AdminHaOfflineRequest, ) -> Result<AdminHaOfflineResponse, KineticaError>
Sends a pre-built AdminHaOfflineRequest to the /admin/ha/offline endpoint.
Source
pub async fn admin_ha_offline_from_url( &self, url: &str, request: &AdminHaOfflineRequest, ) -> Result<AdminHaOfflineResponse, KineticaError>
Sends a pre-built AdminHaOfflineRequest to a specific worker URL, bypassing HA head-node selection. Used for multi-head access.