apache / pekko-persistence-jdbc - Conditional Complexity

Intro

Conditional complexity (also called cyclomatic complexity) is a term used to measure the complexity of software. The term refers to the number of possible paths through a program function. A higher value ofter means higher maintenance and testing costs (infosecinstitute.com).
Conditional complexity is calculated by counting all conditions in the program that can affect the execution path (e.g. if statement, loops, switches, and/or operators, try and catch blocks...).
Conditional complexity is measured at the unit level (methods, functions...).
Units are classified in four categories based on the measured McCabe index: 1-5 (simple units), 6-10 (medium complex units), 11-25 (complex units), 26+ (very complex units).

Learn more...

Conditional Complexity Overall

There are 147 units with 1,615 lines of code in units (37.6% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
6 medium complex units (267 lines of code)
8 simple units (118 lines of code)
133 very simple units (1,230 lines of code)

Legend:

51+

26-50

11-25

6-10

1-5

Alternative Visuals

3D view of all units

Conditional Complexity per Extension

51+

26-50

11-25

6-10

1-5

Conditional Complexity per Logical Component

primary logical decomposition

51+

26-50

11-25

6-10

1-5

Most Complex Units

Top 50 most complex units

Unit	# lines	McCabe index	# params
private[dao] def internalBatchStream() in core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/BaseJournalDaoWithReadMessages.scala	49	18	6
final def findGaps() in core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/DurableStateSequenceActor.scala	69	16	5
private[jdbc] def changesByTag() in core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/JdbcDurableStateStore.scala	40	14	3
private def eventsByTag() in core/src/main/scala/org/apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala	40	14	3
final def receive() in core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/DurableStateSequenceActor.scala	37	12	5
def receive() in core/src/main/scala/org/apache/pekko/persistence/jdbc/query/JournalSequenceActor.scala	32	11	5
def props() in core/src/main/scala/org/apache/pekko/persistence/jdbc/query/JournalSequenceActor.scala	17	9	2
override def apply() in project/CopyrightHeader.scala	14	7	2
def findGaps() in core/src/main/scala/org/apache/pekko/persistence/jdbc/query/JournalSequenceActor.scala	30	7	5
private def dropScriptFor() in core/src/main/scala/org/apache/pekko/persistence/jdbc/testkit/internal/SchemaUtilsImpl.scala	10	7	2
private def createScriptFor() in core/src/main/scala/org/apache/pekko/persistence/jdbc/testkit/internal/SchemaUtilsImpl.scala	10	7	2
private[jdbc] def slickProfileToSchemaType() in core/src/main/scala/org/apache/pekko/persistence/jdbc/testkit/internal/SchemaUtilsImpl.scala	9	7	1
override def loadAsync() in core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/JdbcSnapshotStore.scala	16	6	2
override def deleteAsync() in core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/JdbcSnapshotStore.scala	12	6	2
override def apply() in project/CopyrightHeader.scala	11	5	2
def writeJournalRows() in core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/BaseDao.scala	15	5	1
override def asyncWriteMessages() in core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/DefaultJournalDao.scala	36	5	1
private def applyScriptWithSlick() in core/src/main/scala/org/apache/pekko/persistence/jdbc/testkit/internal/SchemaUtilsImpl.scala	21	5	4
def fromRow() in core/src/main/scala/org/apache/pekko/persistence/jdbc/PekkoSerialization.scala	25	5	1
def sequence[A]() in core/src/main/scala/org/apache/pekko/persistence/jdbc/util/TrySeq.scala	9	4	1
private def toSnapshotData() in core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/DefaultSnapshotDao.scala	17	4	1
override def asyncDeleteMessagesTo() in core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/JdbcAsyncWriteJournal.scala	10	4	2
def writeJournalRows() in core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/JournalQueries.scala	14	4	2
def contains() in core/src/main/scala/org/apache/pekko/persistence/jdbc/MissingElements.scala	12	4	1
def migrate() in migrator/src/main/scala/org/apache/pekko/persistence/jdbc/migrator/JournalMigrator.scala	7	3	0
private def isApacheCopyrighted() in project/CopyrightHeader.scala	6	3	1
override def getObject() in core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/JdbcDurableStateStore.scala	12	3	1
override def upsertObject() in core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/JdbcDurableStateStore.scala	27	3	4
override def deleteObject() in core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/JdbcDurableStateStore.scala	15	3	1
override def receive: Receive = receive() in core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/DurableStateSequenceActor.scala	10	3	3
private def addToRevisionCache() in core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/DurableStateSequenceActor.scala	4	3	2
private def evictRevisionCacheIfNeeded() in core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/DurableStateSequenceActor.scala	8	3	0
override def receive: Receive = receive() in core/src/main/scala/org/apache/pekko/persistence/jdbc/query/JournalSequenceActor.scala	10	3	3
override def currentEventsByPersistenceId() in core/src/main/scala/org/apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala	30	3	3
override def currentEventsByTag() in core/src/main/scala/org/apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala	16	3	2
override def lastPersistenceIdSequenceNumber() in core/src/main/scala/org/apache/pekko/persistence/jdbc/query/dao/legacy/ByteArrayReadJournalDao.scala	17	3	1
private def isOracleDriver() in core/src/main/scala/org/apache/pekko/persistence/jdbc/query/dao/legacy/ByteArrayReadJournalDao.scala	5	3	1
def asStringOption() in core/src/main/scala/org/apache/pekko/persistence/jdbc/util/ConfigOps.scala	6	3	1
def check() in core/src/main/scala/org/apache/pekko/persistence/jdbc/util/PluginVersionChecker.scala	8	3	0
def toSnapshotData() in core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/legacy/ByteArraySnapshotDao.scala	5	3	1
private def zeroOrOneSnapshot() in core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/DefaultSnapshotDao.scala	9	3	1
def asyncWriteMessages() in core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/ByteArrayJournalDao.scala	10	3	1
def update() in core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/ByteArrayJournalDao.scala	11	3	3
override def messages() in core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/ByteArrayJournalDao.scala	14	3	4
private def getSharedDbOrThrow() in core/src/main/scala/org/apache/pekko/persistence/jdbc/db/SlickExtension.scala	12	3	1
def serialize() in core/src/main/scala/org/apache/pekko/persistence/jdbc/serialization/PersistentReprSerializer.scala	6	3	1
private def toSnapshotData() in migrator/src/main/scala/org/apache/pekko/persistence/jdbc/migrator/SnapshotMigrator.scala	14	2	1
private def writeJournalRowsStatements() in migrator/src/main/scala/org/apache/pekko/persistence/jdbc/migrator/JournalMigrator.scala	10	2	2
override def changes() in core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/JdbcDurableStateStore.scala	10	2	2
private def updateDurableState() in core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/JdbcDurableStateStore.scala	7	2	1