Package com.orientechnologies.enterprise.server

Class OEnterpriseServerImpl

java.lang.Object

com.orientechnologies.enterprise.server.OEnterpriseServerImpl

All Implemented Interfaces:

OService, OEnterpriseServer, ODatabaseLifecycleListener, ODatabaseListener, OServerLifecycleListener, OServerPlugin

public class OEnterpriseServerImpl
extends Object
implements OEnterpriseServer, OServerPlugin, ODatabaseLifecycleListener, ODatabaseListener, OServerLifecycleListener

Created by Enrico Risa on 16/07/2018.

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.db.ODatabaseLifecycleListener

ODatabaseLifecycleListener.PRIORITY

Constructor Summary

Constructors

Constructor	Description
OEnterpriseServerImpl(OServer server, OEnterpriseAgent agent)

Method Summary

Modifier and Type	Method	Description
void	config(OServer oServer, OServerParameterConfiguration[] oServerParameterConfigurations)	Configures the handler.
boolean	existsDatabase(String databaseName)
Map<String,String>	getAvailableStorageNames()
List<OClientConnection>	getConnections()
Object	getContent(String s)
OrientDBInternal	getDatabases()
ODistributedServerManager	getDistributedManager()
String	getName()
NodesManager	getNodesManager()
ODatabaseLifecycleListener.PRIORITY	getPriority()
Optional<QueryInfo>	getQueryInfo(OResultSet resultSet)
List<OResult>	getQueryStats(Optional<String> database)
OSecuritySystem	getSecurity()
<T extends OEnterpriseService> Optional<T>	getServiceByClass(Class<T> klass)
OSystemDatabase	getSystemDatabase()
void	interruptConnection(Integer connectionId)
Collection<OServerCommand>	listCommands()
List<OResult>	listQueries(Optional<Function<OClientConnection,Boolean>> filter)
void	onAfterActivate()
void	onAfterClientRequest(OClientConnection oClientConnection, byte b)	Callback invoked after a client request is processed.
void	onBeforeClientRequest(OClientConnection oClientConnection, byte b)	Callback invoked before a client request is processed.
void	onClientConnection(OClientConnection oClientConnection)	Callback invoked when a client connection begins.
void	onClientDisconnection(OClientConnection oClientConnection)	Callback invoked when a client connection ends.
void	onClientError(OClientConnection oClientConnection, Throwable throwable)	Callback invoked when a client connection has errors.
void	onCommandEnd(ODatabase database, OResultSet result)
void	onCommandStart(ODatabase database, OResultSet result)
void	onCreate(ODatabaseInternal iDatabase)
void	onDrop(ODatabaseInternal iDatabase)
void	onOpen(ODatabaseInternal iDatabase)
void	onSocketAccepted(ONetworkProtocol protocol)
void	onSocketDestroyed(ONetworkProtocol protocol)
void	registerConnectionListener(OEnterpriseConnectionListener listener)
void	registerDatabaseListener(OEnterpriseStorageListener listener)
void	registerFunction(OSQLFunction function)
void	registerStatelessCommand(OServerCommand iCommand)
void	restore(String databaseName, String path)
void	sendShutdown()
void	shutdown()
void	startup()
void	unregisterConnectionListener(OEnterpriseConnectionListener listener)
void	unRegisterDatabaseListener(OEnterpriseStorageListener listener)
void	unregisterFunction(String function)
void	unregisterStatelessCommand(Class<? extends OServerCommand> iCommandClass)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.core.db.ODatabaseLifecycleListener

onClose, onCreateClass, onCreateView, onDropClass, onDropView, onLocalNodeConfigurationRequest

Methods inherited from interface com.orientechnologies.orient.core.db.ODatabaseListener

onAfterTxCommit, onAfterTxRollback, onBeforeTxBegin, onBeforeTxCommit, onBeforeTxRollback, onClose, onCorruptionRepairDatabase, onCreate, onCreateClass, onCreateView, onDelete, onDropClass, onDropView, onOpen

Methods inherited from interface com.orientechnologies.orient.server.OServerLifecycleListener

onAfterDeactivate, onBeforeActivate, onBeforeDeactivate

Constructor Details

OEnterpriseServerImpl

public OEnterpriseServerImpl(OServer server,
 OEnterpriseAgent agent)

Method Details

registerConnectionListener

public void registerConnectionListener(OEnterpriseConnectionListener listener)

Specified by:

registerConnectionListener in interface OEnterpriseServer

unregisterConnectionListener

public void unregisterConnectionListener(OEnterpriseConnectionListener listener)

Specified by:

unregisterConnectionListener in interface OEnterpriseServer

registerDatabaseListener

public void registerDatabaseListener(OEnterpriseStorageListener listener)

Specified by:

registerDatabaseListener in interface OEnterpriseServer

unRegisterDatabaseListener

public void unRegisterDatabaseListener(OEnterpriseStorageListener listener)

Specified by:

unRegisterDatabaseListener in interface OEnterpriseServer

getAvailableStorageNames

public Map<String,String> getAvailableStorageNames()

Specified by:

getAvailableStorageNames in interface OEnterpriseServer

getName

public String getName()

Specified by:

getName in interface OService

startup

public void startup()

Specified by:

startup in interface OService

shutdown

public void shutdown()

Specified by:

shutdown in interface OEnterpriseServer

Specified by:

shutdown in interface OService

getDatabases

public OrientDBInternal getDatabases()

Specified by:

getDatabases in interface OEnterpriseServer

interruptConnection

public void interruptConnection(Integer connectionId)

Specified by:

interruptConnection in interface OEnterpriseServer

onClientConnection

public void onClientConnection(OClientConnection oClientConnection)

Description copied from interface: OServerPlugin

Callback invoked when a client connection begins.

Specified by:

onClientConnection in interface OServerPlugin

onSocketAccepted

public void onSocketAccepted(ONetworkProtocol protocol)

Specified by:

onSocketAccepted in interface OServerPlugin

onSocketDestroyed

public void onSocketDestroyed(ONetworkProtocol protocol)

Specified by:

onSocketDestroyed in interface OServerPlugin

getSystemDatabase

public OSystemDatabase getSystemDatabase()

Specified by:

getSystemDatabase in interface OEnterpriseServer

getNodesManager

public NodesManager getNodesManager()

Specified by:

getNodesManager in interface OEnterpriseServer

getDistributedManager

public ODistributedServerManager getDistributedManager()

Specified by:

getDistributedManager in interface OEnterpriseServer

existsDatabase

public boolean existsDatabase(String databaseName)

Specified by:

existsDatabase in interface OEnterpriseServer

restore

public void restore(String databaseName,
 String path)

Specified by:

restore in interface OEnterpriseServer

onClientDisconnection

public void onClientDisconnection(OClientConnection oClientConnection)

Description copied from interface: OServerPlugin

Callback invoked when a client connection ends.

Specified by:

onClientDisconnection in interface OServerPlugin

onBeforeClientRequest

public void onBeforeClientRequest(OClientConnection oClientConnection,
 byte b)

Description copied from interface: OServerPlugin

Callback invoked before a client request is processed.

Specified by:

onBeforeClientRequest in interface OServerPlugin

onAfterClientRequest

public void onAfterClientRequest(OClientConnection oClientConnection,
 byte b)

Description copied from interface: OServerPlugin

Callback invoked after a client request is processed.

Specified by:

onAfterClientRequest in interface OServerPlugin

onClientError

public void onClientError(OClientConnection oClientConnection,
 Throwable throwable)

Description copied from interface: OServerPlugin

Callback invoked when a client connection has errors.

Specified by:

onClientError in interface OServerPlugin

throwable - Throwable instance received

config

public void config(OServer oServer,
 OServerParameterConfiguration[] oServerParameterConfigurations)

Description copied from interface: OServerPlugin

Configures the handler. Called at startup.

Specified by:

config in interface OServerPlugin

sendShutdown

public void sendShutdown()

Specified by:

sendShutdown in interface OServerPlugin

getContent

public Object getContent(String s)

Specified by:

getContent in interface OServerPlugin

getPriority

public ODatabaseLifecycleListener.PRIORITY getPriority()

Specified by:

getPriority in interface ODatabaseLifecycleListener

onAfterActivate

public void onAfterActivate()

Specified by:

onAfterActivate in interface OServerLifecycleListener

onCreate

public void onCreate(ODatabaseInternal iDatabase)

Specified by:

onCreate in interface ODatabaseLifecycleListener

onOpen

public void onOpen(ODatabaseInternal iDatabase)

Specified by:

onOpen in interface ODatabaseLifecycleListener

onDrop

public void onDrop(ODatabaseInternal iDatabase)

Specified by:

onDrop in interface ODatabaseLifecycleListener

registerFunction

public void registerFunction(OSQLFunction function)

Specified by:

registerFunction in interface OEnterpriseServer

registerStatelessCommand

public void registerStatelessCommand(OServerCommand iCommand)

Specified by:

registerStatelessCommand in interface OEnterpriseServer

unregisterStatelessCommand

public void unregisterStatelessCommand(Class<? extends OServerCommand> iCommandClass)

Specified by:

unregisterStatelessCommand in interface OEnterpriseServer

listCommands

public Collection<OServerCommand> listCommands()

Specified by:

listCommands in interface OEnterpriseServer

getConnections

public List<OClientConnection> getConnections()

Specified by:

getConnections in interface OEnterpriseServer

unregisterFunction

public void unregisterFunction(String function)

Specified by:

unregisterFunction in interface OEnterpriseServer

getSecurity

public OSecuritySystem getSecurity()

Specified by:

getSecurity in interface OEnterpriseServer

listQueries

public List<OResult> listQueries(Optional<Function<OClientConnection,Boolean>> filter)

Specified by:

listQueries in interface OEnterpriseServer

getQueryStats

public List<OResult> getQueryStats(Optional<String> database)

Specified by:

getQueryStats in interface OEnterpriseServer

onCommandStart

public void onCommandStart(ODatabase database,
 OResultSet result)

Specified by:

onCommandStart in interface ODatabaseListener

onCommandEnd

public void onCommandEnd(ODatabase database,
 OResultSet result)

Specified by:

onCommandEnd in interface ODatabaseListener

getQueryInfo

public Optional<QueryInfo> getQueryInfo(OResultSet resultSet)

Specified by:

getQueryInfo in interface OEnterpriseServer

getServiceByClass

public <T extends OEnterpriseService> Optional<T> getServiceByClass(Class<T> klass)

Specified by:

getServiceByClass in interface OEnterpriseServer