< Summary - CoreWCF Coverage — PR #1766

Information

Class:	CoreWCF.ServiceModel.Channels.KafkaTransportBindingElement
Assembly:	CoreWCF.Kafka.Client
File(s):	File 1: /home/runner/work/CoreWCF/CoreWCF/src/CoreWCF.Kafka.Client/src/CoreWCF/ServiceModel/Channels/KafkaTransportBindingElement.Config.cs File 2: /home/runner/work/CoreWCF/CoreWCF/src/CoreWCF.Kafka.Client/src/CoreWCF/ServiceModel/Channels/KafkaTransportBindingElement.cs File 3: /home/runner/work/CoreWCF/CoreWCF/src/CoreWCF.Kafka.Client/src/CoreWCF/ServiceModel/Channels/KafkaTransportBindingElement.Security.Config.cs

Line coverage

55%

Covered lines:	125
Uncovered lines:	100
Coverable lines:	225
Total lines:	986
Line coverage:	55.5%

Branch coverage

30%

Covered branches:	11
Total branches:	36
Branch coverage:	30.5%

Method coverage

Feature is only available for sponsors

Upgrade to PRO version

Metrics

Method	Branch coverage	Cyclomatic complexity	NPath complexity	Sequence coverage
File 2: .ctor()	100%	1	1	100%
File 2: .ctor(...)	100%	1	1	100%
File 2: GetProperty(...)	50%	2	2	66.66%
File 2: Clone()	100%	1	1	100%
File 2: CanBuildChannelFactory(...)	100%	1	1	100%
File 2: BuildChannelFactory(...)	50%	2	2	66.66%

File(s)

/home/runner/work/CoreWCF/CoreWCF/src/CoreWCF.Kafka.Client/src/CoreWCF/ServiceModel/Channels/KafkaTransportBindingElement.Config.cs

#	Line	Line coverage
	`1`	`// Licensed to the .NET Foundation under one or more agreements.`
	`2`	`// The .NET Foundation licenses this file to you under the MIT license.`
	`3`
	`4`	`using System;`
	`5`	`using Confluent.Kafka;`
	`6`
	`7`	`namespace CoreWCF.ServiceModel.Channels;`
	`8`
	`9`	`public partial class KafkaTransportBindingElement`
	`10`	`{`
	`11`	`/// <summary>`
	`12`	`/// <inheritdoc cref="Confluent.Kafka.ClientConfig.Acks"/>`
	`13`	`/// </summary>`
	`14`	`/// <exception cref="ArgumentOutOfRangeException"></exception>`
	`15`	`public Acks? Acks`
	`16`	`{`
1	`17`	`get => Config.Acks;`
	`18`	`set`
	`19`	`{`
0	`20`	`if (value.HasValue && !AcksHelper.IsDefined(value.Value))`
	`21`	`{`
0	`22`	`throw new ArgumentOutOfRangeException(nameof(value));`
	`23`	`}`
	`24`
0	`25`	`Config.Acks = value;`
0	`26`	`}`
	`27`	`}`
	`28`
	`29`	`/// <summary>`
	`30`	`/// <inheritdoc cref="Confluent.Kafka.ClientConfig.MessageMaxBytes"/>`
	`31`	`/// </summary>`
	`32`	`public int? MessageMaxBytes`
	`33`	`{`
1	`34`	`get => Config.MessageMaxBytes;`
0	`35`	`set => Config.MessageMaxBytes = value;`
	`36`	`}`
	`37`
	`38`	`/// <summary>`
	`39`	`/// <inheritdoc cref="Confluent.Kafka.ClientConfig.ReceiveMessageMaxBytes"/>`
	`40`	`/// </summary>`
	`41`	`public int? ReceiveMessageMaxBytes`
	`42`	`{`
1	`43`	`get => Config.ReceiveMessageMaxBytes;`
0	`44`	`set => Config.ReceiveMessageMaxBytes = value;`
	`45`	`}`
	`46`
	`47`	`/// <summary>`
	`48`	`/// <inheritdoc cref="Confluent.Kafka.ClientConfig.SocketConnectionSetupTimeoutMs"/>`
	`49`	`/// </summary>`
	`50`	`public int? SocketConnectionSetupTimeoutMs`
	`51`	`{`
1	`52`	`get => Config.SocketConnectionSetupTimeoutMs;`
0	`53`	`set => Config.SocketConnectionSetupTimeoutMs = value;`
	`54`	`}`
	`55`
	`56`	`/// <summary>`
	`57`	`/// <inheritdoc cref="Confluent.Kafka.ClientConfig.ConnectionsMaxIdleMs"/>`
	`58`	`/// </summary>`
	`59`	`public int? ConnectionsMaxIdleMs`
	`60`	`{`
1	`61`	`get => Config.ConnectionsMaxIdleMs;`
0	`62`	`set => Config.ConnectionsMaxIdleMs = value;`
	`63`	`}`
	`64`
	`65`	`/// <summary>`
	`66`	`/// <inheritdoc cref="Confluent.Kafka.ClientConfig.ReconnectBackoffMs"/>`
	`67`	`/// </summary>`
	`68`	`public int? ReconnectBackoffMs`
	`69`	`{`
1	`70`	`get => Config.ReconnectBackoffMs;`
0	`71`	`set => Config.ReconnectBackoffMs = value;`
	`72`	`}`
	`73`
	`74`	`/// <summary>`
	`75`	`/// <inheritdoc cref="Confluent.Kafka.ClientConfig.ReconnectBackoffMaxMs"/>`
	`76`	`/// </summary>`
	`77`	`public int? ReconnectBackoffMaxMs`
	`78`	`{`
1	`79`	`get => Config.ReconnectBackoffMaxMs;`
0	`80`	`set => Config.ReconnectBackoffMaxMs = value;`
	`81`	`}`
	`82`
	`83`	`/// <summary>`
	`84`	`/// <inheritdoc cref="Confluent.Kafka.ClientConfig.StatisticsIntervalMs"/>`
	`85`	`/// </summary>`
	`86`	`public int? StatisticsIntervalMs`
	`87`	`{`
1	`88`	`get => Config.StatisticsIntervalMs;`
0	`89`	`set => Config.StatisticsIntervalMs = value;`
	`90`	`}`
	`91`
	`92`	`/// <summary>`
	`93`	`/// <inheritdoc cref="Confluent.Kafka.ClientConfig.ApiVersionRequest"/>`
	`94`	`/// </summary>`
	`95`	`public bool? ApiVersionRequest`
	`96`	`{`
1	`97`	`get => Config.ApiVersionRequest;`
0	`98`	`set => Config.ApiVersionRequest = value;`
	`99`	`}`
	`100`
	`101`	`/// <summary>`
	`102`	`/// <inheritdoc cref="Confluent.Kafka.ClientConfig.ApiVersionFallbackMs"/>`
	`103`	`/// </summary>`
	`104`	`public int? ApiVersionFallbackMs`
	`105`	`{`
1	`106`	`get => Config.ApiVersionFallbackMs;`
0	`107`	`set => Config.ApiVersionFallbackMs = value;`
	`108`	`}`
	`109`
	`110`	`/// <summary>`
	`111`	`/// <inheritdoc cref="Confluent.Kafka.ClientConfig.BrokerVersionFallback"/>`
	`112`	`/// </summary>`
	`113`	`public string BrokerVersionFallback`
	`114`	`{`
1	`115`	`get => Config.BrokerVersionFallback;`
0	`116`	`set => Config.BrokerVersionFallback = value;`
	`117`	`}`
	`118`
	`119`	`/// <summary>`
	`120`	`/// <inheritdoc cref="Confluent.Kafka.ProducerConfig.CompressionType"/>`
	`121`	`/// </summary>`
	`122`	`/// <exception cref="ArgumentOutOfRangeException"></exception>`
	`123`	`public CompressionType? CompressionType`
	`124`	`{`
1	`125`	`get => Config.CompressionType;`
	`126`	`set`
	`127`	`{`
1	`128`	`if (value.HasValue && !CompressionTypeHelper.IsDefined(value.Value))`
	`129`	`{`
0	`130`	`throw new ArgumentOutOfRangeException(nameof(value));`
	`131`	`}`
	`132`
1	`133`	`Config.CompressionType = value;`
1	`134`	`}`
	`135`	`}`
	`136`
	`137`	`/// <summary>`
	`138`	`/// <inheritdoc cref="Confluent.Kafka.ProducerConfig.CompressionLevel"/>`
	`139`	`/// </summary>`
	`140`	`public int? CompressionLevel`
	`141`	`{`
1	`142`	`get => Config.CompressionLevel;`
0	`143`	`set => Config.CompressionLevel = value;`
	`144`	`}`
	`145`
	`146`	`/// <summary>`
	`147`	`/// <inheritdoc cref="Confluent.Kafka.ProducerConfig.MessageSendMaxRetries"/>`
	`148`	`/// </summary>`
	`149`	`public int? MessageSendMaxRetries`
	`150`	`{`
1	`151`	`get => Config.MessageSendMaxRetries;`
0	`152`	`set => Config.MessageSendMaxRetries = value;`
	`153`	`}`
	`154`
	`155`	`/// <summary>`
	`156`	`/// <inheritdoc cref="Confluent.Kafka.ProducerConfig.RetryBackoffMs"/>`
	`157`	`/// </summary>`
	`158`	`public int? RetryBackoffMs`
	`159`	`{`
1	`160`	`get => Config.RetryBackoffMs;`
0	`161`	`set => Config.RetryBackoffMs = value;`
	`162`	`}`
	`163`
	`164`	`/// <summary>`
	`165`	`/// <inheritdoc cref="Confluent.Kafka.ProducerConfig.EnableIdempotence"/>`
	`166`	`/// </summary>`
	`167`	`public bool? EnableIdempotence`
	`168`	`{`
1	`169`	`get => Config.EnableIdempotence;`
0	`170`	`set => Config.EnableIdempotence = value;`
	`171`	`}`
	`172`
	`173`	`/// <summary>`
	`174`	`/// <inheritdoc cref="Confluent.Kafka.ProducerConfig.LingerMs"/>`
	`175`	`/// </summary>`
	`176`	`public double? LingerMs`
	`177`	`{`
1	`178`	`get => Config.LingerMs;`
0	`179`	`set => Config.LingerMs = value;`
	`180`	`}`
	`181`
	`182`	`/// <summary>`
	`183`	`/// <inheritdoc cref="Confluent.Kafka.ProducerConfig.RequestTimeoutMs"/>`
	`184`	`/// </summary>`
	`185`	`public int? RequestTimeoutMs`
	`186`	`{`
1	`187`	`get => Config.RequestTimeoutMs;`
0	`188`	`set => Config.RequestTimeoutMs = value;`
	`189`	`}`
	`190`
	`191`	`/// <summary>`
	`192`	`/// <inheritdoc cref="Confluent.Kafka.ProducerConfig.BatchSize"/>`
	`193`	`/// </summary>`
	`194`	`public int? BatchSize`
	`195`	`{`
1	`196`	`get => Config.BatchSize;`
0	`197`	`set => Config.BatchSize = value;`
	`198`	`}`
	`199`
	`200`	`/// <summary>`
	`201`	`/// <inheritdoc cref="Confluent.Kafka.ProducerConfig.BatchNumMessages"/>`
	`202`	`/// </summary>`
	`203`	`public int? BatchNumMessages`
	`204`	`{`
1	`205`	`get => Config.BatchNumMessages;`
0	`206`	`set => Config.BatchNumMessages = value;`
	`207`	`}`
	`208`
	`209`	`/// <summary>`
	`210`	`/// <inheritdoc cref="Confluent.Kafka.ProducerConfig.MessageTimeoutMs"/>`
	`211`	`/// </summary>`
	`212`	`public int? MessageTimeoutMs`
	`213`	`{`
1	`214`	`get => Config.MessageTimeoutMs;`
1	`215`	`set => Config.MessageTimeoutMs = value;`
	`216`	`}`
	`217`
	`218`	`/// <summary>`
	`219`	`/// <inheritdoc cref="Confluent.Kafka.ProducerConfig.TransactionalId"/>`
	`220`	`/// </summary>`
	`221`	`public string TransactionalId`
	`222`	`{`
1	`223`	`get => Config.TransactionalId;`
0	`224`	`set => Config.TransactionalId = value;`
	`225`	`}`
	`226`
	`227`	`/// <summary>`
	`228`	`/// <inheritdoc cref="Confluent.Kafka.ProducerConfig.TransactionTimeoutMs"/>`
	`229`	`/// </summary>`
	`230`	`public int? TransactionTimeoutMs`
	`231`	`{`
1	`232`	`get => Config.TransactionTimeoutMs;`
0	`233`	`set => Config.TransactionTimeoutMs = value;`
	`234`	`}`
	`235`
	`236`	`/// <summary>`
	`237`	`/// <inheritdoc cref="Confluent.Kafka.ProducerConfig.Partitioner"/>`
	`238`	`/// </summary>`
	`239`	`public Partitioner? Partitioner`
	`240`	`{`
1	`241`	`get => Config.Partitioner;`
	`242`	`set`
	`243`	`{`
0	`244`	`if (value.HasValue && !PartitionerHelper.IsDefined(value.Value))`
	`245`	`{`
0	`246`	`throw new ArgumentOutOfRangeException(nameof(value));`
	`247`	`}`
0	`248`	`Config.Partitioner = value;`
0	`249`	`}`
	`250`	`}`
	`251`
	`252`	`/// <summary>`
	`253`	`/// <inheritdoc cref="Confluent.Kafka.ProducerConfig.QueueBufferingMaxMessages"/>`
	`254`	`/// </summary>`
	`255`	`public int? QueueBufferingMaxMessages`
	`256`	`{`
1	`257`	`get => Config.QueueBufferingMaxMessages;`
0	`258`	`set => Config.QueueBufferingMaxMessages = value;`
	`259`	`}`
	`260`
	`261`	`/// <summary>`
	`262`	`/// <inheritdoc cref="Confluent.Kafka.ProducerConfig.QueueBufferingMaxKbytes"/>`
	`263`	`/// </summary>`
	`264`	`public int? QueueBufferingMaxKbytes`
	`265`	`{`
1	`266`	`get => Config.QueueBufferingMaxKbytes;`
0	`267`	`set => Config.QueueBufferingMaxKbytes = value;`
	`268`	`}`
	`269`
	`270`	`/// <summary>`
	`271`	`/// <inheritdoc cref="ClientConfig.Debug"/>`
	`272`	`/// </summary>`
	`273`	`public string Debug`
	`274`	`{`
1	`275`	`get => Config.Debug;`
0	`276`	`set => Config.Debug = value;`
	`277`	`}`
	`278`
	`279`	`/// <summary>`
	`280`	`/// <inheritdoc cref="ClientConfig.ClientId"/>`
	`281`	`/// </summary>`
	`282`	`public string ClientId`
	`283`	`{`
1	`284`	`get => Config.ClientId;`
0	`285`	`set => Config.ClientId = value;`
	`286`	`}`
	`287`
	`288`	`/// <summary>`
	`289`	`/// <inheritdoc cref="ClientConfig.MessageCopyMaxBytes"/>`
	`290`	`/// </summary>`
	`291`	`public int? MessageCopyMaxBytes`
	`292`	`{`
1	`293`	`get => Config.MessageMaxBytes;`
0	`294`	`set => Config.MessageMaxBytes = value;`
	`295`	`}`
	`296`
	`297`	`/// <summary>`
	`298`	`/// <inheritdoc cref="ClientConfig.MaxInFlight"/>`
	`299`	`/// </summary>`
	`300`	`public int? MaxInFlight`
	`301`	`{`
1	`302`	`get => Config.MaxInFlight;`
0	`303`	`set => Config.MaxInFlight= value;`
	`304`	`}`
	`305`
	`306`	`/// <summary>`
	`307`	`/// <inheritdoc cref="ClientConfig.TopicMetadataRefreshIntervalMs"/>`
	`308`	`/// </summary>`
	`309`	`public int? TopicMetadataRefreshIntervalMs`
	`310`	`{`
1	`311`	`get => Config.TopicMetadataRefreshIntervalMs;`
0	`312`	`set => Config.TopicMetadataRefreshIntervalMs = value;`
	`313`	`}`
	`314`
	`315`	`/// <summary>`
	`316`	`/// <inheritdoc cref="ClientConfig.MetadataMaxAgeMs"/>`
	`317`	`/// </summary>`
	`318`	`public int? MetadataMaxAgeMs`
	`319`	`{`
1	`320`	`get => Config.MetadataMaxAgeMs;`
0	`321`	`set => Config.MetadataMaxAgeMs = value;`
	`322`	`}`
	`323`
	`324`	`/// <summary>`
	`325`	`/// <inheritdoc cref="ClientConfig.TopicMetadataRefreshFastIntervalMs"/>`
	`326`	`/// </summary>`
	`327`	`public int? TopicMetadataRefreshFastIntervalMs`
	`328`	`{`
1	`329`	`get => Config.TopicMetadataRefreshFastIntervalMs;`
0	`330`	`set => Config.TopicMetadataRefreshFastIntervalMs = value;`
	`331`	`}`
	`332`
	`333`	`/// <summary>`
	`334`	`/// <inheritdoc cref="ClientConfig.TopicMetadataRefreshSparse"/>`
	`335`	`/// </summary>`
	`336`	`public bool? TopicMetadataRefreshSparse`
	`337`	`{`
