koog-agents-optimization

0.1.0-SNAPSHOT

koog-agents-optimization/ai.koog.agents.optimization.utils.common/ResilientPath

ResilientPath

class ResilientPath(path: Path)

A wrapper around Path whose write operations retry on transient I/O failures.

Intended for paths that may live on a GCS-fuse mount, where close()-time uploads can fail with transient errors (e.g. "Stale file handle"). Read operations delegate directly to Path; mutating operations (writeText, createDirectories, deleteRecursively, etc.) wrap the call in an exponential-backoff retry loop. See writeText for the full rationale.

Constructors

constructor(path: String)

Constructs a ResilientPath from a string path, parsed via Path.of.

constructor(path: Path)

Types

object Companion

Factory helpers for constructing ResilientPath instances.

Properties

absolutePathString

val absolutePathString: String

The normalized, absolute string form of this path.

Functions

createDirectories

fun createDirectories(maxRetries: Int = DEFAULT_MAX_RETRIES, initialDelayMs: Long = DEFAULT_INITIAL_DELAY_MS)

Retry-wrapped directory creation (including this path). See writeText for rationale.

createParentDirectories

fun createParentDirectories(maxRetries: Int = DEFAULT_MAX_RETRIES, initialDelayMs: Long = DEFAULT_INITIAL_DELAY_MS)

Retry-wrapped createParentDirectories. See writeText for rationale.

fun deleteIfExists(maxRetries: Int = DEFAULT_MAX_RETRIES, initialDelayMs: Long = DEFAULT_INITIAL_DELAY_MS)

Retry-wrapped deleteIfExists. See writeText for rationale.

deleteRecursively

fun deleteRecursively(maxRetries: Int = DEFAULT_MAX_RETRIES, initialDelayMs: Long = DEFAULT_INITIAL_DELAY_MS)

Retry-wrapped recursive delete. See writeText for rationale.

operator fun div(other: ResilientPath): ResilientPath

operator fun div(other: String): ResilientPath

Path-join operator, equivalent to resolve.

fun exists(): Boolean

Whether the underlying path exists on the filesystem.

fun ~~getPath~~(): Path

Returns the wrapped Path, bypassing the retry behavior; avoid unless strictly necessary.

fun isJsonFile(): Boolean

Whether the path's file name has a .json extension (case-insensitive).

fun readText(): String

Reads the entire file content as text.

fun resolve(other: ResilientPath): ResilientPath

fun resolve(other: String): ResilientPath

Resolves other against this path, returning a new ResilientPath.

fun ResilientPath?.toFilePathLog(): String

Formats this path as a clickable file:// URI for log output, or file://<file not specified> when the receiver is null.

open override fun toString(): String

Returns absolutePathString.

fun writeText(text: String, maxRetries: Int = DEFAULT_MAX_RETRIES, initialDelayMs: Long = DEFAULT_INITIAL_DELAY_MS)

Writes text to this path with automatic retry on transient I/O failures.