Skip to content

A tiny Scala/Kyo POC that makes cloud uploads cancel-safe.#1

Open
vim89 wants to merge 12 commits intomainfrom
poc-0.0.1
Open

A tiny Scala/Kyo POC that makes cloud uploads cancel-safe.#1
vim89 wants to merge 12 commits intomainfrom
poc-0.0.1

Conversation

@vim89
Copy link
Copy Markdown
Owner

@vim89 vim89 commented Sep 14, 2025

  • GcsUploadSink — IO-specific resumable upload using:
    • com.google.cloud.storage.WriteChannel.capture/restore()
    • chunked streaming via FS2
    • cancel preemption via IO.interruptibleMany
    • deterministic failure injection (see FAIL_AFTER_CHUNKS)
    • replay buffer for bytes written since last checkpoint to keep writer offset and source position consistent after restore
  • KyoInterOp — tiny bridge to run Kyo < Async & Abort[Throwable] & Env[Ctx] > programs as IO.
  • Main — CLI to demo success, cancel, and resume scenarios.

@vim89 vim89 self-assigned this Sep 14, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant