THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
public class DescribeClientQuotasOptions extends AbstractOptions<DescribeClientQuotasOptions> { // Empty. } /** * The result of the {@link Admin#DescribeClientQuotasAdmin#describeClientQuotas(Collection<QuotaFilter>Collection, DescribeClientQuotasOptions)} call. */ public class DescribeClientQuotasResult { /** * Maps an entity to its configured quota value(s). Note if no value is defined for a quota * type for that entity's config, then it is not included in the resulting value map. * * @param entities the collection of entities that matched the filter */ public DescribeClientQuotasResult(KafkaFuture<Map<QuotaEntity, Map<String, Double>>> entities); /** * Returns a map from quota entity to a future which can be used to check the status of the operation. */ public KafkaFuture<Map<QuotaEntity, Map<String, Double>>> entities(); } public interface Admin extends AutoCloseable { ... /** * Describes all entities matching all provided filters (logical AND) that have at least one * quota value defined. * * @param filters filters to apply to matching entities * @param options the options to use * @return result containing all matching entities */ DescribeClientQuotasResult describeClientQuotas(Collection<QuotaFilter> filters, DescribeClientQuotasOptions options); } |
...
Code Block | ||
---|---|---|
| ||
public class ResolveClientQuotasOptions extends AbstractOptions<ResolveClientQuotasOptions> { // Empty. } /** * The result of the {@link Admin#ResolveClientQuotasAdmin#resolveClientQuotas(Collection<QuotaEntity>Collection, ResolveClientQuotasOptions)} call. */ public class ResolveClientQuotasResult { /** * Information about a specific quota configuration entry. */ public class Entry { /** * @param source the entity source for the value * @param value the non-null value */ public Entry(QuotaEntity source, Double value); } /** * Information about the value for a quota type. * * NOTE: We maintain a `Value` class because additional information may be added, e.g., * a list of overridden entries. */ public class Value { /** * @param entry the quota entry */ public Value(Entry entry); } /** * Maps a collection of entities to their resolved quota values. * * @param config the quota configuration for the requested entities */ public ResolveClientQuotasResult(Map<QuotaEntity, KafkaFuture<Map<String, Value>>> config); /** * Returns a map from quota entity to a future which can be used to check the status of the operation. */ public Map<QuotaEntity, KafkaFuture<Map<String, Value>>> config(); /** * Returns a future which succeeds only if all quota descriptions succeed. */ public KafkaFuture<Void> all(); } public interface Admin extends AutoCloseable { ... /** * Resolves the effective quota values for the provided entities. * * @param entities the entities to describe the resolved quotas for * @param options the options to use * @return the resolved quotas for the entities */ ResolveClientQuotasResult resolveClientQuotas(Collection<QuotaEntity> entities, ResolveClientQuotasOptions options); } |
...
Code Block | ||||
---|---|---|---|---|
| ||||
public class AlterClientQuotasEntry { public class Op { /** * @param key the quota type to alter * @param value if set then the existing value is updated, * otherwise if null, the existing value is cleared */ public Op(String key, Double value); } /** * @param entity the entity whose config will be modified * @param ops the alteration to perform - if value is set, then the existing value is updated, * otherwise if null, the existing value is cleared */ public AlterClientQuotasEntry(QuotaEntity entity, Collection<Op> ops); } public class AlterClientQuotasOptions extends AbstractOptions<AlterClientQuotasOptions> { /** * Sets whether the request should be validated without altering the configs. */ public AlterClientQuotasOptions validateOnly(boolean validateOnly); } /** * The result of the {@link Admin#AlterClientQuotasAdmin#alterClientQuotas(Collection<AlterClientQuotasEntry>Collection, AlterClientQuotasOptions)} call. * * The API of this class is evolving, see {@link Admin} for details. */ public class AlterClientQuotasResult { public AlterClientQuotasResult(Map<QuotaEntity, KafkaFuture<Void>> futures); /** * Returns a map from quota entity to a future which can be used to check the status of the operation. */ public Map<QuotaEntity, KafkaFuture<Void>> values(); /** * Returns a future which succeeds only if all quota alterations succeed. */ public KafkaFuture<Void> all(); } public interface Admin extends AutoCloseable { ... /** * Alters the quotas as specified for the entries. * * @param alterations the alterations to perform * @return the result of the alterations */ AlterClientQuotasResult alterClientQuotas(Collection<AlterClientQuotasEntry> entries, AlterClientQuotasOptions options); } |
...