public abstract class BasePhysicalClusterMetadata<LCMType extends LogicalClusterMetadata> extends Object implements org.apache.kafka.server.multitenant.MultiTenantMetadata
Modifier and Type | Field and Description |
---|---|
protected static Map<String,BasePhysicalClusterMetadata> |
INSTANCES |
Constructor and Description |
---|
BasePhysicalClusterMetadata() |
Modifier and Type | Method and Description |
---|---|
static BasePhysicalClusterMetadata |
getInstance(String sessionUuid) |
abstract Set<String> |
logicalClusterIds()
Returns all active logical clusters with up-to-date/valid metadata hosted by this physical
cluster
|
abstract Set<String> |
logicalClusterIdsIncludingStale()
Returns all active logical clusters hosted by this physical cluster, including logical clusters
with stale/invalid metadata
|
abstract LCMType |
metadata(String logicalClusterId)
Returns metadata LCMType of a given logical cluster ID
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
protected static final Map<String,BasePhysicalClusterMetadata> INSTANCES
public static BasePhysicalClusterMetadata getInstance(String sessionUuid)
public abstract Set<String> logicalClusterIds()
IllegalStateException
- if not yet started or already shut downpublic abstract Set<String> logicalClusterIdsIncludingStale()
IllegalStateException
- if not yet started or already shut downpublic abstract LCMType metadata(String logicalClusterId)
logicalClusterId
- logical cluster IDIllegalStateException
- if not yet started or already shut down