Versions in this module Expand all Collapse all v0 v0.1.0 Aug 5, 2025 Changes in this version + type Config struct + AllowCriticalCVEs bool + AllowedRegistries []string + BlockedRegistries []string + EnableImageValidation bool + EnableSecurityScan bool + Endpoint string + EnforceTrustedImages bool + KubeConfig string + Labels map[string]string + MaxHighCVEs int + MaxImageAgeDays int + MaxMediumCVEs int + Namespace string + RequireImageDigest bool + Type string + type DockerFactory struct + func (f *DockerFactory) Create(config Config) (Runtime, error) + type DockerManifestList struct + Manifests []struct{ ... } + MediaType string + SchemaVersion int + type DockerRuntime struct + func NewDockerRuntime(config Config) (*DockerRuntime, error) + func (r *DockerRuntime) CreateAgent(ctx context.Context, agent *arctypes.Agent) error + func (r *DockerRuntime) DestroyAgent(ctx context.Context, agentID string) error + func (r *DockerRuntime) ExecCommand(ctx context.Context, agentID string, cmd []string) (io.ReadCloser, error) + func (r *DockerRuntime) GetAgentStatus(ctx context.Context, agentID string) (*arctypes.Agent, error) + func (r *DockerRuntime) ListAgents(ctx context.Context) ([]*arctypes.Agent, error) + func (r *DockerRuntime) StartAgent(ctx context.Context, agentID string) error + func (r *DockerRuntime) StopAgent(ctx context.Context, agentID string) error + func (r *DockerRuntime) StreamLogs(ctx context.Context, agentID string) (io.ReadCloser, error) + type Factory interface + Create func(config Config) (Runtime, error) + type GVisorConfig struct + AllowedSyscalls []string + BlockedSyscalls []string + CgroupsPath string + DNSServers []string + Debug bool + EnableAppArmor bool + EnableCgroups bool + EnableHealthChecks bool + EnableIPv6 bool + EnableProfiling bool + EnableSandbox bool + EnableSeccomp bool + HealthCheckInterval time.Duration + ImageCacheSize int64 + ImageCacheTTL time.Duration + LogLevel string + NetworkMode string + Platform GVisorPlatform + type GVisorPlatform string + const PlatformKVM + const PlatformPtrace + const PlatformSystrap + type GVisorRuntime struct + func NewGVisorRuntime(config Config) (*GVisorRuntime, error) + func NewGVisorRuntimeWithConfig(config GVisorConfig) (*GVisorRuntime, error) + func (r *GVisorRuntime) CreateAgent(ctx context.Context, agent *arctypes.Agent) error + func (r *GVisorRuntime) DestroyAgent(ctx context.Context, agentID string) error + func (r *GVisorRuntime) ExecCommand(ctx context.Context, agentID string, cmd []string) (io.ReadCloser, error) + func (r *GVisorRuntime) GetAgentLogs(ctx context.Context, agentID string, follow bool) (io.ReadCloser, error) + func (r *GVisorRuntime) GetAgentStatus(ctx context.Context, agentID string) (*arctypes.Agent, error) + func (r *GVisorRuntime) GetRuntimeInfo(ctx context.Context) (map[string]interface{}, error) + func (r *GVisorRuntime) ListAgents(ctx context.Context) ([]*arctypes.Agent, error) + func (r *GVisorRuntime) Shutdown(ctx context.Context) error + func (r *GVisorRuntime) StartAgent(ctx context.Context, agentID string) error + func (r *GVisorRuntime) StopAgent(ctx context.Context, agentID string) error + func (r *GVisorRuntime) StreamLogs(ctx context.Context, agentID string) (io.ReadCloser, error) + type HealthStatus struct + FailureCount int + LastCheck time.Time + Output string + Status string + type ImageCacheEntry struct + Config map[string]interface{} + Digest string + LastUsed time.Time + Layers []string + Path string + Size int64 + type KubernetesFactory struct + func (f *KubernetesFactory) Create(config Config) (Runtime, error) + type KubernetesRuntime struct + func NewKubernetesRuntime(config Config) (*KubernetesRuntime, error) + func (r *KubernetesRuntime) CreateAgent(ctx context.Context, agent *arctypes.Agent) error + func (r *KubernetesRuntime) DestroyAgent(ctx context.Context, agentID string) error + func (r *KubernetesRuntime) ExecCommand(ctx context.Context, agentID string, cmd []string) (io.ReadCloser, error) + func (r *KubernetesRuntime) GetAgentStatus(ctx context.Context, agentID string) (*arctypes.Agent, error) + func (r *KubernetesRuntime) ListAgents(ctx context.Context) ([]*arctypes.Agent, error) + func (r *KubernetesRuntime) StartAgent(ctx context.Context, agentID string) error + func (r *KubernetesRuntime) StopAgent(ctx context.Context, agentID string) error + func (r *KubernetesRuntime) StreamLogs(ctx context.Context, agentID string) (io.ReadCloser, error) + type NetworkConfig struct + DNS []string + Gateway string + IPAddress string + Mode string + Ports map[string]string + type OCIManifest struct + Config struct{ ... } + Layers []struct{ ... } + MediaType string + SchemaVersion int + type OCIPuller struct + func NewOCIPuller(cacheDir string) *OCIPuller + func (p *OCIPuller) ExtractLocalImage(ctx context.Context, tarPath string, rootfsDir string) error + func (p *OCIPuller) PullImage(ctx context.Context, imageRef string, rootfsDir string) error + type ResourceUsage struct + CPUUsage float64 + DiskUsage int64 + MemoryUsage int64 + NetworkRx int64 + NetworkTx int64 + UpdatedAt time.Time + type Runtime interface + CreateAgent func(ctx context.Context, agent *types.Agent) error + DestroyAgent func(ctx context.Context, agentID string) error + ExecCommand func(ctx context.Context, agentID string, cmd []string) (io.ReadCloser, error) + GetAgentStatus func(ctx context.Context, agentID string) (*types.Agent, error) + ListAgents func(ctx context.Context) ([]*types.Agent, error) + StartAgent func(ctx context.Context, agentID string) error + StopAgent func(ctx context.Context, agentID string) error + StreamLogs func(ctx context.Context, agentID string) (io.ReadCloser, error) + type TokenResponse struct + AccessToken string + ExpiresIn int + Token string