GoogleCloudPlatform / cloud-run-kafka-scaler

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 125 units with 1,417 lines of code in units (53.5% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
3 medium complex units (174 lines of code)
5 simple units (193 lines of code)
117 very simple units (1,050 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
public void scale() in src/main/java/com/google/cloud/run/kafkascaler/Scaler.java	83	20	0
private Optional stabilizeRecommendation() in src/main/java/com/google/cloud/run/kafkascaler/ScalingStabilizer.java	41	11	5
public static Recommendation makeRecommendation() in src/main/java/com/google/cloud/run/kafkascaler/CpuScaling.java	50	11	2
public void scheduleTasks() in src/main/java/com/google/cloud/run/kafkascaler/SelfScheduler.java	30	9	2
static Scaling fromYamlMap() in src/main/java/com/google/cloud/run/kafkascaler/scalingconfig/Scaling.java	32	8	2
private Optional rateLimitScaleUpRecommendation() in src/main/java/com/google/cloud/run/kafkascaler/ScalingStabilizer.java	50	8	4
private Optional rateLimitScaleDownRecommendation() in src/main/java/com/google/cloud/run/kafkascaler/ScalingStabilizer.java	50	8	4
public int getBoundedRecommendation() in src/main/java/com/google/cloud/run/kafkascaler/ScalingStabilizer.java	31	7	4
public void markScaleEvent() in src/main/java/com/google/cloud/run/kafkascaler/ScalingStabilizer.java	16	5	4
SchedulingConfig selfSchedulingConfig() in src/main/java/com/google/cloud/run/kafkascaler/ConfigurationProvider.java	28	5	0
public int getWorkerPoolInstanceCount() in src/main/java/com/google/cloud/run/kafkascaler/clients/CloudRunClientWrapper.java	13	5	1
public int getServiceInstanceCount() in src/main/java/com/google/cloud/run/kafkascaler/clients/CloudRunClientWrapper.java	13	5	1
public static Behavior merge() in src/main/java/com/google/cloud/run/kafkascaler/scalingconfig/Merger.java	21	4	2
static Behavior fromYamlMap() in src/main/java/com/google/cloud/run/kafkascaler/scalingconfig/Behavior.java	21	4	2
static Metric fromYamlMap() in src/main/java/com/google/cloud/run/kafkascaler/scalingconfig/Metric.java	28	4	2
private void updateInstanceCount() in src/main/java/com/google/cloud/run/kafkascaler/Scaler.java	16	4	1
private int getBoundedRecommendationForScaleUp() in src/main/java/com/google/cloud/run/kafkascaler/ScalingStabilizer.java	23	4	5
private int getBoundedRecommendationForScaleDown() in src/main/java/com/google/cloud/run/kafkascaler/ScalingStabilizer.java	23	4	5
StaticConfig staticConfig() in src/main/java/com/google/cloud/run/kafkascaler/ConfigurationProvider.java	21	4	0
static ImmutableMap getRequestHeaderMap() in src/main/java/com/google/cloud/run/kafkascaler/RequestResponseHandler.java	10	4	1
public void updateWorkerPoolMinInstances() in src/main/java/com/google/cloud/run/kafkascaler/clients/CloudRunClientWrapper.java	32	4	2
public void updateServiceMinInstances() in src/main/java/com/google/cloud/run/kafkascaler/clients/CloudRunClientWrapper.java	31	4	2
static Spec fromYamlMap() in src/main/java/com/google/cloud/run/kafkascaler/scalingconfig/Spec.java	22	3	2
static MetricTarget fromYamlMap() in src/main/java/com/google/cloud/run/kafkascaler/scalingconfig/MetricTarget.java	26	3	2
static Policy fromYamlMap() in src/main/java/com/google/cloud/run/kafkascaler/scalingconfig/Policy.java	20	3	2
private static Instant getStabilizationCutoff() in src/main/java/com/google/cloud/run/kafkascaler/ScalingStabilizer.java	6	3	2
public static Recommendation makeRecommendation() in src/main/java/com/google/cloud/run/kafkascaler/LagScaling.java	23	3	3
public void handle() in src/main/java/com/google/cloud/run/kafkascaler/KafkaScaler.java	15	3	1
public void writeMetric() in src/main/java/com/google/cloud/run/kafkascaler/MetricsService.java	31	3	3
public static WorkloadInfo parse() in src/main/java/com/google/cloud/run/kafkascaler/WorkloadInfoParser.java	19	3	1
private ImmutableSet getMissingEnvVars() in src/main/java/com/google/cloud/run/kafkascaler/ConfigurationProvider.java	10	3	1
public String scalerUrl() in src/main/java/com/google/cloud/run/kafkascaler/ConfigurationProvider.java	14	3	1
public String projectNumberRegion() in src/main/java/com/google/cloud/run/kafkascaler/clients/CloudRunMetadataClient.java	19	3	0
public static void checkKeyExists() in src/main/java/com/google/cloud/run/kafkascaler/scalingconfig/Validation.java	6	2	3
private Instant getNextUpdateAllowedTime() in src/main/java/com/google/cloud/run/kafkascaler/Scaler.java	12	2	1
private void writeMetrics() in src/main/java/com/google/cloud/run/kafkascaler/Scaler.java	11	2	3
private void setSelectorDebugString() in src/main/java/com/google/cloud/run/kafkascaler/ScalingStabilizer.java	6	2	1
private String toString() in src/main/java/com/google/cloud/run/kafkascaler/ScalingStabilizer.java	6	2	2
private void scheduleTask() in src/main/java/com/google/cloud/run/kafkascaler/SelfScheduler.java	22	2	2
public MetricsService() in src/main/java/com/google/cloud/run/kafkascaler/MetricsService.java	9	2	2
public int getCurrentConsumerCount() in src/main/java/com/google/cloud/run/kafkascaler/Kafka.java	6	2	1
Properties kafkaClientProperties() in src/main/java/com/google/cloud/run/kafkascaler/ConfigurationProvider.java	8	2	1
Properties kafkaClientProperties() in src/main/java/com/google/cloud/run/kafkascaler/ConfigurationProvider.java	14	2	1
public ScalingConfig scalingConfig() in src/main/java/com/google/cloud/run/kafkascaler/ConfigurationProvider.java	7	2	0
public static int getInstanceCount() in src/main/java/com/google/cloud/run/kafkascaler/InstanceCountProvider.java	7	2	2
static void sendFailureResponse() in src/main/java/com/google/cloud/run/kafkascaler/RequestResponseHandler.java	9	2	2
static void sendSuccessResponse() in src/main/java/com/google/cloud/run/kafkascaler/RequestResponseHandler.java	9	2	1
public Instant getWorkerPoolLastDeploymentTime() in src/main/java/com/google/cloud/run/kafkascaler/clients/CloudRunClientWrapper.java	6	2	1
public void updateWorkerPoolManualInstances() in src/main/java/com/google/cloud/run/kafkascaler/clients/CloudRunClientWrapper.java	29	2	2
public Instant getServiceLastDeploymentTime() in src/main/java/com/google/cloud/run/kafkascaler/clients/CloudRunClientWrapper.java	4	2	1