epam / epam-kafkaConditional 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 383 units with 4,767 lines of code in units (66.0% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
5 medium complex units (305 lines of code)
29 simple units (1,041 lines of code)
349 very simple units (3,421 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 IReadOnlyCollection CommitOrReset() in src/Epam.Kafka.PubSub.EntityFrameworkCore/Subscription/DbContextOffsetsStorage.cs	59	12	3
public void Execute() in src/Epam.Kafka.PubSub/Subscription/Replication/ReplicationHandler.cs	65	12	2
public IReadOnlyCollection GetOrCreate() in src/Epam.Kafka.PubSub.EntityFrameworkCore/Subscription/DbContextOffsetsStorage.cs	47	11	3
public async Task CheckHealthAsync() in src/Epam.Kafka.HealthChecks/ClusterHealthCheck.cs	78	11	2
private void ReadToBuffer() in src/Epam.Kafka.PubSub/Subscription/Topics/SubscriptionTopicWrapper.cs	56	11	2
protected override HealthStatus GetBatchStatus() in src/Epam.Kafka.PubSub/Subscription/HealthChecks/SubscriptionHealthCheck.cs	36	10	0
public Task CheckHealthAsync() in src/Epam.Kafka.PubSub/Common/HealthChecks/PubSubHealthCheck.cs	42	10	2
public static string Replace() in src/Epam.Kafka/Internals/CompatibilityExtensions.cs	47	9	4
private static string? ValidateSerializers() in src/Epam.Kafka.PubSub/Subscription/Options/SubscriptionOptionsValidate.cs	29	9	1
public static void CommitOffsetIfNeeded() in src/Epam.Kafka.PubSub/Subscription/State/ExternalStateExtensions.cs	42	9	3
internal bool TryRegisterGroupId() in src/Epam.Kafka.PubSub/Common/Pipeline/PipelineMonitor.cs	33	9	3
protected sealed override void Callback() in src/Epam.Kafka.PubSub.EntityFrameworkCore/Publication/DbContextPublicationHandler.cs	31	8	3
public static string? ValidateInternal() in src/Epam.Kafka.PubSub/Publication/Options/PublicationOptionsValidate.cs	21	8	1
protected override HealthStatus GetBatchStatus() in src/Epam.Kafka.PubSub/Publication/HealthChecks/PublicationHealthCheck.cs	27	8	0
public static IPublicationTopicWrapper CreatePublicationTopicWrapper() in src/Epam.Kafka.PubSub/Publication/Topics/PublicationTopicWrapperExtensions.cs	38	8	4
protected override void ExecuteBatch() in src/Epam.Kafka.PubSub/Subscription/SubscriptionBackgroundService.cs	54	8	4
public PublicationTopicWrapper() in src/Epam.Kafka.PubSub/Publication/Topics/PublicationTopicWrapper.cs	50	7	7
public void SetResult() in src/Epam.Kafka.PubSub/Utils/ActivityWrapper.cs	33	7	1
public static void GetOffsetsRange() in src/Epam.Kafka.PubSub/Utils/OffsetsExtensions.cs	26	7	3
protected override void AssignConsumer() in src/Epam.Kafka.PubSub/Subscription/State/ExternalState.cs	42	7	3
private bool OnPauseEnumerate() in src/Epam.Kafka.PubSub/Subscription/Topics/SubscriptionTopicWrapper.cs	31	7	1
private void OnPartitionsAssigned() in src/Epam.Kafka.PubSub/Subscription/Topics/SubscriptionTopicWrapper.cs	40	7	2
private static List GetLocalState() in src/Epam.Kafka.PubSub.EntityFrameworkCore/Subscription/DbContextOffsetsStorage.cs	23	6	4
public IConsumer CreateConsumer() in src/Epam.Kafka/Internals/KafkaFactory.cs	50	6	3
public IProducer CreateProducer() in src/Epam.Kafka/Internals/KafkaFactory.cs	50	6	3
private void ExecuteBatchInternal() in src/Epam.Kafka.PubSub/Publication/PublicationBackgroundService.cs	50	6	4
private void TryCompact() in src/Epam.Kafka.PubSub/Subscription/SubscriptionHandler.cs	28	6	2
private List AutoResetOffsets() in src/Epam.Kafka.PubSub/Subscription/Topics/SubscriptionTopicWrapper.cs	34	6	2
public void OnReset() in src/Epam.Kafka.PubSub/Subscription/Topics/SubscriptionTopicWrapper.cs	30	6	1
public static string? ValidateString() in src/Epam.Kafka.PubSub/Common/Options/PubSubOptionsValidate.cs	13	6	4
private void ExecutePipeline() in src/Epam.Kafka.PubSub/Common/PubSubBackgroundService.cs	43	6	1
internal void AddReplication() in src/Epam.Kafka.PubSub/Common/PubSubContext.cs	34	6	1
internal SubscriptionMonitor AddSubscription() in src/Epam.Kafka.PubSub/Common/PubSubContext.cs	32	6	1
internal PublicationMonitor AddPublication() in src/Epam.Kafka.PubSub/Common/PubSubContext.cs	32	6	1
protected override void TransactionCommitted() in src/Epam.Kafka.PubSub.EntityFrameworkCore/Publication/Contracts/DbContextEntityPublicationHandler.cs	25	5	2
public ValidateOptionsResult Validate() in src/Epam.Kafka/Options/Validation/ConsumerValidation.cs	24	5	2
public KafkaBuilder WithConfigPlaceholders() in src/Epam.Kafka/KafkaBuilder.Placeholders.cs	26	5	2
public static int GetCancellationDelayMaxMs() in src/Epam.Kafka/KafkaConfigExtensions.cs	18	5	1
internal static void ValidatePlaceholder() in src/Epam.Kafka/KafkaConfigExtensions.cs	13	5	2
private static void ConfigureReports() in src/Epam.Kafka.PubSub/Publication/Topics/PublicationTopicWrapper.cs	24	5	1
private static IEnumerable SplitTopics() in src/Epam.Kafka.PubSub/Subscription/Options/SubscriptionOptionsExtensions.cs	18	5	2
protected override void AssignConsumer() in src/Epam.Kafka.PubSub/Subscription/State/CombinedState.cs	28	5	3
public static IReadOnlyCollection CommitState() in src/Epam.Kafka.PubSub/Subscription/State/ExternalStateExtensions.cs	41	5	5
protected override TimeSpan? GetBatchFinishedTimeout() in src/Epam.Kafka.PubSub/Subscription/SubscriptionBackgroundService.cs	14	5	1
public SubscriptionTopicWrapper() in src/Epam.Kafka.PubSub/Subscription/Topics/SubscriptionTopicWrapper.cs	41	5	6
private void ConfigureConsumerConfig() in src/Epam.Kafka.PubSub/Subscription/Topics/SubscriptionTopicWrapper.cs	17	5	1
public Task CheckHealthAsync() in src/Epam.Kafka.PubSub/Common/HealthChecks/PubSubSummaryHealthCheck.cs	27	5	2
private TBatchResult ExecuteBatchWrapper() in src/Epam.Kafka.PubSub/Common/PubSubBackgroundService.cs	49	5	3
private void HandleBatchSizeReduction() in src/Epam.Kafka.PubSub/Common/PubSubBackgroundService.cs	12	5	1
protected sealed override void Callback() in src/Epam.Kafka.PubSub.EntityFrameworkCore/Publication/Contracts/DbContextEntityPublicationHandler.cs	21	4	3