111 lines
2.7 KiB
Go
111 lines
2.7 KiB
Go
package service // import "github.com/docker/docker/volume/service"
|
|
|
|
import (
|
|
"fmt"
|
|
"strings"
|
|
)
|
|
|
|
const (
|
|
// errVolumeInUse is a typed error returned when trying to remove a volume that is currently in use by a container
|
|
errVolumeInUse conflictError = "volume is in use"
|
|
// errNoSuchVolume is a typed error returned if the requested volume doesn't exist in the volume store
|
|
errNoSuchVolume notFoundError = "no such volume"
|
|
// errNameConflict is a typed error returned on create when a volume exists with the given name, but for a different driver
|
|
errNameConflict conflictError = "volume name must be unique"
|
|
)
|
|
|
|
type conflictError string
|
|
|
|
func (e conflictError) Error() string {
|
|
return string(e)
|
|
}
|
|
func (conflictError) Conflict() {}
|
|
|
|
type notFoundError string
|
|
|
|
func (e notFoundError) Error() string {
|
|
return string(e)
|
|
}
|
|
|
|
func (notFoundError) NotFound() {}
|
|
|
|
// OpErr is the error type returned by functions in the store package. It describes
|
|
// the operation, volume name, and error.
|
|
type OpErr struct {
|
|
// Err is the error that occurred during the operation.
|
|
Err error
|
|
// Op is the operation which caused the error, such as "create", or "list".
|
|
Op string
|
|
// Name is the name of the resource being requested for this op, typically the volume name or the driver name.
|
|
Name string
|
|
// Refs is the list of references associated with the resource.
|
|
Refs []string
|
|
}
|
|
|
|
// Error satisfies the built-in error interface type.
|
|
func (e *OpErr) Error() string {
|
|
if e == nil {
|
|
return "<nil>"
|
|
}
|
|
s := e.Op
|
|
if e.Name != "" {
|
|
s = s + " " + e.Name
|
|
}
|
|
|
|
s = s + ": " + e.Err.Error()
|
|
if len(e.Refs) > 0 {
|
|
s = s + " - " + "[" + strings.Join(e.Refs, ", ") + "]"
|
|
}
|
|
return s
|
|
}
|
|
|
|
// Cause returns the error the caused this error
|
|
func (e *OpErr) Cause() error {
|
|
return e.Err
|
|
}
|
|
|
|
// IsInUse returns a boolean indicating whether the error indicates that a
|
|
// volume is in use
|
|
func IsInUse(err error) bool {
|
|
return isErr(err, errVolumeInUse)
|
|
}
|
|
|
|
// IsNotExist returns a boolean indicating whether the error indicates that the volume does not exist
|
|
func IsNotExist(err error) bool {
|
|
return isErr(err, errNoSuchVolume)
|
|
}
|
|
|
|
// IsNameConflict returns a boolean indicating whether the error indicates that a
|
|
// volume name is already taken
|
|
func IsNameConflict(err error) bool {
|
|
return isErr(err, errNameConflict)
|
|
}
|
|
|
|
type causal interface {
|
|
Cause() error
|
|
}
|
|
|
|
func isErr(err error, expected error) bool {
|
|
switch pe := err.(type) {
|
|
case nil:
|
|
return false
|
|
case causal:
|
|
return isErr(pe.Cause(), expected)
|
|
}
|
|
return err == expected
|
|
}
|
|
|
|
type invalidFilter struct {
|
|
filter string
|
|
value interface{}
|
|
}
|
|
|
|
func (e invalidFilter) Error() string {
|
|
msg := "invalid filter '" + e.filter
|
|
if e.value != nil {
|
|
msg += fmt.Sprintf("=%s", e.value)
|
|
}
|
|
return msg + "'"
|
|
}
|
|
|
|
func (e invalidFilter) InvalidParameter() {}
|