Package com.pkgrove.pkgrovekit.storage
See: Description
-
Enum Summary Enum Description StorageCapability Provider-varying behavior, made DISCOVERABLE (HEL-236 capability model). ChecksumAlgorithm Checksum algorithms the API can express; providers support a subset. -
Class Summary Class Description StorageLimits Provider size limits; workflows size parts/objects against THESE, never constants. StorageCapabilities What one concrete store supports. Checkpoint CheckpointStore Resumable transfer checkpoints with conditional writes (HEL-236 scenario 4). Checksum A content checksum. ChecksumVerifyingInputStream Verifies a SHA-256 checksum WHILE streaming: on the read that reaches EOF the computed digest is compared and a mismatch throws ChecksumMismatchException (HEL-236: corruption fails visibly, exactly at the earliest point it is provable). ExportOptions ExportResult ReadOptions DatasetPart One published dataset part as the manifest records it. DatasetManifest The dataset commit record. DatasetHandle A readable, verified view of a published dataset. StorageException Typed storage outcomes (HEL-236). ObjectNotFoundException The object (or bucket) addressed by a read/copy does not exist. PreconditionFailedException A WriteCondition was not met — for WriteCondition.IfAbsent someone else already created the key (lost the commit race); for WriteCondition.IfMatch the object changed underneath (stale etag). ChecksumMismatchException Content did not match its declared/stored checksum. CapabilityRejectedException A workflow needs capabilities this provider does not support. StorageIoException Transport/provider failure with an explicit retry-safety verdict. InMemoryObjectStore Reference/testing implementation of ObjectStore — plain JDK, thread-safe, strongly consistent, full capability set. Options ObjectKey A validated object key. ObjectSummary One listing entry — deliberately small (listing pages can be huge). ObjectMetadata Full metadata of one object (a head, or what a write reported back).IfMatch Succeed only when the key currently has etag (optimistic update). WriteCondition Conditional-write semantics (HEL-236). PutOptions GetOptions CopyOptions PutResult Typed outcome of a completed write/copy. ObjectContent A streaming object read. CompletedUploadPart Receipt QuarantineWriter Failed-row quarantine with redaction (HEL-236 scenario 6). StagingArea Staged, atomically-published writes (HEL-236 guarantee 2). -
Object Summary Object Description Companion ObjectDataset Row datasets as manifest-committed object parts (HEL-236 scenarios 1–3): bounded encoded parts under a run-scoped prefix, published atomically via StagingArea — the manifest is the ONLY thing a reader trusts, so a mid-export failure never yields a readable half-dataset. MultipartTransfer Bounded streaming upload over the MultipartUpload lifecycle (HEL-236 guarantees 1+3). None Unconditional overwrite (the storage default). IfAbsent Succeed only when the key does not exist yet — the commit primitive. JsonLinesRowFormat JSON Lines: one JSON array per row, positionally aligned with the schema (arrays, not objects — column names live once in the manifest, not per row). -
Interface Summary Interface Description ContentSource Streaming content for uploads (HEL-236 guarantee 1). ObjectStore Vendor-neutral object storage (HEL-236). MultipartUpload Raw multipart lifecycle (HEL-236 guarantee 3). RowPartFormat How rows become object-part bytes and back (HEL-236 scenarios 1–2).