Struct MockAdminClient 

pub struct MockAdminClient { /* private fields */ }

An in-memory Admin implementation for tests.

Every method Java’s MockAdminClient implements works on in-memory state; the ones Java leaves unimplemented return futures failed with an error for which Error::is_local_unsupported_operation_error holds. All futures returned are immediately resolved.

Implementations

impl MockAdminClient

pub const DEFAULT_CLUSTER_ID: &'static str = "I4ZmrWqfT2e-upky_4fdPA"

The cluster id a Builder uses unless set_cluster_id overrides it.

pub const DEFAULT_LOG_DIRS: &'static [&'static str]

The log directories a Builder gives each broker it adds.

pub fn create() -> Builder

Returns a new Builder with one broker.

pub fn new() -> Self

Creates a mock with one broker, Node::no_node, which is also the controller.

It cannot fail: the controller is the only broker.

pub fn with_brokers_controller( brokers: Vec<Node>, controller: Node, ) -> Result<Self, Error>

Creates a mock with the given brokers and controller: DEFAULT_CLUSTER_ID, one default partition, a default replication factor of brokers.len() (unlike Builder::build’s min(brokers.len(), 3)), DEFAULT_LOG_DIRS for every broker, no raft controller and empty feature-level and default-group-config maps.

Arguments

• brokers - The brokers
• controller - The controller, one of brokers

Errors

Error::is_local_illegal_argument_error, with Java’s message “The controller node must be in the list of brokers”, when controller is not one of brokers.

pub fn set_controller(&self, controller: Node) -> Result<(), Error>

Makes controller the controller node reported by describe_cluster.

Arguments

• controller - The controller, one of the mock’s brokers

Errors

Error::is_local_illegal_argument_error, with Java’s message “The controller node must be in the list of brokers”, when controller is not one of the mock’s brokers; the controller is then left unchanged.

pub fn update_beginning_offsets( &self, new_offsets: HashMap<TopicPartition, i64>, )

Seeds the beginning offsets returned by list_offsets for the given partitions.

Arguments

• new_offsets - The beginning offset of each partition

pub fn update_end_offsets(&self, new_offsets: HashMap<TopicPartition, i64>)

Seeds the end offsets returned by list_offsets for the given partitions.

Arguments

• new_offsets - The end offset of each partition

pub fn update_consumer_group_offsets( &self, new_offsets: HashMap<TopicPartition, i64>, )

Seeds the committed consumer-group offsets returned by list_consumer_group_offsets_with_group_specs for the given partitions.

Arguments

• new_offsets - The committed offset of each partition

pub fn add_topic( &self, internal: bool, name: &str, partitions: Vec<TopicPartitionInfo>, configs: Option<BTreeMap<String, String>>, ) -> Result<(), Error>

Adds an existing topic to the mock’s state.

Arguments

• internal - Whether the topic is internal
• name - The topic name
• partitions - The topic’s partitions, whose leaders, replicas and ISR must be brokers of the mock
• configs - The topic configs, or None for none

Errors

Error::is_local_illegal_argument_error, with Java’s message, if the topic was already added, or if any partition names a broker the mock does not have as its leader, in its replica list, or in its ISR.

pub fn mark_topic_for_deletion(&self, name: &str) -> Result<(), Error>

Marks a topic for deletion so describe_topics_with_topics treats it as absent.

Arguments

• name - The topic name

Errors

Error::is_local_illegal_argument_error, with Java’s message, if the topic does not exist.

pub fn set_fetches_remaining_until_visible( &self, topic_name: &str, fetches_remaining_until_visible: i32, ) -> Result<(), Error>

Hides a topic from the next fetches_remaining_until_visible fetches.

Each list_topics, describe_topics (by name or by id) and topic describe_configs that would return the topic decrements the counter instead, until it reaches zero.

Arguments

• topic_name - The topic name
• fetches_remaining_until_visible - The number of fetches that do not return the topic

Errors

Error::is_local_illegal_argument_error, with Java’s message, "No such topic as <name>", if the topic does not exist. Java throws a bare RuntimeException, which has no closer counterpart in the crate.

pub fn timeout_next_request(&self, number_of_requests: i32)

Causes the next number_of_requests operations to fail with a timeout.

Arguments

