worker/

directory
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 13, 2026 License: AGPL-3.0

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL