public class NonKafkaLogicalClusterMetadata
extends io.confluent.kafka.multitenant.LogicalClusterMetadata
Modifier and Type | Field and Description |
---|---|
static String |
KSQL_LOGICAL_CLUSTER_TYPE |
static String |
SCHEMA_REGISTRY_LOGICAL_CLUSTER_TYPE |
Constructor and Description |
---|
NonKafkaLogicalClusterMetadata(String logicalClusterId,
String physicalClusterId,
String logicalClusterName,
String accountId,
String k8sClusterId,
String logicalClusterType,
String organizationId,
String environmentId,
Date creationDate,
Date deletionDate,
String backingLogicalKafkaClusterId) |
Modifier and Type | Method and Description |
---|---|
String |
accountId() |
String |
backingLogicalKafkaClusterId() |
Date |
creationDate() |
Date |
deletionDate() |
String |
environmentId() |
boolean |
equals(Object o) |
static NonKafkaLogicalClusterMetadata |
fromProtobuf(io.confluent.protobuf.cloud.events.v1.LogicalCluster lc) |
int |
hashCode() |
boolean |
isActive() |
boolean |
isHealthcheckLogicalCluster() |
boolean |
isValid()
Returns true if metadata values are valid
|
String |
k8sClusterId() |
String |
logicalClusterId() |
String |
logicalClusterName() |
String |
logicalClusterType() |
String |
organizationId() |
String |
physicalClusterId() |
String |
toString() |
public static final String SCHEMA_REGISTRY_LOGICAL_CLUSTER_TYPE
public static final String KSQL_LOGICAL_CLUSTER_TYPE
public NonKafkaLogicalClusterMetadata(String logicalClusterId, String physicalClusterId, String logicalClusterName, String accountId, String k8sClusterId, String logicalClusterType, String organizationId, String environmentId, Date creationDate, Date deletionDate, String backingLogicalKafkaClusterId)
public static NonKafkaLogicalClusterMetadata fromProtobuf(io.confluent.protobuf.cloud.events.v1.LogicalCluster lc)
public String logicalClusterId()
logicalClusterId
in class io.confluent.kafka.multitenant.LogicalClusterMetadata
public String physicalClusterId()
public String logicalClusterName()
public String accountId()
public String organizationId()
organizationId
in class io.confluent.kafka.multitenant.LogicalClusterMetadata
public String environmentId()
environmentId
in class io.confluent.kafka.multitenant.LogicalClusterMetadata
public String k8sClusterId()
public String logicalClusterType()
public Date creationDate()
creationDate
in class io.confluent.kafka.multitenant.LogicalClusterMetadata
public Date deletionDate()
public String backingLogicalKafkaClusterId()
public boolean isValid()
isValid
in class io.confluent.kafka.multitenant.LogicalClusterMetadata
public boolean isHealthcheckLogicalCluster()
isHealthcheckLogicalCluster
in class io.confluent.kafka.multitenant.LogicalClusterMetadata
public boolean isActive()
isActive
in class io.confluent.kafka.multitenant.LogicalClusterMetadata