• number_of_requests - The number of operations to fail

Trait Implementations

impl Admin for MockAdminClient

fn create_topics_with_options( &self, new_topics: &[NewTopic], _options: CreateTopicsOptions, ) -> CreateTopicsResult

Create a batch of new topics.

fn delete_topics_with_topic_collection_options( &self, topics: TopicCollection, _options: DeleteTopicsOptions, ) -> DeleteTopicsResult

Delete a batch of topics.

fn list_topics_with_options( &self, _options: ListTopicsOptions, ) -> ListTopicsResult

List the topics available in the cluster.

fn describe_topics_with_topics_options( &self, topics: TopicCollection, _options: DescribeTopicsOptions, ) -> DescribeTopicsResult

Describe some topics in the cluster. When using topic IDs, this operation is supported by brokers with version 3.1.0 or higher.

fn create_partitions_with_options( &self, new_partitions: &HashMap<String, NewPartitions>, _options: CreatePartitionsOptions, ) -> CreatePartitionsResult

Increase the number of partitions of the topics given as the keys of new_partitions according to the corresponding values. If partitions are increased for a topic that has a key, the partition logic or ordering of the messages will be affected.

fn delete_records_with_options( &self, records_to_delete: &HashMap<TopicPartition, RecordsToDelete>, _options: DeleteRecordsOptions, ) -> DeleteRecordsResult

Delete records whose offset is smaller than the given offset of the corresponding partition.

fn describe_producers_with_options( &self, partitions: &[TopicPartition], _options: DescribeProducersOptions, ) -> DescribeProducersResult

Describe active producer state on a set of topic partitions. Unless a specific broker is requested through DescribeProducersOptions::broker_id, this will query the partition leader to find the producer state.

fn unregister_controller_with_options( &self, _controller_id: i32, _options: UnregisterControllerOptions, ) -> UnregisterControllerResult

Unregister a controller. The following errors can be anticipated when calling get() on the future from the returned UnregisterControllerResult:

fn abort_transaction_with_options( &self, spec: AbortTransactionSpec, _options: AbortTransactionOptions, ) -> AbortTransactionResult

Forcefully abort a transaction which is open on a topic partition. This will send a WriteTxnMarkers request to the partition leader in order to abort the transaction. This requires administrative privileges.

fn describe_transactions_with_options( &self, transactional_ids: &[String], _options: DescribeTransactionsOptions, ) -> DescribeTransactionsResult

Describe the state of a set of transactional IDs from the respective transaction coordinators, which are dynamically discovered.

fn fence_producers_with_options( &self, transactional_ids: &[String], _options: FenceProducersOptions, ) -> FenceProducersResult

Fence out all active producers that use any of the provided transactional IDs.

fn list_transactions_with_options( &self, _options: ListTransactionsOptions, ) -> ListTransactionsResult

List active transactions in the cluster. This will query all potential transaction coordinators in the cluster and collect the state of all transactions. Users should typically attempt to reduce the size of the result set using ListTransactionsOptions::filter_producer_ids or ListTransactionsOptions::filter_states or ListTransactionsOptions::filter_on_duration.

fn force_terminate_transaction_with_options( &self, transactional_id: &str, options: TerminateTransactionOptions, ) -> TerminateTransactionResult

Force terminate a transaction for the given transactional ID. This operation aborts any ongoing transaction associated with the transactional ID. It’s similar to fenceProducers but only targets a single transactional ID to handle long-running transactions when 2PC is enabled.

fn describe_cluster_with_options( &self, _options: DescribeClusterOptions, ) -> DescribeClusterResult

Get information about the nodes in the cluster.

fn describe_configs_with_options( &self, config_resources: &[ConfigResource], _options: DescribeConfigsOptions, ) -> DescribeConfigsResult

Get the configuration for the specified resources.

fn incremental_alter_configs_with_options( &self, configs: &HashMap<ConfigResource, Vec<AlterConfigOp>>, _options: AlterConfigsOptions, ) -> AlterConfigsResult

Incrementally update the configuration for the specified resources.

fn list_config_resources_with_options( &self, config_resource_types: &HashSet<Type>, _options: ListConfigResourcesOptions, ) -> ListConfigResourcesResult

