public class ConfluentServerCrnAuthority extends Object implements io.confluent.crn.CrnAuthority, org.apache.kafka.common.Configurable
Modifier and Type | Field and Description |
---|---|
static String |
CLOUD_CLUSTER_TYPE |
static Map<String,String> |
CLUSTER_KEY_BY_TYPE |
static Map<String,String> |
CLUSTER_RESOURCE_TYPE_BY_TYPE |
static Set<String> |
CLUSTER_RESOURCE_TYPES |
static Map<String,String> |
CLUSTER_TYPE_BY_KEY |
static String |
CONNECT_CLUSTER_KEY |
static String |
CONNECT_CLUSTER_RESOURCE_TYPE |
static String |
CONNECT_CLUSTER_TYPE |
static String |
ENVIRONMENT_TYPE |
static String |
KAFKA_CLUSTER_KEY |
static String |
KAFKA_CLUSTER_RESOURCE_TYPE |
static String |
KAFKA_CLUSTER_TYPE |
static String |
KSQL_CLUSTER_KEY |
static String |
KSQL_CLUSTER_RESOURCE_TYPE |
static String |
KSQL_CLUSTER_TYPE |
static String |
ORGANIZATION_TYPE |
static String |
SCHEMA_REGISTRY_CLUSTER_KEY |
static String |
SCHEMA_REGISTRY_CLUSTER_RESOURCE_TYPE |
static String |
SCHEMA_REGISTRY_CLUSTER_TYPE |
Constructor and Description |
---|
ConfluentServerCrnAuthority() |
ConfluentServerCrnAuthority(String authorityName,
int initialCacheCapacity) |
Modifier and Type | Method and Description |
---|---|
protected void |
addClusters(io.confluent.crn.ConfluentResourceName.Builder builder,
io.confluent.security.authorizer.Scope scope) |
protected void |
addResource(io.confluent.crn.ConfluentResourceName.Builder builder,
io.confluent.security.authorizer.ResourcePattern resourcePattern) |
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() |
protected void |
parsePathElements(List<String> path,
io.confluent.crn.ConfluentResourceName.Builder builder) |
protected String |
resolvePathElement(io.confluent.crn.ConfluentResourceName.Element element) |
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 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 KAFKA_CLUSTER_RESOURCE_TYPE
public static final String KSQL_CLUSTER_RESOURCE_TYPE
public static final String CONNECT_CLUSTER_RESOURCE_TYPE
public static final String SCHEMA_REGISTRY_CLUSTER_RESOURCE_TYPE
public ConfluentServerCrnAuthority(String authorityName, int initialCacheCapacity)
public ConfluentServerCrnAuthority()
public String name()
name
in interface io.confluent.crn.CrnAuthority
protected 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(List<String> path, io.confluent.crn.ConfluentResourceName.Builder builder) throws io.confluent.crn.CrnSyntaxException
io.confluent.crn.CrnSyntaxException
protected void addClusters(io.confluent.crn.ConfluentResourceName.Builder builder, io.confluent.security.authorizer.Scope scope) throws io.confluent.crn.CrnSyntaxException
io.confluent.crn.CrnSyntaxException
protected void addResource(io.confluent.crn.ConfluentResourceName.Builder builder, 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, 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