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 org.apache.pekko.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
Method Summary

Modifier and Type

Method

Description

scala.PartialFunction<Object,scala.runtime.BoxedUnit>

receiveCompactionInternal()

void

tryCompactOnDelete(String persistenceId, long toSeqNr)

Methods inherited from interface org.apache.pekko.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, org$apache$pekko$actor$Actor$_setter_$context_$eq, org$apache$pekko$actor$Actor$_setter_$self_$eq, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled

Methods inherited from interface org.apache.pekko.actor.ActorLogging
_log_$eq, log

Methods inherited from interface org.apache.pekko.persistence.journal.leveldb.CompactionSegmentManagement
compactionInterval, compactionIntervals, compactionLimit, compactionSegment, isCompactionEnabled, isCompactionRequired, latestCompactionSegment, latestCompactionSegments_$eq, mustCompact, updateCompactionSegment

Method Details
- receiveCompactionInternal
  
  scala.PartialFunction<Object,scala.runtime.BoxedUnit> receiveCompactionInternal()
- tryCompactOnDelete
  
  void tryCompactOnDelete(String persistenceId, long toSeqNr)