Package akka.persistence.journal.leveldb

Interface LeveldbCompaction

All Superinterfaces:

Actor, ActorLogging, CompactionSegmentManagement

All Known Subinterfaces:

LeveldbStore

All Known Implementing Classes:

SharedLeveldbStore

public interface LeveldbCompaction
extends Actor, ActorLogging, CompactionSegmentManagement

INTERNAL API.

Exposure of LevelDB compaction capability to reduce journal size upon message deletions.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	LeveldbCompaction.TryCompactLeveldb
static class	LeveldbCompaction.TryCompactLeveldb$

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Method Summary

Modifier and Type	Method	Description
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receiveCompactionInternal()
void	tryCompactOnDelete(java.lang.String persistenceId, long toSeqNr)

Methods inherited from interface akka.actor.Actor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.actor.ActorLogging

_log_$eq, log

Methods inherited from interface akka.persistence.journal.leveldb.CompactionSegmentManagement

compactionInterval, compactionIntervals, compactionLimit, compactionSegment, isCompactionEnabled, isCompactionRequired, latestCompactionSegment, latestCompactionSegments_$eq, mustCompact, updateCompactionSegment

Method Detail

receiveCompactionInternal

scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveCompactionInternal()

tryCompactOnDelete

void tryCompactOnDelete(java.lang.String persistenceId,
                        long toSeqNr)