public abstract class BasePhysicalClusterMetadata<LCMType extends LogicalClusterMetadata> extends Object implements org.apache.kafka.server.multitenant.MultiTenantMetadata
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
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
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