/** The temporary directory for input/output files. */
    protected File tempDir = null;

    /** The command to execute. */
    protected String command;

    /** The timeout for command execution in milliseconds. */
    protected long executionTimeout = 30L * 1000L; // 30sec

    /** The working directory for the command. */
    protected File workingDirectory = null;

    /** The encoding for the command's output. */

     */
    Long getLastModified();

    /**
     * Sets the last modified timestamp for the URL queue entry.
     *
     * @param lastModified the timestamp of the last modification in milliseconds since epoch.
     */
    void setLastModified(Long lastModified);

    /**
     * Returns the creation time of the URL queue entry.
     *
     * @return the creation time as a Long value.
     */

                session.getResult().addException(e);
                break;
            }
        }

        executor.shutdown();
        executor.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
    }

    private void multiThreadedProjectTaskSegmentBuild(
            ConcurrencyDependencyGraph analyzer,
            ReactorContext reactorContext,
            MavenSession rootSession,

     */
    public boolean shouldRetry() {
        return severity == Severity.RECOVERABLE || severity == Severity.TRANSIENT;
    }

    /**
     * Gets recommended retry delay in milliseconds
     *
     * @return retry delay or 0 if no retry
     */
    public long getRetryDelay() {
        switch (severity) {
        case RECOVERABLE:
            return 100; // Immediate retry with small delay

            // Test implementation
        }

        public boolean waitForNotification(long timeoutMs) throws InterruptedException {
            return notificationLatch.await(timeoutMs, TimeUnit.MILLISECONDS);
        }

        public WitnessNotification getLastNotification() {
            return lastNotification;
        }
    }

    /**

		"Total number of objects which failed replication in the last full minute on a bucket",
		bucketL, targetArnL)
	bucketReplLatencyMsMD = NewGaugeMD(bucketReplLatencyMs,
		"Replication latency on a bucket in milliseconds",
		bucketL, operationL, rangeL, targetArnL)
	bucketReplProxiedDeleteTaggingRequestsTotalMD = NewCounterMD(bucketReplProxiedDeleteTaggingRequestsTotal,
		"Number of DELETE tagging requests proxied to replication target",

            try {
                readInterval = Long.parseLong(value);
            } catch (final NumberFormatException e) {
                logger.warn("Invalid readInterval value: '{}'. Expected: numeric value in milliseconds.", value);
            }
        }
        return readInterval;
    }

    /**
     * Sleep for the specified interval.
     * @param interval The interval.
     */

	}

	return addrs
}

// TCPOptions specify customizable TCP optimizations on raw socket
type TCPOptions struct {
	UserTimeout int // this value is expected to be in milliseconds

	// When the net.Conn is a remote drive this value is honored, we close the connection to remote peer proactively.
	DriveOPTimeout func() time.Duration

    builder = builder.noCache()
    builder = builder.noStore()
    builder = builder.maxAge(0, TimeUnit.MILLISECONDS)
    builder = builder.maxStale(0, TimeUnit.MILLISECONDS)
    builder = builder.minFresh(0, TimeUnit.MILLISECONDS)
    builder = builder.onlyIfCached()
    builder = builder.noTransform()
    builder = builder.immutable()
    val cacheControl: CacheControl = builder.build()

 *   <li>secretKey - The secret key for authentication</li>
 *   <li>region - The AWS region (default: us-east-1)</li>
 *   <li>connectTimeout - Connection timeout in milliseconds (default: 10000)</li>
 *   <li>readTimeout - Read timeout in milliseconds (default: 10000)</li>
 * </ul>
 *
 * <p>The client supports URLs in the format: {@code s3://bucket-name/object-path}
 *
 * <p>Features:
 * <ul>