agent

type BinaryCache struct {
	BaseDir string
}

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

type BinarySource interface {
	GetBinary(ctx context.Context, arch string) (io.ReadCloser, error)
	SourceName() string
}

type Exec func(ctx context.Context, user string, command string, stdin io.Reader, stdout io.Writer, stderr io.Writer) error

type FileCacheSource struct {
	Cache *BinaryCache
}

type HTTPDownloadSource struct {
	BaseURL string
	Cache   *BinaryCache
}

type InjectError struct {
	Stage string
	Cause error
}

type InjectOptions struct {
	// Ctx is the context for the injection operation. Required.
	Ctx context.Context
	// Exec is the function used to execute commands on the remote machine. Required.
	Exec inject.ExecFunc
	// Log is the logger for capturing injection output. Required.
	Log log.Logger

	// IsLocal indicates if the injection target is the local machine.
	IsLocal bool
	// RemoteAgentPath is the path where the agent binary should be placed on the remote machine. Defaults to RemoteDevPodHelperLocation.
	RemoteAgentPath string
	// DownloadURL is the base URL to download the agent binary from. Defaults to DefaultAgentDownloadURL().
	DownloadURL string
	// PreferDownloadFromRemoteUrl forces downloading the agent even if a local binary is available.
	// Defaults to true for release versions, false for dev versions.
	PreferDownloadFromRemoteUrl *bool
	// Timeout is the maximum duration to wait for the injection to complete. Defaults to 5 minutes.
	Timeout time.Duration

	// Command is the command to execute after successful injection.
	Command string

	Stdin  io.Reader
	Stdout io.Writer
	Stderr io.Writer

	// LocalVersion is the version of the local DevPod binary. Defaults to version.GetVersion().
	LocalVersion string
	// RemoteVersion is the expected version of the remote agent. Defaults to LocalVersion.
	RemoteVersion string
	// SkipVersionCheck disables the validation of the remote agent's version. Defaults to false, unless DEVPOD_AGENT_URL is set.
	SkipVersionCheck bool
	// MetricsCollector handles the recording of injection metrics. Defaults to LogMetricsCollector.
	MetricsCollector MetricsCollector
}

type InjectSource struct{}

type InjectionMetrics struct {
	StartTime    time.Time
	EndTime      time.Time
	Attempts     int
	BinarySource string
	AgentVersion string
	VersionCheck bool
	Success      bool
	Error        error
}

type LogMetricsCollector struct {
	Log log.Logger
}

type MetricsCollector interface {
	RecordInjection(metrics *InjectionMetrics)
}

type RetryConfig struct {
	MaxAttempts  int
	InitialDelay time.Duration
	MaxDelay     time.Duration
	Deadline     time.Time
}

type RetryFunc func(attempt int) error