operatingsystemconfig

var (

	// KubeletHealthCheckRetryInterval is the interval at which the kubelet health check is retried. Exposed for testing.
	KubeletHealthCheckRetryInterval = 5 * time.Second
	// KubeletHealthCheckRetryTimeout is the timeout after which the kubelet health check is considered failed. Exposed for testing.
	KubeletHealthCheckRetryTimeout = 5 * time.Minute

	// OSUpdateRetryInterval is the interval between OS update retries. Exported for testing.
	OSUpdateRetryInterval = 30 * time.Second
	// OSUpdateRetryTimeout is the timeout for OS update retries. Exported for testing.
	OSUpdateRetryTimeout = 5 * time.Minute
)

var Exec = func(ctx context.Context, command string, arg ...string) ([]byte, error) {
	return exec.CommandContext(ctx, command, arg...).Output()
}

var ExecCommandCombinedOutput = func(ctx context.Context, command string, args ...string) ([]byte, error) {
	return exec.CommandContext(ctx, command, args...).CombinedOutput()
}

var GetOSVersion = func(inPlaceUpdates *extensionsv1alpha1.InPlaceUpdates, fs afero.Afero) (*string, error) {
	if inPlaceUpdates == nil {
		return nil, nil
	}

	os, err := getOperatingSystem(fs)
	if err != nil {
		return nil, fmt.Errorf("unable to get operating system name: %w", err)
	}

	version := osVersionRegex.FindString(os)
	if version == "" {
		return nil, fmt.Errorf("unable to find version in %q with regex: %s", os, osVersionRegex.String())
	}
	return ptr.To(version), nil
}

var RequestAndStoreKubeconfig = nodeagent.RequestAndStoreKubeconfig