delivery

type AgentDelivery interface {
	Cleaner
	Phase() DeliveryPhase
	DeliverPreStart(ctx context.Context, opts PreStartOptions) error
	DeliverPostStart(ctx context.Context, opts PostStartOptions) error
}

type BinarySourceFunc func(ctx context.Context, arch string) (io.ReadCloser, error)

type Cleaner interface {
	Cleanup(ctx context.Context, workspaceID string) error
}

type DeliveryPhase int

type FactoryOptions struct {
	WorkspaceConfig *provider.AgentWorkspaceInfo
	WorkspaceID     string
	DockerCommand   string
	DockerEnv       []string
	HelperImage     string
	IsRemoteDocker  bool
	ContainerID     string
	ExecFunc        inject.ExecFunc //nolint:staticcheck // legacy delivery strategies require this type
	PodExec         PodExecFunc
}

type KubernetesDelivery struct {
	Exec PodExecFunc

	// ExpectedVersion defaults to version.GetVersion() when empty.
	ExpectedVersion string
}

type LocalDockerDelivery struct {
	DockerCommand   string
	Environment     []string
	HelperImage     string
	ExpectedVersion string
}

type PodExecFunc func(ctx context.Context, argv []string, streams driver.Streams) error

type PostStartOptions struct {
	WorkspaceID      string
	ContainerDetails *config.ContainerDetails
	BinarySource     BinarySourceFunc
	Arch             string
}

type PreStartOptions struct {
	WorkspaceID  string
	RunOptions   *driver.RunOptions
	BinarySource BinarySourceFunc
	Arch         string
}

type RemoteDockerDelivery struct {
	DockerCommand string
	Environment   []string
	ContainerID   string
}

type WorkspaceSeedOptions struct {
	// WorkspaceID owns the volume (used for labels).
	WorkspaceID string
	// VolumeName is the named volume backing the workspace mount.
	VolumeName string
	// SourceDir is the host/remote directory whose contents are copied into
	// the volume (a faithful working-tree copy).
	SourceDir string
	// Reset removes an existing managed volume first so it is re-seeded.
	Reset bool
}

type WorkspaceVolumeSeeder interface {
	SeedWorkspaceVolume(ctx context.Context, opts WorkspaceSeedOptions) error
}