Activity
Reduce ReplicatedLogEntry proliferation
Reduce ReplicatedLogEntry proliferation
Refactor PekkoPersistenceContract a bit
Refactor PekkoPersistenceContract a bit
Isolate Pekko Snapshotter methods in RaftActor
Isolate Pekko Snapshotter methods in RaftActor
Simplify appendReceived() signature
Simplify appendReceived() signature
Add ReplicatedLog.lookupStoredMeta()
Add ReplicatedLog.lookupStoredMeta()
Propagate SegmentedByteBufJournal.close()
Propagate SegmentedByteBufJournal.close()
Report IOException from EntryWriter.flush()
Report IOException from EntryWriter.flush()
Propagate SegmentedByteBufJournal.close()
Propagate SegmentedByteBufJournal.close()
Release FileWriter for inactive JournalSegments
Release FileWriter for inactive JournalSegments
Propagate SegmentedByteBufJournal.close()
Propagate SegmentedByteBufJournal.close()
Report IOException from SegmentedByteBufJournal.size()
Report IOException from SegmentedByteBufJournal.size()
Simplify SharedFileBackedOutputStream callback
Simplify SharedFileBackedOutputStream callback
Refactor base.messages.ApplyState
Refactor base.messages.ApplyState