Directories
¶
| Path | Synopsis |
|---|---|
|
Package cancel implements per-task cancel-signal subscriptions for sqi-worker.
|
Package cancel implements per-task cancel-signal subscriptions for sqi-worker. |
|
Package capabilities provides auto-detection and manual override of sqi-worker host capabilities reported to sqi-server at registration time.
|
Package capabilities provides auto-detection and manual override of sqi-worker host capabilities reported to sqi-server at registration time. |
|
Package config defines the sqi-worker runtime configuration and provides layered loading from built-in defaults, a YAML/JSON file, SQI_WORKER_* environment variables, and CLI flag overrides — in that override order.
|
Package config defines the sqi-worker runtime configuration and provides layered loading from built-in defaults, a YAML/JSON file, SQI_WORKER_* environment variables, and CLI flag overrides — in that override order. |
|
Package diaglog implements the sqi-worker diagnostic-log sink.
|
Package diaglog implements the sqi-worker diagnostic-log sink. |
|
Package discovery provides mDNS-based sqi-server discovery for sqi-worker.
|
Package discovery provides mDNS-based sqi-server discovery for sqi-worker. |
|
Package envutil provides shared helpers for building process environment variable slices from os.Environ() plus a caller-supplied override map.
|
Package envutil provides shared helpers for building process environment variable slices from os.Environ() plus a caller-supplied override map. |
|
Package executor implements the bare-metal task executor for sqi-worker.
|
Package executor implements the bare-metal task executor for sqi-worker. |
|
Package fmtres resolves OpenJD "{{...}}" format strings on the worker, where the session working directory — and therefore Session.WorkingDirectory — is only known at run time.
|
Package fmtres resolves OpenJD "{{...}}" format strings on the worker, where the session working directory — and therefore Session.WorkingDirectory — is only known at run time. |
|
Package heartbeat implements the worker's periodic liveness signal to sqi-server.
|
Package heartbeat implements the worker's periodic liveness signal to sqi-server. |
|
Package lease implements the worker side of the work-lease protocol: it keeps exactly one outstanding lease request per queue and dispatches each assignment the server returns.
|
Package lease implements the worker side of the work-lease protocol: it keeps exactly one outstanding lease request per queue and dispatches each assignment the server returns. |
|
Package logstreamer implements the log-chunk publisher for sqi-worker.
|
Package logstreamer implements the log-chunk publisher for sqi-worker. |
|
Package metrics defines and registers all Prometheus metrics for sqi-worker.
|
Package metrics defines and registers all Prometheus metrics for sqi-worker. |
|
Package natsclient provides the NATS client factory for sqi-worker.
|
Package natsclient provides the NATS client factory for sqi-worker. |
|
Package obs provides the local observability HTTP server for sqi-worker.
|
Package obs provides the local observability HTTP server for sqi-worker. |
|
Package openjd implements the OpenJD progress-line interceptor for sqi-worker.
|
Package openjd implements the OpenJD progress-line interceptor for sqi-worker. |
|
Package pathmap implements resolved-mode path substitution for sqi-worker.
|
Package pathmap implements resolved-mode path substitution for sqi-worker. |
|
Package protocol defines the versioned JSON wire protocol used between sqi-server and sqi-worker agents.
|
Package protocol defines the versioned JSON wire protocol used between sqi-server and sqi-worker agents. |
|
Package registration manages worker registration with sqi-server over NATS.
|
Package registration manages worker registration with sqi-server over NATS. |
|
Package session manages the lifecycle of OpenJD sessions on the worker.
|
Package session manages the lifecycle of OpenJD sessions on the worker. |
|
Package staging implements the stage_locally path delivery: copying job inputs to worker-local scratch before a task runs and outputs back afterward.
|
Package staging implements the stage_locally path delivery: copying job inputs to worker-local scratch before a task runs and outputs back afterward. |
|
Package status implements the typed task-status publisher for sqi-worker.
|
Package status implements the typed task-status publisher for sqi-worker. |
Click to show internal directories.
Click to hide internal directories.