All Classes and Interfaces

Class
Description
 
 
 
 
Abstract for Codec implementation.
Base class for InputStream extension
 
 
 
 
 
 
 
Accessor Bucket DTO
API REST for Accessor Bucket
Client for Accessor Bucket
Bucket Client API Factory
API REST for Accessor Bucket for Internals between Clone Cloud Store services
Client for Accessor Bucket
Bucket Client API Factory
Bucket API Resource
Accessor Bucket Service
Accessor Bucket Service
 
 
Constants for Accessor Bucket and Object
API Constants
Filter Object Query
Object Headers
Accessor Filter DTO
Utility class for Headers
Accessor Object DTO
API REST for Accessor Object
Client for Accessor Object
Bucket Client API Factory
API REST for Accessor Object for Internals between Clone Cloud Store services
Client for Accessor Object
Bucket Client API Factory
Object API Resource
Accessor Object Service
Accessor Bucket Service
 
Accessor Configurable Values
Bucket API Resource
Bucket API Resource
Object API Resource
Object API Resource
 
 
 
Accessor Status DTO
 
 
 
Adapt an InputStream to a ReadStream that can be used with a Pump in Vertx.
 
 
 
 
 
 
Resource Lifecycle Manager for Azurite (for Azure Blob Storage)
Base16, Base32 and Base64 codecs
 
Metrics can be heavy cost in list operation, this class helps to limit this cost
Already Exists exception
 
 
 
 
 
Generic Abstract class exception for Client Error
Generic DB Exception
Already Deleted exception
 
Argument invalid exception
Not Acceptable exception
Not Allowed/Forbidden exception
ANot Exists exception
Operation exception
Global Server Exception Mapper
Generic exception for Server Error
Ccs Exception used by extension to specify an error and the status according to one BusinessIn object (optional)
 
 
Transform one InputStream to Multiple InputStream, each one being a chunk of the primary one.
Transform one InputStream to Multiple InputStream, each one being a chunk of the primary one.
Cipher InputStream: takes an InputStream as entry and give back a crypt/decrypt InputStream
Client Abstraction with prepared methods for Get and Post request using InputStream
 
The Abstract implementation for the Client Factory.

Note that the implementation can use ApplicationScoped annotation.
 
Implementation for a @Provider for handling exceptions in case of POST/GET InputStream
 
 
 
 
 
Bucket DAO
Bucket DAO Repository
Object DAO
Object DAO Repository
SingleSiteObject uses AccessorStatus rank
 
 
 
 
 
NeedAction uses ReconciliationAction rank
 
SingleSiteObject uses ReconciliationAction rank
 
 
 
DbQuery (Where Condition) for both SQL and NoSQL.
 
Detect type of DB: Mongo ro Postgres
DbUpdate (Update command) for both SQL and NoSQL.
Enum on standard Digest algorithms
Exception raised by the driver: the Bucket or Object already exists and therefore cannot be created
Driver Java Interface for Object Storage.
Driver Java API Factory.
Register on which Driver API Factory will register once initialized
Azure Driver
Azure DriverApi Factory
 
Configurable values for Azure
Register the DriverS3ApiFactory into DriverApiRegistry
Exception raised by the driver: Generic error (meaning 400 or 500 in HTTP) for any not specialized errors
Google Driver
Google DriverApi Factory
 
Configurable values for Google
Register the DriverS3ApiFactory into DriverApiRegistry
Exception raised by the driver: the operation required is not acceptable, such as deletion of a bucket while it is not empty, or deleting an object while not owner
Exception raised by the driver: the Bucket or Object was not found
Exception raised by the driver: Generic error (meaning 400 or 500 in HTTP) for any not specialized errors
S3 Driver
S3 DriverApi Factory
Internal S3 real actions Helper
Configurable values for S3
Register the DriverS3ApiFactory into DriverApiRegistry
 
The base Mongo implementation of the RepositoryBaseInterface
The base Postgre implementation of the RepositoryBaseInterface
 
 
 
 
 
 
 
 
Fake Driver that does not store anything except references in memory
Factory for Fake Driver
Register FakeDriverFactory into DriverApiRegistry
Fake InputStream often used in various situation for testing: It does not really allocate the space in memory so big InputStream can be tested.
 
 
 
 
 
 
 
 
 
