Package io.confluent.crn

Class ConfluentServerCrnAuthority

java.lang.Object

io.confluent.crn.ConfluentServerCrnAuthority

All Implemented Interfaces:

io.confluent.crn.CrnAuthority, org.apache.kafka.common.Configurable

Direct Known Subclasses:

ConfluentCloudCrnAuthority

public class ConfluentServerCrnAuthority
extends Object
implements io.confluent.crn.CrnAuthority, org.apache.kafka.common.Configurable

This CrnAuthority handles the resource types present in the Confluent Platform

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CLOUD_CLUSTER_RESOURCE_TYPE
static final String	CLOUD_CLUSTER_TYPE
static final Map<String,String>	CLUSTER_TYPE_BY_KEY
static final String	CONNECT_CLUSTER_KEY
static final String	CONNECT_CLUSTER_RESOURCE_TYPE
static final String	CONNECT_CLUSTER_TYPE
static final String	ENVIRONMENT_RESOURCE_TYPE
static final String	ENVIRONMENT_TYPE
static final String	FLINK_CLUSTER_KEY
static final String	FLINK_CLUSTER_RESOURCE_TYPE
static final String	FLINK_CLUSTER_TYPE
static final String	FLINK_REGION_RESOURCE_TYPE
static final String	FLINK_REGION_TYPE
static final String	IDENTITY_PROVIDER_KEY
static final String	IDENTITY_PROVIDER_RESOURCE_TYPE
static final String	IDENTITY_PROVIDER_TYPE
static final String	KAFKA_CLUSTER_KEY
static final String	KAFKA_CLUSTER_RESOURCE_TYPE
static final String	KAFKA_CLUSTER_TYPE
static final String	KSQL_CLUSTER_KEY
static final String	KSQL_CLUSTER_RESOURCE_TYPE
static final String	KSQL_CLUSTER_TYPE
static final String	NETWORK_RESOURCE_TYPE
static final String	NETWORK_TYPE
static final String	ORGANIZATION_RESOURCE_TYPE
static final String	ORGANIZATION_TYPE
static final String	SCHEMA_REGISTRY_CLUSTER_KEY
static final String	SCHEMA_REGISTRY_CLUSTER_TYPE
static final String	SCHEMA_REGISTRY_RESOURCE_TYPE
static final Map<String,String>	SCOPE_KEY_BY_TYPE
static final Map<String,String>	SCOPE_RESOURCE_TYPE_BY_TYPE
static final Set<String>	SCOPE_RESOURCE_TYPES

Constructor Summary

Constructors

Constructor	Description
ConfluentServerCrnAuthority()
ConfluentServerCrnAuthority(String authorityName, int initialCacheCapacity)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

ORGANIZATION_TYPE

public static final String ORGANIZATION_TYPE

See Also:

• Constant Field Values

ENVIRONMENT_TYPE

public static final String ENVIRONMENT_TYPE

See Also:

• Constant Field Values

CLOUD_CLUSTER_TYPE

public static final String CLOUD_CLUSTER_TYPE

See Also:

• Constant Field Values

KAFKA_CLUSTER_TYPE

public static final String KAFKA_CLUSTER_TYPE

See Also:

• Constant Field Values

KSQL_CLUSTER_TYPE

public static final String KSQL_CLUSTER_TYPE

See Also:

• Constant Field Values

CONNECT_CLUSTER_TYPE

public static final String CONNECT_CLUSTER_TYPE

See Also:

• Constant Field Values

SCHEMA_REGISTRY_CLUSTER_TYPE

public static final String SCHEMA_REGISTRY_CLUSTER_TYPE

See Also:

• Constant Field Values

IDENTITY_PROVIDER_TYPE

public static final String IDENTITY_PROVIDER_TYPE

See Also:

• Constant Field Values

FLINK_CLUSTER_TYPE

public static final String FLINK_CLUSTER_TYPE

See Also:

• Constant Field Values

FLINK_REGION_TYPE

public static final String FLINK_REGION_TYPE

See Also:

• Constant Field Values

NETWORK_TYPE

public static final String NETWORK_TYPE

See Also:

• Constant Field Values

KAFKA_CLUSTER_KEY

public static final String KAFKA_CLUSTER_KEY

See Also:

• Constant Field Values

KSQL_CLUSTER_KEY

public static final String KSQL_CLUSTER_KEY

See Also:

• Constant Field Values

CONNECT_CLUSTER_KEY

public static final String CONNECT_CLUSTER_KEY

See Also:

• Constant Field Values

SCHEMA_REGISTRY_CLUSTER_KEY

public static final String SCHEMA_REGISTRY_CLUSTER_KEY

See Also:

• Constant Field Values

IDENTITY_PROVIDER_KEY

public static final String IDENTITY_PROVIDER_KEY