1	`338`	`get => Config.TopicMetadataRefreshSparse;`
0	`339`	`set => Config.TopicMetadataRefreshSparse = value;`
	`340`	`}`
	`341`
	`342`	`/// <summary>`
	`343`	`/// <inheritdoc cref="ClientConfig.TopicMetadataPropagationMaxMs"/>`
	`344`	`/// </summary>`
	`345`	`public int? TopicMetadataPropagationMaxMs`
	`346`	`{`
1	`347`	`get => Config.TopicMetadataPropagationMaxMs;`
0	`348`	`set => Config.TopicMetadataPropagationMaxMs = value;`
	`349`	`}`
	`350`
	`351`	`/// <summary>`
	`352`	`/// <inheritdoc cref="ClientConfig.TopicBlacklist"/>`
	`353`	`/// </summary>`
	`354`	`public string TopicBlacklist`
	`355`	`{`
1	`356`	`get => Config.TopicBlacklist;`
0	`357`	`set => Config.TopicBlacklist = value;`
	`358`	`}`
	`359`
	`360`	`/// <summary>`
	`361`	`/// <inheritdoc cref="ClientConfig.SocketTimeoutMs"/>`
	`362`	`/// </summary>`
	`363`	`public int? SocketTimeoutMs`
	`364`	`{`
1	`365`	`get => Config.SocketTimeoutMs;`
0	`366`	`set => Config.SocketTimeoutMs = value;`
	`367`	`}`
	`368`
	`369`	`/// <summary>`
	`370`	`/// <inheritdoc cref="ClientConfig.SocketSendBufferBytes"/>`
	`371`	`/// </summary>`
	`372`	`public int? SocketSendBufferBytes`
	`373`	`{`
1	`374`	`get => Config.SocketSendBufferBytes;`
0	`375`	`set => Config.SocketSendBufferBytes = value;`
	`376`	`}`
	`377`
	`378`	`/// <summary>`
	`379`	`/// <inheritdoc cref="ClientConfig.SocketReceiveBufferBytes"/>`
	`380`	`/// </summary>`
	`381`	`public int? SocketReceiveBufferBytes`
	`382`	`{`
1	`383`	`get => Config.SocketReceiveBufferBytes;`
0	`384`	`set => Config.SocketReceiveBufferBytes = value;`
	`385`	`}`
	`386`
	`387`	`/// <summary>`
	`388`	`/// <inheritdoc cref="ClientConfig.SocketKeepaliveEnable"/>`
	`389`	`/// </summary>`
	`390`	`public bool? SocketKeepaliveEnable`
	`391`	`{`
1	`392`	`get => Config.SocketKeepaliveEnable;`
0	`393`	`set => Config.SocketKeepaliveEnable = value;`
	`394`	`}`
	`395`
	`396`	`/// <summary>`
	`397`	`/// <inheritdoc cref="ClientConfig.SocketNagleDisable"/>`
	`398`	`/// </summary>`
	`399`	`public bool? SocketNagleDisable`
	`400`	`{`
1	`401`	`get => Config.SocketNagleDisable;`
0	`402`	`set => Config.SocketNagleDisable = value;`
	`403`	`}`
	`404`
	`405`	`/// <summary>`
	`406`	`/// <inheritdoc cref="ClientConfig.SocketMaxFails"/>`
	`407`	`/// </summary>`
	`408`	`public int? SocketMaxFails`
	`409`	`{`
1	`410`	`get => Config.SocketMaxFails;`
0	`411`	`set => Config.SocketMaxFails = value;`
	`412`	`}`
	`413`
	`414`	`/// <summary>`
	`415`	`/// <inheritdoc cref="ClientConfig.BrokerAddressTtl"/>`
	`416`	`/// </summary>`
	`417`	`public int? BrokerAddressTtl`
	`418`	`{`
1	`419`	`get => Config.BrokerAddressTtl;`
0	`420`	`set => Config.BrokerAddressTtl = value;`
	`421`	`}`
	`422`
	`423`	`/// <summary>`
	`424`	`/// <inheritdoc cref="ClientConfig.BrokerAddressFamily"/>`
	`425`	`/// </summary>`
	`426`	`/// <exception cref="ArgumentOutOfRangeException"></exception>`
	`427`	`public BrokerAddressFamily? BrokerAddressFamily`
	`428`	`{`
1	`429`	`get => Config.BrokerAddressFamily;`
	`430`	`set`
	`431`	`{`
0	`432`	`if (value.HasValue && !BrokerAddressFamilyHelper.IsDefined(value.Value))`
	`433`	`{`
0	`434`	`throw new ArgumentOutOfRangeException(nameof(value));`
	`435`	`}`
	`436`
0	`437`	`Config.BrokerAddressFamily = value;`
0	`438`	`}`
	`439`	`}`
	`440`
	`441`	`/// <summary>`
	`442`	`/// <inheritdoc cref="ClientConfig.LogQueue"/>`
	`443`	`/// </summary>`
	`444`	`public bool? LogQueue`
	`445`	`{`
1	`446`	`get => Config.LogQueue;`
0	`447`	`set => Config.LogQueue = value;`
	`448`	`}`
	`449`
	`450`	`/// <summary>`
	`451`	`/// <inheritdoc cref="ClientConfig.LogThreadName"/>`
	`452`	`/// </summary>`
	`453`	`public bool? LogThreadName`
	`454`	`{`
1	`455`	`get => Config.LogThreadName;`
0	`456`	`set => Config.LogThreadName = value;`
	`457`	`}`
	`458`
	`459`	`/// <summary>`
	`460`	`/// <inheritdoc cref="ClientConfig.EnableRandomSeed"/>`
	`461`	`/// </summary>`
	`462`	`public bool? EnableRandomSeed`
	`463`	`{`
1	`464`	`get => Config.EnableRandomSeed;`
0	`465`	`set => Config.EnableRandomSeed = value;`
	`466`	`}`
	`467`
	`468`	`/// <summary>`
	`469`	`/// <inheritdoc cref="ClientConfig.LogConnectionClose"/>`
	`470`	`/// </summary>`
	`471`	`public bool? LogConnectionClose`
	`472`	`{`