List the configuration resources available in the cluster which matches config resource type. If no config resource types are specified, all configuration resources will be listed.

fn describe_log_dirs_with_options( &self, brokers: &[i32], _options: DescribeLogDirsOptions, ) -> DescribeLogDirsResult

Query the information of all log directories on the given set of brokers

fn alter_replica_log_dirs_with_options( &self, replica_assignment: &HashMap<TopicPartitionReplica, String>, _options: AlterReplicaLogDirsOptions, ) -> AlterReplicaLogDirsResult

Change the log directory for the specified replicas. If the replica does not exist on the broker, the result shows REPLICA_NOT_AVAILABLE for the given replica and the replica will be created in the given log directory on the broker when it is created later. If the replica already exists on the broker, the replica will be moved to the given log directory if it is not already there. For detailed result, inspect the returned AlterReplicaLogDirsResult instance.

fn describe_replica_log_dirs_with_options( &self, replicas: &[TopicPartitionReplica], _options: DescribeReplicaLogDirsOptions, ) -> DescribeReplicaLogDirsResult

Query the replica log directory information for the specified replicas.

fn elect_leaders_with_options( &self, _election_type: ElectionType, _partitions: Option<HashSet<TopicPartition>>, _options: ElectLeadersOptions, ) -> ElectLeadersResult

Elect a replica as leader for the given partitions, or for all partitions if the argument to partitions is None.

fn alter_partition_reassignments_with_options( &self, reassignments: &HashMap<TopicPartition, Option<NewPartitionReassignment>>, _options: AlterPartitionReassignmentsOptions, ) -> AlterPartitionReassignmentsResult

Change the reassignments for one or more partitions. Providing None will revert the reassignment for the associated partition.

fn list_partition_reassignments_with_partitions_options( &self, partitions: Option<HashSet<TopicPartition>>, _options: ListPartitionReassignmentsOptions, ) -> ListPartitionReassignmentsResult

List the current reassignments for the given partitions.

fn list_offsets_with_options( &self, topic_partition_offsets: &HashMap<TopicPartition, OffsetSpec>, _options: ListOffsetsOptions, ) -> ListOffsetsResult

List offset for the specified partitions. This operation enables to find the beginning offset, end offset as well as the offset matching a timestamp in partitions.

fn list_groups_with_options( &self, _options: ListGroupsOptions, ) -> ListGroupsResult

List the groups available in the cluster.

fn describe_consumer_groups_with_options( &self, group_ids: &[String], _options: DescribeConsumerGroupsOptions, ) -> DescribeConsumerGroupsResult

Describe some consumer groups in the cluster.

fn describe_classic_groups_with_options( &self, group_ids: &[String], _options: DescribeClassicGroupsOptions, ) -> DescribeClassicGroupsResult

Describe some classic groups in the cluster.

fn list_consumer_group_offsets_with_group_specs_options( &self, group_specs: &HashMap<String, ListConsumerGroupOffsetsSpec>, _options: ListConsumerGroupOffsetsOptions, ) -> ListConsumerGroupOffsetsResult

List the consumer group offsets available in the cluster for the specified consumer groups.

fn alter_consumer_group_offsets_with_options( &self, _group_id: &str, _offsets: &HashMap<TopicPartition, OffsetAndMetadata>, _options: AlterConsumerGroupOffsetsOptions, ) -> AlterConsumerGroupOffsetsResult

Alters offsets for the specified group. In order to succeed, the group must be empty.

fn delete_consumer_group_offsets_with_options( &self, _group_id: &str, partitions: &HashSet<TopicPartition>, _options: DeleteConsumerGroupOffsetsOptions, ) -> DeleteConsumerGroupOffsetsResult

Delete committed offsets for a set of partitions in a consumer group. This will succeed at the partition level only if the group is not actively subscribed to the corresponding topic.

fn delete_consumer_groups_with_options( &self, group_ids: &[String], _options: DeleteConsumerGroupsOptions, ) -> DeleteConsumerGroupsResult

Delete consumer groups from the cluster.

fn remove_members_from_consumer_group_with_options( &self, _group_id: &str, options: RemoveMembersFromConsumerGroupOptions, ) -> RemoveMembersFromConsumerGroupResult

Remove members from the consumer group by given member identities.

