io.confluent.kafka.schemaregistry.storage

Class InMemoryCache<K,V>

java.lang.Object

io.confluent.kafka.schemaregistry.storage.InMemoryCache<K,V>

All Implemented Interfaces:

LookupCache<K,V>, Store<K,V>, AutoCloseable

public class InMemoryCache<K,V>
extends Object
implements LookupCache<K,V>

In-memory store based on maps

Constructor Summary

Constructors

Constructor and Description
InMemoryCache(Serializer<K,V> serializer)

Method Summary

Modifier and Type	Method and Description
Map<String,Integer>	clearSubjects(String subject) Clears the cache of deleted schemas that match the given subject.
void	close()
Config	config(String subject, boolean returnTopLevelIfNotFound, Config defaultForTopLevel) Retrieves the config for a subject.
boolean	containsSchema(Schema schema) Checks if a schema is registered in any subject.
V	delete(K key)
void	flush()
V	get(K key)
CloseableIterator<V>	getAll(K key1, K key2) Iterator over keys in the specified range
CloseableIterator<K>	getAllKeys()
boolean	hasSubjects(String subject, boolean lookupDeletedSubjects) Returns whether there exist schemas (that are not deleted) that match the given subject.
void	init()
protected Predicate<String>	matchingSubjectPredicate(String subject)
Mode	mode(String subject, boolean returnTopLevelIfNotFound, Mode defaultForTopLevel) Retrieves the mode for a subject.
V	put(K key, V value)
void	putAll(Map<K,V> entries)
Set<Integer>	referencesSchema(SchemaKey schema) Returns schemas that reference the given schema.
void	schemaDeleted(SchemaKey schemaKey, SchemaValue schemaValue, SchemaValue oldSchemaValue) Callback that is invoked when a schema is deleted.
SchemaIdAndSubjects	schemaIdAndSubjects(Schema schema) Provides SchemaIdAndSubjects associated with the schema.
SchemaKey	schemaKeyById(Integer id, String subject) Provides the SchemaKey for the provided schema id.
void	schemaRegistered(SchemaKey schemaKey, SchemaValue schemaValue, SchemaValue oldSchemaValue) Callback that is invoked when a schema is registered.
void	schemaTombstoned(SchemaKey schemaKey, SchemaValue schemaValue) Callback that is invoked when a schema is tombstoned.
Set<String>	subjects(String subject, boolean lookupDeletedSubjects) Returns subjects that have schemas (that are not deleted) that match the given subject.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.confluent.kafka.schemaregistry.storage.LookupCache

compatibilityLevel, setTenant, tenant

Methods inherited from interface io.confluent.kafka.schemaregistry.storage.Store

isPersistent

Constructor Detail

InMemoryCache

public InMemoryCache(Serializer<K,V> serializer)

Method Detail

init

public void init()
          throws StoreInitializationException

Specified by:

init in interface Store<K,V>

Throws:

StoreInitializationException

get

public V get(K key)
      throws StoreException

Specified by:

get in interface Store<K,V>

Throws:

StoreException

put

public V put(K key,
             V value)
      throws StoreException

Specified by:

put in interface Store<K,V>

Throws:

StoreException

getAll

public CloseableIterator<V> getAll(K key1,
                                   K key2)
                            throws StoreException

Description copied from interface: Store

Iterator over keys in the specified range

Specified by:

getAll in interface Store<K,V>

Parameters:

key1 - If key1 is null, start from the first key in sorted order

key2 - If key2 is null, end at the last key

Returns:

Iterator over keys in the half-open interval [key1, key2). If both keys are null, return an iterator over all keys in the database

Throws:

StoreException

putAll

public void putAll(Map<K,V> entries)
            throws StoreException

Specified by:

putAll in interface Store<K,V>

Throws:

StoreException

delete

public V delete(K key)
         throws StoreException

Specified by:

delete in interface Store<K,V>

Throws:

StoreException

getAllKeys

public CloseableIterator<K> getAllKeys()
                                throws StoreException

Specified by:

getAllKeys in interface Store<K,V>

Throws:

StoreException

flush

public void flush()
           throws StoreException

Specified by:

flush in interface Store<K,V>

Throws:

StoreException

close

public void close()
           throws StoreException

Specified by:

close in interface Store<K,V>

Specified by:

close in interface AutoCloseable

Throws:

StoreException

schemaIdAndSubjects

public SchemaIdAndSubjects schemaIdAndSubjects(Schema schema)
                                        throws StoreException

Description copied from interface: LookupCache

Provides SchemaIdAndSubjects associated with the schema.

Specified by:

schemaIdAndSubjects in interface LookupCache<K,V>

Parameters:

schema - schema object; never null

Returns:

the schema id and subjects associated with the schema, null otherwise.

Throws:

StoreException

containsSchema

