Module cloud.quinimbus.persistence.api

Package cloud.quinimbus.persistence.api.storage

Interface PersistenceSchemaStorage

All Known Implementing Classes:

MongoSchemaStorage, PersistenceSchemaStorageDelegate

public interface PersistenceSchemaStorage

Method Summary

Modifier and Type	Method	Description
<K> Optional<Entity<K>>	find(EntityType type, K id)
<K> name.falgout.jeffrey.throwing.stream.ThrowingStream<Entity<K>,PersistenceException>	findAll(EntityType type)
<K> name.falgout.jeffrey.throwing.stream.ThrowingStream<K,PersistenceException>	findAllIDs(EntityType type)
<K> name.falgout.jeffrey.throwing.stream.ThrowingStream<Entity<K>,PersistenceException>	findFiltered(EntityType type, Set<? extends PropertyFilter> propertyFilters)
<K> name.falgout.jeffrey.throwing.stream.ThrowingStream<K,PersistenceException>	findIDsFiltered(EntityType type, Set<? extends PropertyFilter> propertyFilters)
PersistenceSchemaStorageMigrator	getMigrator()
Metadata	getSchemaMetadata()
void	increaseSchemaVersion(Long version)
void	logMigrationRun(String identifier, String entityType, Long schemaVersion, Instant runAt)
<K> void	remove(EntityType type, K id)
<K> void	save(Entity<K> entity)

Method Details

getSchemaMetadata

Metadata getSchemaMetadata()
                    throws PersistenceException

Throws:

PersistenceException

increaseSchemaVersion

void increaseSchemaVersion(Long version)
                    throws PersistenceException

Throws:

PersistenceException

getMigrator

PersistenceSchemaStorageMigrator getMigrator()

logMigrationRun

void logMigrationRun(String identifier,
 String entityType,
 Long schemaVersion,
 Instant runAt)

save

<K> void save(Entity<K> entity)
       throws PersistenceException

Throws:

PersistenceException

find

<K> Optional<Entity<K>> find(EntityType type,
 K id)
                      throws PersistenceException

Throws:

PersistenceException

findFiltered

<K>
name.falgout.jeffrey.throwing.stream.ThrowingStream<Entity<K>,PersistenceException> findFiltered(EntityType type,
 Set<? extends PropertyFilter> propertyFilters)

findIDsFiltered

<K>
name.falgout.jeffrey.throwing.stream.ThrowingStream<K,PersistenceException> findIDsFiltered(EntityType type,
 Set<? extends PropertyFilter> propertyFilters)

remove

<K> void remove(EntityType type,
 K id)
         throws PersistenceException

Throws:

PersistenceException

findAll

<K>
name.falgout.jeffrey.throwing.stream.ThrowingStream<Entity<K>,PersistenceException> findAll(EntityType type)
                                                                                     throws PersistenceException

Throws:

PersistenceException

findAllIDs

<K>
name.falgout.jeffrey.throwing.stream.ThrowingStream<K,PersistenceException> findAllIDs(EntityType type)
                                                                                throws PersistenceException

Throws:

PersistenceException