/* * CDDL HEADER START * * The contents of this file are subject to the terms of the * Common Development and Distribution License, Version 1.0 only * (the "License"). You may not use this file except in compliance * with the License. * * You can obtain a copy of the license at legal-notices/CDDLv1_0.txt * or http://forgerock.org/license/CDDLv1.0.html. * See the License for the specific language governing permissions * and limitations under the License. * * When distributing Covered Code, include this CDDL HEADER in each * file and include the License file at legal-notices/CDDLv1_0.txt. * If applicable, add the following below this CDDL HEADER, with the * fields enclosed by brackets "[]" replaced with your own identifying * information: * Portions Copyright [yyyy] [name of copyright owner] * * CDDL HEADER END * * * Copyright 2013 ForgeRock AS */ package org.opends.server.replication.server.changelog.api; import org.opends.server.replication.common.CSN; import org.opends.server.replication.common.ServerState; import org.opends.server.replication.protocol.UpdateMsg; import org.opends.server.types.DN; /** * This interface allows to query or control the replication domain database(s) * (composed of one or more ReplicaDBs) and query/update each ReplicaDB. */ public interface ReplicationDomainDB { /** * Get the number of changes for the specified replication domain. * * @param baseDN * the replication domain baseDN * @return the number of changes. */ long getDomainChangesCount(DN baseDN); /** * Returns the oldest {@link CSN}s from the replicaDBs for each serverId in * the specified replication domain. * * @param baseDN * the replication domain baseDN * @return a new ServerState object holding the {serverId => oldest CSN} * mapping. If a replica DB is empty or closed, the oldest CSN will be * null for that replica. The caller owns the generated ServerState. */ ServerState getDomainOldestCSNs(DN baseDN); /** * Returns the newest {@link CSN}s from the replicaDBs for each serverId in * the specified replication domain. * * @param baseDN * the replication domain baseDN * @return a new ServerState object holding the {serverId => newest CSN} Map. * If a replica DB is empty or closed, the newest CSN will be null for * that replica. The caller owns the generated ServerState. */ ServerState getDomainNewestCSNs(DN baseDN); /** * Returns the last time each serverId was seen alive for the specified * replication domain. * * @param baseDN * the replication domain baseDN * @return a non null new ServerState object holding the {serverId => CSN} Map */ ServerState getDomainLastAliveCSNs(DN baseDN); /** * Retrieves the latest trim date for the specified replication domain. *

* FIXME will be removed when ECLServerHandler will not be responsible anymore * for lazily building the ChangeNumberIndexDB. * * @param baseDN * the replication domain baseDN * @return the domain latest trim date */ long getDomainLatestTrimDate(DN baseDN); /** * Removes all the data relating to the specified replication domain and * shutdown all its replica databases. In particular, it will: *

    *
  1. remove all the changes from the replica databases
    2. *
  2. remove all knowledge of the serverIds in this domain
    3. *
  3. remove any knowledge of the current generationId for this domain
    4. *
* * @param baseDN * the replication domain baseDN * @throws ChangelogException * If a database problem happened */ void removeDomain(DN baseDN) throws ChangelogException; // serverId methods /** * Generates a {@link DBCursor} across all the replicaDBs for the specified * replication domain, with all cursors starting after the provided CSN. *

* The cursor is already advanced to the record after startAfterCSN. *

* When the cursor is not used anymore, client code MUST call the * {@link DBCursor#close()} method to free the resources and locks used by the * cursor. * * @param baseDN * the replication domain baseDN * @param startAfterCSN * Starting point for each ReplicaDB cursor. If null, start from the * oldest CSN for each ReplicaDB cursor. * @return a non null {@link DBCursor} * @throws ChangelogException * If a database problem happened * @see #getCursorFrom(DN, ServerState) */ DBCursor getCursorFrom(DN baseDN, CSN startAfterCSN) throws ChangelogException; /** * Generates a {@link DBCursor} across all the replicaDBs for the specified * replication domain starting after the provided {@link ServerState} for each * replicaDBs. *

* The cursor is already advanced to the records after the serverState. *

* When the cursor is not used anymore, client code MUST call the * {@link DBCursor#close()} method to free the resources and locks used by the * cursor. * * @param baseDN * the replication domain baseDN * @param startAfterServerState * Starting point for each ReplicaDB cursor. If any CSN for a * replicaDB is null, then start from the oldest CSN for this * replicaDB * @return a non null {@link DBCursor} * @throws ChangelogException * If a database problem happened * @see #getCursorFrom(DN, CSN) */ DBCursor getCursorFrom(DN baseDN, ServerState startAfterServerState) throws ChangelogException; /** * Generates a {@link DBCursor} for one replicaDB for the specified * replication domain and serverId starting after the provided {@link CSN}. *

* The cursor is already advanced to the records after the CSN. *

* When the cursor is not used anymore, client code MUST call the * {@link DBCursor#close()} method to free the resources and locks used by the * cursor. * * @param baseDN * the replication domain baseDN of the replicaDB * @param serverId * the serverId of the replicaDB * @param startAfterCSN * Starting point for the ReplicaDB cursor. If the CSN is null, then * start from the oldest CSN for this replicaDB * @return a non null {@link DBCursor} * @throws ChangelogException * If a database problem happened * @see #getCursorFrom(DN, CSN) */ DBCursor getCursorFrom(DN baseDN, int serverId, CSN startAfterCSN) throws ChangelogException; /** * Publishes the provided change to the changelog DB for the specified * serverId and replication domain. After a change has been successfully * published, it becomes available to be returned by the External ChangeLog. * * @param baseDN * the replication domain baseDN * @param updateMsg * the update message to publish to the replicaDB * @return true if a db had to be created to publish this message * @throws ChangelogException * If a database problem happened */ boolean publishUpdateMsg(DN baseDN, UpdateMsg updateMsg) throws ChangelogException; /** * Let the DB know this replica is alive. *

* This method allows the medium consistency point to move forward in case * this replica did not publish new changes. * * @param baseDN * the replication domain baseDN * @param heartbeatCSN * The CSN heartbeat sent by this replica (contains the serverId and * timestamp of the heartbeat) */ void replicaHeartbeat(DN baseDN, CSN heartbeatCSN); /** * Let the DB know this replica is going down. *

* This method allows to let the medium consistency point move forward while * this replica is offline. *

* Note: This method must not be called to let the DB know the replica is not * sending heartbeats anymore, i.e. it must not be used in case of suspected * network partition. * * @param baseDN * the replication domain baseDN * @param offlineCSN * The CSN (serverId and timestamp) for the replica's going offline */ void replicaOffline(DN baseDN, CSN offlineCSN); }