1	`473`	`get => Config.LogConnectionClose;`
0	`474`	`set => Config.LogConnectionClose = value;`
	`475`	`}`
	`476`
	`477`	`/// <summary>`
	`478`	`/// <inheritdoc cref="ClientConfig.InternalTerminationSignal"/>`
	`479`	`/// </summary>`
	`480`	`public int? InternalTerminationSignal`
	`481`	`{`
1	`482`	`get => Config.InternalTerminationSignal;`
0	`483`	`set => Config.InternalTerminationSignal = value;`
	`484`	`}`
	`485`
	`486`	`/// <summary>`
	`487`	`/// <inheritdoc cref="ClientConfig.ApiVersionRequestTimeoutMs"/>`
	`488`	`/// </summary>`
	`489`	`public int? ApiVersionRequestTimeoutMs`
	`490`	`{`
1	`491`	`get => Config.ApiVersionRequestTimeoutMs;`
0	`492`	`set => Config.ApiVersionRequestTimeoutMs = value;`
	`493`	`}`
	`494`
	`495`	`/// <summary>`
	`496`	`/// <inheritdoc cref="ClientConfig.PluginLibraryPaths"/>`
	`497`	`/// </summary>`
	`498`	`public string PluginLibraryPaths`
	`499`	`{`
1	`500`	`get => Config.PluginLibraryPaths;`
0	`501`	`set => Config.PluginLibraryPaths = value;`
	`502`	`}`
	`503`
	`504`	`/// <summary>`
	`505`	`/// <inheritdoc cref="ClientConfig.ClientRack"/>`
	`506`	`/// </summary>`
	`507`	`public string ClientRack`
	`508`	`{`
1	`509`	`get => Config.ClientRack;`
0	`510`	`set => Config.ClientRack = value;`
	`511`	`}`
	`512`
	`513`	`/// <summary>`
	`514`	`/// <inheritdoc cref="ProducerConfig.EnableBackgroundPoll"/>`
	`515`	`/// </summary>`
	`516`	`public bool? EnableBackgroundPoll`
	`517`	`{`
1	`518`	`get => Config.EnableBackgroundPoll;`
0	`519`	`set => Config.EnableBackgroundPoll = value;`
	`520`	`}`
	`521`
	`522`	`/// <summary>`
	`523`	`/// <inheritdoc cref="ProducerConfig.EnableDeliveryReports"/>`
	`524`	`/// </summary>`
	`525`	`public bool? EnableDeliveryReports`
	`526`	`{`
1	`527`	`get => Config.EnableDeliveryReports;`
0	`528`	`set => Config.EnableDeliveryReports = value;`
	`529`	`}`
	`530`
	`531`	`/// <summary>`
	`532`	`/// <inheritdoc cref="ProducerConfig.DeliveryReportFields"/>`
	`533`	`/// </summary>`
	`534`	`public string DeliveryReportFields`
	`535`	`{`
1	`536`	`get => Config.DeliveryReportFields;`
0	`537`	`set => Config.DeliveryReportFields = value;`
	`538`	`}`
	`539`
	`540`	`/// <summary>`
	`541`	`/// <inheritdoc cref="ProducerConfig.QueueBufferingBackpressureThreshold"/>`
	`542`	`/// </summary>`
	`543`	`public int? QueueBufferingBackpressureThreshold`
	`544`	`{`
1	`545`	`get => Config.QueueBufferingBackpressureThreshold;`
0	`546`	`set => Config.QueueBufferingBackpressureThreshold = value;`
	`547`	`}`
	`548`
	`549`	`/// <summary>`
	`550`	`/// <inheritdoc cref="ProducerConfig.StickyPartitioningLingerMs"/>`
	`551`	`/// </summary>`
	`552`	`public int? StickyPartitioningLingerMs`
	`553`	`{`
1	`554`	`get => Config.StickyPartitioningLingerMs;`
0	`555`	`set => Config.StickyPartitioningLingerMs = value;`
	`556`	`}`
	`557`	`}`

/home/runner/work/CoreWCF/CoreWCF/src/CoreWCF.Kafka.Client/src/CoreWCF/ServiceModel/Channels/KafkaTransportBindingElement.cs

#	Line	Line coverage
	`1`	`// Licensed to the .NET Foundation under one or more agreements.`
	`2`	`// The .NET Foundation licenses this file to you under the MIT license.`
	`3`
	`4`	`using System;`
	`5`	`using System.ServiceModel.Channels;`
	`6`	`using Confluent.Kafka;`
	`7`
	`8`	`namespace CoreWCF.ServiceModel.Channels`
	`9`	`{`
	`10`	`public partial class KafkaTransportBindingElement : TransportBindingElement`
	`11`	`{`
78	`12`	`public override string Scheme => KafkaConstants.Scheme;`
	`13`
1758	`14`	`internal ProducerConfig Config { get; } = new();`
	`15`
39	`16`	`public KafkaTransportBindingElement()`
	`17`	`{`
	`18`
39	`19`	`}`
	`20`
	`21`	`private KafkaTransportBindingElement(KafkaTransportBindingElement other)`
540	`22`	`: base(other)`
	`23`	`{`
540	`24`	`Config = other.Config;`
540	`25`	`}`
	`26`
	`27`	`public override T GetProperty<T>(BindingContext context)`
	`28`	`{`
114	`29`	`if (context == null)`
	`30`	`{`
0	`31`	`throw new ArgumentNullException(nameof(context));`
	`32`	`}`
	`33`
114	`34`	`return context.GetInnerProperty<T>();`
	`35`	`}`
	`36`
	`37`	`public override BindingElement Clone()`
	`38`	`{`
540	`39`	`return new KafkaTransportBindingElement(this);`
	`40`	`}`
	`41`
