giles
16cb727406
Some checks failed
Test, Build, and Deploy / test-build-deploy (push) Failing after 42s
flow-replicate-to copies the plain-data store export to a peer's replica slot; flow-restore-from imports it. Handoff = replicate, local instance dies, peer restores and resumes by id. The replay log survives the move, so all resolved suspends carry over. Same durable-data mechanism as crash recovery, across instances. All four phases complete: 93/93. Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
63 lines
2.2 KiB
Plaintext
63 lines
2.2 KiB
Plaintext
;; lib/flow/api.sx — flow runtime entry points.
|
|
;;
|
|
;; Builds a Scheme env preloaded with the flow combinators (lib/flow/spec.sx),
|
|
;; the durable store + lifecycle (lib/flow/store.sx), and the fed-sx remote layer
|
|
;; (lib/flow/remote.sx), and provides SX helpers to run flow programs.
|
|
;;
|
|
;; Scheme-level API (available inside flow programs):
|
|
;; (flow/start flow input) — run a flow; raw result if it completes, else
|
|
;; (flow-suspended id tag). Defined in store.sx.
|
|
;; (flow/resume id value) — resume a suspended flow (store.sx)
|
|
;; (flow/cancel id) — cancel a flow (store.sx)
|
|
;; (suspend tag) — suspension point (spec.sx)
|
|
;; (remote-node addr fn) — node executed on a federation peer (remote.sx)
|
|
;;
|
|
;; SX-level helpers (for hosts and tests):
|
|
;; (flow-make-env) — fresh standard env + combinators + store + remote
|
|
;; (flow-run src) — eval a Scheme program string in a reset shared env
|
|
;; (flow-run-in env src) — eval a Scheme program string in a given env
|
|
;;
|
|
;; flow-run reuses ONE env (building the full standard env is expensive) and
|
|
;; resets the mutable flow globals before each program, so tests stay isolated
|
|
;; without paying for a fresh standard env each time. flow-registry persists (it
|
|
;; models reloaded flow definitions surviving a restart).
|
|
|
|
(define
|
|
flow-make-env
|
|
(fn
|
|
()
|
|
(let
|
|
((env (scheme-standard-env)))
|
|
(flow-load-combinators! env)
|
|
(flow-load-store! env)
|
|
(flow-load-remote! env)
|
|
env)))
|
|
|
|
(define
|
|
flow-run-in
|
|
(fn (env src) (scheme-eval-program (scheme-parse-all src) env)))
|
|
|
|
(define
|
|
flow-reset-src
|
|
"(set! flow-store (list)) (set! flow-next-id 0) (set! flow-replay-log (list)) (set! flow-suspend-k #f) (set! flow-timeout-budget -1) (set! flow-peers (list)) (set! flow-replicas (list))")
|
|
|
|
(define flow-env-cache false)
|
|
|
|
(define
|
|
flow-shared-env
|
|
(fn
|
|
()
|
|
(begin
|
|
(if flow-env-cache nil (set! flow-env-cache (flow-make-env)))
|
|
flow-env-cache)))
|
|
|
|
(define
|
|
flow-run
|
|
(fn
|
|
(src)
|
|
(let
|
|
((env (flow-shared-env)))
|
|
(begin
|
|
(scheme-eval-program (scheme-parse-all flow-reset-src) env)
|
|
(scheme-eval-program (scheme-parse-all src) env)))))
|