connections.size(), nonPooledConnections.size(), maxPoolSize, failCounts.size(), totalHealthChecks.get(),
                connectionsRemoved.get());
    }

    // Enhanced health checking methods

    /**
     * Start proactive health checking
     */
    private void startProactiveHealthChecking() {
        if (proactiveHealthCheckEnabled && healthCheckTask == null) {

     */
    public static void secureWipe(byte[] array) {
        if (array != null) {
            Arrays.fill(array, (byte) 0);
            // Additional passes with different patterns for enhanced security
            Arrays.fill(array, (byte) 0xFF);
            Arrays.fill(array, (byte) 0xAA);
            Arrays.fill(array, (byte) 0x55);
            Arrays.fill(array, (byte) 0);
        }
    }

            this.handle.decode(_src);
            this.retval = _src.dec_ndr_long();
        }
    }

    /**
     * SAMR Connect4 operation for establishing a connection to the SAM database.
     * This is an enhanced version of Connect2 with additional parameters.
     */
    public static class SamrConnect4 extends DcerpcMessage {

        @Override
        public int getOpnum() {
            return 0x3e;
        }

            handle.decode(_src);
            retval = _src.dec_ndr_long();
        }
    }

    /**
     * SAMR Connect4 operation for establishing a connection to the SAM database.
     * This is an enhanced version of Connect2 with additional parameters.
     */
    public static class SamrConnect4 extends DcerpcMessage {

        @Override
        public int getOpnum() {
            return 0x3e;
        }

    private final Semaphore requestSemaphore;
    private final AtomicInteger activeRequests = new AtomicInteger(0);
    private final AtomicLong totalBackpressureRejections = new AtomicLong(0);

    // Enhanced metrics
    private final AtomicLong minResponseTime = new AtomicLong(Long.MAX_VALUE);
    private final AtomicLong maxResponseTime = new AtomicLong(0);
    private final AtomicInteger consecutiveFailures = new AtomicInteger(0);

        String configuratorId = mojoDescriptor.getComponentConfigurator();

        if (configuratorId == null || configuratorId.isEmpty()) {
            configuratorId = mojoDescriptor.isV4Api() ? "enhanced" : "basic";
        }

        try {
            // TODO could the configuration be passed to lookup and the configurator known to plexus via the descriptor

            if (b != 0) {
                return false;
            }
        }
        return true;
    }

    @Test
    @DisplayName("Should generate secure nonces with enhanced randomness when using generateSecureNonce")
    void testEnhancedNonceGeneration() {
        // Given

     *
     * @param serverAddress the server address
     * @return cluster name or null
     */
    private String getClusterName(InetAddress serverAddress) {
        // Simple implementation - could be enhanced with proper cluster discovery
        String hostname = serverAddress.getHostName();
        if (hostname != null && hostname.contains(".")) {
            // Extract potential cluster name from hostname

        }
        return false;
    }

    /**
     * Simple connection retry logic - could be enhanced with exponential backoff
     */
    private boolean shouldRetryConnection() {
        // For now, allow one retry. Could be enhanced with more sophisticated logic.
        return true;
    }

    /**
     * @param context
     * @param name
     */

  - Easier to get a cluster up and running (eg: `kubeadm`, intra-cluster bootstrapping)
  - Easier to understand a cluster (eg: API audit logs, server-based API defaults)
- **Stateful Application Support**
  - Enhanced persistence capabilities (eg: `StorageClasses`, new volume plugins)
  - New resources and scheduler features (eg: `ScheduledJob` resource, pod/node affinity/anti-affinity)
- **Cluster Federation**