Package com.arangodb.internal

Class ArangoDBAsyncImpl

java.lang.Object

com.arangodb.internal.ArangoExecuteable

com.arangodb.internal.InternalArangoDB

com.arangodb.internal.ArangoDBAsyncImpl

All Implemented Interfaces:

ArangoDBAsync, ArangoSerdeAccessor

public class ArangoDBAsyncImpl
extends InternalArangoDB
implements ArangoDBAsync

Author:

Mark Vollmary, Heiko Kernbach, Michele Rastelli

Constructor Summary

Constructors

Constructor	Description
ArangoDBAsyncImpl(ArangoDBImpl arangoDB)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Boolean>	createDatabase(DBCreateOptions options)	Asynchronous version of ArangoDB.createDatabase(DBCreateOptions)
CompletableFuture<Boolean>	createDatabase(String dbName)	Asynchronous version of ArangoDB.createDatabase(String)
CompletableFuture<UserEntity>	createUser(String user, String passwd)	Asynchronous version of ArangoDB.createUser(String, String)
CompletableFuture<UserEntity>	createUser(String user, String passwd, UserCreateOptions options)	Asynchronous version of ArangoDB.createUser(String, String, UserCreateOptions)
ArangoDatabaseAsync	db()	Returns a ArangoDatabase instance for the _system database.
ArangoDatabaseAsync	db(String dbName)	Returns a ArangoDatabase instance for the given database name.
CompletableFuture<Void>	deleteUser(String user)	Asynchronous version of ArangoDB.deleteUser(String)
<T> CompletableFuture<Response<T>>	execute(Request<?> request, Class<T> type)	Asynchronous version of ArangoDB.execute(Request, Class)
CompletableFuture<Collection<String>>	getAccessibleDatabases()	Asynchronous version of ArangoDB.getAccessibleDatabases()
CompletableFuture<Collection<String>>	getAccessibleDatabasesFor(String user)	Asynchronous version of ArangoDB.getAccessibleDatabasesFor(String)
CompletableFuture<Collection<String>>	getDatabases()	Asynchronous version of ArangoDB.getDatabases()
CompletableFuture<ArangoDBEngine>	getEngine()	Asynchronous version of ArangoDB.getEngine()
CompletableFuture<LogEntriesEntity>	getLogEntries(LogOptions options)	Asynchronous version of ArangoDB.getLogEntries(LogOptions)
CompletableFuture<LogLevelEntity>	getLogLevel()	Asynchronous version of ArangoDB.getLogLevel()
CompletableFuture<LogLevelEntity>	getLogLevel(LogLevelOptions options)	Asynchronous version of ArangoDB.getLogLevel(LogLevelOptions)
CompletableFuture<Collection<QueryOptimizerRule>>	getQueryOptimizerRules()	Asynchronous version of ArangoDB.getQueryOptimizerRules()
CompletableFuture<ServerRole>	getRole()	Asynchronous version of ArangoDB.getRole()
CompletableFuture<String>	getServerId()	Asynchronous version of ArangoDB.getServerId()
CompletableFuture<UserEntity>	getUser(String user)	Asynchronous version of ArangoDB.getUser(String)
CompletableFuture<Collection<UserEntity>>	getUsers()	Asynchronous version of ArangoDB.getUsers()
CompletableFuture<ArangoDBVersion>	getVersion()	Asynchronous version of ArangoDB.getVersion()
CompletableFuture<Void>	grantDefaultCollectionAccess(String user, Permissions permissions)	Asynchronous version of ArangoDB.grantDefaultCollectionAccess(String, Permissions)
CompletableFuture<Void>	grantDefaultDatabaseAccess(String user, Permissions permissions)	Asynchronous version of ArangoDB.grantDefaultDatabaseAccess(String, Permissions)
ArangoMetrics	metrics()
CompletableFuture<UserEntity>	replaceUser(String user, UserUpdateOptions options)	Asynchronous version of ArangoDB.replaceUser(String, UserUpdateOptions)
CompletableFuture<LogLevelEntity>	resetLogLevels(LogLevelOptions options)	Asynchronous version of ArangoDB.resetLogLevels(LogLevelOptions)
CompletableFuture<LogLevelEntity>	setLogLevel(LogLevelEntity entity)	Asynchronous version of ArangoDB.setLogLevel(LogLevelEntity)
CompletableFuture<LogLevelEntity>	setLogLevel(LogLevelEntity entity, LogLevelOptions options)	Asynchronous version of ArangoDB.setLogLevel(LogLevelEntity, LogLevelOptions)
void	shutdown()	Releases all connections to the server and clear the connection pool.
void	updateJwt(String jwt)	Updates the JWT used for requests authorization.
CompletableFuture<UserEntity>	updateUser(String user, UserUpdateOptions options)	Asynchronous version of ArangoDB.updateUser(String, UserUpdateOptions)

Methods inherited from class com.arangodb.internal.InternalArangoDB

createDatabaseRequest, createDatabaseResponseDeserializer, createUserRequest, deleteUserRequest, executeRequest, getAccessibleDatabasesForRequest, getAccessibleDatabasesForResponseDeserializer, getDatabaseResponseDeserializer, getDatabasesRequest, getLogEntriesRequest, getLogLevelRequest, getQueryOptimizerRulesRequest, getRoleRequest, getRoleResponseDeserializer, getServerIdRequest, getServerIdResponseDeserializer, getUserRequest, getUsersRequest, getUsersResponseDeserializer, replaceUserRequest, resetLogLevelsRequest, responseDeserializer, setLogLevelRequest, updateUserDefaultCollectionAccessRequest, updateUserDefaultDatabaseAccessRequest, updateUserRequest

Methods inherited from class com.arangodb.internal.ArangoExecuteable

createPath, executorAsync, executorSync, getSerde, request

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.arangodb.ArangoSerdeAccessor

getSerde

Constructor Details

ArangoDBAsyncImpl

public ArangoDBAsyncImpl(ArangoDBImpl arangoDB)

Method Details

shutdown

public void shutdown()

Description copied from interface: ArangoDBAsync

Releases all connections to the server and clear the connection pool.

Specified by:

shutdown in interface ArangoDBAsync

updateJwt

public void updateJwt(String jwt)

Description copied from interface: ArangoDBAsync

Updates the JWT used for requests authorization. It does not change already existing VST connections, since VST connections are authenticated during the initialization phase.

Specified by:

updateJwt in interface ArangoDBAsync

Parameters:

jwt - token to use

db

public ArangoDatabaseAsync db()

Description copied from interface: ArangoDBAsync

Returns a ArangoDatabase instance for the _system database.

Specified by:

db in interface ArangoDBAsync

Returns:

database handler

db

public ArangoDatabaseAsync db(String dbName)

Description copied from interface: ArangoDBAsync

Returns a ArangoDatabase instance for the given database name.

Specified by:

db in interface ArangoDBAsync

Parameters:

dbName - Name of the database

Returns:

database handler

metrics

public ArangoMetrics metrics()

Specified by:

metrics in interface ArangoDBAsync

Returns:

entry point for accessing client metrics

createDatabase

public CompletableFuture<Boolean> createDatabase(String dbName)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.createDatabase(String)

Specified by:

createDatabase in interface ArangoDBAsync

createDatabase

public CompletableFuture<Boolean> createDatabase(DBCreateOptions options)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.createDatabase(DBCreateOptions)

Specified by:

createDatabase in interface ArangoDBAsync

getDatabases

public CompletableFuture<Collection<String>> getDatabases()

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.getDatabases()

Specified by:

getDatabases in interface ArangoDBAsync

getAccessibleDatabases

public CompletableFuture<Collection<String>> getAccessibleDatabases()

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.getAccessibleDatabases()

Specified by:

getAccessibleDatabases in interface ArangoDBAsync

getAccessibleDatabasesFor

public CompletableFuture<Collection<String>> getAccessibleDatabasesFor(String user)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.getAccessibleDatabasesFor(String)

Specified by:

getAccessibleDatabasesFor in interface ArangoDBAsync

getVersion

public CompletableFuture<ArangoDBVersion> getVersion()

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.getVersion()

Specified by:

