public class ConfluentServerCrnAuthority extends Object implements io.confluent.crn.CrnAuthority, org.apache.kafka.common.Configurable
Constructor and Description |
---|
ConfluentServerCrnAuthority() |
ConfluentServerCrnAuthority(String authorityName,
int initialCacheCapacity) |
Modifier and Type | Method and Description |
---|---|
boolean |
areEquivalent(io.confluent.crn.ConfluentResourceName a,
io.confluent.crn.ConfluentResourceName b) |
io.confluent.crn.ConfluentResourceName |
canonicalCrn(io.confluent.crn.ConfluentResourceName crn) |
io.confluent.crn.ConfluentResourceName |
canonicalCrn(io.confluent.security.authorizer.Scope scope) |
io.confluent.crn.ConfluentResourceName |
canonicalCrn(io.confluent.security.authorizer.Scope scope,
io.confluent.security.authorizer.ResourcePattern resourcePattern)
This is the base canonicalCrn method.
|
io.confluent.crn.ConfluentResourceName |
canonicalCrn(String crnString) |
void |
configure(Map<String,?> configs) |
String |
name() |
ScopedResourcePattern |
resolveScopePattern(io.confluent.crn.ConfluentResourceName crn) |
public static final String ORGANIZATION_TYPE
public static final String ENVIRONMENT_TYPE
public static final String CLOUD_CLUSTER_TYPE
public static final String KAFKA_CLUSTER_TYPE
public static final String KSQL_CLUSTER_TYPE
public static final String CONNECT_CLUSTER_TYPE
public static final String SCHEMA_REGISTRY_CLUSTER_TYPE
public static final String IDENTITY_PROVIDER_TYPE
public static final String FLINK_CLUSTER_TYPE
public static final String FLINK_REGION_TYPE
public static final String NETWORK_TYPE
public static final String KAFKA_CLUSTER_KEY
public static final String KSQL_CLUSTER_KEY
public static final String CONNECT_CLUSTER_KEY
public static final String SCHEMA_REGISTRY_CLUSTER_KEY
public static final String IDENTITY_PROVIDER_KEY
public static final String FLINK_CLUSTER_KEY
public static final String ORGANIZATION_RESOURCE_TYPE
public static final String ENVIRONMENT_RESOURCE_TYPE
public static final String CLOUD_CLUSTER_RESOURCE_TYPE
public static final String KAFKA_CLUSTER_RESOURCE_TYPE
public static final String KSQL_CLUSTER_RESOURCE_TYPE
public static final String FLINK_CLUSTER_RESOURCE_TYPE
public static final String FLINK_REGION_RESOURCE_TYPE
public static final String NETWORK_RESOURCE_TYPE
public static final String CONNECT_CLUSTER_RESOURCE_TYPE
public static final String SCHEMA_REGISTRY_RESOURCE_TYPE
public static final String IDENTITY_PROVIDER_RESOURCE_TYPE
public ConfluentServerCrnAuthority(String authorityName, int initialCacheCapacity)
public ConfluentServerCrnAuthority()
public String name()
name
in interface io.confluent.crn.CrnAuthority
public ScopedResourcePattern resolveScopePattern(io.confluent.crn.ConfluentResourceName crn) throws io.confluent.crn.CrnSyntaxException
io.confluent.crn.CrnSyntaxException
public io.confluent.crn.ConfluentResourceName canonicalCrn(io.confluent.security.authorizer.Scope scope, io.confluent.security.authorizer.ResourcePattern resourcePattern) throws io.confluent.crn.CrnSyntaxException
io.confluent.crn.CrnSyntaxException
public io.confluent.crn.ConfluentResourceName canonicalCrn(io.confluent.security.authorizer.Scope scope) throws io.confluent.crn.CrnSyntaxException
io.confluent.crn.CrnSyntaxException
public io.confluent.crn.ConfluentResourceName canonicalCrn(String crnString) throws io.confluent.crn.CrnSyntaxException
canonicalCrn
in interface io.confluent.crn.CrnAuthority
io.confluent.crn.CrnSyntaxException
public io.confluent.crn.ConfluentResourceName canonicalCrn(io.confluent.crn.ConfluentResourceName crn) throws io.confluent.crn.CrnSyntaxException
canonicalCrn
in interface io.confluent.crn.CrnAuthority
io.confluent.crn.CrnSyntaxException
public boolean areEquivalent(io.confluent.crn.ConfluentResourceName a, io.confluent.crn.ConfluentResourceName b) throws io.confluent.crn.CrnSyntaxException
areEquivalent
in interface io.confluent.crn.CrnAuthority
io.confluent.crn.CrnSyntaxException