38	`42`	`public override bool CanBuildChannelFactory<TChannel>(BindingContext context) => typeof(TChannel) == typeof(IOut`
	`43`
	`44`	`public override IChannelFactory<TChannel> BuildChannelFactory<TChannel>(BindingContext context)`
	`45`	`{`
38	`46`	`if (context == null)`
	`47`	`{`
0	`48`	`throw new ArgumentNullException(nameof(context));`
	`49`	`}`
	`50`
38	`51`	`return (IChannelFactory<TChannel>)new KafkaChannelFactory(this, context);`
	`52`	`}`
	`53`	`}`
	`54`	`}`

/home/runner/work/CoreWCF/CoreWCF/src/CoreWCF.Kafka.Client/src/CoreWCF/ServiceModel/Channels/KafkaTransportBindingElement.Security.Config.cs

#	Line	Line coverage
	`1`	`// Licensed to the .NET Foundation under one or more agreements.`
	`2`	`// The .NET Foundation licenses this file to you under the MIT license.`
	`3`
	`4`	`using System;`
	`5`	`using Confluent.Kafka;`
	`6`
	`7`	`namespace CoreWCF.ServiceModel.Channels;`
	`8`
	`9`	`public partial class KafkaTransportBindingElement`
	`10`	`{`
	`11`	`/// <summary>`
	`12`	`/// <inheritdoc cref="ClientConfig.SecurityProtocol"/>`
	`13`	`/// </summary>`
	`14`	`/// <exception cref="ArgumentOutOfRangeException"></exception>`
	`15`	`public SecurityProtocol? SecurityProtocol`
	`16`	`{`
332	`17`	`get => Config.SecurityProtocol;`
	`18`	`set`
	`19`	`{`
39	`20`	`if (value.HasValue && !SecurityProtocolHelper.IsDefined(value.Value))`
	`21`	`{`
0	`22`	`throw new ArgumentOutOfRangeException(nameof(value));`
	`23`	`}`
	`24`
39	`25`	`Config.SecurityProtocol = value;`
39	`26`	`}`
	`27`	`}`
	`28`
	`29`	`/// <summary>`
	`30`	`/// <inheritdoc cref="ClientConfig.SaslMechanism"/>`
	`31`	`/// </summary>`
	`32`	`/// <exception cref="ArgumentOutOfRangeException"></exception>`
	`33`	`public SaslMechanism? SaslMechanism`
	`34`	`{`
21	`35`	`get => Config.SaslMechanism;`
	`36`	`set`
	`37`	`{`
2	`38`	`if (value.HasValue && !SaslMechanismHelper.IsDefined(value.Value))`
	`39`	`{`
0	`40`	`throw new ArgumentOutOfRangeException(nameof(value));`
	`41`	`}`
	`42`
2	`43`	`Config.SaslMechanism = value;`
2	`44`	`}`
	`45`	`}`
	`46`
	`47`	`/// <summary>`
	`48`	`/// <inheritdoc cref="ClientConfig.SslCaLocation"/>`
	`49`	`/// </summary>`
	`50`	`public string SslCaLocation`
	`51`	`{`
1	`52`	`get => Config.SslCaLocation;`
1	`53`	`set => Config.SslCaLocation = value;`
	`54`	`}`
	`55`
	`56`	`/// <summary>`
	`57`	`/// <inheritdoc cref="ClientConfig.SslCaPem"/>`
	`58`	`/// </summary>`
	`59`	`public string SslCaPem`
	`60`	`{`
31	`61`	`get => Config.SslCaPem;`
3	`62`	`set => Config.SslCaPem = value;`
	`63`	`}`
	`64`
	`65`	`/// <summary>`
	`66`	`/// <inheritdoc cref="ClientConfig.SaslUsername"/>`
	`67`	`/// </summary>`
	`68`	`public string SaslUsername`
	`69`	`{`
21	`70`	`get => Config.SaslUsername;`
2	`71`	`set => Config.SaslUsername = value;`
	`72`	`}`
	`73`
	`74`	`/// <summary>`
	`75`	`/// <inheritdoc cref="ClientConfig.SaslPassword"/>`
	`76`	`/// </summary>`
	`77`	`public string SaslPassword`
	`78`	`{`
21	`79`	`get => Config.SaslPassword;`
2	`80`	`set => Config.SaslPassword = value;`
	`81`	`}`
	`82`
	`83`	`/// <summary>`
	`84`	`/// <inheritdoc cref="ClientConfig.SslKeyPem"/>`
	`85`	`/// </summary>`
	`86`	`public string SslKeyPem`
	`87`	`{`
11	`88`	`get => Config.SslKeyPem;`
1	`89`	`set => Config.SslKeyPem = value;`
	`90`	`}`
	`91`
	`92`	`/// <summary>`
	`93`	`/// <inheritdoc cref="ClientConfig.SslKeyPassword"/>`
	`94`	`/// </summary>`
	`95`	`public string SslKeyPassword`
	`96`	`{`
11	`97`	`get => Config.SslKeyPassword;`
2	`98`	`set => Config.SslKeyPassword = value;`
	`99`	`}`
	`100`
	`101`	`/// <summary>`
	`102`	`/// <inheritdoc cref="ClientConfig.SslKeyLocation"/>`
	`103`	`/// </summary>`
	`104`	`public string SslKeyLocation`
	`105`	`{`
1	`106`	`get => Config.SslKeyLocation;`
1	`107`	`set => Config.SslKeyLocation = value;`
	`108`	`}`
	`109`
	`110`	`/// <summary>`
	`111`	`/// <inheritdoc cref="ClientConfig.SslKeystorePassword"/>`
	`112`	`/// </summary>`
	`113`	`public string SslKeystorePassword`
	`114`	`{`
1	`115`	`get => Config.SslKeystorePassword;`
0	`116`	`set => Config.SslKeystorePassword = value;`
	`117`	`}`
	`118`
	`119`	`/// <summary>`
	`120`	`/// <inheritdoc cref="ClientConfig.SslKeystoreLocation"/>`
	`121`	`/// </summary>`
	`122`	`public string SslKeystoreLocation`
	`123`	`{`
