Function pushAWSCmd

src/cmd/linuxkit/push_aws.go:21–193

()

const timeoutVar = "LINUXKIT_UPLOAD_TIMEOUT"

func pushAWSCmd() *cobra.Command {
	var (
		timeoutFlag int
		bucketFlag  string
		nameFlag    string
		ena         bool
		sriovNet    string
		uefi        bool
		tpm         bool
	)
	cmd := &cobra.Command{
		Use:   "aws",
		Short: "push image to AWS",
		Long: `Push image to AWS.
		Single argument specifies the full path of an AWS image. It will be uploaded to S3 and an AMI will be created from it.
		`,
		Args: cobra.ExactArgs(1),
		RunE: func(cmd *cobra.Command, args []string) error {
			path := args[0]

			timeout := getIntValue(timeoutVar, timeoutFlag, 600)
			bucket := getStringValue(bucketVar, bucketFlag, "")
			name := getStringValue(nameVar, nameFlag, "")

			var sriovNetFlag *string
			if sriovNet != "" {
				*sriovNetFlag = sriovNet
			}

			if !uefi && tpm {
				return fmt.Errorf("cannot use tpm without uefi mode")
			}

			sess := session.Must(session.NewSession())
			storage := s3.New(sess)

			ctx, cancelFn := context.WithTimeout(context.Background(), time.Duration(timeout)*time.Second)
			defer cancelFn()

			if bucket == "" {
				return fmt.Errorf("please provide the bucket to use")
			}

			f, err := os.Open(path)
			if err != nil {
				return fmt.Errorf("error opening file: %v", err)
			}
			defer func() { _ = f.Close() }()

			if name == "" {
				name = strings.TrimSuffix(path, filepath.Ext(path))
				name = filepath.Base(name)
			}

			fi, err := f.Stat()
			if err != nil {
				return fmt.Errorf("error reading file information: %v", err)
			}