Directories
¶
| Path | Synopsis |
|---|---|
|
_LICENSES
|
|
|
cmd
|
|
|
ate-setup
command
Command ate-setup installs and tears down Agent Substrate on a Kubernetes cluster.
|
Command ate-setup installs and tears down Agent Substrate on a Kubernetes cluster. |
|
ate-setup/internal/cmd
Package cmd implements the ate-setup command tree.
|
Package cmd implements the ate-setup command tree. |
|
ate-setup/internal/config
Package config resolves the environment ate-setup installs into.
|
Package config resolves the environment ate-setup installs into. |
|
ate-setup/internal/demos
Package demos holds the contract every bundled demo implements, the registry the command tree is built from, and the shared behavior of a demo that is one manifest template.
|
Package demos holds the contract every bundled demo implements, the registry the command tree is built from, and the shared behavior of a demo that is one manifest template. |
|
ate-setup/internal/demos/all
Package all links every bundled demo into the binary.
|
Package all links every bundled demo into the binary. |
|
ate-setup/internal/demos/autoscaledworkerpool
Package autoscaledworkerpool installs the counter workload plus the custom-metrics stack that drives a HorizontalPodAutoscaler over its WorkerPool.
|
Package autoscaledworkerpool installs the counter workload plus the custom-metrics stack that drives a HorizontalPodAutoscaler over its WorkerPool. |
|
ate-setup/internal/demos/claudemultiplex
Package claudemultiplex installs the claude-code-multiplex demo, which runs several Claude Code agents side by side on one WorkerPool.
|
Package claudemultiplex installs the claude-code-multiplex demo, which runs several Claude Code agents side by side on one WorkerPool. |
|
ate-setup/internal/demos/counter
Package counter installs the counter demo: a counter actor exercising snapshot, resume, and atenet ingress, optionally with an external volume attached so the CSI path is covered end to end.
|
Package counter installs the counter demo: a counter actor exercising snapshot, resume, and atenet ingress, optionally with an external volume attached so the CSI path is covered end to end. |
|
ate-setup/internal/demos/demotest
Package demotest provides the fixtures the demo packages share in their tests: an Env that needs no cluster, and the assertion that a rendered template is a complete manifest.
|
Package demotest provides the fixtures the demo packages share in their tests: an Env that needs no cluster, and the assertion that a rendered template is a complete manifest. |
|
ate-setup/internal/demos/egress
Package egress installs the egress demo, which exercises egress policy enforcement through atenet.
|
Package egress installs the egress demo, which exercises egress policy enforcement through atenet. |
|
ate-setup/internal/demos/multitemplate
Package multitemplate installs the multi-template demo, where two ActorTemplates in two different atespaces share a single WorkerPool.
|
Package multitemplate installs the multi-template demo, where two ActorTemplates in two different atespaces share a single WorkerPool. |
|
ate-setup/internal/demos/parking
Package parking installs the parking demo, which parks and unparks actors on a small WorkerPool.
|
Package parking installs the parking demo, which parks and unparks actors on a small WorkerPool. |
|
ate-setup/internal/demos/sandbox
Package sandbox installs the sandbox demo: an ActorTemplate driven on demand by the sandbox client rather than by a long-lived workload.
|
Package sandbox installs the sandbox demo: an ActorTemplate driven on demand by the sandbox client rather than by a long-lived workload. |
|
ate-setup/internal/images
Package images decides where ate-setup gets container images from.
|
Package images decides where ate-setup gets container images from. |
|
ate-setup/internal/ko
Package ko builds and publishes images referenced by manifests, replacing the run_ko helper in the shell installer.
|
Package ko builds and publishes images referenced by manifests, replacing the run_ko helper in the shell installer. |
|
ate-setup/internal/kube
Package kube provides the cluster operations ate-setup needs, replacing the kubectl invocations the install shell scripts made.
|
Package kube provides the cluster operations ate-setup needs, replacing the kubectl invocations the install shell scripts made. |
|
ate-setup/internal/kustomize
Package kustomize renders the overlays under manifests/ate-install, standing in for `kubectl kustomize <dir> --load-restrictor LoadRestrictionsNone`.
|
Package kustomize renders the overlays under manifests/ate-install, standing in for `kubectl kustomize <dir> --load-restrictor LoadRestrictionsNone`. |
|
ate-setup/internal/log
Package log prints install progress, preserving the "[step]: name" output the shell scripts produced so existing CI log scrapers keep working.
|
Package log prints install progress, preserving the "[step]: name" output the shell scripts produced so existing CI log scrapers keep working. |
|
ate-setup/internal/render
Package render expands the demos' *.yaml.tmpl files.
|
Package render expands the demos' *.yaml.tmpl files. |
|
ate-setup/internal/steps
Package steps holds the install and teardown operations that the shell installer implemented as bash functions.
|
Package steps holds the install and teardown operations that the shell installer implemented as bash functions. |
|
ateapi
command
|
|
|
ateapi/internal/ateletauth
Package ateletauth authenticates RPCs that arrive from an atelet, for the ateapi services served only to atelet.
|
Package ateletauth authenticates RPCs that arrive from an atelet, for the ateapi services served only to atelet. |
|
ateapi/internal/ateletauth/ateletauthtest
Package ateletauthtest builds the peer contexts that the ateapi services served only to atelet authenticate against.
|
Package ateletauthtest builds the peer contexts that the ateapi services served only to atelet authenticate against. |
|
ateapi/internal/oidcjwt
Package oidcjwt verifies JWTs using OIDC discovery.
|
Package oidcjwt verifies JWTs using OIDC discovery. |
|
ateapi/internal/scheduling
Package scheduling decides which worker should host an actor.
|
Package scheduling decides which worker should host an actor. |
|
ateapi/internal/store
Package store contains common types for the persistence layer.
|
Package store contains common types for the persistence layer. |
|
ateapi/internal/store/atepg
Package atepg is an ate storage backend built on PostgreSQL.
|
Package atepg is an ate storage backend built on PostgreSQL. |
|
ateapi/internal/store/dockerenv
Package dockerenv points testcontainers at the active Docker context.
|
Package dockerenv points testcontainers at the active Docker context. |
|
ateapi/internal/store/storecontract
Package storecontract provides backend-neutral assertions for store.Interface implementations.
|
Package storecontract provides backend-neutral assertions for store.Interface implementations. |
|
ateapi/internal/store/storetest
Package storetest provides isolated PostgreSQL-backed stores for tests.
|
Package storetest provides isolated PostgreSQL-backed stores for tests. |
|
ateapi/internal/workercache
Package workercache maintains an in-memory view of all workers, kept current via store.Interface.WatchWorkers.
|
Package workercache maintains an in-memory view of all workers, kept current via store.Interface.WatchWorkers. |
|
ateapi/internal/workerservice
Package workerservice serves the RPCs a Worker uses to tell the control plane about itself.
|
Package workerservice serves the RPCs a Worker uses to tell the control plane about itself. |
|
atecontroller
command
|
|
|
atecontroller/internal/workersync
Package workersync reconciles Kubernetes worker pods into the Worker registry behind the ateapi Control API.
|
Package workersync reconciles Kubernetes worker pods into the Worker registry behind the ateapi Control API. |
|
atelet
command
|
|
|
atenet
command
|
|
|
atenet/internal/router/egress
Package egress implements the ext_proc handler for outbound actor traffic: it authenticates the actor behind an egress CONNECT before the gateway tunnels it out.
|
Package egress implements the ext_proc handler for outbound actor traffic: it authenticates the actor behind an egress CONNECT before the gateway tunnels it out. |
|
atenet/internal/router/extproc
Package extproc implements the external processing (ext_proc) gRPC server that the atenet router serves to its dataplane gateways.
|
Package extproc implements the external processing (ext_proc) gRPC server that the atenet router serves to its dataplane gateways. |
|
atenet/internal/router/ingress
Package ingress implements the ext_proc handler for traffic arriving at the ingress gateway: it resolves the actor a request is addressed to, resumes it through the control plane (parking the request while the worker pool is saturated), and points the dataplane at the worker that ends up hosting it.
|
Package ingress implements the ext_proc handler for traffic arriving at the ingress gateway: it resolves the actor a request is addressed to, resumes it through the control plane (parking the request while the worker pool is saturated), and points the dataplane at the worker that ends up hosting it. |
|
atenet/internal/sdsmint
Delta SDS: the stateful, per-connection half of the server.
|
Delta SDS: the stateful, per-connection half of the server. |
|
ateom-gvisor
command
|
|
|
ateom-gvisor/internal/cdiinject
Package cdiinject applies CDI container edits to an actor's OCI bundle.
|
Package cdiinject applies CDI container edits to an actor's OCI bundle. |
|
ateom-gvisor/internal/cgroupstats
Package cgroupstats reads resource usage out of a cgroup v2 directory.
|
Package cgroupstats reads resource usage out of a cgroup v2 directory. |
|
ateom-microvm
command
Command ateom-microvm is the kata + cloud-hypervisor micro-VM implementation of the ateompb.Ateom service, a peer to cmd/ateom-gvisor.
|
Command ateom-microvm is the kata + cloud-hypervisor micro-VM implementation of the ateompb.Ateom service, a peer to cmd/ateom-gvisor. |
|
ateom-microvm/internal/agentstats
Package agentstats turns the kata guest agent's per-container cgroup accounting into the resource-usage sample ateom reports.
|
Package agentstats turns the kata guest agent's per-container cgroup accounting into the resource-usage sample ateom reports. |
|
ateom-microvm/internal/ch
Package ch drives a single cloud-hypervisor instance over its REST api-socket: pause, snapshot, resume against a running VMM (e.g.
|
Package ch drives a single cloud-hypervisor instance over its REST api-socket: pause, snapshot, resume against a running VMM (e.g. |
|
ateom-microvm/internal/kata
Package kata holds the helpers ateom uses to boot and drive a kata guest in a cloud-hypervisor micro-VM without the kata shim: ateom boots cloud-hypervisor itself (see internal/ch), then drives the stock kata-agent over its hybrid-vsock ttrpc API (DialAgent / AgentClient) to create the sandbox and run each container on its host-merged rootfs (overlay_linux.go).
|
Package kata holds the helpers ateom uses to boot and drive a kata guest in a cloud-hypervisor micro-VM without the kata shim: ateom boots cloud-hypervisor itself (see internal/ch), then drives the stock kata-agent over its hybrid-vsock ttrpc API (DialAgent / AgentClient) to create the sandbox and run each container on its host-merged rootfs (overlay_linux.go). |
|
ateom-microvm/internal/reaper
Package reaper collects detached child processes in ateom-microvm.
|
Package reaper collects detached child processes in ateom-microvm. |
|
benchmarking/boomer-worker
command
boomer-worker is the Go re-implementation of the GluttonUser locust test.
|
boomer-worker is the Go re-implementation of the GluttonUser locust test. |
|
benchmarking/glutton
command
glutton is a small benchmarking workload that exposes a gRPC API for consuming RAM, disk, and file descriptors, and for gossiping with other glutton instances.
|
glutton is a small benchmarking workload that exposes a gRPC API for consuming RAM, disk, and file descriptors, and for gossiping with other glutton instances. |
|
kubectl-ate
command
|
|
|
podcertcontroller
command
Command podcertcontroller is a pod certificate controller that implements two signers.
|
Command podcertcontroller is a pod certificate controller that implements two signers. |
|
podcertcontroller/internal/rendezvous
Package rendezvous uses rendezvous hashing to help multiple controller replicas agree on which replica should handle an item.
|
Package rendezvous uses rendezvous hashing to help multiple controller replicas agree on which replica should handle an item. |
|
demos
|
|
|
claude-code-multiplex/ui
command
Demo UI server — substrate multiplex visualization.
|
Demo UI server — substrate multiplex visualization. |
|
counter
command
Command counter is a simple server that will be used as a worker pod.
|
Command counter is a simple server that will be used as a worker pod. |
|
egress
command
Command egress is a small HTTP service for demonstrating per-Actor egress policy.
|
Command egress is a small HTTP service for demonstrating per-Actor egress policy. |
|
multi-template/fspersist
command
Command fspersist is a simple server used as an actor workload.
|
Command fspersist is a simple server used as an actor workload. |
|
sandbox
command
|
|
|
sandbox/client
command
|
|
|
internal
|
|
|
actorlog
Package actorlog provides structured JSON logging for actor sandboxes shared by the gVisor and micro-VM ateom runtimes.
|
Package actorlog provides structured JSON logging for actor sandboxes shared by the gVisor and micro-VM ateom runtimes. |
|
ateapiauth
Package ateapiauth authenticates clients of the ateapi gRPC server, and provides a matching client dial helper.
|
Package ateapiauth authenticates clients of the ateapi gRPC server, and provides a matching client dial helper. |
|
ateattr
Package ateattr is the single source of truth for substrate's ate.* telemetry attributes: the identity keys stamped on spans/logs, and the bounded value sets used as metric labels.
|
Package ateattr is the single source of truth for substrate's ate.* telemetry attributes: the identity keys stamped on spans/logs, and the bounded value sets used as metric labels. |
|
atelet
Package atelet contains shared constants and definitions that are used across Substrate components related to atelet.
|
Package atelet contains shared constants and definitions that are used across Substrate components related to atelet. |
|
ateletdial
Package ateletdial connects a worker Pod to the atelet on its own node over the node-local socket, authenticating both ends by Pod certificate.
|
Package ateletdial connects a worker Pod to the atelet on its own node over the node-local socket, authenticating both ends by Pod certificate. |
|
ateomcapacity
Package ateomcapacity reports what an ateom can supply to the actors it hosts.
|
Package ateomcapacity reports what an ateom can supply to the actors it hosts. |
|
ateomnet
Package ateomnet provides shared networking configuration logic for Substrate runtime agents.
|
Package ateomnet provides shared networking configuration logic for Substrate runtime agents. |
|
ateompath
Ateom and atelet need to agree on many filesystem paths.
|
Ateom and atelet need to agree on many filesystem paths. |
|
ateomstats
Package ateomstats holds the pieces both ateom runtimes need to answer ateompb.Ateom/GetWorkloadStats.
|
Package ateomstats holds the pieces both ateom runtimes need to answer ateompb.Ateom/GetWorkloadStats. |
|
atunnel
Package atunnel carries actor ingress and egress through an ateom worker pod.
|
Package atunnel carries actor ingress and egress through an ateom worker pod. |
|
benchmarking/boomer/dynconfig
Package dynconfig fetches and holds the boomer worker's runtime-mutable settings — the subset of locust flags the operator can change in the web UI form.
|
Package dynconfig fetches and holds the boomer worker's runtime-mutable settings — the subset of locust flags the operator can change in the web UI form. |
|
benchmarking/boomer/glutton
Package glutton implements the boomer-Go re-implementation of the GluttonUser locust test (see the legacy Python in benchmarking/locust/tests/glutton.py for the reference behavior).
|
Package glutton implements the boomer-Go re-implementation of the GluttonUser locust test (see the legacy Python in benchmarking/locust/tests/glutton.py for the reference behavior). |
|
benchmarking/boomer/metrics
Package metrics mirrors the Prometheus surface emitted by benchmarking/locust/common/metrics.py — same metric names and labels so dashboards built against the Python locust workers keep working when the load source is a boomer-Go worker.
|
Package metrics mirrors the Prometheus surface emitted by benchmarking/locust/common/metrics.py — same metric names and labels so dashboards built against the Python locust workers keep working when the load source is a boomer-Go worker. |
|
benchmarking/boomer/trace
Package trace wires the OTLP tracer + W3C propagator used by the boomer load-test workers.
|
Package trace wires the OTLP tracer + W3C propagator used by the boomer load-test workers. |
|
benchmarking/glutton/fake
Package fake provides an httptest-backed stand-in for a glutton actor.
|
Package fake provides an httptest-backed stand-in for a glutton actor. |
|
cdi
Package cdi reads a Container Device Interface spec and resolves what a named set of devices asks a container runtime to do.
|
Package cdi reads a Container Device Interface spec and resolves what a named set of devices asks a container runtime to do. |
|
credbundle
Package credbundle handles credential bundle files written by Kubernetes Pod Certificates.
|
Package credbundle handles credential bundle files written by Kubernetes Pod Certificates. |
|
deviceplugin
Package deviceplugin advertises host device nodes (for example /dev/kvm) to kubelet as extended resources, so a worker pod can be granted just those devices instead of running privileged.
|
Package deviceplugin advertises host device nodes (for example /dev/kvm) to kubelet as extended resources, so a worker pod can be granted just those devices instead of running privileged. |
|
e2e/fixtures/probe
command
Command probe is a minimal introspection actor used by the e2e suites.
|
Command probe is a minimal introspection actor used by the e2e suites. |
|
e2e/fixtures/testserver
command
Command testserver is the one binary behind every plain helper pod the egress e2e suites stand up.
|
Command testserver is the one binary behind every plain helper pod the egress e2e suites stand up. |
|
imagecache
Package imagecache implements the node-local OCI image cache: a content-addressed pool of unpacked image layers shared by every actor on the node, plus the per-bundle overlay spec that tells the ateom runtimes how to compose an actor rootfs from cached layers.
|
Package imagecache implements the node-local OCI image cache: a content-addressed pool of unpacked image layers shared by every actor on the node, plus the per-bundle overlay spec that tells the ateom runtimes how to compose an actor rootfs from cached layers. |
|
localca
Package localca implements a CA whose state can be stored in a local file or Kubernetes secret.
|
Package localca implements a CA whose state can be stored in a local file or Kubernetes secret. |
|
localjwtauthority
Package localjwtauthority implements a simple "CA" for JWTs.
|
Package localjwtauthority implements a simple "CA" for JWTs. |
|
objectstore
Package objectstore manages the existence of the objects an external snapshot is made of: listing them, copying them, and deleting them once nothing owns them any more.
|
Package objectstore manages the existence of the objects an external snapshot is made of: listing them, copying them, and deleting them once nothing owns them any more. |
|
objectstore/objectstoretest
Package objectstoretest provides an in-memory objectstore.Store for tests that need to observe which external snapshots a flow created and released.
|
Package objectstoretest provides an in-memory objectstore.Store for tests that need to observe which external snapshots a flow created and released. |
|
ocispec
Package ocispec builds the runtime-neutral OCI spec for actor bundles, which each ateom shapes for its runtime.
|
Package ocispec builds the runtime-neutral OCI spec for actor bundles, which each ateom shapes for its runtime. |
|
otlprelay
Package otlprelay carries ateom's OTLP telemetry to the collector over a unix socket served by atelet, so a worker pod needs no network path of its own to export spans and metrics.
|
Package otlprelay carries ateom's OTLP telemetry to the collector over a unix socket served by atelet, so a worker pod needs no network path of its own to export spans and metrics. |
|
pemutil
Package pemutil sanitizes PEM certificate bundles for projection into actors, the way kubelet does for clusterTrustBundle projected volumes.
|
Package pemutil sanitizes PEM certificate bundles for projection into actors, the way kubelet does for clusterTrustBundle projected volumes. |
|
portforward
Package portforward tunnels to the pods behind a Service.
|
Package portforward tunnels to the pods behind a Service. |
|
readyz
Package readyz polls a container's HTTP readiness endpoint from inside an ateom.
|
Package readyz polls a container's HTTP readiness endpoint from inside an ateom. |
|
roottest
Package roottest gates tests that need root privileges (mounts, mknod, trusted.* xattrs, ...).
|
Package roottest gates tests that need root privileges (mounts, mknod, trusted.* xattrs, ...). |
|
serverboot
Package serverboot collects the startup boilerplate shared by the long-running substrate server binaries (ateapi, atelet, ateom-gvisor, ateom-microvm): slog wiring, OTel tracer + meter providers, a Prometheus + /readyz HTTP surface, and a couple of small helpers for startup fail-fast.
|
Package serverboot collects the startup boilerplate shared by the long-running substrate server binaries (ateapi, atelet, ateom-gvisor, ateom-microvm): slog wiring, OTel tracer + meter providers, a Prometheus + /readyz HTTP surface, and a couple of small helpers for startup fail-fast. |
|
sizing
Package sizing right-sizes a sandbox to the actor's declared resource limits.
|
Package sizing right-sizes a sandbox to the actor's declared resource limits. |
|
substratex509
Package substratex509 contains routines for creating and parsing x509 certificates that embed Substrate-specific X.509 extensions communicating the identity of a given workload.
|
Package substratex509 contains routines for creating and parsing x509 certificates that embed Substrate-specific X.509 extensions communicating the identity of a given workload. |
|
tarutil
Package tarutil archives and restores a directory tree as a tar file, preserving the metadata a workload's data directory depends on: modes, ownership, modification times, symlinks, hardlinks, FIFOs, device nodes, and user.* / trusted.overlay.* extended attributes (as PAX SCHILY.xattr records).
|
Package tarutil archives and restores a directory tree as a tar file, preserving the metadata a workload's data directory depends on: modes, ownership, modification times, symlinks, hardlinks, FIFOs, device nodes, and user.* / trusted.overlay.* extended attributes (as PAX SCHILY.xattr records). |
|
testenv
Package testenv starts the envtest (kubebuilder) control plane shared by the repo's apiserver-backed test packages.
|
Package testenv starts the envtest (kubebuilder) control plane shared by the repo's apiserver-backed test packages. |
|
version
Package version exposes build-time identity for substrate binaries.
|
Package version exposes build-time identity for substrate binaries. |
|
versionlabel
Package versionlabel derives the ate.dev/substrate-version label that keys versioned dataplane objects to a substrate build version.
|
Package versionlabel derives the ate.dev/substrate-version label that keys versioned dataplane objects to a substrate build version. |
|
versionlabel/cmd
command
Command cmd prints "<label value> <object-name suffix>" for a build version, so shell installers and upgrade tooling use the same derivation instead of mirroring it.
|
Command cmd prints "<label value> <object-name suffix>" for a build version, so shell installers and upgrade tooling use the same derivation instead of mirroring it. |
|
pkg
|
|
|
api/v1alpha1
Package v1alpha1 contains API Schema definitions for the agents v1alpha1 API group.
|
Package v1alpha1 contains API Schema definitions for the agents v1alpha1 API group. |
|
client/clientset/versioned/fake
This package has the automatically generated fake clientset.
|
This package has the automatically generated fake clientset. |
|
client/clientset/versioned/scheme
This package contains the scheme of the automatically generated clientset.
|
This package contains the scheme of the automatically generated clientset. |
|
client/clientset/versioned/typed/api/v1alpha1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/api/v1alpha1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
tools
|
|
|
setup-gcp
command
|
|
|
validate-image-cache
command
validate-image-cache batch-validates that OCI images can be pulled, parsed, and unpacked by internal/imagecache (the atelet-side half of the node-local image cache).
|
validate-image-cache batch-validates that OCI images can be pulled, parsed, and unpacked by internal/imagecache (the atelet-side half of the node-local image cache). |
Click to show internal directories.
Click to hide internal directories.