1	`124`	`get => Config.SslKeystoreLocation;`
0	`125`	`set => Config.SslKeystoreLocation = value;`
	`126`	`}`
	`127`
	`128`	`/// <summary>`
	`129`	`/// <inheritdoc cref="ClientConfig.SslCertificateLocation"/>`
	`130`	`/// </summary>`
	`131`	`public string SslCertificateLocation`
	`132`	`{`
1	`133`	`get => Config.SslCertificateLocation;`
1	`134`	`set => Config.SslCertificateLocation = value;`
	`135`	`}`
	`136`
	`137`	`/// <summary>`
	`138`	`/// <inheritdoc cref="ClientConfig.SslCertificatePem"/>`
	`139`	`/// </summary>`
	`140`	`public string SslCertificatePem`
	`141`	`{`
11	`142`	`get => Config.SslCertificatePem;`
1	`143`	`set => Config.SslCertificatePem = value;`
	`144`	`}`
	`145`
	`146`
	`147`
	`148`
	`149`
	`150`
	`151`	`/// <summary>`
	`152`	`/// <inheritdoc cref="ClientConfig.SslCipherSuites"/>`
	`153`	`/// </summary>`
	`154`	`public string SslCipherSuites`
	`155`	`{`
1	`156`	`get => Config.SslCipherSuites;`
0	`157`	`set => Config.SslCipherSuites = value;`
	`158`	`}`
	`159`
	`160`	`/// <summary>`
	`161`	`/// <inheritdoc cref="ClientConfig.SslCurvesList"/>`
	`162`	`/// </summary>`
	`163`	`public string SslCurvesList`
	`164`	`{`
1	`165`	`get => Config.SslCurvesList;`
0	`166`	`set => Config.SslCurvesList = value;`
	`167`	`}`
	`168`
	`169`	`/// <summary>`
	`170`	`/// <inheritdoc cref="ClientConfig.SslSigalgsList"/>`
	`171`	`/// </summary>`
	`172`	`public string SslSigalgsList`
	`173`	`{`
1	`174`	`get => Config.SslSigalgsList;`
0	`175`	`set => Config.SslSigalgsList = value;`
	`176`	`}`
	`177`
	`178`	`/// <summary>`
	`179`	`/// <inheritdoc cref="ClientConfig.SslCaCertificateStores"/>`
	`180`	`/// </summary>`
	`181`	`public string SslCaCertificateStores`
	`182`	`{`
1	`183`	`get => Config.SslCaCertificateStores;`
0	`184`	`set => Config.SslCaCertificateStores = value;`
	`185`	`}`
	`186`
	`187`	`/// <summary>`
	`188`	`/// <inheritdoc cref="ClientConfig.SslCrlLocation"/>`
	`189`	`/// </summary>`
	`190`	`public string SslCrlLocation`
	`191`	`{`
1	`192`	`get => Config.SslCrlLocation;`
0	`193`	`set => Config.SslCrlLocation = value;`
	`194`	`}`
	`195`
	`196`	`/// <summary>`
	`197`	`/// <inheritdoc cref="ClientConfig.SslProviders"/>`
	`198`	`/// </summary>`
	`199`	`public string SslProviders`
	`200`	`{`
1	`201`	`get => Config.SslProviders;`
0	`202`	`set => Config.SslProviders = value;`
	`203`	`}`
	`204`
	`205`	`/// <summary>`
	`206`	`/// <inheritdoc cref="ClientConfig.SslEngineLocation"/>`
	`207`	`/// </summary>`
	`208`	`public string SslEngineLocation`
	`209`	`{`
1	`210`	`get => Config.SslEngineLocation;`
0	`211`	`set => Config.SslEngineLocation = value;`
	`212`	`}`
	`213`
	`214`	`/// <summary>`
	`215`	`/// <inheritdoc cref="ClientConfig.SslEngineId"/>`
	`216`	`/// </summary>`
	`217`	`public string SslEngineId`
	`218`	`{`
1	`219`	`get => Config.SslEngineId;`
0	`220`	`set => Config.SslEngineId = value;`
	`221`	`}`
	`222`
	`223`	`/// <summary>`
	`224`	`/// <inheritdoc cref="ClientConfig.EnableSslCertificateVerification"/>`
	`225`	`/// </summary>`
	`226`	`public bool? EnableSslCertificateVerification`
	`227`	`{`
1	`228`	`get => Config.EnableSslCertificateVerification;`
0	`229`	`set => Config.EnableSslCertificateVerification = value;`
	`230`	`}`
	`231`
	`232`	`/// <summary>`
	`233`	`/// <inheritdoc cref="ClientConfig.SslEndpointIdentificationAlgorithm"/>`
	`234`	`/// </summary>`
	`235`	`/// <exception cref="ArgumentOutOfRangeException"></exception>`
	`236`	`public SslEndpointIdentificationAlgorithm? SslEndpointIdentificationAlgorithm`
	`237`	`{`
1	`238`	`get => Config.SslEndpointIdentificationAlgorithm;`
	`239`	`set`
	`240`	`{`
0	`241`	`if (value.HasValue && !SslEndpointIdentificationAlgorithmHelper.IsDefined(value.Value))`
	`242`	`{`
0	`243`	`throw new ArgumentOutOfRangeException(nameof(value));`
	`244`	`}`
	`245`
0	`246`	`Config.SslEndpointIdentificationAlgorithm = value;`
0	`247`	`}`
	`248`	`}`
	`249`
	`250`	`/// <summary>`
	`251`	`/// <inheritdoc cref="ClientConfig.SaslKerberosServiceName"/>`
	`252`	`/// </summary>`
	`253`	`public string SaslKerberosServiceName`
	`254`	`{`
