remove volumes on down

modules/compose/compose_api.go

@@ -50,7 +50,7 @@ func (io IgnoreOrphans) applyToStackUp(co *api.CreateOptions, _ *api.StartOption
 	co.IgnoreOrphans = bool(io)
 }
 
-// RemoveOrphans will cleanup containers that are not declared on the compose model but own the same labels
+// RemoveOrphans will clean up containers that are not declared on the compose model but own the same labels
 type RemoveOrphans bool
 
 func (ro RemoveOrphans) applyToStackUp(o *stackUpOptions) {
@@ -68,6 +68,12 @@ func (w Wait) applyToStackUp(o *stackUpOptions) {
 	o.Wait = bool(w)
 }
 
+type RemoveVolumes bool
+
+func (ro RemoveVolumes) applyToStackDown(o *stackDownOptions) {
+	o.Volumes = bool(ro)
+}
+
 // RemoveImages used by services
 type RemoveImages uint8
 

modules/compose/compose_api_test.go

@@ -3,6 +3,8 @@ package compose
 import (
 	"context"
 	"fmt"
+	"github.com/docker/docker/api/types/filters"
+	"github.com/google/uuid"
 	"hash/fnv"
 	"testing"
 	"time"
@@ -365,6 +367,29 @@ func TestDockerComposeAPIWithVolume(t *testing.T) {
 	assert.NoError(t, err, "compose.Up()")
 }
 
+func TestDockerComposeAPIVolumesDeletedOnDown(t *testing.T) {
+	identifier := uuid.New().String()
+	stackFiles := WithStackFiles("./testresources/docker-compose-volume.yml")
+	compose, err := NewDockerComposeWith(stackFiles, StackIdentifier(identifier))
+	assert.NoError(t, err, "NewDockerCompose()")
+
+	ctx, cancel := context.WithCancel(context.Background())
+	t.Cleanup(cancel)
+
+	err = compose.Up(ctx, Wait(true))
+	assert.NoError(t, err, "compose.Up()")
+
+	err = compose.Down(context.Background(), RemoveOrphans(true), RemoveVolumes(true), RemoveImagesLocal)
+	assert.NoError(t, err, "compose.Down()")
+
+	volumeListFilters := filters.NewArgs()
+	volumeListFilters.Add("name", fmt.Sprintf("%s_mydata", identifier))
+	volumeList, err := compose.dockerClient.VolumeList(ctx, volumeListFilters)
+	assert.NoError(t, err, "compose.dockerClient.VolumeList()")
+
+	assert.Equal(t, 0, len(volumeList.Volumes), "Volumes are not cleaned up")
+}
+
 func TestDockerComposeAPIWithBuild(t *testing.T) {
 	compose, err := NewDockerCompose("./testresources/docker-compose-build.yml")
 	assert.NoError(t, err, "NewDockerCompose()")