Resource Lifecycle Manager for Fake Gcs Server (for Google Cloud Storage)
UUID Generator with 2 longs (128 bits), compatible multi instances (through the PID, but not multi servers, neither multi-sites due to lack of Mac address/Platform Id).
 
InputStream dnd BusinessOut for Getting both information on Read Object
InputStream dnd BusinessOut for Getting both information on Read Object
 
Utility class for Json to get the Jackson ObjectMapper, either from CDI of Quarkus, or from scratch if not in CDI (but should, in that case a Warning will be raised)
 
Internal class for Process Id, Mac Address and Jvm Id (PID + MacAddress)
 
Resource Lifecycle Manager for Kafka
 
 
 
 
 
 
 
 
Interface of Replicator Client and Broker
 
 
 
 
UUID Generator but limited to 1 Long (64 bits), compatible multi instances (through the PID, but not multi servers, neither multi-sites due to lack of Mac address/Platform Id.
 
 
MongoDB DAO for Bucket
MongoDB DAO Bucket Repository
MongoDB DAO for Object
MongoDB DAO Object Repository
MongoDB DAO for Native (local) listing
MongoDB DAO Bucket Repository
 
 
 
MongoDB DAO for Bucket
MongoDB DAO Bucket Repository
MongoDB DAO for Bucket
MongoDB DAO Bucket Repository
MongoDB DAO for Bucket
MongoDB DAO Bucket Repository
 
 
 
 
 
 
 
 
 
Resource Lifecycle Manager for MinIo (for S3)
 
Mongo implementation of the BulkHelper
 
Resource Lifecycle Manager for MongoDB
 
Mongo Sql Helper
Mongo implementation of the StreamHelper
 
 
 
 
 
 
 
 
 
 
Checker for Parameters

Can be used for String (testing also emptiness) and for general Object.
For null String only, use the special method.
Postgre implementation of the BulkHelper
 
Postgre Sql Helper
Resource Lifecycle Manager for PostgreSQL
Postgre implementation of the StreamHelper
Array type for PostgreSQL through Hibernate
 
Resource Lifecycle Manager for Pulsar
 
 
Configurable values
A collection of utility methods to retrieve and parse the values of the Java system properties and from ConfigProvider.
Efficient Random generator using ThreadLocalRandom
 
 
 
 
Reconciliator Configurable Values
 
 
 
 
 
 
Note: URI is needed for the cache
 
 
 
 
 
replicator-request-out replicator-request-in : topic for local replication requests out from Accessor, in from Replicator (=> /replicator/remote/orders) replicator-reconciliation-out replicator-reconciliation-in : topic for requests to remote requests in from Reconciliator, out from Replicator (=> /replicator/remote => replicator-action-in) replicator-action-out replicator-action-in : topic to apply remote requests locally out from Replicator, in from Accessor (=> /replicator/local/buckets)
 
Replicator Configurable Values
 
 
Interface for Repository for a Database
 
Request Action Service
 
All constants for Resources
 
 
 
 
 
 
 
RestQuery enabling Query to be serialized as Json
CONJUNCTION
QUERY
 
 
 
Cloud Cloud Store Common Configurable Values
Client Abstraction
The Abstract implementation for the Client Factory.
 
Singleton utility class
 
Dto for Java and possibly Rest API: Bucket minimal information
Dto for Java and possibly Rest API: Object minimal information
Used in some methods as type of the tested target
 
Helper for stream (real one) and Iterator (faster) operation
Utility class to help to create an InputStream of serialized objects from a Stream of Objects and reverse.
Transform interface
Abstraction to enable InputStream Get (Pull) and Post (Push) implementations.
Utility class to be used only in classes where standard Logger is not allowed
A collection of utility methods to retrieve and parse the values of the Java system properties and from ConfigProvider.
Inspired from http://commons.apache.org/lang/api-2.4/org/apache/commons/lang/ SystemUtils.html
Improve Random generation
 
 
 
 
 
 
 
 
Helper class to get Map within MongoDB natively
 
 
 
 
Void OutputStream as /dev/null
Zstd InputStream: takes an InputStream as entry and give back a compressed InputStream
Zstd InputStream: takes an InputStream as entry and give back a uncompressed InputStream