fn create_acls_with_options( &self, acls: &[AclBinding], _options: CreateAclsOptions, ) -> CreateAclsResult

Creates access control lists (ACLs) which are bound to specific resources.

fn describe_acls_with_options( &self, _filter: &AclBindingFilter, _options: DescribeAclsOptions, ) -> DescribeAclsResult

Lists access control lists (ACLs) according to the supplied filter.

fn delete_acls_with_options( &self, filters: &[AclBindingFilter], _options: DeleteAclsOptions, ) -> DeleteAclsResult

Deletes access control lists (ACLs) according to the supplied filters.

fn describe_client_quotas_with_options( &self, _filter: &ClientQuotaFilter, _options: DescribeClientQuotasOptions, ) -> DescribeClientQuotasResult

Describes all entities matching the provided filter that have at least one client quota configuration value defined.

fn alter_client_quotas_with_options( &self, entries: &[ClientQuotaAlteration], _options: AlterClientQuotasOptions, ) -> AlterClientQuotasResult

Alters client quota configurations with the specified alterations.

fn describe_user_scram_credentials_with_users_options( &self, _users: &[String], _options: DescribeUserScramCredentialsOptions, ) -> DescribeUserScramCredentialsResult

Describe SASL/SCRAM credentials.

fn alter_user_scram_credentials_with_options( &self, alterations: &[UserScramCredentialAlteration], _options: AlterUserScramCredentialsOptions, ) -> AlterUserScramCredentialsResult

Alter SASL/SCRAM credentials.

fn create_delegation_token_with_options( &self, options: CreateDelegationTokenOptions, ) -> CreateDelegationTokenResult

Create a Delegation Token.

fn renew_delegation_token_with_options( &self, hmac: &[u8], options: RenewDelegationTokenOptions, ) -> RenewDelegationTokenResult

Renew a Delegation Token.

fn expire_delegation_token_with_options( &self, hmac: &[u8], options: ExpireDelegationTokenOptions, ) -> ExpireDelegationTokenResult

Expire a Delegation Token.

fn describe_delegation_token_with_options( &self, options: DescribeDelegationTokenOptions, ) -> DescribeDelegationTokenResult

Describe the Delegation Tokens.

fn describe_features_with_options( &self, _options: DescribeFeaturesOptions, ) -> DescribeFeaturesResult

Describes finalized as well as supported features. The request is issued to any random broker.

fn update_features_with_options( &self, feature_updates: &HashMap<String, FeatureUpdate>, options: UpdateFeaturesOptions, ) -> Result<UpdateFeaturesResult, Error>

Applies specified updates to finalized features. This operation is not transactional so some updates may succeed while the rest may fail.

