worker

type CLIPImageManager struct {
	// contains filtered or unexported fields
}

type ConsoleWriter struct {
	// contains filtered or unexported fields
}

type FileWriter struct {
	// contains filtered or unexported fields
}

type ImageManager interface {
	// PrepareRootfs prepares a rootfs from a container image.
	// Returns the path to the rootfs and a cleanup function.
	PrepareRootfs(ctx context.Context, imageRef string) (rootfsPath string, cleanup func(), err error)

	// Close cleans up all resources.
	Close() error
}

type ManagedSandbox struct {
	Config        types.SandboxConfig
	State         types.SandboxState
	BundlePath    string
	Cancel        context.CancelFunc
	RootfsCleanup func()                   // Cleanup function for the CLIP rootfs mount
	Overlay       *common.ContainerOverlay // Overlay filesystem for writable layer
	OutputWriter  io.Writer                // Output destination (stdout/stderr combined)
	OutputFlusher func()                   // Flush pending output on completion
}

type MountConfig struct {
	// MountDir is the base directory for per-task mounts
	MountDir string

	// CLIBinary is the path to the CLI binary
	CLIBinary string

	// GatewayAddr is the gateway gRPC address
	GatewayAddr string

	// MountReadyTimeout is how long to wait for a mount to be ready
	MountReadyTimeout time.Duration
}

type MountManager struct {
	// contains filtered or unexported fields
}

type OutputConfig struct {
	TaskID   string
	S2Client *streams.S2Client
	Console  bool // Write to worker stdout
}

type S2Writer struct {
	// contains filtered or unexported fields
}

type SandboxConfig struct {
	// Paths configuration
	Paths types.WorkerPaths

	// WorkerID is the unique ID of this worker
	WorkerID string

	// GatewayGRPCAddr is the gateway gRPC address
	GatewayGRPCAddr string

	// AuthToken is the worker's authentication token (fallback)
	AuthToken string

	// EnableFilesystem enables FUSE filesystem mounts
	EnableFilesystem bool
}

type SandboxManager struct {
	// contains filtered or unexported fields
}

type SandboxManagerConfig struct {
	RuntimeType      string // "runc" or "gvisor"
	BundleDir        string
	StateDir         string
	MountDir         string // Directory for per-task FUSE mounts
	WorkerMount      string // Global worker FUSE mount path
	WorkerID         string
	GatewayGRPCAddr  string            // gRPC address for gateway (e.g., "airstore-gateway:1993")
	AuthToken        string            // Token for authenticating with gateway
	FilesystemBinary string            // Path to filesystem binary on host
	EnableFilesystem bool              // Whether to mount the airstore filesystem
	ImageConfig      types.ImageConfig // Image management configuration (CLIP + S3)
	RuntimeConfig    runtime.Config

	// S2 configuration for log streaming
	S2Token string
	S2Basin string
}

type TaskOutput struct {
	// contains filtered or unexported fields
}

type Worker struct {
	// contains filtered or unexported fields
}