public boolean containsSchema(Schema schema)
                       throws StoreException

Description copied from interface: LookupCache

Checks if a schema is registered in any subject.

Specified by:

containsSchema in interface LookupCache<K,V>

Parameters:

schema - schema object

Returns:

true if the schema is already registered else false

Throws:

StoreException

referencesSchema

public Set<Integer> referencesSchema(SchemaKey schema)
                              throws StoreException

Description copied from interface: LookupCache

Returns schemas that reference the given schema.

Specified by:

referencesSchema in interface LookupCache<K,V>

Parameters:

schema - schema object

Returns:

the ids of schemas that reference the given schema

Throws:

StoreException

schemaKeyById

public SchemaKey schemaKeyById(Integer id,
                               String subject)
                        throws StoreException

Description copied from interface: LookupCache

Provides the SchemaKey for the provided schema id.

Specified by:

schemaKeyById in interface LookupCache<K,V>

Parameters:

id - the schema id; never null

subject - the qualified context or subject

Returns:

the SchemaKey if found, otherwise null.

Throws:

StoreException

schemaDeleted

public void schemaDeleted(SchemaKey schemaKey,
                          SchemaValue schemaValue,
                          SchemaValue oldSchemaValue)

Description copied from interface: LookupCache

Callback that is invoked when a schema is deleted. This can be used to update any internal data structure. This is invoked synchronously during delete.

Specified by:

schemaDeleted in interface LookupCache<K,V>

Parameters:

schemaKey - the deleted SchemaKey; never null

schemaValue - the deleted SchemaValue; never null

oldSchemaValue - the previous SchemaValue

schemaTombstoned

public void schemaTombstoned(SchemaKey schemaKey,
                             SchemaValue schemaValue)

Description copied from interface: LookupCache

Callback that is invoked when a schema is tombstoned.

Specified by:

schemaTombstoned in interface LookupCache<K,V>

Parameters:

schemaKey - the tombstoned SchemaKey; never null

schemaValue - the tombstoned SchemaValue

schemaRegistered

public void schemaRegistered(SchemaKey schemaKey,
                             SchemaValue schemaValue,
                             SchemaValue oldSchemaValue)

Description copied from interface: LookupCache

Callback that is invoked when a schema is registered. This can be used to update any internal data structure. This is invoked synchronously during register.

Specified by:

schemaRegistered in interface LookupCache<K,V>

Parameters:

schemaKey - the registered SchemaKey; never null

schemaValue - the registered SchemaValue; never null

oldSchemaValue - the previous SchemaValue

config

public Config config(String subject,
                     boolean returnTopLevelIfNotFound,
                     Config defaultForTopLevel)
              throws StoreException

Description copied from interface: LookupCache

Retrieves the config for a subject.

Specified by:

config in interface LookupCache<K,V>

Parameters:

subject - the subject

returnTopLevelIfNotFound - whether to return the top level scope if not found

defaultForTopLevel - default value for the top level scope

Returns:

the compatibility level if found, otherwise null

Throws:

StoreException

mode

public Mode mode(String subject,
                 boolean returnTopLevelIfNotFound,
                 Mode defaultForTopLevel)
          throws StoreException

Description copied from interface: LookupCache

Retrieves the mode for a subject.

Specified by:

mode in interface LookupCache<K,V>

Parameters:

subject - the subject

returnTopLevelIfNotFound - whether to return the top level scope if not found

defaultForTopLevel - default value for the top level scope

Returns:

the mode if found, otherwise null.

Throws:

StoreException

subjects

public Set<String> subjects(String subject,
                            boolean lookupDeletedSubjects)
                     throws StoreException

Description copied from interface: LookupCache

Returns subjects that have schemas (that are not deleted) that match the given subject.

Specified by:

subjects in interface LookupCache<K,V>

Parameters:

subject - the subject, or null for all subjects

Returns:

the subjects with matching schemas

Throws:

StoreException

hasSubjects

public boolean hasSubjects(String subject,
                           boolean lookupDeletedSubjects)
                    throws StoreException

Description copied from interface: LookupCache

Returns whether there exist schemas (that are not deleted) that match the given subject.

Specified by:

hasSubjects in interface LookupCache<K,V>

Parameters:

subject - the subject, or null for all subjects

Returns:

whether there exist matching schemas

Throws:

StoreException

clearSubjects

public Map<String,Integer> clearSubjects(String subject)
                                  throws StoreException

Description copied from interface: LookupCache

Clears the cache of deleted schemas that match the given subject.

Specified by:

clearSubjects in interface LookupCache<K,V>

Parameters:

subject - the subject, or null for all subjects

Returns:

the number of schemas cleared by schema type

Throws:

StoreException

matchingSubjectPredicate

protected Predicate<String> matchingSubjectPredicate(String subject)