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 and Description
protected Set<WeakReference<ONetworkProtocolBinary>>	distributedConfigPush
protected OPushEventType	functions
protected OPushEventType	indexManager
protected OPushEventType	schema
protected OPushEventType	sequences
protected OPushEventType	storageConfigurations

Constructor Summary

Constructors

Constructor and Description
OPushManager()

Method Summary

Modifier and Type	Method and Description
void	cleanPushSockets()
void	genericNotify(Map<String,Set<WeakReference<ONetworkProtocolBinary>>> 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)
void	subscribeFunctions(ODatabaseDocumentInternal database, ONetworkProtocolBinary protocol)
void	subscribeIndexManager(ODatabaseDocumentInternal database, ONetworkProtocolBinary protocol)
void	subscribeSchema(ODatabaseDocumentInternal database, ONetworkProtocolBinary protocol)
void	subscribeSequences(ODatabaseDocumentInternal database, ONetworkProtocolBinary protocol)
void	subscribeStorageConfiguration(ODatabaseDocumentInternal database, ONetworkProtocolBinary protocol)

Methods inherited from class java.lang.Object

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

Field Detail

distributedConfigPush

protected final Set<WeakReference<ONetworkProtocolBinary>> 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 Detail

OPushManager

public OPushManager()

Method Detail

pushDistributedConfig

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

subscribeDistributeConfig

public void subscribeDistributeConfig(ONetworkProtocolBinary channel)

cleanPushSockets

public void cleanPushSockets()

shutdown

public void shutdown()

subscribeStorageConfiguration

public void subscribeStorageConfiguration(ODatabaseDocumentInternal database,
                                          ONetworkProtocolBinary protocol)

subscribeSchema

public void subscribeSchema(ODatabaseDocumentInternal database,
                            ONetworkProtocolBinary protocol)

subscribeIndexManager

public void subscribeIndexManager(ODatabaseDocumentInternal database,
                                  ONetworkProtocolBinary protocol)

subscribeFunctions

public void subscribeFunctions(ODatabaseDocumentInternal database,
                               ONetworkProtocolBinary protocol)

subscribeSequences

public void subscribeSequences(ODatabaseDocumentInternal database,
                               ONetworkProtocolBinary protocol)

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

genericNotify

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