Package com.orientechnologies.orient.server

Class OPushManager

java.lang.Object

com.orientechnologies.orient.server.OPushManager

All Implemented Interfaces:

OMetadataUpdateListener

public class OPushManager
extends Object
implements OMetadataUpdateListener

Field Summary

Fields

Modifier and Type	Field	Description
protected final Set<OPushInfo>	distributedConfigPush
protected final OPushEventType	functions
protected final OPushEventType	indexManager
protected final OPushEventType	schema
protected final OPushEventType	sequences
protected final OPushEventType	storageConfigurations

Constructor Summary

Constructors

Constructor	Description
OPushManager(OContextConfiguration contextConfiguration, OClientConnectionManager sessions)

Method Summary

Modifier and Type	Method	Description
void	cleanPushSockets()
void	close(OPushInfo info)
void	genericNotify(Map<String,Set<OPushInfo>> context, String database, OPushEventType pack)
void	onFunctionLibraryUpdate(String database)
void	onIndexManagerUpdate(String database, OIndexManagerAbstract indexManager)
void	onSchemaUpdate(String database, OSchemaShared schema)
void	onSequenceLibraryUpdate(String database)
void	onStorageConfigurationUpdate(String database, OStorageConfiguration update)
void	pushDistributedConfig(String database, List<String> hosts)
void	shutdown()
void	subscribeDistributeConfig(ONetworkProtocolBinary channel, OClientConnection session)
void	subscribeFunctions(ODatabaseDocumentInternal database, ONetworkProtocolBinary protocol, OClientConnection session)
void	subscribeIndexManager(ODatabaseDocumentInternal database, ONetworkProtocolBinary protocol, OClientConnection session)
void	subscribeSchema(ODatabaseDocumentInternal database, ONetworkProtocolBinary protocol, OClientConnection session)
void	subscribeSequences(ODatabaseDocumentInternal database, ONetworkProtocolBinary protocol, OClientConnection session)
void	subscribeStorageConfiguration(ODatabaseDocumentInternal database, ONetworkProtocolBinary protocol, OClientConnection session)

Methods inherited from class java.lang.Object

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

Field Details

distributedConfigPush

protected final Set<OPushInfo> distributedConfigPush

storageConfigurations

protected final OPushEventType storageConfigurations

schema

protected final OPushEventType schema

indexManager

protected final OPushEventType indexManager

functions

protected final OPushEventType functions

sequences

protected final OPushEventType sequences

Constructor Details

OPushManager

public OPushManager(OContextConfiguration contextConfiguration,
 OClientConnectionManager sessions)

Method Details

pushDistributedConfig

public void pushDistributedConfig(String database,
 List<String> hosts)

subscribeDistributeConfig

public void subscribeDistributeConfig(ONetworkProtocolBinary channel,
 OClientConnection session)

cleanPushSockets

public void cleanPushSockets()

shutdown

public void shutdown()

subscribeStorageConfiguration

public void subscribeStorageConfiguration(ODatabaseDocumentInternal database,
 ONetworkProtocolBinary protocol,
 OClientConnection session)

subscribeSchema

public void subscribeSchema(ODatabaseDocumentInternal database,
 ONetworkProtocolBinary protocol,
 OClientConnection session)

subscribeIndexManager

public void subscribeIndexManager(ODatabaseDocumentInternal database,
 ONetworkProtocolBinary protocol,
 OClientConnection session)

subscribeFunctions

public void subscribeFunctions(ODatabaseDocumentInternal database,
 ONetworkProtocolBinary protocol,
 OClientConnection session)

subscribeSequences

public void subscribeSequences(ODatabaseDocumentInternal database,
 ONetworkProtocolBinary protocol,
 OClientConnection session)

onSchemaUpdate

public void onSchemaUpdate(String database,
 OSchemaShared schema)

Specified by:

onSchemaUpdate in interface OMetadataUpdateListener

onIndexManagerUpdate

public void onIndexManagerUpdate(String database,
 OIndexManagerAbstract indexManager)

Specified by:

onIndexManagerUpdate in interface OMetadataUpdateListener

onFunctionLibraryUpdate

public void onFunctionLibraryUpdate(String database)

Specified by:

onFunctionLibraryUpdate in interface OMetadataUpdateListener

onSequenceLibraryUpdate

public void onSequenceLibraryUpdate(String database)

Specified by:

onSequenceLibraryUpdate in interface OMetadataUpdateListener

onStorageConfigurationUpdate

public void onStorageConfigurationUpdate(String database,
 OStorageConfiguration update)

Specified by:

onStorageConfigurationUpdate in interface OMetadataUpdateListener

close

public void close(OPushInfo info)

genericNotify

public void genericNotify(Map<String,Set<OPushInfo>> context,
 String database,
 OPushEventType pack)