Method export

pkg/compose/export.go:38–95

(ctx context.Context, projectName string, options api.ExportOptions)

}

func (s *composeService) export(ctx context.Context, projectName string, options api.ExportOptions) error {
	projectName = strings.ToLower(projectName)

	container, err := s.getSpecifiedContainer(ctx, projectName, oneOffInclude, false, options.Service, options.Index)
	if err != nil {
		return err
	}

	if options.Output == "" {
		if s.stdout().IsTerminal() {
			return fmt.Errorf("output option is required when exporting to terminal")
		}
	} else if err := command.ValidateOutputPath(options.Output); err != nil {
		return fmt.Errorf("failed to export container: %w", err)
	}

	name := getCanonicalContainerName(container)
	s.events.On(api.Resource{
		ID:     name,
		Text:   api.StatusExporting,
		Status: api.Working,
	})

	responseBody, err := s.apiClient().ContainerExport(ctx, container.ID, client.ContainerExportOptions{})
	if err != nil {
		return err
	}

	defer func() {
		if err := responseBody.Close(); err != nil {
			s.events.On(errorEventf(name, "Failed to close response body: %s", err.Error()))
		}
	}()

	if !s.dryRun {
		if options.Output == "" {
			_, err := io.Copy(s.stdout(), responseBody)
			return err
		} else {
			writer, err := atomicwriter.New(options.Output, 0o600)
			if err != nil {
				return err
			}
			defer func() { _ = writer.Close() }()

			_, err = io.Copy(writer, responseBody)
			return err
		}
	}

	s.events.On(api.Resource{
		ID:     name,
		Text:   api.StatusExported,
		Status: api.Done,
	})

	return nil
}