mirror of
https://github.com/containers/podman.git
synced 2025-06-09 00:53:41 +08:00
Consolidate filter logic to pkg subdirectory
Per the conversation on pull/8724 I am consolidating filter logic and helper functions under the pkg/domain/filters dir. Signed-off-by: Baron Lenardson <lenardson.baron@gmail.com>
This commit is contained in:

committed by
Baron Lenardson

parent
8f75ed9585
commit
76afb50f3a
@ -11,8 +11,8 @@ import (
|
|||||||
"github.com/containers/podman/v2/cmd/podman/registry"
|
"github.com/containers/podman/v2/cmd/podman/registry"
|
||||||
"github.com/containers/podman/v2/cmd/podman/utils"
|
"github.com/containers/podman/v2/cmd/podman/utils"
|
||||||
"github.com/containers/podman/v2/cmd/podman/validate"
|
"github.com/containers/podman/v2/cmd/podman/validate"
|
||||||
lpfilters "github.com/containers/podman/v2/libpod/filters"
|
|
||||||
"github.com/containers/podman/v2/pkg/domain/entities"
|
"github.com/containers/podman/v2/pkg/domain/entities"
|
||||||
|
dfilters "github.com/containers/podman/v2/pkg/domain/filters"
|
||||||
"github.com/spf13/cobra"
|
"github.com/spf13/cobra"
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -80,7 +80,7 @@ Are you sure you want to continue? [y/N] `, volumeString)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
pruneOptions.Filters, err = lpfilters.ParseFilterArgumentsIntoFilters(filters)
|
pruneOptions.Filters, err = dfilters.ParseFilterArgumentsIntoFilters(filters)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
@ -1,20 +0,0 @@
|
|||||||
package lpfilters
|
|
||||||
|
|
||||||
import (
|
|
||||||
"net/url"
|
|
||||||
"strings"
|
|
||||||
|
|
||||||
"github.com/pkg/errors"
|
|
||||||
)
|
|
||||||
|
|
||||||
func ParseFilterArgumentsIntoFilters(filters []string) (url.Values, error) {
|
|
||||||
parsedFilters := make(url.Values)
|
|
||||||
for _, f := range filters {
|
|
||||||
t := strings.SplitN(f, "=", 2)
|
|
||||||
if len(t) < 2 {
|
|
||||||
return parsedFilters, errors.Errorf("filter input must be in the form of filter=value: %s is invalid", f)
|
|
||||||
}
|
|
||||||
parsedFilters.Add(t[0], t[1])
|
|
||||||
}
|
|
||||||
return parsedFilters, nil
|
|
||||||
}
|
|
@ -4,9 +4,9 @@ import (
|
|||||||
"net/http"
|
"net/http"
|
||||||
|
|
||||||
"github.com/containers/podman/v2/libpod"
|
"github.com/containers/podman/v2/libpod"
|
||||||
lpfilters "github.com/containers/podman/v2/libpod/filters"
|
|
||||||
"github.com/containers/podman/v2/pkg/api/handlers/utils"
|
"github.com/containers/podman/v2/pkg/api/handlers/utils"
|
||||||
"github.com/containers/podman/v2/pkg/domain/entities"
|
"github.com/containers/podman/v2/pkg/domain/entities"
|
||||||
|
"github.com/containers/podman/v2/pkg/domain/filters"
|
||||||
"github.com/docker/docker/api/types"
|
"github.com/docker/docker/api/types"
|
||||||
"github.com/gorilla/schema"
|
"github.com/gorilla/schema"
|
||||||
"github.com/pkg/errors"
|
"github.com/pkg/errors"
|
||||||
@ -29,7 +29,7 @@ func PruneContainers(w http.ResponseWriter, r *http.Request) {
|
|||||||
}
|
}
|
||||||
filterFuncs := make([]libpod.ContainerFilter, 0, len(query.Filters))
|
filterFuncs := make([]libpod.ContainerFilter, 0, len(query.Filters))
|
||||||
for k, v := range query.Filters {
|
for k, v := range query.Filters {
|
||||||
generatedFunc, err := lpfilters.GenerateContainerFilterFuncs(k, v, runtime)
|
generatedFunc, err := filters.GenerateContainerFilterFuncs(k, v, runtime)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
utils.InternalServerError(w, err)
|
utils.InternalServerError(w, err)
|
||||||
return
|
return
|
||||||
|
@ -4,8 +4,8 @@ import (
|
|||||||
"net/http"
|
"net/http"
|
||||||
|
|
||||||
"github.com/containers/podman/v2/libpod"
|
"github.com/containers/podman/v2/libpod"
|
||||||
lpfilters "github.com/containers/podman/v2/libpod/filters"
|
|
||||||
"github.com/containers/podman/v2/pkg/domain/entities"
|
"github.com/containers/podman/v2/pkg/domain/entities"
|
||||||
|
dfilters "github.com/containers/podman/v2/pkg/domain/filters"
|
||||||
"github.com/gorilla/schema"
|
"github.com/gorilla/schema"
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -31,7 +31,7 @@ func GetPods(w http.ResponseWriter, r *http.Request) ([]*entities.ListPodsReport
|
|||||||
|
|
||||||
filters := make([]libpod.PodFilter, 0, len(query.Filters))
|
filters := make([]libpod.PodFilter, 0, len(query.Filters))
|
||||||
for k, v := range query.Filters {
|
for k, v := range query.Filters {
|
||||||
f, err := lpfilters.GeneratePodFilterFunc(k, v)
|
f, err := dfilters.GeneratePodFilterFunc(k, v)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
@ -1,4 +1,4 @@
|
|||||||
package lpfilters
|
package filters
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"strconv"
|
"strconv"
|
@ -1,4 +1,4 @@
|
|||||||
package lpfilters
|
package filters
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"strconv"
|
"strconv"
|
@ -16,12 +16,12 @@ import (
|
|||||||
"github.com/containers/podman/v2/libpod"
|
"github.com/containers/podman/v2/libpod"
|
||||||
"github.com/containers/podman/v2/libpod/define"
|
"github.com/containers/podman/v2/libpod/define"
|
||||||
"github.com/containers/podman/v2/libpod/events"
|
"github.com/containers/podman/v2/libpod/events"
|
||||||
lpfilters "github.com/containers/podman/v2/libpod/filters"
|
|
||||||
"github.com/containers/podman/v2/libpod/image"
|
"github.com/containers/podman/v2/libpod/image"
|
||||||
"github.com/containers/podman/v2/libpod/logs"
|
"github.com/containers/podman/v2/libpod/logs"
|
||||||
"github.com/containers/podman/v2/pkg/cgroups"
|
"github.com/containers/podman/v2/pkg/cgroups"
|
||||||
"github.com/containers/podman/v2/pkg/checkpoint"
|
"github.com/containers/podman/v2/pkg/checkpoint"
|
||||||
"github.com/containers/podman/v2/pkg/domain/entities"
|
"github.com/containers/podman/v2/pkg/domain/entities"
|
||||||
|
dfilters "github.com/containers/podman/v2/pkg/domain/filters"
|
||||||
"github.com/containers/podman/v2/pkg/domain/infra/abi/terminal"
|
"github.com/containers/podman/v2/pkg/domain/infra/abi/terminal"
|
||||||
parallelctr "github.com/containers/podman/v2/pkg/parallel/ctr"
|
parallelctr "github.com/containers/podman/v2/pkg/parallel/ctr"
|
||||||
"github.com/containers/podman/v2/pkg/ps"
|
"github.com/containers/podman/v2/pkg/ps"
|
||||||
@ -207,7 +207,7 @@ func (ic *ContainerEngine) ContainerStop(ctx context.Context, namesOrIds []strin
|
|||||||
func (ic *ContainerEngine) ContainerPrune(ctx context.Context, options entities.ContainerPruneOptions) (*entities.ContainerPruneReport, error) {
|
func (ic *ContainerEngine) ContainerPrune(ctx context.Context, options entities.ContainerPruneOptions) (*entities.ContainerPruneReport, error) {
|
||||||
filterFuncs := make([]libpod.ContainerFilter, 0, len(options.Filters))
|
filterFuncs := make([]libpod.ContainerFilter, 0, len(options.Filters))
|
||||||
for k, v := range options.Filters {
|
for k, v := range options.Filters {
|
||||||
generatedFunc, err := lpfilters.GenerateContainerFilterFuncs(k, v, ic.Libpod)
|
generatedFunc, err := dfilters.GenerateContainerFilterFuncs(k, v, ic.Libpod)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
@ -5,8 +5,8 @@ import (
|
|||||||
|
|
||||||
"github.com/containers/podman/v2/libpod"
|
"github.com/containers/podman/v2/libpod"
|
||||||
"github.com/containers/podman/v2/libpod/define"
|
"github.com/containers/podman/v2/libpod/define"
|
||||||
lpfilters "github.com/containers/podman/v2/libpod/filters"
|
|
||||||
"github.com/containers/podman/v2/pkg/domain/entities"
|
"github.com/containers/podman/v2/pkg/domain/entities"
|
||||||
|
dfilters "github.com/containers/podman/v2/pkg/domain/filters"
|
||||||
"github.com/containers/podman/v2/pkg/signal"
|
"github.com/containers/podman/v2/pkg/signal"
|
||||||
"github.com/containers/podman/v2/pkg/specgen"
|
"github.com/containers/podman/v2/pkg/specgen"
|
||||||
"github.com/containers/podman/v2/pkg/specgen/generate"
|
"github.com/containers/podman/v2/pkg/specgen/generate"
|
||||||
@ -288,7 +288,7 @@ func (ic *ContainerEngine) PodPs(ctx context.Context, options entities.PodPSOpti
|
|||||||
|
|
||||||
filters := make([]libpod.PodFilter, 0, len(options.Filters))
|
filters := make([]libpod.PodFilter, 0, len(options.Filters))
|
||||||
for k, v := range options.Filters {
|
for k, v := range options.Filters {
|
||||||
f, err := lpfilters.GeneratePodFilterFunc(k, v)
|
f, err := dfilters.GeneratePodFilterFunc(k, v)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
@ -11,8 +11,8 @@ import (
|
|||||||
|
|
||||||
"github.com/containers/podman/v2/libpod"
|
"github.com/containers/podman/v2/libpod"
|
||||||
"github.com/containers/podman/v2/libpod/define"
|
"github.com/containers/podman/v2/libpod/define"
|
||||||
lpfilters "github.com/containers/podman/v2/libpod/filters"
|
|
||||||
"github.com/containers/podman/v2/pkg/domain/entities"
|
"github.com/containers/podman/v2/pkg/domain/entities"
|
||||||
|
"github.com/containers/podman/v2/pkg/domain/filters"
|
||||||
psdefine "github.com/containers/podman/v2/pkg/ps/define"
|
psdefine "github.com/containers/podman/v2/pkg/ps/define"
|
||||||
"github.com/containers/storage"
|
"github.com/containers/storage"
|
||||||
"github.com/pkg/errors"
|
"github.com/pkg/errors"
|
||||||
@ -27,7 +27,7 @@ func GetContainerLists(runtime *libpod.Runtime, options entities.ContainerListOp
|
|||||||
all := options.All || options.Last > 0
|
all := options.All || options.Last > 0
|
||||||
if len(options.Filters) > 0 {
|
if len(options.Filters) > 0 {
|
||||||
for k, v := range options.Filters {
|
for k, v := range options.Filters {
|
||||||
generatedFunc, err := lpfilters.GenerateContainerFilterFuncs(k, v, runtime)
|
generatedFunc, err := filters.GenerateContainerFilterFuncs(k, v, runtime)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
@ -41,7 +41,7 @@ func GetContainerLists(runtime *libpod.Runtime, options entities.ContainerListOp
|
|||||||
all = true
|
all = true
|
||||||
}
|
}
|
||||||
if !all {
|
if !all {
|
||||||
runningOnly, err := lpfilters.GenerateContainerFilterFuncs("status", []string{define.ContainerStateRunning.String()}, runtime)
|
runningOnly, err := filters.GenerateContainerFilterFuncs("status", []string{define.ContainerStateRunning.String()}, runtime)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user