apache / incubator-pekko-persistence-r2dbcConditional 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 191 units with 3,849 lines of code in units (66.2% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
6 medium complex units (500 lines of code)
21 simple units (759 lines of code)
164 very simple units (2,590 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 add() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcOffsetStore.scala	38	12	1
def writeEvents() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/journal/JournalDao.scala	77	11	1
private def beforeQuery() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/BySliceQuery.scala	41	10	5
def nextOffset() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/BySliceQuery.scala	44	9	2
override def withStatusObserver() in projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcProjectionImpl.scala	76	9	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
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
override def asyncWriteMessages() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/journal/R2dbcJournal.scala	64	7	1
override def apply() in project/CopyrightHeader.scala	13	7	2
@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
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
private def stateBySlicesRangeSql() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/scaladsl/DurableStateDao.scala	26	6	5
override def deleteObject() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/scaladsl/R2dbcDurableStateStore.scala	54	6	1
private def createConnectionFactory() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/ConnectionFactoryProvider.scala	31	6	1
private def createConnectionPoolFactory() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/ConnectionFactoryProvider.scala	29	6	1
@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 eventsBySlicesRangeSql() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/QueryDao.scala	28	6	5
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 findTimeForLimit() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/BySliceQuery.scala	17	5	2
def withConnection[A]() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/R2dbcExecutor.scala	27	5	1
private 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
@InternalApi private[pekko] def deduplicate[Event]() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/R2dbcReadJournal.scala	31	5	1
private 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 apply() in project/CopyrightHeader.scala	11	5	2
private def migrateEvents() in migration/src/main/scala/org/apache/pekko/persistence/r2dbc/migration/MigrationTool.scala	29	5	2
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
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
def readHighestSequenceNr() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/journal/JournalDao.scala	17	4	2
def deserializeRow() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/journal/R2dbcJournal.scala	19	4	2
override def asyncReadHighestSequenceNr() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/journal/R2dbcJournal.scala	10	4	2
def clearUntil() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/BySliceQuery.scala	10	4	1
private def deserializeAndAddOffset() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/BySliceQuery.scala	32	4	1
def select[A]() in core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/R2dbcExecutor.scala	27	4	1