azure / azure-functions-kafka-extension

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 249 units with 2,956 lines of code in units (63.1% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
4 medium complex units (268 lines of code)
13 simple units (531 lines of code)
232 very simple units (2,157 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
private ScaleStatus GetScaleStatusCore() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/Scaler/KafkaGenericTopicScaler.cs	87	19	2
public FuncAsyncConverter GetConverter() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaEventDataConvertManager.cs	42	14	2
protected override async Task ReaderAsync() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/MultipleItemFunctionExecutor.cs	76	12	3
internal static void InitializeLibrdKafka() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Config/AzureFunctionsFileHelper.cs	63	11	1
private void ProcessSubscription() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/KafkaListener.cs	66	10	1
private object BuildKafkaDataEvent() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaProducerAsyncCollector.cs	14	8	1
public ProducerConfig GetProducerConfig() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaProducerFactory.cs	66	8	1
private long GetTotalLag() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/Scaler/KafkaMetricsProvider.cs	32	8	2
private static ISchemaRegistryClient CreateSchemaRegistry() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Serialization/SerializationHelper.cs	22	7	6
public KafkaProducer() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaProducer.cs	43	7	4
protected override async Task ReaderAsync() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/SingleItemFunctionExecutor.cs	27	7	3
private KafkaListenerConfiguration CreateConsumerConfiguration() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaTriggerAttributeBindingProvider.cs	47	7	1
private ConsumerConfig GetConsumerConfiguration() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/Scaler/KafkaScalerProvider.cs	40	7	3
public Message BuildFrom() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaMessageBuilder.cs	41	6	1
private ConsumerConfig GetConsumerConfiguration() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/KafkaListener.cs	74	6	0
private async Task SafeCloseConsumerAsync() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/KafkaListener.cs	32	6	0
protected virtual List LoadTopicPartitions() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/Scaler/KafkaMetricsProvider.cs	27	6	0
internal static object ResolveDeserializer() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Serialization/SerializationHelper.cs	16	5	5
internal static object ResolveValueSerializer() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Serialization/SerializationHelper.cs	15	5	5
public IArgumentBinding TryCreate() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaEventDataArgumentBindingProvider.cs	17	5	1
public IArgumentBinding TryCreate() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/StringArgumentBindingProvider.cs	14	5	1
internal static Type GetDataType() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Extensions/KafkaMessageKeyTypeExtensions.cs	16	5	1
internal static bool TryGetValidFilePath() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Config/AzureFunctionsFileHelper.cs	26	5	2
internal void ApplyToConfig() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaListenerConfiguration.cs	19	5	1
private async Task ProcessPartitionItemsAsync() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/SingleItemFunctionExecutor.cs	37	5	3
internal void Flush() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/FunctionExecutorBase.cs	26	5	1
public async Task CloseAsync() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/FunctionExecutorBase.cs	25	5	0
internal int ThrottleResultIfNecessary() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/Scaler/KafkaGenericTargetScaler.cs	16	5	1
protected virtual List LoadAssignedPartitions() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/Scaler/KafkaMetricsProvider.cs	21	5	0
public void Produce() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaProducer.cs	30	4	2
public IArgumentBinding TryCreate() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/SerializableTypeArgumentBindingProvider.cs	17	4	1
private static object BuildKafkaEventDataForKeyValue() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaProducerAsyncCollector.cs	21	4	1
public IArgumentBinding TryCreate() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/AsyncCollectorArgumentBindingProvider.cs	20	4	1
internal static string GetFunctionBaseFolder() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Config/AzureFunctionsFileHelper.cs	18	4	0
bool IsValidValueType() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaTriggerAttribute.cs	8	4	1
private Task ConvertToByteArray() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaEventDataConvertManager.cs	22	4	3
string EnsureValidEventHubsCertificateLocation() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/KafkaListener.cs	17	4	1
private static bool IsTrueForLast() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/Scaler/KafkaGenericTopicScaler.cs	15	4	3
public async Task ProduceAsync() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaProducer.cs	22	3	2
private static string FindTopic() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaProducer.cs	13	3	2
public IArgumentBinding TryCreate() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/ByteArrayArgumentBindingProvider.cs	8	3	1
public object Convert() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaProducerAsyncCollector.cs	12	3	1
public CollectorValueProvider() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/CollectorValueProvider.cs	10	3	3
public Task TryCreateAsync() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaAttributeBindingProvider.cs	27	3	1
public IArgumentBinding TryCreate() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/CompositeKafkaProducerBindingProvider.cs	12	3	1
private string ExtractSection() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaProducerFactory.cs	13	3	2
internal static string ResolveSecureSetting() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Extensions/ConfigurationExtensions.cs	10	3	3
public static IWebJobsBuilder AddKafka() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Config/KafkaWebJobsBuilderExtensions.cs	19	3	2
internal FunctionExecutorBase() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/FunctionExecutorBase.cs	41	3	7
private string GetValidFilePath() in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaTriggerAttributeBindingProvider.cs	13	3	1