sandbox

type AttachOptions struct {
	Stdin      io.Reader
	Stdout     io.Writer
	Stderr     io.Writer
	TTY        bool
	ResizeChan <-chan TerminalSize
}

type Capability string

type CapabilityDetector interface {
	Supports(cap Capability) bool
}

type ExecOptions struct {
	Command []string
	Stdin   io.Reader
	Stdout  io.Writer
	Stderr  io.Writer
}

type LogOptions struct {
	Follow     bool
	TailLines  *int64
	Timestamps bool
}

type PoolInfo struct {
	Name       string
	Ready      int32
	Allocated  int32
	TargetSize int32
	Image      string
}

type PortForwardOptions struct {
	Ports     []string // e.g. ["8080:8080"]
	StopChan  <-chan struct{}
	ReadyChan chan struct{}
	Out       io.Writer
	ErrOut    io.Writer
}

type SandboxAttacher interface {
	Attach(ctx context.Context, task *v1alpha1.AgentTask, opts AttachOptions) error
}

type SandboxExecutor interface {
	Exec(ctx context.Context, task *v1alpha1.AgentTask, opts ExecOptions) (exitCode int, err error)
}

type SandboxFileTransfer interface {
	CopyTo(ctx context.Context, task *v1alpha1.AgentTask, src io.Reader, dstPath string) error
	CopyFrom(ctx context.Context, task *v1alpha1.AgentTask, srcPath string) (io.ReadCloser, error)
}

type SandboxMetrics struct {
	CPUUsageMillicores int64
	MemoryUsageBytes   int64
	StorageUsageBytes  int64
	NetworkRxBytes     int64
	NetworkTxBytes     int64
}

type SandboxMetricsCollector interface {
	GetMetrics(ctx context.Context, task *v1alpha1.AgentTask) (*SandboxMetrics, error)
}

type SandboxPoolManager interface {
	ListPools(ctx context.Context, namespace string) ([]PoolInfo, error)
	GetPool(ctx context.Context, namespace, name string) (*PoolInfo, error)
	ScalePool(ctx context.Context, namespace, name string, targetSize int32) error
}

type SandboxPortForwarder interface {
	PortForward(ctx context.Context, task *v1alpha1.AgentTask, opts PortForwardOptions) error
}

type SandboxProvider interface {
	// Provision creates or claims an isolated sandbox workspace for the AgentTask.
	Provision(ctx context.Context, task *v1alpha1.AgentTask) (*SandboxResult, error)

	// Teardown cleanly releases the sandbox workspace and deletes associated resources.
	// Must be idempotent.
	Teardown(ctx context.Context, task *v1alpha1.AgentTask) error

	// Status returns the live runtime state of the sandbox.
	Status(ctx context.Context, task *v1alpha1.AgentTask) (*SandboxStatus, error)

	// StreamLogs opens a stream to the sandbox container logs.
	StreamLogs(ctx context.Context, task *v1alpha1.AgentTask, opts LogOptions) (io.ReadCloser, error)
}

type SandboxResult struct {
	ClaimName      string
	PodName        string
	PodIP          string
	TokenMountPath string
	Ready          bool
	Message        string
}

type SandboxSnapshotter interface {
	Snapshot(ctx context.Context, task *v1alpha1.AgentTask, opts SnapshotOptions) (string, error)
	Restore(ctx context.Context, task *v1alpha1.AgentTask, snapshotID string) error
}

type SandboxStatus struct {
	ClaimName string
	PodName   string
	PodIP     string
	Phase     string
	Ready     bool
	Message   string
}

type SandboxSuspender interface {
	Suspend(ctx context.Context, task *v1alpha1.AgentTask) error
	Resume(ctx context.Context, task *v1alpha1.AgentTask) error
}

type SnapshotOptions struct {
	Name        string
	Description string
}

type TerminalSize struct {
	Width  uint16
	Height uint16
}