Package-level declarations
Types
Link copied to clipboard
class AkkBlockPacker(onBlockReady: (ByteBufferL) -> Unit, pool: BufferPool = Pools.io()) : BlockPacker, Closeable
Direct-write 32 KiB block packer using ByteBufferL and AKHdr32.
Link copied to clipboard
High-throughput unpacker for blocks with AKHdr32-based records. Validates frame bounds, iterates record-by-record, and returns zero-copy slices.
Link copied to clipboard
class AkkStripeReader(val k: Int, val m: Int, laneDir: Path, pool: BufferPool, coder: ParityCoder, laneFilePrefixData: String = "data_", laneFilePrefixParity: String = "parity_", laneFileExtData: String = ".akd", laneFileExtParity: String = ".akp") : StripeReader
Link copied to clipboard
class AkkStripeWriter(val k: Int, val m: Int, laneDir: Path, pool: BufferPool, coder: ParityCoder = when (m) {
0 -> NoParityCoder()
1 -> XorParityCoder()
2 -> DualXorParityCoder()
else -> RSParityCoder(m)
}, var flushPolicy: FlushPolicy = FlushPolicy(), fastMode: Boolean = false, fallocateHintBytes: Long = 0, laneFilePrefixData: String = "data_", laneFilePrefixParity: String = "parity_", laneFileExtData: String = ".akd", laneFileExtParity: String = ".akp") : StripeWriter
High-performance StripeWriter (ByteBufferL-only).