Package io.confluent.kafka.schemaregistry.storage

Interface Store<K,V>

All Superinterfaces:

AutoCloseable

All Known Subinterfaces:

LookupCache<K,V>

All Known Implementing Classes:

InMemoryCache, KafkaStore

public interface Store<K,V>
extends AutoCloseable

Method Summary

Modifier and Type	Method	Description
void	close()
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()
void	init()
default boolean	isPersistent()	Whether the store is persistent.
V	put(K key, V value)
void	putAll(Map<K,V> entries)

Method Details

isPersistent

default boolean isPersistent()

Whether the store is persistent.

Returns:

whether the store is persistent

init

void init()
   throws StoreInitializationException

Throws:

StoreInitializationException

get

V get(K key)
throws StoreException

Throws:

StoreException

put

V put(K key,
 V value)
throws StoreException

Throws:

StoreException

getAll

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

Iterator over keys in the specified range

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

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

Throws:

StoreException

delete

V delete(K key)
  throws StoreException

Throws:

StoreException

getAllKeys

CloseableIterator<K> getAllKeys()
                         throws StoreException

Throws:

StoreException

flush

void flush()
    throws StoreException

Throws:

StoreException

close

void close()
    throws StoreException

Specified by:

close in interface AutoCloseable

Throws:

StoreException