1	`255`	`get => Config.SaslKerberosServiceName;`
0	`256`	`set => Config.SaslKerberosServiceName = value;`
	`257`	`}`
	`258`
	`259`	`/// <summary>`
	`260`	`/// <inheritdoc cref="ClientConfig.SaslKerberosPrincipal"/>`
	`261`	`/// </summary>`
	`262`	`public string SaslKerberosPrincipal`
	`263`	`{`
1	`264`	`get => Config.SaslKerberosPrincipal;`
0	`265`	`set => Config.SaslKerberosPrincipal = value;`
	`266`	`}`
	`267`
	`268`	`/// <summary>`
	`269`	`/// <inheritdoc cref="ClientConfig.SaslKerberosKinitCmd"/>`
	`270`	`/// </summary>`
	`271`	`public string SaslKerberosKinitCmd`
	`272`	`{`
1	`273`	`get => Config.SaslKerberosKinitCmd;`
0	`274`	`set => Config.SaslKerberosKinitCmd = value;`
	`275`	`}`
	`276`
	`277`	`/// <summary>`
	`278`	`/// <inheritdoc cref="ClientConfig.SaslKerberosKeytab"/>`
	`279`	`/// </summary>`
	`280`	`public string SaslKerberosKeytab`
	`281`	`{`
1	`282`	`get => Config.SaslKerberosKeytab;`
0	`283`	`set => Config.SaslKerberosKeytab = value;`
	`284`	`}`
	`285`
	`286`	`/// <summary>`
	`287`	`/// <inheritdoc cref="ClientConfig.SaslKerberosMinTimeBeforeRelogin"/>`
	`288`	`/// </summary>`
	`289`	`public int? SaslKerberosMinTimeBeforeRelogin`
	`290`	`{`
1	`291`	`get => Config.SaslKerberosMinTimeBeforeRelogin;`
0	`292`	`set => Config.SaslKerberosMinTimeBeforeRelogin = value;`
	`293`	`}`
	`294`
	`295`	`/// <summary>`
	`296`	`/// <inheritdoc cref="ClientConfig.SaslOauthbearerConfig"/>`
	`297`	`/// </summary>`
	`298`	`public string SaslOauthbearerConfig`
	`299`	`{`
1	`300`	`get => Config.SaslOauthbearerConfig;`
0	`301`	`set => Config.SaslOauthbearerConfig = value;`
	`302`	`}`
	`303`
	`304`	`/// <summary>`
	`305`	`/// <inheritdoc cref="ClientConfig.EnableSaslOauthbearerUnsecureJwt"/>`
	`306`	`/// </summary>`
	`307`	`public bool? EnableSaslOauthbearerUnsecureJwt`
	`308`	`{`
1	`309`	`get => Config.EnableSaslOauthbearerUnsecureJwt;`
0	`310`	`set => Config.EnableSaslOauthbearerUnsecureJwt = value;`
	`311`	`}`
	`312`
	`313`	`/// <summary>`
	`314`	`/// <inheritdoc cref="ClientConfig.SaslOauthbearerMethod"/>`
	`315`	`/// </summary>`
	`316`	`/// <exception cref="ArgumentOutOfRangeException"></exception>`
	`317`	`public SaslOauthbearerMethod? SaslOauthbearerMethod`
	`318`	`{`
1	`319`	`get => Config.SaslOauthbearerMethod;`
	`320`	`set`
	`321`	`{`
0	`322`	`if (value.HasValue && !SaslOauthbearerMethodHelper.IsDefined(value.Value))`
	`323`	`{`
0	`324`	`throw new ArgumentOutOfRangeException(nameof(value));`
	`325`	`}`
	`326`
0	`327`	`Config.SaslOauthbearerMethod = value;`
0	`328`	`}`
	`329`	`}`
	`330`
	`331`	`/// <summary>`
	`332`	`/// <inheritdoc cref="ClientConfig.SaslOauthbearerClientId"/>`
	`333`	`/// </summary>`
	`334`	`public string SaslOauthbearerClientId`
	`335`	`{`
1	`336`	`get => Config.SaslOauthbearerClientId;`
0	`337`	`set => Config.SaslOauthbearerClientId = value;`
	`338`	`}`
	`339`
	`340`	`/// <summary>`
	`341`	`/// <inheritdoc cref="ClientConfig.SaslOauthbearerClientSecret"/>`
	`342`	`/// </summary>`
	`343`	`public string SaslOauthbearerClientSecret`
	`344`	`{`
1	`345`	`get => Config.SaslOauthbearerClientSecret;`
0	`346`	`set => Config.SaslOauthbearerClientSecret = value;`
	`347`	`}`
	`348`
	`349`	`/// <summary>`
	`350`	`/// <inheritdoc cref="ClientConfig.SaslOauthbearerScope"/>`
	`351`	`/// </summary>`
	`352`	`public string SaslOauthbearerScope`
	`353`	`{`
1	`354`	`get => Config.SaslOauthbearerScope;`
0	`355`	`set => Config.SaslOauthbearerScope = value;`
	`356`	`}`
	`357`
	`358`	`/// <summary>`
	`359`	`/// <inheritdoc cref="ClientConfig.SaslOauthbearerExtensions"/>`
	`360`	`/// </summary>`
	`361`	`public string SaslOauthbearerExtensions`
	`362`	`{`
1	`363`	`get => Config.SaslOauthbearerExtensions;`
0	`364`	`set => Config.SaslOauthbearerExtensions = value;`
	`365`	`}`
	`366`
	`367`	`/// <summary>`
	`368`	`/// <inheritdoc cref="ClientConfig.SaslOauthbearerTokenEndpointUrl"/>`
	`369`	`/// </summary>`
	`370`	`public string SaslOauthbearerTokenEndpointUrl`
	`371`	`{`
1	`372`	`get => Config.SaslOauthbearerTokenEndpointUrl;`
0	`373`	`set => Config.SaslOauthbearerTokenEndpointUrl = value;`
	`374`	`}`
	`375`	`}`

Methods/Properties