| | |
| | | * |
| | | * @param <T> |
| | | * type of the record being returned |
| | | * \@NotThreadSafe |
| | | */ |
| | | public interface DBCursor<T> extends Closeable |
| | | { |
| | |
| | | * |
| | | * @param <Data> |
| | | * The type of data associated with each cursor |
| | | * \@NotThreadSafe |
| | | */ |
| | | abstract class CompositeDBCursor<Data> implements DBCursor<UpdateMsg> |
| | | { |
| | |
| | | |
| | | /** |
| | | * Cursor iterating over a replication domain's replica DBs. |
| | | * |
| | | * \@NotThreadSafe |
| | | */ |
| | | public class DomainDBCursor extends CompositeDBCursor<Void> |
| | | { |
| | |
| | | import org.opends.server.replication.server.changelog.je.DraftCNDB.*; |
| | | |
| | | /** |
| | | * This class allows to iterate through the changes received from a given |
| | | * LDAP Server Identifier. |
| | | * This class allows to iterate through the changes comming from the change number index DB. |
| | | * |
| | | * \@NotThreadSafe |
| | | */ |
| | | public class JEChangeNumberIndexDBCursor implements |
| | | DBCursor<ChangeNumberIndexRecord> |
| | |
| | | |
| | | /** |
| | | * Berkeley DB JE implementation of {@link DBCursor}. |
| | | * |
| | | * \@NotThreadSafe |
| | | */ |
| | | public class JEReplicaDBCursor implements DBCursor<UpdateMsg> |
| | | { |
| | |
| | | |
| | | /** |
| | | * Cursor iterating over a all the replication domain known to the changelog DB. |
| | | * |
| | | * \@NotThreadSafe |
| | | */ |
| | | public class MultiDomainDBCursor extends CompositeDBCursor<DN> |
| | | { |