public class ConfluentServerCrnAuthority
extends java.lang.Object
implements io.confluent.crn.CrnAuthority, org.apache.kafka.common.Configurable
Modifier and Type | Field and Description |
---|---|
static java.util.Map<java.lang.String,java.lang.String> |
CLUSTER_KEY_BY_TYPE |
static java.util.Map<java.lang.String,java.lang.String> |
CLUSTER_RESOURCE_TYPE_BY_TYPE |
static java.util.Set<java.lang.String> |
CLUSTER_RESOURCE_TYPES |
static java.util.Map<java.lang.String,java.lang.String> |
CLUSTER_TYPE_BY_KEY |
static java.lang.String |
CONNECT_CLUSTER_KEY |
static java.lang.String |
CONNECT_CLUSTER_RESOURCE_TYPE |
static java.lang.String |
CONNECT_CLUSTER_TYPE |
static java.lang.String |
ENVIRONMENT_TYPE |
static java.lang.String |
KAFKA_CLUSTER_KEY |
static java.lang.String |
KAFKA_CLUSTER_RESOURCE_TYPE |
static java.lang.String |
KAFKA_CLUSTER_TYPE |
static java.lang.String |
KSQL_CLUSTER_KEY |
static java.lang.String |
KSQL_CLUSTER_RESOURCE_TYPE |
static java.lang.String |
KSQL_CLUSTER_TYPE |
static java.lang.String |
ORGANIZATION_TYPE |
static java.lang.String |
SCHEMA_REGISTRY_CLUSTER_KEY |
static java.lang.String |
SCHEMA_REGISTRY_CLUSTER_RESOURCE_TYPE |
static java.lang.String |
SCHEMA_REGISTRY_CLUSTER_TYPE |
Constructor and Description |
---|
ConfluentServerCrnAuthority() |
ConfluentServerCrnAuthority(java.lang.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(java.lang.String crnString) |
void |
configure(java.util.Map<java.lang.String,?> configs) |
java.lang.String |
name() |
protected void |
parsePathElements(java.util.List<java.lang.String> path,
io.confluent.crn.ConfluentResourceName.Builder builder) |
protected java.lang.String |
resolvePathElement(io.confluent.crn.ConfluentResourceName.Element element) |
ScopedResourcePattern |
resolveScopePattern(io.confluent.crn.ConfluentResourceName crn) |
public static final java.lang.String ORGANIZATION_TYPE
public static final java.lang.String ENVIRONMENT_TYPE
public static final java.lang.String KAFKA_CLUSTER_TYPE
public static final java.lang.String KSQL_CLUSTER_TYPE
public static final java.lang.String CONNECT_CLUSTER_TYPE
public static final java.lang.String SCHEMA_REGISTRY_CLUSTER_TYPE
public static final java.lang.String KAFKA_CLUSTER_KEY
public static final java.lang.String KSQL_CLUSTER_KEY
public static final java.lang.String CONNECT_CLUSTER_KEY
public static final java.lang.String SCHEMA_REGISTRY_CLUSTER_KEY
public static final java.lang.String KAFKA_CLUSTER_RESOURCE_TYPE
public static final java.lang.String KSQL_CLUSTER_RESOURCE_TYPE
public static final java.lang.String CONNECT_CLUSTER_RESOURCE_TYPE
public static final java.lang.String SCHEMA_REGISTRY_CLUSTER_RESOURCE_TYPE
public static final java.util.Set<java.lang.String> CLUSTER_RESOURCE_TYPES
public static final java.util.Map<java.lang.String,java.lang.String> CLUSTER_KEY_BY_TYPE
public static final java.util.Map<java.lang.String,java.lang.String> CLUSTER_TYPE_BY_KEY
public static final java.util.Map<java.lang.String,java.lang.String> CLUSTER_RESOURCE_TYPE_BY_TYPE
public ConfluentServerCrnAuthority(java.lang.String authorityName, int initialCacheCapacity)
public ConfluentServerCrnAuthority()
public java.lang.String name()
name
in interface io.confluent.crn.CrnAuthority
protected java.lang.String resolvePathElement(io.confluent.crn.ConfluentResourceName.Element element) throws io.confluent.crn.CrnSyntaxException
io.confluent.crn.CrnSyntaxException
public ScopedResourcePattern resolveScopePattern(io.confluent.crn.ConfluentResourceName crn) throws io.confluent.crn.CrnSyntaxException
io.confluent.crn.CrnSyntaxException
protected void parsePathElements(java.util.List<java.lang.String> path, io.confluent.crn.ConfluentResourceName.Builder builder) 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(java.lang.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
public void configure(java.util.Map<java.lang.String,?> configs)
configure
in interface org.apache.kafka.common.Configurable