fn close_with_timeout<'life0, 'async_trait>( &'life0 self, _timeout: Duration, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Close the Admin client and release all associated resources.

fn create_topics(&self, new_topics: &[NewTopic]) -> CreateTopicsResult

Create a batch of new topics with the default options.

fn delete_topics_with_string_slice( &self, topics: &[String], ) -> DeleteTopicsResult

This is a convenience method for Self::delete_topics_with_topic_collection_options with default options. See the overload for more details.

fn delete_topics_with_string_slice_options( &self, topics: &[String], options: DeleteTopicsOptions, ) -> DeleteTopicsResult

This is a convenience method for Self::delete_topics_with_topic_collection_options with default options. See the overload for more details.

fn delete_topics_with_topic_collection( &self, topics: TopicCollection, ) -> DeleteTopicsResult

This is a convenience method for Self::delete_topics_with_topic_collection_options with default options. See the overload for more details.

fn list_topics(&self) -> ListTopicsResult

List the topics available in the cluster with the default options.

fn describe_topics_with_topic_names( &self, topic_names: &[String], ) -> DescribeTopicsResult

Describe some topics in the cluster, with the default options.

fn describe_topics_with_topic_names_options( &self, topic_names: &[String], options: DescribeTopicsOptions, ) -> DescribeTopicsResult

Describe some topics in the cluster.

fn describe_topics_with_topics( &self, topics: TopicCollection, ) -> DescribeTopicsResult

This is a convenience method for Self::describe_topics_with_topics_options with default options. See the overload for more details.

fn create_partitions( &self, new_partitions: &HashMap<String, NewPartitions>, ) -> CreatePartitionsResult

Increase the number of partitions of the topics given as the keys of new_partitions according to the corresponding values. If partitions are increased for a topic that has a key, the partition logic or ordering of the messages will be affected.

fn delete_records( &self, records_to_delete: &HashMap<TopicPartition, RecordsToDelete>, ) -> DeleteRecordsResult

Delete records whose offset is smaller than the given offset of the corresponding partition.

fn unregister_controller( &self, controller_id: i32, ) -> UnregisterControllerResult

Unregister a controller. This is a convenience method for Self::unregister_controller_with_options

fn describe_producers( &self, partitions: &[TopicPartition], ) -> DescribeProducersResult

Describe producer state on a set of topic partitions. See Self::describe_producers_with_options for more details.

fn abort_transaction( &self, spec: AbortTransactionSpec, ) -> AbortTransactionResult

Forcefully abort a transaction which is open on a topic partition. See Self::abort_transaction_with_options for more details.

fn describe_transactions( &self, transactional_ids: &[String], ) -> DescribeTransactionsResult

Describe the state of a set of transactional IDs. See Self::describe_transactions_with_options for more details.

fn fence_producers(&self, transactional_ids: &[String]) -> FenceProducersResult

Fence out all active producers that use any of the provided transactional IDs, with the default options.

fn list_transactions(&self) -> ListTransactionsResult

List active transactions in the cluster. See Self::list_transactions_with_options for more details.

fn force_terminate_transaction( &self, transactional_id: &str, ) -> TerminateTransactionResult

Force terminate a transaction for the given transactional ID with the default options.

fn describe_cluster(&self) -> DescribeClusterResult

Get information about the nodes in the cluster, using the default options.

fn describe_configs( &self, config_resources: &[ConfigResource], ) -> DescribeConfigsResult

Get the configuration for the specified resources with the default options.

fn incremental_alter_configs( &self, configs: &HashMap<ConfigResource, Vec<AlterConfigOp>>, ) -> AlterConfigsResult

Incrementally updates the configuration for the specified resources with default options.

fn list_config_resources(&self) -> ListConfigResourcesResult

List all configuration resources available in the cluster with the default options.

fn describe_log_dirs(&self, brokers: &[i32]) -> DescribeLogDirsResult

Query the information of all log directories on the given set of brokers

fn alter_replica_log_dirs( &self, replica_assignment: &HashMap<TopicPartitionReplica, String>, ) -> AlterReplicaLogDirsResult

Change the log directory for the specified replicas. If the replica does not exist on the broker, the result shows REPLICA_NOT_AVAILABLE for the given replica and the replica will be created in the given log directory on the broker when it is created later. If the replica already exists on the broker, the replica will be moved to the given log directory if it is not already there. For detailed result, inspect the returned AlterReplicaLogDirsResult instance.

fn describe_replica_log_dirs( &self, replicas: &[TopicPartitionReplica], ) -> DescribeReplicaLogDirsResult

Query the replica log directory information for the specified replicas.

fn elect_leaders( &self, election_type: ElectionType, partitions: Option<HashSet<TopicPartition>>, ) -> ElectLeadersResult

Elect a replica as leader for topic partitions.

fn alter_partition_reassignments( &self, reassignments: &HashMap<TopicPartition, Option<NewPartitionReassignment>>, ) -> AlterPartitionReassignmentsResult

Change the reassignments for one or more partitions. Providing None will revert the reassignment for the associated partition. This is a convenience method for Self::alter_partition_reassignments_with_options with default options. See the overload for more details.

fn list_partition_reassignments(&self) -> ListPartitionReassignmentsResult

List all of the current partition reassignments.

fn list_partition_reassignments_with_partitions( &self, partitions: HashSet<TopicPartition>, ) -> ListPartitionReassignmentsResult

List the current reassignments for the given partitions.

fn list_partition_reassignments_with_options( &self, options: ListPartitionReassignmentsOptions, ) -> ListPartitionReassignmentsResult

List all of the current partition reassignments.

fn list_offsets( &self, topic_partition_offsets: &HashMap<TopicPartition, OffsetSpec>, ) -> ListOffsetsResult

List offset for the specified partitions and OffsetSpec. This operation enables to find the beginning offset, end offset as well as the offset matching a timestamp in partitions.

fn list_groups(&self) -> ListGroupsResult

List the groups available in the cluster with the default options.

fn describe_consumer_groups( &self, group_ids: &[String], ) -> DescribeConsumerGroupsResult

Describe some consumer groups in the cluster, with the default options.

fn describe_classic_groups( &self, group_ids: &[String], ) -> DescribeClassicGroupsResult

Describe some classic groups in the cluster, with the default options.

fn list_consumer_group_offsets_with_group_id( &self, group_id: &str, ) -> ListConsumerGroupOffsetsResult

List the consumer group offsets available in the cluster with the default options.

fn list_consumer_group_offsets_with_group_id_options( &self, group_id: &str, options: ListConsumerGroupOffsetsOptions, ) -> ListConsumerGroupOffsetsResult

List the consumer group offsets available in the cluster.

fn list_consumer_group_offsets_with_group_specs( &self, group_specs: &HashMap<String, ListConsumerGroupOffsetsSpec>, ) -> ListConsumerGroupOffsetsResult

List the consumer group offsets available in the cluster for the specified groups with the default options.

fn alter_consumer_group_offsets( &self, group_id: &str, offsets: &HashMap<TopicPartition, OffsetAndMetadata>, ) -> AlterConsumerGroupOffsetsResult

Alters offsets for the specified group. In order to succeed, the group must be empty.

fn delete_consumer_group_offsets( &self, group_id: &str, partitions: &HashSet<TopicPartition>, ) -> DeleteConsumerGroupOffsetsResult

Delete committed offsets for a set of partitions in a consumer group with the default options. This will succeed at the partition level only if the group is not actively subscribed to the corresponding topic.

fn delete_consumer_groups( &self, group_ids: &[String], ) -> DeleteConsumerGroupsResult

Delete consumer groups from the cluster with the default options.

fn create_acls(&self, acls: &[AclBinding]) -> CreateAclsResult

This is a convenience method for Self::create_acls_with_options with default options. See the overload for more details.

fn describe_acls(&self, filter: &AclBindingFilter) -> DescribeAclsResult

This is a convenience method for Self::describe_acls_with_options with default options. See the overload for more details.

fn delete_acls(&self, filters: &[AclBindingFilter]) -> DeleteAclsResult

This is a convenience method for Self::delete_acls_with_options with default options. See the overload for more details.

fn describe_client_quotas( &self, filter: &ClientQuotaFilter, ) -> DescribeClientQuotasResult

Describes all entities matching the provided filter that have at least one client quota configuration value defined.

fn alter_client_quotas( &self, entries: &[ClientQuotaAlteration], ) -> AlterClientQuotasResult

Alters client quota configurations with the specified alterations.

fn describe_user_scram_credentials(&self) -> DescribeUserScramCredentialsResult

Describe all SASL/SCRAM credentials.

fn describe_user_scram_credentials_with_users( &self, users: &[String], ) -> DescribeUserScramCredentialsResult

Describe SASL/SCRAM credentials for the given users.

fn alter_user_scram_credentials( &self, alterations: &[UserScramCredentialAlteration], ) -> AlterUserScramCredentialsResult

Alter SASL/SCRAM credentials for the given users.

fn create_delegation_token(&self) -> CreateDelegationTokenResult

Create a Delegation Token.

fn renew_delegation_token(&self, hmac: &[u8]) -> RenewDelegationTokenResult

Renew a Delegation Token.

fn expire_delegation_token(&self, hmac: &[u8]) -> ExpireDelegationTokenResult

Expire a Delegation Token.

fn describe_delegation_token(&self) -> DescribeDelegationTokenResult

Describe the Delegation Tokens.

fn describe_features(&self) -> DescribeFeaturesResult

Describes finalized as well as supported features.

fn update_features( &self, feature_updates: &HashMap<String, FeatureUpdate>, ) -> Result<UpdateFeaturesResult, Error>

Applies specified updates to finalized features.

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Close the Admin and release all associated resources.

impl Debug for MockAdminClient

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

Formats the value using the given formatter.

impl Default for MockAdminClient

fn default() -> Self

Same as MockAdminClient::new.