apache / pekko-persistence-r2dbc - 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 215 units with 4,184 lines of code in units (64.4% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
7 medium complex units (521 lines of code)
23 simple units (817 lines of code)
185 very simple units (2,846 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
override def shape: SourceShape[T] = SourceShape() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/ContinuousQuery.scala	97	23	1
def liveBySlices() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/BySliceQuery.scala	112	21	5
private def isAccepted[Envelope]() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcOffsetStore.scala	115	17	3
def loadEnvelope[Envelope]() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcProjectionImpl.scala	61	16	3
def writeEvents() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/journal/JournalDao.scala	87	15	1
override def equals() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/R2dbcProjectionSettings.scala	11	13	1
def add() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcOffsetStore.scala	38	12	1
private def beforeQuery() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/BySliceQuery.scala	41	10	5
override def withStatusObserver() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcProjectionImpl.scala	76	9	1
def nextOffset() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/BySliceQuery.scala	44	9	2
private def saveTimestampOffsetInTx[Offset]() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcOffsetStore.scala	43	8	2
private def createRecordWithOffset[Envelope]() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcOffsetStore.scala	24	8	1
def writeState() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/scaladsl/DurableStateDao.scala	71	8	1
def migrateAll() in migration/src/main/scala/org/apache/pekko/persistence/r2dbc/migration/MigrationTool.scala	44	8	0
@tailrec private def cleanupInflight() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcOffsetStore.scala	19	7	1
def isDuplicate() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcOffsetStore.scala	25	7	1
override def apply() in project/CopyrightHeader.scala	13	7	2
private def createConnectionFactory() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/ConnectionFactoryProvider.scala	36	7	3
override def asyncWriteMessages() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/journal/R2dbcJournal.scala	64	7	1
private def createConnectionPoolFactory() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/ConnectionFactoryProvider.scala	32	6	3
override def stateBySlicesRangeSql() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/scaladsl/mysql/MySQLDurableStateDao.scala	26	6	5
protected def stateBySlicesRangeSql() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/scaladsl/DurableStateDao.scala	26	6	5
override def sliceForPersistenceId() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/scaladsl/R2dbcDurableStateStore.scala	50	6	1
protected def eventsBySlicesRangeSql() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/QueryDao.scala	28	6	5
override def eventsBySlicesRangeSql() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/mysql/MySQLQueryDao.scala	28	6	5
@InternalApi private[r2dbc] def internalEventsByPersistenceId() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/R2dbcReadJournal.scala	43	6	3
override def currentPersistenceIds() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/R2dbcReadJournal.scala	34	6	2
private def selectSql() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/snapshot/SnapshotDao.scala	20	6	1
private def deleteSql() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/snapshot/SnapshotDao.scala	18	6	1
def nextQueryToTimestamp() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/BySliceQuery.scala	12	6	1
def readOffset[Offset]() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcOffsetStore.scala	11	5	0
private def readTimestampOffset() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcOffsetStore.scala	41	5	0
def saveOffsetsInTx[Offset]() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcOffsetStore.scala	13	5	2
private def insertTimestampOffsetInTx() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcOffsetStore.scala	34	5	2
def isInflight[Envelope]() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcOffsetStore.scala	12	5	1
def deleteOldTimestampOffsets() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcOffsetStore.scala	39	5	0
def managementSetOffset[Offset]() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcOffsetStore.scala	23	5	1
override def apply() in project/CopyrightHeader.scala	11	5	2
private def createConnectionFactoryOptionsCustomizer() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/ConnectionFactoryProvider.scala	14	5	1
override def selectBucketsSql() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/scaladsl/mysql/MySQLDurableStateDao.scala	10	5	2
protected def selectBucketsSql() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/scaladsl/DurableStateDao.scala	10	5	2
override def rowsBySlices() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/scaladsl/DurableStateDao.scala	59	5	7
protected def selectBucketsSql() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/QueryDao.scala	11	5	2
def rowsBySlices() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/QueryDao.scala	64	5	7
override def selectBucketsSql() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/mysql/MySQLQueryDao.scala	11	5	2
@InternalApi private[pekko] def deduplicate[Event]() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/R2dbcReadJournal.scala	31	5	1
def fromString() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/R2dbcSettings.scala	10	5	1
def load() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/snapshot/SnapshotDao.scala	29	5	2
def delete() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/snapshot/SnapshotDao.scala	27	5	2
def withConnection[A]() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/R2dbcExecutor.scala	27	5	1