See Also:

• Constant Field Values

FLINK_CLUSTER_KEY

public static final String FLINK_CLUSTER_KEY

See Also:

• Constant Field Values

ORGANIZATION_RESOURCE_TYPE

public static final String ORGANIZATION_RESOURCE_TYPE

See Also:

• Constant Field Values

ENVIRONMENT_RESOURCE_TYPE

public static final String ENVIRONMENT_RESOURCE_TYPE

See Also:

• Constant Field Values

CLOUD_CLUSTER_RESOURCE_TYPE

public static final String CLOUD_CLUSTER_RESOURCE_TYPE

See Also:

• Constant Field Values

KAFKA_CLUSTER_RESOURCE_TYPE

public static final String KAFKA_CLUSTER_RESOURCE_TYPE

See Also:

• Constant Field Values

KSQL_CLUSTER_RESOURCE_TYPE

public static final String KSQL_CLUSTER_RESOURCE_TYPE

See Also:

• Constant Field Values

FLINK_CLUSTER_RESOURCE_TYPE

public static final String FLINK_CLUSTER_RESOURCE_TYPE

See Also:

• Constant Field Values

FLINK_REGION_RESOURCE_TYPE

public static final String FLINK_REGION_RESOURCE_TYPE

See Also:

• Constant Field Values

NETWORK_RESOURCE_TYPE

public static final String NETWORK_RESOURCE_TYPE

See Also:

• Constant Field Values

CONNECT_CLUSTER_RESOURCE_TYPE

public static final String CONNECT_CLUSTER_RESOURCE_TYPE

See Also:

• Constant Field Values

SCHEMA_REGISTRY_RESOURCE_TYPE

public static final String SCHEMA_REGISTRY_RESOURCE_TYPE

See Also:

• Constant Field Values

IDENTITY_PROVIDER_RESOURCE_TYPE

public static final String IDENTITY_PROVIDER_RESOURCE_TYPE

See Also:

• Constant Field Values

SCOPE_RESOURCE_TYPES

public static final Set<String> SCOPE_RESOURCE_TYPES

SCOPE_KEY_BY_TYPE

public static final Map<String,String> SCOPE_KEY_BY_TYPE

CLUSTER_TYPE_BY_KEY

public static final Map<String,String> CLUSTER_TYPE_BY_KEY

SCOPE_RESOURCE_TYPE_BY_TYPE

public static final Map<String,String> SCOPE_RESOURCE_TYPE_BY_TYPE

Constructor Details

ConfluentServerCrnAuthority

public ConfluentServerCrnAuthority(String authorityName,
 int initialCacheCapacity)

ConfluentServerCrnAuthority

public ConfluentServerCrnAuthority()

Method Details

name

public String name()

Specified by:

name in interface io.confluent.crn.CrnAuthority

resolveScopePattern

public ScopedResourcePattern resolveScopePattern(io.confluent.crn.ConfluentResourceName crn)
                                          throws io.confluent.crn.CrnSyntaxException

Throws:

io.confluent.crn.CrnSyntaxException

canonicalCrn

public io.confluent.crn.ConfluentResourceName canonicalCrn(io.confluent.security.authorizer.Scope scope,
 io.confluent.security.authorizer.ResourcePattern resourcePattern)
                                                    throws io.confluent.crn.CrnSyntaxException

This is the base canonicalCrn method. The other canonicalCrn methods are convenience methods that all call this one.

Throws:

io.confluent.crn.CrnSyntaxException

canonicalCrn

public io.confluent.crn.ConfluentResourceName canonicalCrn(io.confluent.security.authorizer.Scope scope)
                                                    throws io.confluent.crn.CrnSyntaxException

Throws:

io.confluent.crn.CrnSyntaxException

canonicalCrn

public io.confluent.crn.ConfluentResourceName canonicalCrn(String crnString)
                                                    throws io.confluent.crn.CrnSyntaxException

Specified by:

canonicalCrn in interface io.confluent.crn.CrnAuthority

Throws:

io.confluent.crn.CrnSyntaxException

canonicalCrn

public io.confluent.crn.ConfluentResourceName canonicalCrn(io.confluent.crn.ConfluentResourceName crn)
                                                    throws io.confluent.crn.CrnSyntaxException

Specified by:

canonicalCrn in interface io.confluent.crn.CrnAuthority

Throws:

io.confluent.crn.CrnSyntaxException

areEquivalent

public boolean areEquivalent(io.confluent.crn.ConfluentResourceName a,
 io.confluent.crn.ConfluentResourceName b)
                      throws io.confluent.crn.CrnSyntaxException

Specified by:

areEquivalent in interface io.confluent.crn.CrnAuthority

Throws:

io.confluent.crn.CrnSyntaxException

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable