Modifier and Type | Method and Description |
---|---|
JournalIdentifier |
JournalEntry.getJournalId() |
Constructor and Description |
---|
JournalEntry(JournalIdentifier journalId,
String type,
@Nullable String message)
Creates a new journal entry for persisting.
|
JournalEntry(long id,
JournalIdentifier journalId,
Date creationDate,
String type,
@Nullable String message)
Creates a new journal entry describing an entry that has been persisted
|
Modifier and Type | Method and Description |
---|---|
boolean |
IndexRecoveryService.createIndexBackup(JournalIdentifier journalId,
String indexDirName,
IndexRecoverer indexRecoverer)
Creates an index snapshot in the cluster shared home.
|
boolean |
IndexRecoveryService.isIndexRecoveryRequired(JournalIdentifier journalId,
String indexDirName)
Checks to see whether the index needs to be recovered.
|
boolean |
IndexRecoveryService.recoverIndex(JournalIdentifier journalId,
String indexDirName)
Recovers the index required by asking other nodes in the cluster for a snapshot of their index
and copying it to its local home directory.
|
boolean |
IndexRecoveryService.recoverIndexFromSharedHome(JournalIdentifier journalId,
String indexDirName)
Recovers the index snapshot stored in the shared home.
|
Modifier and Type | Method and Description |
---|---|
int |
JournalService.countEntries(@NonNull JournalIdentifier journalId)
Counts the number of entries in a journal.
|
Iterable<JournalEntry> |
JournalService.peek(@NonNull JournalIdentifier journalId,
int maxEntries)
Return a copy of journal entries that are waiting to be processed.
|
<V> V |
JournalService.processEntries(@NonNull JournalIdentifier journalId,
int maxEntries,
com.google.common.base.Function<Iterable<JournalEntry>,EntryProcessorResult<V>> entryProcessor)
Deprecated.
since 7.0.1. Use
JournalService.processNewEntries(JournalIdentifier, int, Function) |
default <V> V |
JournalService.processNewEntries(@NonNull JournalIdentifier journalId,
int maxEntries,
@NonNull Function<Iterable<JournalEntry>,EntryProcessorResult<V>> entryProcessor)
Processes journal entries that were added since the last time this
method was called for this journal on this cluster node.
|
void |
JournalService.reset(@NonNull JournalIdentifier journalId)
Resets the state of the journal so that all entries currently in the
journal will be skipped.
|
Modifier and Type | Method and Description |
---|---|
JournalIdentifier |
ClusterIndexRequestEvent.getJournalId() |
JournalIdentifier |
ClusterIndexSnapshotRequestEvent.getJournalId() |
JournalIdentifier |
ClusterIndexResponseEvent.getJournalId() |
Constructor and Description |
---|
ClusterIndexRequestEvent(Object src,
String senderNodeId,
JournalIdentifier journalId,
String buildNumber,
String indexDirName)
Construct an event to request for a recovery snapshot of the index.
|
ClusterIndexResponseEvent(Object src,
String senderNodeId,
String receiverNodeId,
JournalIdentifier journalId,
String indexDirName)
Construct an event to indicate that this node can provide a recovery snapshot of the index.
|
ClusterIndexSnapshotRequestEvent(Object src,
String senderNodeId,
String receiverNodeId,
JournalIdentifier journalId,
String indexDirName)
Construct an event to request for a recovery snapshot of the index.
|
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultIndexRecoveryService.createIndexBackup(JournalIdentifier journalId,
String indexDirName,
IndexRecoverer indexRecoverer) |
boolean |
DefaultIndexRecoveryService.isIndexRecoveryRequired(JournalIdentifier journalId,
String indexDirName) |
boolean |
DefaultIndexRecoveryService.recoverIndex(JournalIdentifier journalId,
String indexDirName) |
boolean |
DefaultIndexRecoveryService.recoverIndexFromSharedHome(JournalIdentifier journalId,
String indexDirName) |
Modifier and Type | Method and Description |
---|---|
JournalIdentifier |
JournalEntry.getJournalId() |
JournalIdentifier |
JournalIdentifierUserType.nullSafeGet(ResultSet rs,
String[] columns,
Object owner) |
Modifier and Type | Method and Description |
---|---|
int |
JournalManager.countEntries(@NonNull JournalIdentifier journalId)
Counts the number of entries in a journal.
|
int |
DefaultJournalService.countEntries(@NonNull JournalIdentifier journalId) |
int |
DefaultJournalManager.countEntries(@NonNull JournalIdentifier journalId) |
int |
JournalDao.countEntries(@NonNull JournalIdentifier journalId,
long afterId,
long ignoreWithinMillis)
Counts the number of entries in a journal.
|
int |
HibernateJournalDao.countEntries(@NonNull JournalIdentifier journalId,
long afterId,
long ignoreWithinMillis) |
List<JournalEntry> |
JournalDao.findEntries(@NonNull JournalIdentifier journalId,
long afterId,
long ignoreWithinMillis,
int maxEntries)
Finds journal entries that were added after an entry with the given id
but earlier than given milliseconds ago.
|
List<JournalEntry> |
HibernateJournalDao.findEntries(@NonNull JournalIdentifier journalId,
long afterId,
long ignoreWithinMillis,
int maxEntries) |
com.atlassian.fugue.Option<JournalEntry> |
JournalDao.findLatestEntry(@NonNull JournalIdentifier journalId,
long ignoreWithinMillis)
Finds the latest journal entry if any.
|
com.atlassian.fugue.Option<JournalEntry> |
HibernateJournalDao.findLatestEntry(@NonNull JournalIdentifier journalId,
long ignoreWithinMillis) |
com.atlassian.fugue.Option<JournalEntry> |
JournalDao.findMostRecentEntryByMessage(@NonNull JournalIdentifier journalId,
String message)
Finds the most recent journal entry (if any) for the given journal that
exactly matches the given journal entry message.
|
com.atlassian.fugue.Option<JournalEntry> |
HibernateJournalDao.findMostRecentEntryByMessage(@NonNull JournalIdentifier journalId,
String message) |
long |
BandanaJournalStateStore.getMostRecentId(@NonNull JournalIdentifier journalId) |
long |
CachingJournalStateStore.getMostRecentId(@NonNull JournalIdentifier journalId) |
long |
FilesystemJournalStateStore.getMostRecentId(@NonNull JournalIdentifier journalId) |
long |
JournalStateStore.getMostRecentId(@NonNull JournalIdentifier journalId)
Returns the most recent id for a journal or 0 if no id has
been stored yet.
|
Iterable<JournalEntry> |
JournalManager.peek(@NonNull JournalIdentifier journalId,
int maxEntries)
Return a copy of journal entries that are waiting to be processed.
|
Iterable<JournalEntry> |
DefaultJournalService.peek(@NonNull JournalIdentifier journalId,
int maxEntries) |
Iterable<JournalEntry> |
DefaultJournalManager.peek(@NonNull JournalIdentifier journalId,
int maxEntries) |
<V> V |
JournalManager.processEntries(@NonNull JournalIdentifier journalId,
int maxEntries,
com.google.common.base.Function<Iterable<JournalEntry>,EntryProcessorResult<V>> entryProcessor)
Deprecated.
since 7.0.1. Use
JournalManager.processNewEntries(JournalIdentifier, int, Function) |
<V> V |
DefaultJournalService.processEntries(@NonNull JournalIdentifier journalId,
int maxEntries,
@NonNull com.google.common.base.Function<Iterable<JournalEntry>,EntryProcessorResult<V>> entryProcessor) |
<V> V |
DefaultJournalManager.processEntries(@NonNull JournalIdentifier journalId,
int maxEntries,
com.google.common.base.Function<Iterable<JournalEntry>,EntryProcessorResult<V>> entryProcessor)
Deprecated.
|
default <V> V |
JournalManager.processNewEntries(@NonNull JournalIdentifier journalId,
int maxEntries,
@NonNull Function<Iterable<JournalEntry>,EntryProcessorResult<V>> entryProcessor)
Processes journal entries that were added since the last time this
method was called for this journal on this cluster node.
|
<V> V |
DefaultJournalManager.processNewEntries(@NonNull JournalIdentifier journalId,
int maxEntries,
@NonNull Function<Iterable<JournalEntry>,EntryProcessorResult<V>> entryProcessor) |
void |
JournalManager.reset(@NonNull JournalIdentifier journalId)
Resets the state of the journal so that all entries currently in the
journal will be skipped.
|
void |
DefaultJournalService.reset(@NonNull JournalIdentifier journalId) |
void |
DefaultJournalManager.reset(@NonNull JournalIdentifier journalId) |
void |
JournalEntry.setJournalId(JournalIdentifier journalId) |
void |
BandanaJournalStateStore.setMostRecentId(@NonNull JournalIdentifier journalId,
long id) |
void |
CachingJournalStateStore.setMostRecentId(@NonNull JournalIdentifier journalId,
long id) |
void |
FilesystemJournalStateStore.setMostRecentId(@NonNull JournalIdentifier journalId,
long id) |
void |
JournalStateStore.setMostRecentId(@NonNull JournalIdentifier journalId,
long id)
Set the most recent identifier for a journal.
|
Constructor and Description |
---|
JournalEntry(JournalIdentifier journalId,
String type,
@Nullable String message)
Creates a new journal entry.
|
Constructor and Description |
---|
ChangeIndexTaskQueue(JournalService journalService,
IndexTaskFactory indexTaskFactory,
AnyTypeDao anyTypeDao,
IndexFlushRequester indexFlushRequester,
JournalIdentifier journalIdentifier) |
ContentIndexTaskQueue(JournalService journalService,
IndexTaskFactory indexTaskFactory,
AnyTypeDao anyTypeDao,
IndexFlushRequester indexFlushRequester,
JournalIdentifier journalIdentifier) |
Modifier and Type | Method and Description |
---|---|
JournalIdentifier |
Index.getJournalIdentifier() |
Modifier and Type | Method and Description |
---|---|
JournalIdentifier |
LuceneIndexSnapshot.getJournalIdentifier() |
Modifier and Type | Method and Description |
---|---|
LuceneIndexSnapshot |
LuceneIndexSnapshotManager.create(JournalIdentifier journalIdentifier)
Create a new Lucene index snapshot for given journal (index)
|
LuceneIndexSnapshot |
DefaultLuceneIndexSnapshotManager.create(JournalIdentifier journalIdentifier) |
Optional<LuceneIndexSnapshot> |
LuceneIndexSnapshotManager.find(JournalIdentifier journalIdentifier,
long journalEntryId)
Find a specific index snapshot corresponding to a journal entry ID.
|
Optional<LuceneIndexSnapshot> |
DefaultLuceneIndexSnapshotManager.find(JournalIdentifier journalIdentifier,
long journalEntryId) |
Optional<LuceneIndexSnapshot> |
LuceneIndexSnapshotManager.find(JournalIdentifier journalIdentifier,
long journalEntryId,
long waitTimeMs)
Find a specific index snapshot corresponding to a journal entry ID.
|
Optional<LuceneIndexSnapshot> |
DefaultLuceneIndexSnapshotManager.find(JournalIdentifier journalIdentifier,
long journalEntryId,
long timeoutMs) |
List<LuceneIndexSnapshot> |
LuceneIndexSnapshotManager.findForJournal(JournalIdentifier journalIdentifier) |
List<LuceneIndexSnapshot> |
DefaultLuceneIndexSnapshotManager.findForJournal(JournalIdentifier journalIdentifier) |
Constructor and Description |
---|
LuceneIndexSnapshot(JournalIdentifier journalIdentifier,
long journalEntryId) |
Modifier and Type | Method and Description |
---|---|
JournalIdentifier |
IndexRecovererModuleDescriptor.getJournalId() |
Modifier and Type | Method and Description |
---|---|
Optional<JournalEntry> |
ConvertibleToJournalEntry.convertToJournalEntry(JournalIdentifier journalId)
Convert to journal entry.
|
Constructor and Description |
---|
JournalIndexTaskQueue(JournalService journalService,
IndexTaskFactory indexTaskFactory,
AnyTypeDao anyTypeDao,
IndexFlushRequester indexFlushRequester,
JournalIdentifier journalIdentifier) |
Modifier and Type | Field and Description |
---|---|
static JournalIdentifier |
AbstractJournalIndexTaskQueue.CHANGE_JOURNAL_ID
Deprecated.
since 7.9.0. Use spring dependency injection to get this instead of reffering static field
|
static JournalIdentifier |
AbstractJournalIndexTaskQueue.CONTENT_JOURNAL_ID
Deprecated.
since 7.9.0. Use spring dependency injection to get this instead of reffering static field
|
protected JournalIdentifier |
AbstractJournalIndexTaskQueue.journalIdentifier |
Modifier and Type | Method and Description |
---|---|
static Optional<JournalEntry> |
JournalEntryFactory.createJournalEntry(JournalIdentifier journalId,
JournalEntryType journalEntryType,
String message) |
Constructor and Description |
---|
AbstractJournalIndexTaskQueue(JournalService journalService,
AnyTypeDao anyTypeDao,
IndexFlushRequester indexFlushRequester,
JournalIdentifier journalIdentifier) |
Constructor and Description |
---|
SplitIndexUpgradeTask(@NonNull com.atlassian.bonnie.ILuceneConnection contentConnection,
@NonNull com.atlassian.bonnie.ILuceneConnection changesConnection,
@NonNull I18NBeanFactory i18NBeanFactory,
@NonNull JournalStateStore journalStateStore,
@NonNull JournalIdentifier contentJournalIdentifier,
@NonNull JournalIdentifier changeJournalIdentifier,
@NonNull SplitIndexSnapshotManager snapshotManager)
Creates a new SplitIndexUpgradeTask that will split the index.
|
SplitIndexUpgradeTask(@NonNull com.atlassian.bonnie.ILuceneConnection contentConnection,
@NonNull com.atlassian.bonnie.ILuceneConnection changesConnection,
@NonNull I18NBeanFactory i18NBeanFactory,
@NonNull JournalStateStore journalStateStore,
@NonNull JournalIdentifier contentJournalIdentifier,
@NonNull JournalIdentifier changeJournalIdentifier,
@NonNull SplitIndexSnapshotManager snapshotManager)
Creates a new SplitIndexUpgradeTask that will split the index.
|
SplitJournalUpgradeTask(@NonNull DdlExecutor ddlExecutor,
@NonNull JournalStateStore journalStateStore,
@NonNull JournalIdentifier contentJournalIdentifier,
@NonNull JournalIdentifier changeJournalIdentifier,
@NonNull org.hibernate.SessionFactory sessionFactory,
@NonNull IndexTaskFactory indexTaskFactory,
@NonNull JournalIndexTaskQueue changeQueue) |
SplitJournalUpgradeTask(@NonNull DdlExecutor ddlExecutor,
@NonNull JournalStateStore journalStateStore,
@NonNull JournalIdentifier contentJournalIdentifier,
@NonNull JournalIdentifier changeJournalIdentifier,
@NonNull org.hibernate.SessionFactory sessionFactory,
@NonNull IndexTaskFactory indexTaskFactory,
@NonNull JournalIndexTaskQueue changeQueue) |
Constructor and Description |
---|
SplitIndexSnapshotManager(LuceneIndexSnapshotManager snapshotManager,
JournalDao journalDao,
ClusterManager clusterManager,
JournalIdentifier contentIdentifier,
JournalIdentifier changeIdentifier) |
Copyright © 2003–2023 Atlassian. All rights reserved.