While updating, also addressed some redundant fmt.Sprintf() opts/throttledevice.go:86:2: Consider pre-allocating `out` (prealloc) var out []string ^ opts/ulimit.go:37:2: Consider pre-allocating `out` (prealloc) var out []string ^ opts/ulimit.go:47:2: Consider pre-allocating `ulimits` (prealloc) var ulimits []*units.Ulimit ^ opts/weightdevice.go:68:2: Consider pre-allocating `out` (prealloc) var out []string ^ cli/context/store/metadatastore.go:96:2: Consider pre-allocating `res` (prealloc) var res []Metadata ^ cli/context/store/store.go:127:2: Consider pre-allocating `names` (prealloc) var names []string ^ cli/compose/loader/loader.go:223:2: Consider pre-allocating `keys` (prealloc) var keys []string ^ cli/compose/loader/loader.go:397:2: Consider pre-allocating `services` (prealloc) var services []types.ServiceConfig ^ cli/command/stack/loader/loader.go:63:2: Consider pre-allocating `msgs` (prealloc) var msgs []string ^ cli/command/stack/loader/loader.go:118:2: Consider pre-allocating `configFiles` (prealloc) var configFiles []composetypes.ConfigFile ^ cli/command/formatter/container.go:245:2: Consider pre-allocating `joinLabels` (prealloc) var joinLabels []string ^ cli/command/formatter/container.go:265:2: Consider pre-allocating `mounts` (prealloc) var mounts []string ^ cli/command/formatter/container.go:316:2: Consider pre-allocating `result` (prealloc) var result []string ^ cli/command/formatter/displayutils.go:43:2: Consider pre-allocating `display` (prealloc) var ( ^ cli/command/formatter/volume.go:103:2: Consider pre-allocating `joinLabels` (prealloc) var joinLabels []string ^ cli-plugins/manager/manager_test.go:49:2: Consider pre-allocating `dirs` (prealloc) var dirs []string ^ cli/command/swarm/init.go:69:2: Consider pre-allocating `defaultAddrPool` (prealloc) var defaultAddrPool []string ^ cli/command/manifest/push.go:195:2: Consider pre-allocating `blobReqs` (prealloc) var blobReqs []manifestBlob ^ cli/command/secret/formatter.go:111:2: Consider pre-allocating `joinLabels` (prealloc) var joinLabels []string ^ cli/command/network/formatter.go:104:2: Consider pre-allocating `joinLabels` (prealloc) var joinLabels []string ^ cli/command/context/list.go:52:2: Consider pre-allocating `contexts` (prealloc) var contexts []*formatter.ClientContext ^ cli/command/config/formatter.go:104:2: Consider pre-allocating `joinLabels` (prealloc) var joinLabels []string ^ cli/command/trust/common_test.go:23:2: Consider pre-allocating `targetNames` (prealloc) var targetNames []string ^ cli/command/service/generic_resource_opts.go:55:2: Consider pre-allocating `generic` (prealloc) var generic []swarm.GenericResource ^ cli/command/service/generic_resource_opts.go:98:2: Consider pre-allocating `l` (prealloc) var l []swarm.GenericResource ^ cli/command/service/opts.go:378:2: Consider pre-allocating `netAttach` (prealloc) var netAttach []swarm.NetworkAttachmentConfig ^ cli/command/service/update.go:731:2: Consider pre-allocating `limits` (prealloc) var limits []*units.Ulimit ^ cli/command/service/update.go:1315:2: Consider pre-allocating `newNetworks` (prealloc) var newNetworks []swarm.NetworkAttachmentConfig ^ cli/command/service/update.go:1514:2: Consider pre-allocating `out` (prealloc) var out []string ^ cli/compose/convert/service.go:713:2: Consider pre-allocating `ulimits` (prealloc) var ulimits []*units.Ulimit ^ cli/compose/convert/volume.go:13:2: Consider pre-allocating `mounts` (prealloc) var mounts []mount.Mount ^ cli/command/stack/swarm/list.go:39:2: Consider pre-allocating `stacks` (prealloc) var stacks []*formatter.Stack ^ Signed-off-by: Sebastiaan van Stijn <github@gone.nl>
166 lines
3.4 KiB
Go
166 lines
3.4 KiB
Go
package formatter
|
|
|
|
import (
|
|
"fmt"
|
|
"strconv"
|
|
"strings"
|
|
|
|
"github.com/docker/docker/api/types/volume"
|
|
units "github.com/docker/go-units"
|
|
)
|
|
|
|
const (
|
|
defaultVolumeQuietFormat = "{{.Name}}"
|
|
defaultVolumeTableFormat = "table {{.Driver}}\t{{.Name}}"
|
|
|
|
idHeader = "ID"
|
|
volumeNameHeader = "VOLUME NAME"
|
|
mountpointHeader = "MOUNTPOINT"
|
|
linksHeader = "LINKS"
|
|
groupHeader = "GROUP"
|
|
availabilityHeader = "AVAILABILITY"
|
|
statusHeader = "STATUS"
|
|
)
|
|
|
|
// NewVolumeFormat returns a format for use with a volume Context
|
|
func NewVolumeFormat(source string, quiet bool) Format {
|
|
switch source {
|
|
case TableFormatKey:
|
|
if quiet {
|
|
return defaultVolumeQuietFormat
|
|
}
|
|
return defaultVolumeTableFormat
|
|
case RawFormatKey:
|
|
if quiet {
|
|
return `name: {{.Name}}`
|
|
}
|
|
return `name: {{.Name}}\ndriver: {{.Driver}}\n`
|
|
}
|
|
return Format(source)
|
|
}
|
|
|
|
// VolumeWrite writes formatted volumes using the Context
|
|
func VolumeWrite(ctx Context, volumes []*volume.Volume) error {
|
|
render := func(format func(subContext SubContext) error) error {
|
|
for _, vol := range volumes {
|
|
if err := format(&volumeContext{v: *vol}); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
return ctx.Write(newVolumeContext(), render)
|
|
}
|
|
|
|
type volumeContext struct {
|
|
HeaderContext
|
|
v volume.Volume
|
|
}
|
|
|
|
func newVolumeContext() *volumeContext {
|
|
volumeCtx := volumeContext{}
|
|
volumeCtx.Header = SubHeaderContext{
|
|
"ID": idHeader,
|
|
"Name": volumeNameHeader,
|
|
"Group": groupHeader,
|
|
"Driver": DriverHeader,
|
|
"Scope": ScopeHeader,
|
|
"Availability": availabilityHeader,
|
|
"Mountpoint": mountpointHeader,
|
|
"Labels": LabelsHeader,
|
|
"Links": linksHeader,
|
|
"Size": SizeHeader,
|
|
"Status": statusHeader,
|
|
}
|
|
return &volumeCtx
|
|
}
|
|
|
|
func (c *volumeContext) MarshalJSON() ([]byte, error) {
|
|
return MarshalJSON(c)
|
|
}
|
|
|
|
func (c *volumeContext) Name() string {
|
|
return c.v.Name
|
|
}
|
|
|
|
func (c *volumeContext) Driver() string {
|
|
return c.v.Driver
|
|
}
|
|
|
|
func (c *volumeContext) Scope() string {
|
|
return c.v.Scope
|
|
}
|
|
|
|
func (c *volumeContext) Mountpoint() string {
|
|
return c.v.Mountpoint
|
|
}
|
|
|
|
func (c *volumeContext) Labels() string {
|
|
if c.v.Labels == nil {
|
|
return ""
|
|
}
|
|
|
|
joinLabels := make([]string, 0, len(c.v.Labels))
|
|
for k, v := range c.v.Labels {
|
|
joinLabels = append(joinLabels, k+"="+v)
|
|
}
|
|
return strings.Join(joinLabels, ",")
|
|
}
|
|
|
|
func (c *volumeContext) Label(name string) string {
|
|
if c.v.Labels == nil {
|
|
return ""
|
|
}
|
|
return c.v.Labels[name]
|
|
}
|
|
|
|
func (c *volumeContext) Links() string {
|
|
if c.v.UsageData == nil {
|
|
return "N/A"
|
|
}
|
|
return strconv.FormatInt(c.v.UsageData.RefCount, 10)
|
|
}
|
|
|
|
func (c *volumeContext) Size() string {
|
|
if c.v.UsageData == nil {
|
|
return "N/A"
|
|
}
|
|
return units.HumanSize(float64(c.v.UsageData.Size))
|
|
}
|
|
|
|
func (c *volumeContext) Group() string {
|
|
if c.v.ClusterVolume == nil {
|
|
return "N/A"
|
|
}
|
|
|
|
return c.v.ClusterVolume.Spec.Group
|
|
}
|
|
|
|
func (c *volumeContext) Availability() string {
|
|
if c.v.ClusterVolume == nil {
|
|
return "N/A"
|
|
}
|
|
|
|
return string(c.v.ClusterVolume.Spec.Availability)
|
|
}
|
|
|
|
func (c *volumeContext) Status() string {
|
|
if c.v.ClusterVolume == nil {
|
|
return "N/A"
|
|
}
|
|
|
|
if c.v.ClusterVolume.Info == nil || c.v.ClusterVolume.Info.VolumeID == "" {
|
|
return "pending creation"
|
|
}
|
|
|
|
l := len(c.v.ClusterVolume.PublishStatus)
|
|
switch l {
|
|
case 0:
|
|
return "created"
|
|
case 1:
|
|
return "in use (1 node)"
|
|
default:
|
|
return fmt.Sprintf("in use (%d nodes)", l)
|
|
}
|
|
}
|