public async Task CheckHealthAsync()

in src/Epam.Kafka.HealthChecks/ClusterHealthCheck.cs [34:124]
78 lines of code
11 McCabe index (conditional complexity)

    public async Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context,
        CancellationToken cancellationToken = new CancellationToken())
    {
        string description = "Not used by application.";
        HealthStatus status = HealthStatus.Healthy;

        string name = context.Registration.Name.Substring(NamePrefix.Length);

        ClusterHealthCheckOptions options = this._optionsMonitor.Get(name);

        if (options.IncludeUnused || this._kafkaFactory is not KafkaFactory kf || kf.UsedClusters.Contains(name))
        {
            description = "AdminClient: ";

            if (options.SkipAdminClient)
            {
                description += "check skipped.";
            }
            else
            {
#pragma warning disable CA1031 // Not applicable for this health checks

                try
                {
                    using IClient client = this._kafkaFactory.GetOrCreateClient(name);

                    using IDisposable subscription = ((IObservable<Error>)client).Subscribe(this);

                    using IAdminClient adminClient = client.CreateDependentAdminClient();

                    await adminClient
                        .DescribeClusterAsync(new DescribeClusterOptions
                        { RequestTimeout = context.Registration.Timeout })
                        .ConfigureAwait(false);

                    if (this._errors.Count > 0)
                    {
                        status = HealthStatus.Degraded;
                        description += string.Join(", ", this._errors) + ".";
                    }
                    else
                    {
                        description += "OK.";
                    }
                }
                catch (Exception e)
                {
                    status = context.Registration.FailureStatus;

                    if (this._errors.Count > 0)
                    {
                        description += string.Join(", ", this._errors) + ".";
                    }
                    else
                    {
                        description += $"{e.Message}.";
                    }
                }
            }

            if (options.SkipSchemaRegistry)
            {
                description += " SchemaRegistry: check skipped.";
            }
            else
            {
                try
                {
                    if (this._clusterOptionsMonitor.Get(name).SchemaRegistryConfig.Any())
                    {
                        ISchemaRegistryClient sr = this._kafkaFactory.GetOrCreateSchemaRegistryClient(name);
                        await sr.GetCompatibilityAsync().ConfigureAwait(false);
                        description += " SchemaRegistry: OK.";
                    }
                    else
                    {
                        description += " SchemaRegistry: not configured.";
                    }
                }
                catch (Exception e)
                {
                    status = context.Registration.FailureStatus;
                    description += $" SchemaRegistry: {e.Message}.";
                }
            }

#pragma warning restore CA1031
        }

        return new HealthCheckResult(status, description);
    }