Struct AlterReplicaLogDirsResult 

pub struct AlterReplicaLogDirsResult { /* private fields */ }

The result of the Admin::alter_replica_log_dirs call.

To retrieve the detailed result per specified TopicPartitionReplica, use values. To retrieve the overall result only, use all.

Implementations

impl AlterReplicaLogDirsResult

pub fn values(&self) -> &HashMap<TopicPartitionReplica, KafkaFuture<()>>

Returns a map from TopicPartitionReplica to KafkaFuture which holds the status of individual replica movement. To check the result of individual replica movement, call KafkaFuture::get from the value contained in the returned map. If there is no error, it will return silently; if not, it returns an error like the following:

• Error::is_cluster_authorization_error: Authorization failed. (CLUSTER_AUTHORIZATION_FAILED, 31)
• Error::is_invalid_topic_error: The specified topic name is too long. (INVALID_TOPIC_EXCEPTION, 17)
• Error::is_log_dir_not_found_error: The specified log directory is not found in the broker. (LOG_DIR_NOT_FOUND, 57)
• Error::is_replica_not_available_error: The replica does not exist on the broker. (REPLICA_NOT_AVAILABLE, 9)
• Error::is_kafka_storage_error: Disk error occurred. (KAFKA_STORAGE_ERROR, 56)
• Error::is_unknown_server_error: Unknown. (UNKNOWN_SERVER_ERROR, -1)

Translation notes

KafkaFuture::get returns the cause itself: it has no cancellation, interruption or execution wrapper.

pub fn all(&self) -> KafkaFuture<()>

Returns a future which succeeds if all the replica movements have succeeded, otherwise yields the first error described in values.

Trait Implementations

impl Debug for AlterReplicaLogDirsResult

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.