akkaradb/dev.swiftstorm.akkaradb.format.api

Package-level declarations

Types

Packs TLV records directly into a 32 KiB block using the fixed 32-byte header (AKHdr32).

Unpacks a 32 KiB block built with AKHdr32 records. StripeReader is responsible for CRC verification/repair; the Unpacker only trusts and parses.

CommitTicket

data class CommitTicket(val uptoStripe: Long, val future: CompletableFuture<Long>)

Result of a flush() call.

ECParityCoder

interface ECParityCoder : ParityCoder

Error-correcting extension for ParityCoder (supports unknown-location errors).

FlushMode

enum FlushMode : Enum<FlushMode>

Flush mode for durability.

FlushPolicy

data class FlushPolicy(val maxBlocks: Int = 32, val maxMicros: Long = 1000, val executor: Executor? = null)

Group-commit policy.

ParityCoder

interface ParityCoder : Closeable

ParityCoder — zero-allocation parity codec for AkkaraDB stripes (ByteBufferL-only).

ParityKind

enum ParityKind : Enum<ParityKind>

Kind hint for metrics/logging.

ReaderMetricsSnapshot

data class ReaderMetricsSnapshot(val stripesReturned: Long = 0, val bytesReadData: Long = 0, val bytesReadParity: Long = 0, val readMicros: Long = 0, val verifyMicros: Long = 0, val reconstructMicros: Long = 0)

One-shot metrics snapshot for the reader.

ReaderRecoveryResult

data class ReaderRecoveryResult(val lastSealed: Long, val lastDurable: Long, val truncatedTail: Boolean)

Recovery outcome for the reader.

RecordCursor

interface RecordCursor

Forward-only iterator over TLVs inside the payload.

RecordView

data class RecordView(val key: ByteBufferL, val value: ByteBufferL, val seq: U64, val flags: Int, val kLen: Int, val vLen: U32, val totalLen: Int)

Read-only, zero-copy view over a TLV inside a block payload. TLV (LE): u32 vLenu8 flagskey

RecoveryResult

data class RecoveryResult(val lastSealed: Long, val lastDurable: Long, val truncatedTail: Boolean)

Recovery outcome.

StripeMetricsSnapshot

data class StripeMetricsSnapshot(val sealedStripes: Long = 0, val durableStripes: Long = 0, val bytesWrittenData: Long = 0, val bytesWrittenParity: Long = 0, val parityMicros: Long = 0, val laneWriteMicros: Long = 0, val fsyncMicros: Long = 0, val maxBackpressureMicros: Long = 0)

One-shot metrics snapshot. All counters are monotonic since writer creation.

StripeReader

interface StripeReader : Closeable

Reader abstraction for sequentially consuming stripes from a segment.

StripeWriter

interface StripeWriter : Closeable

Stripe-aligned block appender.