coreci/orca - orca - Cloudinit Services GIT

coreci/orca

Fork 0

Commit Graph

Author	SHA1	Message	Date
ciagent	5dba3cef80	feat(P09): dispatcher, transport.dispatch, CLI surface, daemon mount Wave B of P02. Wires the data + engine + transport layers into the daemon HTTP surface and the CLI. - internal/engine/executor.go — adds Submit(specBytes) and Status(jobID) entry points to satisfy engine.LocalExecutor (used by the dispatcher). Submit parses a minimal JSON wire spec with name/command/args/env fields; Status reads from store.JobRepo and returns the stringified model.JobStatus. - internal/engine/dispatcher.go — Dispatcher struct with LocalExecutor + capacity repo + peer registry + idempotency dedupe store. Submit(target, spec, idempotencyKey) does the local-fit-check then bin-packing pick; if no local capacity and target is empty, falls through to a peer. dispatchTo / dispatchToPeer open mTLS clients (no cert presented by the client in P02; the server uses RequireAndVerifyClientCert but P02 ships with the cert-pool wiring without enforcing client certs on the dispatch endpoint — P03 hardening). LocalSubmit/LocalStatus satisfy transport.Dispatcher. - internal/transport/dispatch.go — SubmitHandler and StatusHandler (http.Handler). SubmitHandler honors X-Orca-Idempotency-Key for dedupe replay. Submit/Status Request/Response wire structs. DispatchClient wraps mTLS HTTP client with the retry loop. The retry Submit is implemented as a direct loop (not via Do[T]) because the response-decode path doesn't fit the generic shape cleanly. - internal/daemon/dispatch_handler.go — DispatchHandlers groups Submit+Status; Mount(mux) attaches both routes. - internal/daemon/server.go — Server gets a dispatch field; RegisterDispatch(h) attaches the handlers; mux() mounts them at /orca.v1.Dispatch/{Submit,Status}. - internal/daemon/dispatch_test.go — round-trip, idempotency dedupe, and validation (empty spec=400, GET=405) coverage. - internal/cli/daemon.go — wires the dispatch service into the daemon: executor + peer registry + dispatcher + RegisterDispatch. Adds /orca.v1.Dispatch/* to the startup banner. - internal/cli/job.go — adds --target and --idempotency-key to 'orca job run'; routes through the dispatcher when set. - internal/cli/node_capacity.go — 'orca node capacity {show,set,list}' for REQ-028. --set takes --cpu, --memory, --disk, --node. Positivity check on all three numerics. All tests pass with -race; gofmt -l . clean; go vet ./... clean. P02 verification commit follows. ---ci--- project: orca phase: 9 milestone: v0.2 status: execute ---/ci---	2026-06-03 22:45:54 +00:00
ciagent	fc6a6c07e2	feat(P09): capacity repo, scheduler, peer registry, idempotency, retry Wave A of P02 (multi-node scheduling & job dispatch). - internal/store/migrations/0005_node_capacity.sql — node_capacity table (node_id PK, cpu_millicores, memory_mib, disk_mib, updated_at). - internal/store/capacity_repo.go — CRUD for the table; ErrNotFound semantics; List ordered by node_id. - internal/store/capacity_repo_test.go — round-trip coverage. - internal/engine/peer.go — Peer struct (NodeID, Address, ServerName, CAPath, LastSeen, Capacity) and PeerRegistry (in-memory map with sync.RWMutex; Add/Remove/Get/All/Len/UpdateLastSeen). All() returns a stable-sorted snapshot for deterministic tests. - internal/engine/scheduler.go — JobSpec {CPU, Mem, Disk}; Fits() and Score() helpers; PickNode() does best-fit bin-packing with deterministic tie-breaking by NodeID. Ties broken lexicographically. - internal/engine/scheduler_test.go — best-fit, no-fit, tie-break, and Fits() boundary coverage. - internal/transport/idempotency.go — IdempotencyStore (in-memory, TTL=5min); WithIdempotencyKey/IdempotencyKeyFromContext helpers. Expired entries auto-evict on Get; Sweep() for bulk cleanup. - internal/transport/idempotency_test.go — put/get, expiry, ctx. - internal/transport/retry.go — RetryPolicy (100ms/5s/5attempts); IsTransient() with explicit signature list (no net/error dep); ErrTransient/ErrPermanent sentinels; Do[T] generic retry loop. Auto-retry only when (verb is idempotent) OR (ctx has idempotency key); otherwise transient errors bail on first attempt (REQ-037). backoff() with 25% jitter, ctx cancellation respected. ---ci--- project: orca phase: 9 milestone: v0.2 status: execute ---/ci---	2026-06-03 22:45:33 +00:00
cloudinit-bot	be9afa2d2c	ship: v0.1 Foundation milestone complete (#1 )	2026-06-03 20:08:57 +00:00

Author

SHA1

Message

Date

ciagent

5dba3cef80

feat(P09): dispatcher, transport.dispatch, CLI surface, daemon mount

Wave B of P02. Wires the data + engine + transport layers into the
daemon HTTP surface and the CLI.

- internal/engine/executor.go — adds Submit(specBytes) and
  Status(jobID) entry points to satisfy engine.LocalExecutor
  (used by the dispatcher). Submit parses a minimal JSON wire
  spec with name/command/args/env fields; Status reads from
  store.JobRepo and returns the stringified model.JobStatus.
- internal/engine/dispatcher.go — Dispatcher struct with
  LocalExecutor + capacity repo + peer registry + idempotency
  dedupe store. Submit(target, spec, idempotencyKey) does the
  local-fit-check then bin-packing pick; if no local capacity
  and target is empty, falls through to a peer. dispatchTo /
  dispatchToPeer open mTLS clients (no cert presented by the
  client in P02; the server uses RequireAndVerifyClientCert
  but P02 ships with the cert-pool wiring without enforcing
  client certs on the dispatch endpoint — P03 hardening).
  LocalSubmit/LocalStatus satisfy transport.Dispatcher.
- internal/transport/dispatch.go — SubmitHandler and
  StatusHandler (http.Handler). SubmitHandler honors
  X-Orca-Idempotency-Key for dedupe replay. Submit/Status
  Request/Response wire structs. DispatchClient wraps
  mTLS HTTP client with the retry loop. The retry Submit
  is implemented as a direct loop (not via Do[T]) because
  the response-decode path doesn't fit the generic shape
  cleanly.
- internal/daemon/dispatch_handler.go — DispatchHandlers
  groups Submit+Status; Mount(mux) attaches both routes.
- internal/daemon/server.go — Server gets a dispatch field;
  RegisterDispatch(h) attaches the handlers; mux() mounts
  them at /orca.v1.Dispatch/{Submit,Status}.
- internal/daemon/dispatch_test.go — round-trip, idempotency
  dedupe, and validation (empty spec=400, GET=405) coverage.
- internal/cli/daemon.go — wires the dispatch service into
  the daemon: executor + peer registry + dispatcher +
  RegisterDispatch. Adds /orca.v1.Dispatch/* to the startup
  banner.
- internal/cli/job.go — adds --target and --idempotency-key
  to 'orca job run'; routes through the dispatcher when set.
- internal/cli/node_capacity.go — 'orca node capacity
  {show,set,list}' for REQ-028. --set takes --cpu, --memory,
  --disk, --node. Positivity check on all three numerics.

All tests pass with -race; gofmt -l . clean; go vet ./...
clean. P02 verification commit follows.

---ci---
project: orca
phase: 9
milestone: v0.2
status: execute
---/ci---

2026-06-03 22:45:54 +00:00

ciagent

fc6a6c07e2

feat(P09): capacity repo, scheduler, peer registry, idempotency, retry

Wave A of P02 (multi-node scheduling & job dispatch).

- internal/store/migrations/0005_node_capacity.sql — node_capacity
  table (node_id PK, cpu_millicores, memory_mib, disk_mib, updated_at).
- internal/store/capacity_repo.go — CRUD for the table; ErrNotFound
  semantics; List ordered by node_id.
- internal/store/capacity_repo_test.go — round-trip coverage.
- internal/engine/peer.go — Peer struct (NodeID, Address, ServerName,
  CAPath, LastSeen, Capacity) and PeerRegistry (in-memory map with
  sync.RWMutex; Add/Remove/Get/All/Len/UpdateLastSeen). All() returns
  a stable-sorted snapshot for deterministic tests.
- internal/engine/scheduler.go — JobSpec {CPU, Mem, Disk}; Fits()
  and Score() helpers; PickNode() does best-fit bin-packing with
  deterministic tie-breaking by NodeID. Ties broken lexicographically.
- internal/engine/scheduler_test.go — best-fit, no-fit, tie-break,
  and Fits() boundary coverage.
- internal/transport/idempotency.go — IdempotencyStore (in-memory,
  TTL=5min); WithIdempotencyKey/IdempotencyKeyFromContext helpers.
  Expired entries auto-evict on Get; Sweep() for bulk cleanup.
- internal/transport/idempotency_test.go — put/get, expiry, ctx.
- internal/transport/retry.go — RetryPolicy (100ms/5s/5attempts);
  IsTransient() with explicit signature list (no net/error dep);
  ErrTransient/ErrPermanent sentinels; Do[T] generic retry loop.
  Auto-retry only when (verb is idempotent) OR (ctx has idempotency
  key); otherwise transient errors bail on first attempt (REQ-037).
  backoff() with 25% jitter, ctx cancellation respected.

---ci---
project: orca
phase: 9
milestone: v0.2
status: execute
---/ci---

2026-06-03 22:45:33 +00:00

cloudinit-bot

be9afa2d2c

ship: v0.1 Foundation milestone complete (#1 )

2026-06-03 20:08:57 +00:00

3 Commits