getVersion in interface ArangoDBAsync

getEngine

public CompletableFuture<ArangoDBEngine> getEngine()

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.getEngine()

Specified by:

getEngine in interface ArangoDBAsync

getRole

public CompletableFuture<ServerRole> getRole()

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.getRole()

Specified by:

getRole in interface ArangoDBAsync

getServerId

public CompletableFuture<String> getServerId()

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.getServerId()

Specified by:

getServerId in interface ArangoDBAsync

createUser

public CompletableFuture<UserEntity> createUser(String user,
 String passwd)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.createUser(String, String)

Specified by:

createUser in interface ArangoDBAsync

createUser

public CompletableFuture<UserEntity> createUser(String user,
 String passwd,
 UserCreateOptions options)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.createUser(String, String, UserCreateOptions)

Specified by:

createUser in interface ArangoDBAsync

deleteUser

public CompletableFuture<Void> deleteUser(String user)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.deleteUser(String)

Specified by:

deleteUser in interface ArangoDBAsync

getUser

public CompletableFuture<UserEntity> getUser(String user)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.getUser(String)

Specified by:

getUser in interface ArangoDBAsync

getUsers

public CompletableFuture<Collection<UserEntity>> getUsers()

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.getUsers()

Specified by:

getUsers in interface ArangoDBAsync

updateUser

public CompletableFuture<UserEntity> updateUser(String user,
 UserUpdateOptions options)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.updateUser(String, UserUpdateOptions)

Specified by:

updateUser in interface ArangoDBAsync

replaceUser

public CompletableFuture<UserEntity> replaceUser(String user,
 UserUpdateOptions options)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.replaceUser(String, UserUpdateOptions)

Specified by:

replaceUser in interface ArangoDBAsync

grantDefaultDatabaseAccess

public CompletableFuture<Void> grantDefaultDatabaseAccess(String user,
 Permissions permissions)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.grantDefaultDatabaseAccess(String, Permissions)

Specified by:

grantDefaultDatabaseAccess in interface ArangoDBAsync

grantDefaultCollectionAccess

public CompletableFuture<Void> grantDefaultCollectionAccess(String user,
 Permissions permissions)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.grantDefaultCollectionAccess(String, Permissions)

Specified by:

grantDefaultCollectionAccess in interface ArangoDBAsync

execute

public <T> CompletableFuture<Response<T>> execute(Request<?> request,
 Class<T> type)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.execute(Request, Class)

Specified by:

execute in interface ArangoDBAsync

getLogEntries

public CompletableFuture<LogEntriesEntity> getLogEntries(LogOptions options)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.getLogEntries(LogOptions)

Specified by:

getLogEntries in interface ArangoDBAsync

getLogLevel

public CompletableFuture<LogLevelEntity> getLogLevel()

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.getLogLevel()

Specified by:

getLogLevel in interface ArangoDBAsync

getLogLevel

public CompletableFuture<LogLevelEntity> getLogLevel(LogLevelOptions options)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.getLogLevel(LogLevelOptions)

Specified by:

getLogLevel in interface ArangoDBAsync

setLogLevel

public CompletableFuture<LogLevelEntity> setLogLevel(LogLevelEntity entity)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.setLogLevel(LogLevelEntity)

Specified by:

setLogLevel in interface ArangoDBAsync

setLogLevel

public CompletableFuture<LogLevelEntity> setLogLevel(LogLevelEntity entity,
 LogLevelOptions options)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.setLogLevel(LogLevelEntity, LogLevelOptions)

Specified by:

setLogLevel in interface ArangoDBAsync

resetLogLevels

public CompletableFuture<LogLevelEntity> resetLogLevels(LogLevelOptions options)

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.resetLogLevels(LogLevelOptions)

Specified by:

resetLogLevels in interface ArangoDBAsync

getQueryOptimizerRules

public CompletableFuture<Collection<QueryOptimizerRule>> getQueryOptimizerRules()

Description copied from interface: ArangoDBAsync

Asynchronous version of ArangoDB.getQueryOptimizerRules()

Specified by:

getQueryOptimizerRules in interface ArangoDBAsync