remote_runtime.go RawHistoryFolder

1package ports
2
3import (
4	"context"
5	"time"
6
7	"github.com/bnema/vev/internal/domain"
8	"github.com/bnema/vev/internal/protocol/catalogue"
9)
10
11// RemoteJobKind identifies one bounded unit of remote infrastructure work.
12// Jobs and results are typed tagged values with request identity, not
13// callbacks or raw frames.
14type RemoteJobKind uint8
15
16const (
17	RemoteJobRegistryRead RemoteJobKind = iota + 1
18	RemoteJobCacheLoad
19	RemoteJobCatalogObserve
20	RemoteJobCacheStore
21)
22
23// RemoteJob is one admitted unit of remote work. Registration and Generation
24// fence the job: results bound to a superseded registration never apply.
25// Deadline bounds catalogue observation; Entries carries cache-store payload.
26type RemoteJob struct {
27	Kind         RemoteJobKind
28	Endpoint     string
29	Registration domain.RemoteRegistration
30	Generation   domain.RemoteGeneration
31	Deadline     time.Duration
32	Entries      []catalogue.RemoteCatalogCacheEntry
33}
34
35// RemoteJobResult is exactly one completion for an admitted job: success,
36// failure or cancellation. Exactly one result retires one admission credit.
37// FailureKind carries the runtime's sanitized classification; Err preserves
38// the cause for errors.Is/As callers.
39type RemoteJobResult struct {
40	Kind          RemoteJobKind
41	Endpoint      string
42	Registration  domain.RemoteRegistration
43	Generation    domain.RemoteGeneration
44	FailureKind   domain.RemoteFailureKind
45	Catalog       catalogue.RemoteCatalog
46	Registrations []domain.RemoteRegistration
47	Entries       []catalogue.RemoteCatalogCacheEntry
48	Err           error
49}
50
51// RemoteRuntime is the bounded infrastructure seam executing remote jobs. It
52// owns subprocesses, storage calls and per-lane dispatch; workers never call
53// into the use case. A successful job-channel send transfers exactly one
54// admission credit until exactly one completion. Dispatch never blocks
55// forwarding into an occupied lane; cancelled completions select on context
56// cancellation.
57type RemoteRuntime interface {
58	Run(ctx context.Context, jobs <-chan RemoteJob, results chan<- RemoteJobResult) error
59}