protected abstract void |
AbstractJournal.append(AppendRecord record,
InputStream in,
int length) |
Append a record backed by a file.
|
protected void |
DatabaseJournal.append(AppendRecord record,
InputStream in,
int length) |
Append a record backed by a file.
|
Record |
DefaultRecordProducer.append() |
Append a record.
|
protected void |
FileJournal.append(AppendRecord record,
InputStream in,
int length) |
Append a record backed by a file.
|
protected void |
MemoryJournal.append(AppendRecord record,
InputStream in,
int length) |
Append a record backed by a file.
|
Record |
RecordProducer.append() |
Append a record.
|
protected AppendRecord |
DefaultRecordProducer.createRecord() |
Create a new record.
|
protected abstract void |
AbstractJournal.doLock() |
Lock the journal revision.
|
protected void |
DatabaseJournal.doLock() |
Lock the journal revision.
|
protected void |
FileJournal.doLock() |
Lock the journal revision.
|
protected void |
MemoryJournal.doLock() |
Lock the journal revision.
|
protected void |
AbstractJournal.doSync(long startRevision) |
Synchronize contents from journal.
|
protected void |
AbstractJournal.doSync(long startRevision,
boolean startup) |
|
protected void |
DatabaseJournal.doSync(long startRevision,
boolean startup) |
Synchronize contents from journal.
|
long |
FileRevision.get() |
Return current counter value.
|
long |
InstanceRevision.get() |
Return current instance revision.
|
long |
MemoryRevision.get() |
Return current instance revision.
|
protected long |
FileJournal.getGlobalRevision() |
InstanceRevision |
DatabaseJournal.getInstanceRevision() |
|
InstanceRevision |
FileJournal.getInstanceRevision() |
Gets the instance that manages the cluster node's local revision.
|
InstanceRevision |
Journal.getInstanceRevision() |
Gets the instance that manages the cluster node's local revision.
|
InstanceRevision |
MemoryJournal.getInstanceRevision() |
Gets the instance that manages the cluster node's local revision.
|
RecordProducer |
Journal.getProducer(String identifier) |
Return the record producer for a given identifier.
|
RecordIterator |
DatabaseJournal.getRecords() |
Return an iterator over all available records in the journal.
|
RecordIterator |
DatabaseJournal.getRecords(long startRevision) |
Return an iterator over all records after the specified revision.
|
RecordIterator |
FileJournal.getRecords() |
Return an iterator over all available records in the journal.
|
RecordIterator |
FileJournal.getRecords(long startRevision) |
Return an iterator over all records after the specified revision.
|
RecordIterator |
Journal.getRecords() |
Return an iterator over all available records in the journal.
|
RecordIterator |
Journal.getRecords(long startRevision) |
Return an iterator over all records after the specified revision.
|
RecordIterator |
MemoryJournal.getRecords() |
Return an iterator over all available records in the journal.
|
RecordIterator |
MemoryJournal.getRecords(long startRevision) |
Return an iterator over all records after the specified revision.
|
void |
AbstractJournal.init(String id,
NamespaceResolver resolver) |
Initialize journal.
|
protected long |
DatabaseJournal.DatabaseRevision.init(long revision) |
Checks whether there's a local revision value in the database for this
cluster node.
|
protected void |
DatabaseJournal.init() |
Completes initialization of this database journal.
|
void |
DatabaseJournal.init(String id,
NamespaceResolver resolver) |
Initialize journal.
|
void |
FileJournal.init(String id,
NamespaceResolver resolver) |
Initialize journal.
|
protected void |
JNDIDatabaseJournal.init() |
Deprecated.
Overridden to avoid the driver and url checks in DatabaseJournal.
|
void |
Journal.init(String id,
NamespaceResolver resolver) |
Initialize journal.
|
void |
MemoryJournal.init(String id,
NamespaceResolver resolver) |
Initialize journal.
|
void |
AbstractJournal.lockAndSync() |
Lock the journal revision, disallowing changes from other sources until
AbstractJournal.unlock(boolean) has been called, and synchronizes to the latest change.
|
Record |
FileRecordIterator.nextRecord() |
Return the next record.
|
Record |
MemoryJournal.MemoryRecordIterator.nextRecord() |
Return the next record.
|
Record |
RecordIterator.nextRecord() |
Return the next record.
|
boolean |
AppendRecord.readBoolean() |
|
boolean |
ReadRecord.readBoolean() |
Read a boolean from the underlying stream.
|
boolean |
Record.readBoolean() |
Read a boolean from the underlying stream.
|
byte |
AppendRecord.readByte() |
Unsupported methods when appending.
|
byte |
ReadRecord.readByte() |
Read a byte from the underlying stream.
|
byte |
Record.readByte() |
Read a byte from the underlying stream.
|
char |
AppendRecord.readChar() |
|
char |
ReadRecord.readChar() |
Read a character from the underlying stream.
|
char |
Record.readChar() |
Read a character from the underlying stream.
|
void |
AppendRecord.readFully(byte[] b) |
|
void |
ReadRecord.readFully(byte[] b) |
Fully read an array of bytes from the underlying stream.
|
void |
Record.readFully(byte[] b) |
Fully read an array of bytes from the underlying stream.
|
int |
AppendRecord.readInt() |
|
int |
ReadRecord.readInt() |
Read an integer from the underlying stream.
|
int |
Record.readInt() |
Read an integer from the underlying stream.
|
long |
AppendRecord.readLong() |
|
long |
ReadRecord.readLong() |
Read a long from the underlying stream.
|
long |
Record.readLong() |
Read a long from the underlying stream.
|
NodeId |
AbstractRecord.readNodeId() |
Read a NodeId from the underlying stream.
|
NodeId |
Record.readNodeId() |
Read a NodeId from the underlying stream.
|
QNodeTypeDefinition |
AbstractRecord.readNodeTypeDef() |
Read a NodeTypeDef from the underlying stream.
|
QNodeTypeDefinition |
Record.readNodeTypeDef() |
Read a NodeTypeDef from the underlying stream.
|
Path |
AbstractRecord.readPath() |
Read a Path from the underlying stream.
|
Path |
Record.readPath() |
Read a Path from the underlying stream.
|
Path |
AbstractRecord.readPathElement() |
Read a named path element from the underlying stream.
|
Path |
Record.readPathElement() |
Read a named path element from the underlying stream.
|
PrivilegeDefinition |
AbstractRecord.readPrivilegeDef() |
Read a PrivilegeDefinition from the underlying stream.
|
PrivilegeDefinition |
Record.readPrivilegeDef() |
Read a PrivilegeDefinition from the underlying stream.
|
PropertyId |
AbstractRecord.readPropertyId() |
Read a PropertyId from the underlying stream.
|
PropertyId |
Record.readPropertyId() |
Read a PropertyId from the underlying stream.
|
Name |
AbstractRecord.readQName() |
Read a Name frmo the underlying stream.
|
Name |
Record.readQName() |
Read a Name frmo the underlying stream.
|
String |
AppendRecord.readString() |
|
String |
ReadRecord.readString() |
Read a string from the underlying stream.
|
String |
Record.readString() |
Read a string from the underlying stream.
|
void |
AbstractJournal.register(RecordConsumer consumer) |
Register a record consumer.
|
void |
Journal.register(RecordConsumer consumer) |
Register a record consumer.
|
void |
DatabaseJournal.DatabaseRevision.set(long localRevision) |
|
void |
FileRevision.set(long value) |
Set current counter value.
|
void |
InstanceRevision.set(long value) |
Set current instance revision.
|
void |
MemoryRevision.set(long value) |
Set current instance revision.
|
void |
AbstractJournal.sync(boolean startup) |
Synchronize contents from journal.
|
void |
Journal.sync(boolean startup) |
Synchronize contents from journal.
|
long |
AppendRecord.update() |
Update the changes made to an appended record.
|
long |
ReadRecord.update() |
|
long |
Record.update() |
Update the changes made to an appended record.
|
void |
AppendRecord.write(byte[] b) |
Write an array of bytes to the underlying stream.
|
void |
ReadRecord.write(byte[] b) |
|
void |
Record.write(byte[] b) |
Write an array of bytes to the underlying stream.
|
void |
AppendRecord.writeBoolean(boolean b) |
Write a boolean from the underlying stream.
|
void |
ReadRecord.writeBoolean(boolean b) |
|
void |
Record.writeBoolean(boolean b) |
Write a boolean from the underlying stream.
|
void |
AppendRecord.writeByte(int n) |
Write a byte to the underlying stream.
|
void |
ReadRecord.writeByte(int n) |
Unsupported methods when appending.
|
void |
Record.writeByte(int n) |
Write a byte to the underlying stream.
|
void |
AppendRecord.writeChar(char c) |
Write a character to the underlying stream.
|
void |
ReadRecord.writeChar(char c) |
|
void |
Record.writeChar(char c) |
Write a character to the underlying stream.
|
void |
AppendRecord.writeInt(int n) |
Write an integer to the underlying stream.
|
void |
ReadRecord.writeInt(int n) |
|
void |
Record.writeInt(int n) |
Write an integer to the underlying stream.
|
void |
AppendRecord.writeLong(long n) |
Write a long to the underlying stream.
|
void |
ReadRecord.writeLong(long n) |
|
void |
Record.writeLong(long n) |
Write a long to the underlying stream.
|
void |
AbstractRecord.writeNodeId(NodeId nodeId) |
Write a NodeId to the underlying stream.
|
void |
Record.writeNodeId(NodeId nodeId) |
Write a NodeId to the underlying stream.
|
void |
AbstractRecord.writeNodeTypeDef(QNodeTypeDefinition ntd) |
Write a NodeTypeDef to the underlying stream.
|
void |
Record.writeNodeTypeDef(QNodeTypeDefinition ntd) |
Write a NodeTypeDef to the underlying stream.
|
void |
AbstractRecord.writePath(Path path) |
Write a Path to the underlying stream.
|
void |
Record.writePath(Path path) |
Write a Path to the underlying stream.
|
void |
AbstractRecord.writePathElement(Path path) |
Write a Path.Element to the underlying stream.
|
void |
Record.writePathElement(Path element) |
Write a Path.Element to the underlying stream.
|
void |
AbstractRecord.writePrivilegeDef(PrivilegeDefinition privilegeDefinition) |
Write a PrivilegeDefinition to the underlying stream.
|
void |
Record.writePrivilegeDef(PrivilegeDefinition privilegeDefinition) |
Write a PrivilegeDefinition to the underlying stream.
|
void |
AbstractRecord.writePropertyId(PropertyId propertyId) |
Write a PropertyId to the underlying stream.
|
void |
Record.writePropertyId(PropertyId propertyId) |
Write a PropertyId to the underlying stream.
|
void |
AbstractRecord.writeQName(Name name) |
Write a Name to the underlying stream.
|
void |
ReadRecord.writeQName(Name name) |
|
void |
Record.writeQName(Name name) |
Write a Name to the underlying stream.
|
void |
AppendRecord.writeString(String s) |
Write a string to the underlying stream.
|
void |
ReadRecord.writeString(String s) |
|
void |
Record.writeString(String s) |
Write a string to the underlying stream.
|