apache / incubator-pekko-managementConditional 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 180 units with 2,563 lines of code in units (42.5% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
6 medium complex units (376 lines of code)
22 simple units (567 lines of code)
152 very simple units (1,620 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
def encode() in management-cluster-http/src/main/scala/org/apache/pekko/management/cluster/ClusterDomainEventServerSentEventEncoder.scala	62	24	1
private def loadRouteProviders() in management/src/main/scala/org/apache/pekko/management/scaladsl/PekkoManagement.scala	53	16	0
def bootstrapping() in management-cluster-bootstrap/src/main/scala/org/apache/pekko/management/cluster/bootstrap/internal/BootstrapCoordinator.scala	76	15	2
override def decide() in management-cluster-bootstrap/src/main/scala/org/apache/pekko/management/cluster/bootstrap/LowestAddressJoinDecider.scala	65	13	1
private[kubernetes] def targets() in discovery-kubernetes-api/src/main/scala/org/apache/pekko/discovery/kubernetes/KubernetesApiServiceDiscovery.scala	37	12	6
private def routeGetClusterDomainEvents() in management-cluster-http/src/main/scala/org/apache/pekko/management/cluster/scaladsl/ClusterHttpManagementRoutes.scala	83	11	1
private def prepareCombinedRoutes() in management/src/main/scala/org/apache/pekko/management/scaladsl/PekkoManagement.scala	40	9	1
def memberStatus() in management-cluster-http/src/main/scala/org/apache/pekko/management/cluster/scaladsl/ClusterMembershipCheck.scala	13	9	1
private def encode() in management-cluster-http/src/main/scala/org/apache/pekko/management/cluster/ClusterDomainEventServerSentEventEncoder.scala	15	9	1
private def load() in management/src/main/scala/org/apache/pekko/management/internal/HealthChecksImpl.scala	27	8	1
private def check() in management/src/main/scala/org/apache/pekko/management/internal/HealthChecksImpl.scala	29	8	1
override def updateLeaseResource() in lease-kubernetes/src/main/scala/org/apache/pekko/coordination/lease/kubernetes/internal/KubernetesApiImpl.scala	44	8	4
override def lookup() in discovery-kubernetes-api/src/main/scala/org/apache/pekko/discovery/kubernetes/KubernetesApiServiceDiscovery.scala	61	8	2
def apply() in management/src/main/scala/org/apache/pekko/management/HealthCheckSettings.scala	29	7	1
def classicLogLevelName() in management-loglevels-log4j2/src/main/scala/org/apache/pekko/management/loglevels/log4j2/LogLevelRoutes.scala	8	7	1
override def acquire() in lease-kubernetes/src/main/scala/org/apache/pekko/coordination/lease/kubernetes/KubernetesLease.scala	11	7	1
override def readOrCreateLeaseResource() in lease-kubernetes/src/main/scala/org/apache/pekko/coordination/lease/kubernetes/internal/KubernetesApiImpl.scala	23	7	1
def main() in lease-kubernetes-int-test/src/main/scala/org/apache/pekko/coordination/lease/kubernetes/LeaseTestSuite.scala	31	7	1
override def apply() in project/CopyrightHeader.scala	14	7	2
def classicLogLevelName() in management-loglevels-logback/src/main/scala/org/apache/pekko/management/loglevels/logback/LogLevelRoutes.scala	8	7	1
private def resolveTasks() in discovery-aws-api-async/src/main/scala/org/apache/pekko/discovery/awsapi/ecs/AsyncEcsTaskSetDiscovery.scala	16	6	3
def routes: Route = prepareCombinedRoutes() in management/src/main/scala/org/apache/pekko/management/scaladsl/PekkoManagement.scala	38	6	1
def hasDefined() in management/src/main/scala/org/apache/pekko/management/PekkoManagementSettings.scala	11	6	1
override def beforeAll() in integration-test/aws-api-ec2/src/it/scala/org/apache/pekko/cluster/bootstrap/IntegrationTest.scala	51	6	0
override def checkLease() in lease-kubernetes/src/main/scala/org/apache/pekko/coordination/lease/kubernetes/KubernetesLease.scala	13	6	0
private[pekko] def removeLease() in lease-kubernetes/src/main/scala/org/apache/pekko/coordination/lease/kubernetes/internal/KubernetesApiImpl.scala	26	6	1
private def getLeaseResource() in lease-kubernetes/src/main/scala/org/apache/pekko/coordination/lease/kubernetes/internal/KubernetesApiImpl.scala	29	6	1
private def createLeaseResource() in lease-kubernetes/src/main/scala/org/apache/pekko/coordination/lease/kubernetes/internal/KubernetesApiImpl.scala	30	6	1
private[this] def resolveTaskMetadata() in discovery-aws-api-async/src/main/scala/org/apache/pekko/discovery/awsapi/ecs/AsyncEcsTaskSetDiscovery.scala	18	5	1
override def routes() in management-loglevels-log4j2/src/main/scala/org/apache/pekko/management/loglevels/log4j2/LogLevelRoutes.scala	55	5	1
private def routeFindMember() in management-cluster-http/src/main/scala/org/apache/pekko/management/cluster/scaladsl/ClusterHttpManagementRoutes.scala	18	5	2
private def routeGetShardInfo() in management-cluster-http/src/main/scala/org/apache/pekko/management/cluster/scaladsl/ClusterHttpManagementRoutes.scala	25	5	2
override def apply() in project/CopyrightHeader.scala	11	5	2
override def routes() in management-loglevels-logback/src/main/scala/org/apache/pekko/management/loglevels/logback/LogLevelRoutes.scala	59	5	1
def name() in management-cluster-bootstrap/src/main/scala/org/apache/pekko/management/cluster/bootstrap/internal/HttpContactPointBootstrap.scala	6	5	2
private def resetProbingKeepFailingWithinDeadline() in management-cluster-bootstrap/src/main/scala/org/apache/pekko/management/cluster/bootstrap/internal/HttpContactPointBootstrap.scala	24	5	0
private[internal] def ensureProbing() in management-cluster-bootstrap/src/main/scala/org/apache/pekko/management/cluster/bootstrap/internal/BootstrapCoordinator.scala	28	5	2
private[this] def resolveTaskSet() in discovery-aws-api-async/src/main/scala/org/apache/pekko/discovery/awsapi/ecs/AsyncEcsTaskSetDiscovery.scala	33	4	3
private[this] def listTaskArns() in discovery-aws-api-async/src/main/scala/org/apache/pekko/discovery/awsapi/ecs/AsyncEcsServiceDiscovery.scala	28	4	5
def readyResult() in management/src/main/scala/org/apache/pekko/management/internal/HealthChecksImpl.scala	11	4	0
def ready() in management/src/main/scala/org/apache/pekko/management/internal/HealthChecksImpl.scala	12	4	0
override def withAuth() in management/src/main/scala/org/apache/pekko/management/javadsl/ManagementRouteProviderSettings.scala	21	4	2
def hasDefined() in lease-kubernetes/src/main/scala/org/apache/pekko/coordination/lease/kubernetes/KubernetesSettings.scala	8	4	1
protected def readConfigVarFromFilesystem() in lease-kubernetes/src/main/scala/org/apache/pekko/coordination/lease/kubernetes/internal/KubernetesApiImpl.scala	15	4	2
private def routeGetMembers() in management-cluster-http/src/main/scala/org/apache/pekko/management/cluster/scaladsl/ClusterHttpManagementRoutes.scala	17	4	1
private def routePutMember() in management-cluster-http/src/main/scala/org/apache/pekko/management/cluster/scaladsl/ClusterHttpManagementRoutes.scala	15	4	2
def decoded() in management-cluster-http/src/main/scala/org/apache/pekko/management/cluster/scaladsl/ClusterHttpManagementRoutes.scala	6	4	2
private def readConfigVarFromFilesystem() in discovery-kubernetes-api/src/main/scala/org/apache/pekko/discovery/kubernetes/KubernetesApiServiceDiscovery.scala	15	4	2
override def lookup() in discovery-marathon-api/src/main/scala/org/apache/pekko/discovery/marathon/MarathonApiServiceDiscovery.scala	30	4	2
def props() in management-cluster-bootstrap/src/main/scala/org/apache/pekko/management/cluster/bootstrap/internal/BootstrapCoordinator.scala	11	4	3