Modifier and Type | Method and Description |
---|---|
JournalIdentifier |
JournalEntry.getJournalId() |
Constructor and Description |
---|
JournalEntry(JournalIdentifier journalId,
String type,
String message)
Creates a new journal entry for persisting.
|
JournalEntry(long id,
JournalIdentifier journalId,
Date creationDate,
String type,
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(JournalIdentifier journalId)
Counts the number of entries in a journal.
|
Iterable<JournalEntry> |
JournalService.peek(JournalIdentifier journalId,
int maxEntries)
Return a copy of journal entries that are waiting to be processed.
|
<V> V |
JournalService.processEntries(JournalIdentifier journalId,
int maxEntries,
com.google.common.base.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(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 |
ClusterIndexSnapshotRequestEvent.getJournalId() |
JournalIdentifier |
ClusterIndexResponseEvent.getJournalId() |
JournalIdentifier |
ClusterIndexRequestEvent.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(JournalIdentifier journalId)
Counts the number of entries in a journal.
|
int |
DefaultJournalService.countEntries(JournalIdentifier journalId) |
int |
DefaultJournalManager.countEntries(JournalIdentifier journalId) |
int |
JournalDao.countEntries(JournalIdentifier journalId,
long afterId,
long ignoreWithinMillis)
Counts the number of entries in a journal.
|
int |
HibernateJournalDao.countEntries(JournalIdentifier journalId,
long afterId,
long ignoreWithinMillis) |
List<JournalEntry> |
JournalDao.findEntries(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(JournalIdentifier journalId,
long afterId,
long ignoreWithinMillis,
int maxEntries) |
com.atlassian.fugue.Option<JournalEntry> |
JournalDao.findLatestEntry(JournalIdentifier journalId,
long ignoreWithinMillis)
Finds the latest journal entry if any.
|
com.atlassian.fugue.Option<JournalEntry> |
HibernateJournalDao.findLatestEntry(JournalIdentifier journalId,
long ignoreWithinMillis) |
com.atlassian.fugue.Option<JournalEntry> |
JournalDao.findMostRecentEntryByMessage(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(JournalIdentifier journalId,
String message) |
long |
JournalStateStore.getMostRecentId(JournalIdentifier journalId)
Returns the most recent id for a journal or 0 if no id has
been stored yet.
|
long |
FilesystemJournalStateStore.getMostRecentId(JournalIdentifier journalId) |
long |
CachingJournalStateStore.getMostRecentId(JournalIdentifier journalId) |
long |
BandanaJournalStateStore.getMostRecentId(JournalIdentifier journalId) |
Iterable<JournalEntry> |
JournalManager.peek(JournalIdentifier journalId,
int maxEntries)
Return a copy of journal entries that are waiting to be processed.
|
Iterable<JournalEntry> |
DefaultJournalService.peek(JournalIdentifier journalId,
int maxEntries) |
Iterable<JournalEntry> |
DefaultJournalManager.peek(JournalIdentifier journalId,
int maxEntries) |
<V> V |
JournalManager.processEntries(JournalIdentifier journalId,
int maxEntries,
com.google.common.base.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 |
DefaultJournalService.processEntries(JournalIdentifier journalId,
int maxEntries,
com.google.common.base.Function<Iterable<JournalEntry>,EntryProcessorResult<V>> entryProcessor) |
<V> V |
DefaultJournalManager.processEntries(JournalIdentifier journalId,
int maxEntries,
com.google.common.base.Function<Iterable<JournalEntry>,EntryProcessorResult<V>> entryProcessor) |
void |
JournalManager.reset(JournalIdentifier journalId)
Resets the state of the journal so that all entries currently in the
journal will be skipped.
|
void |
DefaultJournalService.reset(JournalIdentifier journalId) |
void |
DefaultJournalManager.reset(JournalIdentifier journalId) |
void |
JournalEntry.setJournalId(JournalIdentifier journalId) |
void |
JournalStateStore.setMostRecentId(JournalIdentifier journalId,
long id)
Set the most recent identifier for a journal.
|
void |
FilesystemJournalStateStore.setMostRecentId(JournalIdentifier journalId,
long id) |
void |
CachingJournalStateStore.setMostRecentId(JournalIdentifier journalId,
long id) |
void |
BandanaJournalStateStore.setMostRecentId(JournalIdentifier journalId,
long id) |
Constructor and Description |
---|
JournalEntry(JournalIdentifier journalId,
String type,
String message)
Creates a new journal entry.
|
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.
|
Modifier and Type | Method and Description |
---|---|
Optional<JournalEntry> |
ESIndexUsersInGroupTask.convertToJournalEntry(JournalIdentifier journalId) |
Optional<JournalEntry> |
ESIndexAllUsersTask.convertToJournalEntry(JournalIdentifier journalId) |
Optional<JournalEntry> |
ESDeleteTask.convertToJournalEntry(JournalIdentifier journalId) |
Optional<JournalEntry> |
ESDeleteSpaceTask.convertToJournalEntry(JournalIdentifier journalId) |
Optional<JournalEntry> |
ESDeleteContentTypeTask.convertToJournalEntry(JournalIdentifier journalId) |
Optional<JournalEntry> |
ESDeleteAllChangesTask.convertToJournalEntry(JournalIdentifier journalId) |
Optional<JournalEntry> |
AbstractESTask.convertToJournalEntry(JournalIdentifier journalId) |
Modifier and Type | Field and Description |
---|---|
static JournalIdentifier |
AbstractJournalIndexTaskQueue.JOURNAL_ID |
Modifier and Type | Method and Description |
---|---|
static Optional<JournalEntry> |
JournalEntryFactory.createJournalEntry(JournalIdentifier journalId,
JournalEntryType journalEntryType,
String message) |
Copyright © 2003–2017 Atlassian. All rights reserved.