Compare commits
	
		
			2 Commits
		
	
	
		
			0.9.0-beta
			...
			prune
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 0d8191bc3e | |||
| 20cdfe7a72 | 
@ -2,15 +2,70 @@ package app
 | 
			
		||||
 | 
			
		||||
import (
 | 
			
		||||
	"context"
 | 
			
		||||
	"fmt"
 | 
			
		||||
	"time"
 | 
			
		||||
 | 
			
		||||
	"coopcloud.tech/abra/cli/internal"
 | 
			
		||||
	"coopcloud.tech/abra/pkg/autocomplete"
 | 
			
		||||
	"coopcloud.tech/abra/pkg/client"
 | 
			
		||||
	stack "coopcloud.tech/abra/pkg/upstream/stack"
 | 
			
		||||
	"github.com/docker/docker/api/types/filters"
 | 
			
		||||
	"github.com/sirupsen/logrus"
 | 
			
		||||
	"github.com/urfave/cli"
 | 
			
		||||
)
 | 
			
		||||
 | 
			
		||||
var prune bool
 | 
			
		||||
 | 
			
		||||
var pruneFlag = &cli.BoolFlag{
 | 
			
		||||
	Name:        "prune, p",
 | 
			
		||||
	Destination: &prune,
 | 
			
		||||
	Usage:       "Prunes unused containers, networks, and dangling images for an app",
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func cleanup(c *cli.Context) error {
 | 
			
		||||
	for {
 | 
			
		||||
		if !prune {
 | 
			
		||||
			return nil
 | 
			
		||||
		}
 | 
			
		||||
		app := internal.ValidateApp(c)
 | 
			
		||||
		stackName := app.StackName()
 | 
			
		||||
		cl, err := client.New(app.Server)
 | 
			
		||||
		if err != nil {
 | 
			
		||||
			logrus.Fatal(err)
 | 
			
		||||
		}
 | 
			
		||||
		ctx := context.Background()
 | 
			
		||||
 | 
			
		||||
		pruneFilters := filters.NewArgs()
 | 
			
		||||
		stackSearch := fmt.Sprintf("%s*", stackName)
 | 
			
		||||
		pruneFilters.Add("label", stackSearch)
 | 
			
		||||
		cr, err := cl.ContainersPrune(ctx, pruneFilters)
 | 
			
		||||
		if err != nil {
 | 
			
		||||
			logrus.Errorf(err.Error())
 | 
			
		||||
			time.Sleep(time.Second)
 | 
			
		||||
			continue
 | 
			
		||||
		}
 | 
			
		||||
		logrus.Infof("Containers deleted: %s; Space reclaimed: %v", cr.ContainersDeleted, cr.SpaceReclaimed)
 | 
			
		||||
 | 
			
		||||
		nr, err := cl.NetworksPrune(ctx, pruneFilters)
 | 
			
		||||
		if err != nil {
 | 
			
		||||
			logrus.Errorf(err.Error())
 | 
			
		||||
			time.Sleep(time.Second)
 | 
			
		||||
			continue
 | 
			
		||||
		}
 | 
			
		||||
		logrus.Infof("Networks deleted %s", nr.NetworksDeleted)
 | 
			
		||||
 | 
			
		||||
		ir, err := cl.ImagesPrune(ctx, pruneFilters)
 | 
			
		||||
		if err != nil {
 | 
			
		||||
			logrus.Errorf(err.Error())
 | 
			
		||||
			time.Sleep(time.Second)
 | 
			
		||||
			continue
 | 
			
		||||
		}
 | 
			
		||||
		logrus.Infof("Images deleted: %s; Space reclaimed: %v", ir.ImagesDeleted, ir.SpaceReclaimed)
 | 
			
		||||
		break
 | 
			
		||||
	}
 | 
			
		||||
	return nil
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
var appUndeployCommand = cli.Command{
 | 
			
		||||
	Name:      "undeploy",
 | 
			
		||||
	Aliases:   []string{"un"},
 | 
			
		||||
@ -18,18 +73,18 @@ var appUndeployCommand = cli.Command{
 | 
			
		||||
	Flags: []cli.Flag{
 | 
			
		||||
		internal.DebugFlag,
 | 
			
		||||
		internal.NoInputFlag,
 | 
			
		||||
		pruneFlag,
 | 
			
		||||
	},
 | 
			
		||||
	Before: internal.SubCommandBefore,
 | 
			
		||||
	Usage:  "Undeploy an app",
 | 
			
		||||
	Description: `
 | 
			
		||||
This does not destroy any of the application data. However, you should remain
 | 
			
		||||
vigilant, as your swarm installation will consider any previously attached
 | 
			
		||||
volumes as eligiblef or pruning once undeployed.
 | 
			
		||||
volumes as eligible for pruning once undeployed.
 | 
			
		||||
`,
 | 
			
		||||
	Action: func(c *cli.Context) error {
 | 
			
		||||
		app := internal.ValidateApp(c)
 | 
			
		||||
		stackName := app.StackName()
 | 
			
		||||
 | 
			
		||||
		cl, err := client.New(app.Server)
 | 
			
		||||
		if err != nil {
 | 
			
		||||
			logrus.Fatal(err)
 | 
			
		||||
@ -54,7 +109,7 @@ volumes as eligiblef or pruning once undeployed.
 | 
			
		||||
		if err := stack.RunRemove(context.Background(), cl, rmOpts); err != nil {
 | 
			
		||||
			logrus.Fatal(err)
 | 
			
		||||
		}
 | 
			
		||||
 | 
			
		||||
		cleanup(c)
 | 
			
		||||
		return nil
 | 
			
		||||
	},
 | 
			
		||||
	BashComplete: autocomplete.AppNameComplete,
 | 
			
		||||
 | 
			
		||||
							
								
								
									
										83
									
								
								cli/server/prune.go
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										83
									
								
								cli/server/prune.go
									
									
									
									
									
										Normal file
									
								
							@ -0,0 +1,83 @@
 | 
			
		||||
package server
 | 
			
		||||
 | 
			
		||||
import (
 | 
			
		||||
	"context"
 | 
			
		||||
 | 
			
		||||
	"coopcloud.tech/abra/cli/internal"
 | 
			
		||||
	"coopcloud.tech/abra/pkg/client"
 | 
			
		||||
	"github.com/docker/docker/api/types/filters"
 | 
			
		||||
	"github.com/sirupsen/logrus"
 | 
			
		||||
	"github.com/urfave/cli"
 | 
			
		||||
)
 | 
			
		||||
 | 
			
		||||
var allFilter bool
 | 
			
		||||
 | 
			
		||||
var allFilterFlag = &cli.BoolFlag{
 | 
			
		||||
	Name:        "all, a",
 | 
			
		||||
	Usage:       "Remove all unused images not just dangling ones",
 | 
			
		||||
	Destination: &allFilter,
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
var volunesFilter bool
 | 
			
		||||
 | 
			
		||||
var volumesFilterFlag = &cli.BoolFlag{
 | 
			
		||||
	Name:        "volumes, v",
 | 
			
		||||
	Usage:       "Prune volumes",
 | 
			
		||||
	Destination: &volunesFilter,
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
var serverPruneCommand = cli.Command{
 | 
			
		||||
	Name:        "prune",
 | 
			
		||||
	Aliases:     []string{"p"},
 | 
			
		||||
	Usage:       "Prune a managed server; Runs a docker system prune",
 | 
			
		||||
	Description: "Prunes unused containers, networks, and dangling images",
 | 
			
		||||
	ArgsUsage:   "[<server>]",
 | 
			
		||||
	Flags: []cli.Flag{
 | 
			
		||||
		allFilterFlag,
 | 
			
		||||
		volumesFilterFlag,
 | 
			
		||||
		internal.DebugFlag,
 | 
			
		||||
	},
 | 
			
		||||
	Before: internal.SubCommandBefore,
 | 
			
		||||
	Action: func(c *cli.Context) error {
 | 
			
		||||
		// Leaving filters empty for now
 | 
			
		||||
		var args filters.Args
 | 
			
		||||
		serverName := internal.ValidateServer(c)
 | 
			
		||||
 | 
			
		||||
		cl, err := client.New(serverName)
 | 
			
		||||
		if err != nil {
 | 
			
		||||
			logrus.Fatal(err)
 | 
			
		||||
		}
 | 
			
		||||
		ctx := context.Background()
 | 
			
		||||
		cr, err := cl.ContainersPrune(ctx, args)
 | 
			
		||||
		if err != nil {
 | 
			
		||||
			logrus.Fatal(err)
 | 
			
		||||
		}
 | 
			
		||||
		logrus.Infof("Containers deleted: %s; Space reclaimed: %v", cr.ContainersDeleted, cr.SpaceReclaimed)
 | 
			
		||||
 | 
			
		||||
		nr, err := cl.NetworksPrune(ctx, args)
 | 
			
		||||
		if err != nil {
 | 
			
		||||
			logrus.Fatal(err)
 | 
			
		||||
		}
 | 
			
		||||
		logrus.Infof("Networks deleted %s", nr.NetworksDeleted)
 | 
			
		||||
 | 
			
		||||
		pruneFilters := filters.NewArgs()
 | 
			
		||||
		if allFilter {
 | 
			
		||||
			pruneFilters.Add("dangling", "false")
 | 
			
		||||
		}
 | 
			
		||||
		ir, err := cl.ImagesPrune(ctx, pruneFilters)
 | 
			
		||||
		if err != nil {
 | 
			
		||||
			logrus.Fatal(err)
 | 
			
		||||
		}
 | 
			
		||||
		logrus.Infof("Images deleted: %s; Space reclaimed: %v", ir.ImagesDeleted, ir.SpaceReclaimed)
 | 
			
		||||
 | 
			
		||||
		if volunesFilter {
 | 
			
		||||
			vr, err := cl.VolumesPrune(ctx, args)
 | 
			
		||||
			if err != nil {
 | 
			
		||||
				logrus.Fatal(err)
 | 
			
		||||
			}
 | 
			
		||||
			logrus.Infof("Volumes deleted: %s; Space reclaimed: %v", vr.VolumesDeleted, vr.SpaceReclaimed)
 | 
			
		||||
		}
 | 
			
		||||
 | 
			
		||||
		return nil
 | 
			
		||||
	},
 | 
			
		||||
}
 | 
			
		||||
@ -22,5 +22,6 @@ recipes, see available flags on "abra server add" for more.
 | 
			
		||||
		serverAddCommand,
 | 
			
		||||
		serverListCommand,
 | 
			
		||||
		serverRemoveCommand,
 | 
			
		||||
		serverPruneCommand,
 | 
			
		||||
	},
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
		Reference in New Issue
	
	Block a user