public class TenantLifecycleManager extends Object
Constructor and Description |
---|
TenantLifecycleManager(Map<String,?> configs,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
createAdminClient(Map<String,Object> interBrokerClientConfigs) |
Set<String> |
deactivatedClusters()
Returns the list of all tenants that are deactivated, but not yet being deleted.
|
Set<String> |
deletedClusters()
Return all logical clusters that were deleted or being deleted
Used for testing
|
void |
deleteTenants() |
Set<String> |
fullyDeletedClusters()
Return all logical clusters that are considered deleted and we won't try to delete again
Used for testing
|
Set<String> |
inactiveClusters()
Return all logical clusters that are deactivated
|
boolean |
isClusterActive(String lcId)
Returns true if the cluster with the given id is active, false otherwise
(a non-existing cluster is considered inactive)
|
boolean |
updateMaxPartitionsIfNecessary(KafkaLogicalClusterMetadata oldMeta,
KafkaLogicalClusterMetadata newMeta) |
void |
updateTenantState(KafkaLogicalClusterMetadata lcMeta) |
public void updateTenantState(KafkaLogicalClusterMetadata lcMeta)
public boolean isClusterActive(String lcId)
public Set<String> inactiveClusters()
public Set<String> deactivatedClusters()
public Set<String> fullyDeletedClusters()
public Set<String> deletedClusters()
public void deleteTenants()
public void close()
public boolean updateMaxPartitionsIfNecessary(KafkaLogicalClusterMetadata oldMeta, KafkaLogicalClusterMetadata newMeta)