From 241326a9a8c20ad7f2bcf651416b836e7778e090 Mon Sep 17 00:00:00 2001 From: Brent Baude Date: Thu, 16 Apr 2020 12:25:26 -0500 Subject: Podman V2 birth remote podman v1 and replace with podman v2. Signed-off-by: Brent Baude --- pkg/adapter/runtime.go | 477 ------------------------------------------------- 1 file changed, 477 deletions(-) delete mode 100644 pkg/adapter/runtime.go (limited to 'pkg/adapter/runtime.go') diff --git a/pkg/adapter/runtime.go b/pkg/adapter/runtime.go deleted file mode 100644 index 7a181e7e5..000000000 --- a/pkg/adapter/runtime.go +++ /dev/null @@ -1,477 +0,0 @@ -// +build !remoteclient - -package adapter - -import ( - "bufio" - "context" - "io" - "io/ioutil" - "os" - "text/template" - - "github.com/containers/buildah" - "github.com/containers/buildah/imagebuildah" - "github.com/containers/buildah/pkg/formats" - "github.com/containers/image/v5/docker/reference" - "github.com/containers/image/v5/types" - "github.com/containers/libpod/cmd/podman/cliconfig" - "github.com/containers/libpod/cmd/podman/libpodruntime" - "github.com/containers/libpod/cmd/podman/shared" - "github.com/containers/libpod/libpod" - "github.com/containers/libpod/libpod/define" - "github.com/containers/libpod/libpod/events" - "github.com/containers/libpod/libpod/image" - "github.com/containers/libpod/pkg/rootless" - "github.com/containers/libpod/pkg/util" - "github.com/containers/storage/pkg/archive" - "github.com/pkg/errors" - v1 "k8s.io/api/core/v1" -) - -// LocalRuntime describes a typical libpod runtime -type LocalRuntime struct { - *libpod.Runtime - Remote bool -} - -// ContainerImage ... -type ContainerImage struct { - *image.Image -} - -// Container ... -type Container struct { - *libpod.Container -} - -// Pod encapsulates the libpod.Pod structure, helps with remote vs. local -type Pod struct { - *libpod.Pod -} - -// Volume ... -type Volume struct { - *libpod.Volume -} - -// VolumeFilter is for filtering volumes on the client -type VolumeFilter func(*Volume) bool - -// GetRuntimeNoStore returns a localruntime struct with an embedded runtime but -// without a configured storage. -func GetRuntimeNoStore(ctx context.Context, c *cliconfig.PodmanCommand) (*LocalRuntime, error) { - runtime, err := libpodruntime.GetRuntimeNoStore(ctx, c) - if err != nil { - return nil, err - } - return getRuntime(runtime) -} - -// GetRuntime returns a LocalRuntime struct with the actual runtime embedded in it -func GetRuntime(ctx context.Context, c *cliconfig.PodmanCommand) (*LocalRuntime, error) { - runtime, err := libpodruntime.GetRuntime(ctx, c) - if err != nil { - return nil, err - } - return getRuntime(runtime) -} - -func getRuntime(runtime *libpod.Runtime) (*LocalRuntime, error) { - return &LocalRuntime{ - Runtime: runtime, - }, nil -} - -// GetFilteredImages returns a slice of images in containerimages that are "filtered" -func (r *LocalRuntime) GetFilteredImages(filters []string, rwOnly bool) ([]*ContainerImage, error) { - images, err := r.ImageRuntime().GetImagesWithFilters(filters) - if err != nil { - return nil, err - } - return r.ImagestoContainerImages(images, rwOnly) -} - -// GetImages returns a slice of images in containerimages -func (r *LocalRuntime) GetImages() ([]*ContainerImage, error) { - return r.getImages(false) -} - -// GetRWImages returns a slice of read/write images in containerimages -func (r *LocalRuntime) GetRWImages() ([]*ContainerImage, error) { - return r.getImages(true) -} - -func (r *LocalRuntime) getImages(rwOnly bool) ([]*ContainerImage, error) { - images, err := r.Runtime.ImageRuntime().GetImages() - if err != nil { - return nil, err - } - return r.ImagestoContainerImages(images, rwOnly) -} - -// ImagestoContainerImages converts the slice of *image.Image to a slice of -// *ContainerImage. ReadOnly images are skipped when rwOnly is set. -func (r *LocalRuntime) ImagestoContainerImages(images []*image.Image, rwOnly bool) ([]*ContainerImage, error) { - var containerImages []*ContainerImage - for _, i := range images { - if rwOnly && i.IsReadOnly() { - continue - } - containerImages = append(containerImages, &ContainerImage{i}) - } - return containerImages, nil -} - -// NewImageFromLocal returns a containerimage representation of a image from local storage -func (r *LocalRuntime) NewImageFromLocal(name string) (*ContainerImage, error) { - img, err := r.Runtime.ImageRuntime().NewFromLocal(name) - if err != nil { - return nil, err - } - return &ContainerImage{img}, nil -} - -// ImageTree reutnrs an new image.Tree for the provided `imageOrID` and `whatrequires` flag -func (r *LocalRuntime) ImageTree(imageOrID string, whatRequires bool) (string, error) { - img, err := r.Runtime.ImageRuntime().NewFromLocal(imageOrID) - if err != nil { - return "", err - } - return img.GenerateTree(whatRequires) -} - -// LoadFromArchiveReference calls into local storage to load an image from an archive -func (r *LocalRuntime) LoadFromArchiveReference(ctx context.Context, srcRef types.ImageReference, signaturePolicyPath string, writer io.Writer) ([]*ContainerImage, error) { - var containerImages []*ContainerImage - imgs, err := r.Runtime.ImageRuntime().LoadFromArchiveReference(ctx, srcRef, signaturePolicyPath, writer) - if err != nil { - return nil, err - } - for _, i := range imgs { - ci := ContainerImage{i} - containerImages = append(containerImages, &ci) - } - return containerImages, nil -} - -// New calls into local storage to look for an image in local storage or to pull it -func (r *LocalRuntime) New(ctx context.Context, name, signaturePolicyPath, authfile string, writer io.Writer, dockeroptions *image.DockerRegistryOptions, signingoptions image.SigningOptions, label *string, pullType util.PullType) (*ContainerImage, error) { - img, err := r.Runtime.ImageRuntime().New(ctx, name, signaturePolicyPath, authfile, writer, dockeroptions, signingoptions, label, pullType) - if err != nil { - return nil, err - } - return &ContainerImage{img}, nil -} - -// RemoveImage calls into local storage and removes an image -func (r *LocalRuntime) RemoveImage(ctx context.Context, img *ContainerImage, force bool) (*image.ImageDeleteResponse, error) { - return r.Runtime.RemoveImage(ctx, img.Image, force) -} - -// PruneImages is wrapper into PruneImages within the image pkg -func (r *LocalRuntime) PruneImages(ctx context.Context, all bool, filter []string) ([]string, error) { - return r.ImageRuntime().PruneImages(ctx, all, filter) -} - -// Export is a wrapper to container export to a tarfile -func (r *LocalRuntime) Export(name string, path string) error { - ctr, err := r.Runtime.LookupContainer(name) - if err != nil { - return errors.Wrapf(err, "error looking up container %q", name) - } - return ctr.Export(path) -} - -// Import is a wrapper to import a container image -func (r *LocalRuntime) Import(ctx context.Context, source, reference string, changes []string, history string, quiet bool) (string, error) { - return r.Runtime.Import(ctx, source, reference, changes, history, quiet) -} - -// CreateVolume is a wrapper to create volumes -func (r *LocalRuntime) CreateVolume(ctx context.Context, c *cliconfig.VolumeCreateValues, labels, opts map[string]string) (string, error) { - var ( - options []libpod.VolumeCreateOption - volName string - ) - - if len(c.InputArgs) > 0 { - volName = c.InputArgs[0] - options = append(options, libpod.WithVolumeName(volName)) - } - - if c.Flag("driver").Changed { - options = append(options, libpod.WithVolumeDriver(c.Driver)) - } - - if len(labels) != 0 { - options = append(options, libpod.WithVolumeLabels(labels)) - } - - if len(opts) != 0 { - // We need to process -o for uid, gid - parsedOptions, err := shared.ParseVolumeOptions(opts) - if err != nil { - return "", err - } - options = append(options, parsedOptions...) - } - newVolume, err := r.NewVolume(ctx, options...) - if err != nil { - return "", err - } - return newVolume.Name(), nil -} - -// RemoveVolumes is a wrapper to remove volumes -func (r *LocalRuntime) RemoveVolumes(ctx context.Context, c *cliconfig.VolumeRmValues) ([]string, map[string]error, error) { - return shared.SharedRemoveVolumes(ctx, r.Runtime, c.InputArgs, c.All, c.Force) -} - -// Push is a wrapper to push an image to a registry -func (r *LocalRuntime) Push(ctx context.Context, srcName, destination, manifestMIMEType, authfile, digestfile, signaturePolicyPath string, writer io.Writer, forceCompress bool, signingOptions image.SigningOptions, dockerRegistryOptions *image.DockerRegistryOptions, additionalDockerArchiveTags []reference.NamedTagged) error { - newImage, err := r.ImageRuntime().NewFromLocal(srcName) - if err != nil { - return err - } - return newImage.PushImageToHeuristicDestination(ctx, destination, manifestMIMEType, authfile, digestfile, signaturePolicyPath, writer, forceCompress, signingOptions, dockerRegistryOptions, nil) -} - -// InspectVolumes returns a slice of volumes based on an arg list or --all -func (r *LocalRuntime) InspectVolumes(ctx context.Context, c *cliconfig.VolumeInspectValues) ([]*libpod.InspectVolumeData, error) { - var ( - volumes []*libpod.Volume - err error - ) - - if c.All { - volumes, err = r.GetAllVolumes() - } else { - for _, v := range c.InputArgs { - vol, err := r.LookupVolume(v) - if err != nil { - return nil, err - } - volumes = append(volumes, vol) - } - } - if err != nil { - return nil, err - } - - inspectVols := make([]*libpod.InspectVolumeData, 0, len(volumes)) - for _, vol := range volumes { - inspectOut, err := vol.Inspect() - if err != nil { - return nil, errors.Wrapf(err, "error inspecting volume %s", vol.Name()) - } - inspectVols = append(inspectVols, inspectOut) - } - - return inspectVols, nil -} - -// Volumes returns a slice of localruntime volumes -func (r *LocalRuntime) Volumes(ctx context.Context) ([]*Volume, error) { - vols, err := r.GetAllVolumes() - if err != nil { - return nil, err - } - return libpodVolumeToVolume(vols), nil -} - -// libpodVolumeToVolume converts a slice of libpod volumes to a slice -// of localruntime volumes (same as libpod) -func libpodVolumeToVolume(volumes []*libpod.Volume) []*Volume { - var vols []*Volume - for _, v := range volumes { - newVol := Volume{ - v, - } - vols = append(vols, &newVol) - } - return vols -} - -// Build is the wrapper to build images -func (r *LocalRuntime) Build(ctx context.Context, c *cliconfig.BuildValues, options imagebuildah.BuildOptions, dockerfiles []string) (string, reference.Canonical, error) { - - authfile := c.Authfile - if len(c.Authfile) == 0 { - authfile = os.Getenv("REGISTRY_AUTH_FILE") - } - - options.SystemContext.AuthFilePath = authfile - - if c.GlobalFlags.Runtime != "" { - options.Runtime = c.GlobalFlags.Runtime - } else { - options.Runtime = r.GetOCIRuntimePath() - } - - if c.Quiet { - options.ReportWriter = ioutil.Discard - } - - if rootless.IsRootless() { - options.Isolation = buildah.IsolationOCIRootless - } - - return r.Runtime.Build(ctx, options, dockerfiles...) -} - -// PruneVolumes is a wrapper function for libpod PruneVolumes -func (r *LocalRuntime) PruneVolumes(ctx context.Context) ([]string, []error) { - var ( - vids []string - errs []error - ) - reports, err := r.Runtime.PruneVolumes(ctx) - if err != nil { - errs = append(errs, err) - return vids, errs - } - for k, v := range reports { - if v == nil { - vids = append(vids, k) - } else { - errs = append(errs, v) - } - } - return vids, errs -} - -// SaveImage is a wrapper function for saving an image to the local filesystem -func (r *LocalRuntime) SaveImage(ctx context.Context, c *cliconfig.SaveValues) error { - source := c.InputArgs[0] - additionalTags := c.InputArgs[1:] - - newImage, err := r.Runtime.ImageRuntime().NewFromLocal(source) - if err != nil { - return err - } - return newImage.Save(ctx, source, c.Format, c.Output, additionalTags, c.Quiet, c.Compress) -} - -// LoadImage is a wrapper function for libpod LoadImage -func (r *LocalRuntime) LoadImage(ctx context.Context, name string, cli *cliconfig.LoadValues) (string, error) { - var ( - writer io.Writer - ) - if !cli.Quiet { - writer = os.Stderr - } - return r.Runtime.LoadImage(ctx, name, cli.Input, writer, cli.SignaturePolicy) -} - -// IsImageNotFound checks if the error indicates that no image was found. -func IsImageNotFound(err error) bool { - return errors.Cause(err) == image.ErrNoSuchImage -} - -// HealthCheck is a wrapper to same named function in libpod -func (r *LocalRuntime) HealthCheck(c *cliconfig.HealthCheckValues) (string, error) { - output := "unhealthy" - status, err := r.Runtime.HealthCheck(c.InputArgs[0]) - if status == libpod.HealthCheckSuccess { - output = "healthy" - } - return output, err -} - -// Events is a wrapper to libpod to obtain libpod/podman events -func (r *LocalRuntime) Events(c *cliconfig.EventValues) error { - var ( - fromStart bool - eventsError error - ) - var tmpl *template.Template - if c.Format != formats.JSONString { - template, err := template.New("events").Parse(c.Format) - if err != nil { - return err - } - tmpl = template - } - if len(c.Since) > 0 || len(c.Until) > 0 { - fromStart = true - } - eventChannel := make(chan *events.Event) - go func() { - readOpts := events.ReadOptions{FromStart: fromStart, Stream: c.Stream, Filters: c.Filter, EventChannel: eventChannel, Since: c.Since, Until: c.Until} - eventsError = r.Runtime.Events(readOpts) - }() - - if eventsError != nil { - return eventsError - } - w := bufio.NewWriter(os.Stdout) - for event := range eventChannel { - switch { - case c.Format == formats.JSONString: - jsonStr, err := event.ToJSONString() - if err != nil { - return errors.Wrapf(err, "unable to format json") - } - if _, err := w.Write([]byte(jsonStr)); err != nil { - return err - } - case len(c.Format) > 0: - if err := tmpl.Execute(w, event); err != nil { - return err - } - default: - if _, err := w.Write([]byte(event.ToHumanReadable())); err != nil { - return err - } - } - if _, err := w.Write([]byte("\n")); err != nil { - return err - } - if err := w.Flush(); err != nil { - return err - } - } - return nil -} - -// Diff shows the difference in two objects -func (r *LocalRuntime) Diff(c *cliconfig.DiffValues, to string) ([]archive.Change, error) { - return r.Runtime.GetDiff("", to) -} - -// GenerateKube creates kubernetes email from containers and pods -func (r *LocalRuntime) GenerateKube(c *cliconfig.GenerateKubeValues) (*v1.Pod, *v1.Service, error) { - return shared.GenerateKube(c.InputArgs[0], c.Service, r.Runtime) -} - -// GetPodsByStatus returns a slice of pods filtered by a libpod status -func (r *LocalRuntime) GetPodsByStatus(statuses []string) ([]*libpod.Pod, error) { - - filterFunc := func(p *libpod.Pod) bool { - state, _ := shared.GetPodStatus(p) - for _, status := range statuses { - if state == status { - return true - } - } - return false - } - - pods, err := r.Runtime.Pods(filterFunc) - if err != nil { - return nil, err - } - - return pods, nil -} - -// GetVersion is an alias to satisfy interface{} -func (r *LocalRuntime) GetVersion() (define.Version, error) { - return define.GetVersion() -} - -// RemoteEndpoint resolve interface requirement -func (r *LocalRuntime) RemoteEndpoint() (*Endpoint, error) { - return nil, errors.New("RemoteEndpoint() not implemented for local connection") -} -- cgit v1.2.3-54-g00ecf