Package | Description |
---|---|
org.apache.jackrabbit.core.cluster | |
org.apache.jackrabbit.core.journal |
Modifier and Type | Method and Description |
---|---|
ClusterRecord |
ClusterRecordDeserializer.deserialize(Record record)
Deserialize a cluster record.
|
protected void |
ChangeLogRecord.doRead()
Deserialize this record.
|
protected abstract void |
ClusterRecord.doRead()
Deserialize this record.
|
protected void |
LockRecord.doRead()
Deserialize this record.
|
protected void |
NamespaceRecord.doRead()
Deserialize this record.
|
protected void |
NodeTypeRecord.doRead()
Deserialize this record.
|
protected void |
PrivilegeRecord.doRead() |
protected void |
WorkspaceRecord.doRead() |
protected void |
ChangeLogRecord.doWrite()
Serialize this record.
|
protected abstract void |
ClusterRecord.doWrite()
Serialize this record.
|
protected void |
LockRecord.doWrite()
Serialize this record.
|
protected void |
NamespaceRecord.doWrite()
Serialize this record.
|
protected void |
NodeTypeRecord.doWrite()
Serialize this record.
|
protected void |
PrivilegeRecord.doWrite() |
protected void |
WorkspaceRecord.doWrite() |
void |
ClusterRecord.read()
Deserialize this record.
|
protected void |
ChangeLogRecord.readEndMarker()
Read end marker.
|
protected void |
ClusterRecord.readEndMarker()
Read end marker.
|
void |
ClusterRecord.update()
Update the record.
|
void |
ClusterRecord.write()
Serialize this record.
|
Modifier and Type | Method and Description |
---|---|
Record |
DefaultRecordProducer.append()
Append a record.
|
Record |
RecordProducer.append()
Append a record.
|
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.
|
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.
|
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 |
FileJournal.getRecords()
Return an iterator over all available records in the journal.
|
RecordIterator |
Journal.getRecords()
Return an iterator over all available records in the journal.
|
RecordIterator |
MemoryJournal.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(long startRevision)
Return an iterator over all records after the specified revision.
|
RecordIterator |
Journal.getRecords(long startRevision)
Return an iterator over all records after the specified revision.
|
RecordIterator |
MemoryJournal.getRecords(long startRevision)
Return an iterator over all records after the specified revision.
|
protected void |
DatabaseJournal.init()
Completes initialization of this database journal.
|
protected void |
JNDIDatabaseJournal.init()
Deprecated.
Overridden to avoid the driver and url checks in DatabaseJournal.
|
protected long |
DatabaseJournal.DatabaseRevision.init(long revision)
Checks whether there's a local revision value in the database for this
cluster node.
|
void |
AbstractJournal.init(String id,
NamespaceResolver resolver)
Initialize journal.
|
void |
DatabaseJournal.init(String id,
NamespaceResolver resolver)
Initialize journal.
|
void |
FileJournal.init(String id,
NamespaceResolver resolver)
Initialize journal.
|
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.
|
Constructor and Description |
---|
FileRevision(File file,
boolean sync)
Creates a new file based revision counter.
|
Copyright © 2004–2021 The Apache Software Foundation. All rights reserved.