Package com.orientechnologies.orient.server.distributed

Interface ODistributedLifecycleListener

All Known Implementing Classes:
ODefaultAuditing
public interface ODistributedLifecycleListener
Distributed lifecycle interface to catch event from the distributed cluster.
Author:
Luca Garulli (l.garulli--(at)--orientdb.com)

  • Method Details

    • onNodeJoining

      boolean onNodeJoining(String iNode)
      Called when a node is joining the cluster. Return false to deny the join.
      Parameters:
      iNode - Node name that is joining
      Returns:
      true to allow the join, otherwise false

    • onNodeJoined

      void onNodeJoined(String iNode)
      Called right after a node joined the cluster.
      Parameters:
      iNode - Node name that is joining

    • onNodeLeft

      void onNodeLeft(String iNode)
      Called right after a node left the cluster.
      Parameters:
      iNode - Node name that left

    • onDatabaseChangeStatus

      void onDatabaseChangeStatus(String iNode, String iDatabaseName, ODistributedServerManager.DB_STATUS iNewStatus)
      Called upon change of database status on a node. Available statuses are defined in ODistributedServerManager.DB_STATUS.
      Parameters:
      iNode - The node name
      iDatabaseName - Database name
      iNewStatus - The new status
      Since:
      2.2.0

    • onMessageReceived

      default void onMessageReceived(ODistributedRequest request)

    • onMessagePartitionCalculated

      default void onMessagePartitionCalculated(ODistributedRequest request, Set<Integer> involvedWorkerQueues)

    • onMessageBeforeOp

      default void onMessageBeforeOp(String op, ODistributedRequestId requestId)

    • onMessageAfterOp

      default void onMessageAfterOp(String op, ODistributedRequestId requestId)

    • onMessageProcessStart

      default void onMessageProcessStart(ODistributedRequest message)

    • onMessageCurrentPayload

      default void onMessageCurrentPayload(ODistributedRequestId requestId, Object responsePayload)

    • onMessageProcessEnd

      default void onMessageProcessEnd(ODistributedRequest iRequest, Object responsePayload)