public interface Control
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
ALL_PATHS_PROXY_MAP_KEY |
static java.lang.String |
COLLECTION_PROXY_MAP_KEY |
static java.lang.String |
COMPONENTS_PROXY_MAP_KEY |
static java.lang.String |
FUTURE_MAP_KEY |
static java.lang.String |
KEYSTORE_PATH_SYSTEM_PROPERTY |
static java.lang.String |
KEYSTORE_SECRET_SYSTEM_PROPERTY |
static java.lang.String |
MAP_PROXY_MAP_KEY |
static java.lang.String |
PGQL_RESULTS_KEY |
static java.lang.String |
PGX_CONFIG_FILE_SYSTEM_PROPERTY |
static java.lang.String |
PROPERTY_PROXY_MAP_KEY |
static java.lang.String |
SERVER_CONFIG_FILE_NAME |
| Modifier and Type | Method and Description |
|---|---|
void |
addUserData(java.lang.String sessionId, java.lang.String key, java.lang.Object data)
add session-private user data to a session.
|
PgxFuture<oracle.pgx.common.pojo.admin.CacheStatistics> |
freeCachedMemory()
Trigger memory cleanup to free unused graphs if RELEASE_MEMORY_THRESHOLD is reached
|
PgxFuture<oracle.pgx.common.pojo.admin.CacheStatistics> |
freeCachedMemory(double threshold)
Trigger memory cleanup to free unused graphs if threshold is reached
|
PgxFuture<oracle.pgx.common.VersionInfo> |
getExtendedVersion()
Gets an extended version.
|
PgxFuture<java.util.Map<PgxConfig.Field,java.lang.Object>> |
getPgxConfig()
Gets the pgx config.
|
default PgxFuture<PgxConfig> |
getPgxConfigObject()
Gets the pgx config as
PgxConfig object |
PgxFuture<com.fasterxml.jackson.databind.JsonNode> |
getServerState()
Gets the server state.
|
java.lang.Object |
getUserData(SessionContext sessionContext, java.lang.String key)
get session-private user data by key.
|
PgxFuture<java.lang.String> |
getVersion() |
PgxFuture<java.lang.Boolean> |
isGraphPreloadingDone()
Check if the preloading of the graphs is finished
|
PgxFuture<java.lang.Boolean> |
isRunning()
Check if the engine is currently up
|
PgxFuture<com.fasterxml.jackson.databind.JsonNode> |
joinMachine(java.lang.String hostname, long raftId)
Join a machine to an existing PGX.D cluster.
|
PgxFuture<java.lang.Void> |
killSession(java.lang.String sessionId)
Kill session.
|
PgxFuture<java.lang.Void> |
setSessionMaxMemorySize(java.lang.String sessionId, int size, oracle.pgx.common.MemoryUnit unit)
Set the maximum memory limit for the given session.
|
PgxFuture<java.lang.Boolean> |
shutdown(long timeout, java.util.concurrent.TimeUnit unit)
gracefully shuts down the engine and cleans up resources.
|
PgxFuture<java.lang.Void> |
shutdownNow()
forces the engine to stop and clean up resources.
|
PgxFuture<java.lang.Void> |
shutdownNowIfRunning() |
PgxFuture<java.lang.Void> |
start() |
PgxFuture<java.lang.Void> |
start(java.io.InputStream config) |
PgxFuture<java.lang.Void> |
start(java.util.Map<PgxConfig.Field,java.lang.Object> config) |
default PgxFuture<java.lang.Void> |
start(PgxConfig config) |
PgxFuture<java.lang.Void> |
start(java.lang.String json) |
PgxFuture<java.lang.Void> |
start(java.lang.String json, java.lang.String keystorePath, char[] keystorePassword) |
PgxFuture<java.lang.Void> |
unpinGraph(java.lang.String graphName)
Unpins the specified published graph so that if no session uses any of its snapshot, it can be removed.
|
PgxFuture<java.lang.Void> |
updatePgxConfig(java.io.InputStream config)
Replaces the current PGX config with the given configuration.
|
PgxFuture<java.lang.Void> |
updatePgxConfig(java.util.Map<PgxConfig.Field,java.lang.Object> config)
Replaces the current PGX config with the given configuration.
|
default PgxFuture<java.lang.Void> |
updatePgxConfig(PgxConfig config)
Replaces the current PGX config with the given configuration.
|
PgxFuture<java.lang.Void> |
updatePgxConfig(java.lang.String json)
Replaces the current PGX config with the given configuration.
|
static final java.lang.String ALL_PATHS_PROXY_MAP_KEY
static final java.lang.String COLLECTION_PROXY_MAP_KEY
static final java.lang.String COMPONENTS_PROXY_MAP_KEY
static final java.lang.String FUTURE_MAP_KEY
static final java.lang.String KEYSTORE_PATH_SYSTEM_PROPERTY
static final java.lang.String KEYSTORE_SECRET_SYSTEM_PROPERTY
static final java.lang.String MAP_PROXY_MAP_KEY
static final java.lang.String PGQL_RESULTS_KEY
static final java.lang.String PGX_CONFIG_FILE_SYSTEM_PROPERTY
static final java.lang.String PROPERTY_PROXY_MAP_KEY
static final java.lang.String SERVER_CONFIG_FILE_NAME
void addUserData(java.lang.String sessionId,
java.lang.String key,
java.lang.Object data)
getUserData(SessionContext, String). If data with the same key already exists, it will be overwritten.
This method is thread safe.
sessionId - the ID of the target sessionkey -data -java.util.concurrent.RejectedExecutionException - if no such session existsjava.lang.IllegalStateException - if engine is not runningPgxFuture<oracle.pgx.common.pojo.admin.CacheStatistics> freeCachedMemory()
PgxFuture<oracle.pgx.common.pojo.admin.CacheStatistics> freeCachedMemory(double threshold)
PgxFuture<oracle.pgx.common.VersionInfo> getExtendedVersion()
PgxFuture<java.util.Map<PgxConfig.Field,java.lang.Object>> getPgxConfig()
default PgxFuture<PgxConfig> getPgxConfigObject()
PgxConfig objectPgxFuture<com.fasterxml.jackson.databind.JsonNode> getServerState()
java.lang.Object getUserData(SessionContext sessionContext, java.lang.String key)
sessionContext - context of the session the data was previously added tokey -null if no such data was set.java.util.concurrent.RejectedExecutionException - if no such session existsjava.lang.IllegalStateException - if engine is not runningPgxFuture<java.lang.String> getVersion()
PgxFuture<java.lang.Boolean> isGraphPreloadingDone()
PgxFuture<java.lang.Boolean> isRunning()
PgxFuture<com.fasterxml.jackson.databind.JsonNode> joinMachine(java.lang.String hostname, long raftId)
PgxFuture<java.lang.Void> killSession(java.lang.String sessionId)
sessionId - the session to be killedPgxFuture<java.lang.Void> setSessionMaxMemorySize(java.lang.String sessionId, int size, oracle.pgx.common.MemoryUnit unit)
sessionId - on which session to apply the memory limitsize - memory limit to be set relative to the provided MemoryUnitunit - the MemoryUnit to use for the given size Only supports MemoryUnit.MEGABYTE, MemoryUnit.GIGABYTE, and MemoryUnit.TERABYTE Requires SERVER_MANAGE permissionPgxFuture<java.lang.Boolean> shutdown(long timeout, java.util.concurrent.TimeUnit unit)
PgxFuture<java.lang.Void> shutdownNow()
PgxFuture<java.lang.Void> shutdownNowIfRunning()
PgxFuture<java.lang.Void> start()
PgxFuture<java.lang.Void> start(java.io.InputStream config)
PgxFuture<java.lang.Void> start(java.util.Map<PgxConfig.Field,java.lang.Object> config)
PgxFuture<java.lang.Void> start(java.lang.String json)
PgxFuture<java.lang.Void> start(java.lang.String json, java.lang.String keystorePath, char[] keystorePassword)
PgxFuture<java.lang.Void> unpinGraph(java.lang.String graphName)
graphName - name of the published graph to unpinPgxFuture<java.lang.Void> updatePgxConfig(java.io.InputStream config)
config - stream that can be read to a new PGX configPgxFuture<java.lang.Void> updatePgxConfig(java.util.Map<PgxConfig.Field,java.lang.Object> config)
config - the new PGX configdefault PgxFuture<java.lang.Void> updatePgxConfig(PgxConfig config)
config - the new PGX configPgxFuture<java.lang.Void> updatePgxConfig(java.lang.String json)
json - JSON string representing the new PGX config