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