io.confluent.kafka.multitenant

Class TenantLifecycleManager

java.lang.Object

io.confluent.kafka.multitenant.TenantLifecycleManager

public class TenantLifecycleManager
extends Object

Constructor Summary

Constructors

Constructor and Description
TenantLifecycleManager(Map<String,?> configs, org.apache.kafka.common.utils.Time time)

Method Summary

Modifier and Type	Method and Description
void	close()
void	createAdminClient()
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)
void	setAdminSupplierAndCreateClient(Function<String,org.apache.kafka.clients.admin.Admin> adminClientSupplier)
void	updateTenantState(io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata lcMeta)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TenantLifecycleManager

public TenantLifecycleManager(Map<String,?> configs,
                              org.apache.kafka.common.utils.Time time)

Method Detail

setAdminSupplierAndCreateClient

public void setAdminSupplierAndCreateClient(Function<String,org.apache.kafka.clients.admin.Admin> adminClientSupplier)

createAdminClient

public void createAdminClient()

updateTenantState

public void updateTenantState(io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata lcMeta)

isClusterActive

public boolean isClusterActive(String lcId)

Returns true if the cluster with the given id is active, false otherwise (a non-existing cluster is considered inactive)

inactiveClusters

public Set<String> inactiveClusters()

Return all logical clusters that are deactivated

deactivatedClusters

public Set<String> deactivatedClusters()

Returns the list of all tenants that are deactivated, but not yet being deleted.

Returns:

a set of logical cluster IDs

fullyDeletedClusters

public Set<String> fullyDeletedClusters()

Return all logical clusters that are considered deleted and we won't try to delete again Used for testing

deletedClusters

public Set<String> deletedClusters()

Return all logical clusters that were deleted or being deleted Used for testing

Returns:

set of logical cluster IDs

deleteTenants

public void deleteTenants()

close

public void close()