Method Info.ExtraAttributes has a Cognitive Complexity of 51 (exceeds 20 allowed). Consider refactoring.

Open

func (info *Info) ExtraAttributes(keyMod func(string) string) (map[string]string, error) {
    extra := make(map[string]string)
    labels, ok := info.Config["labels"]
    if ok && len(labels) > 0 {
        for _, l := range strings.Split(labels, ",") {

• Read up
  Read up

Method tarSum.Read has a Cognitive Complexity of 51 (exceeds 20 allowed). Consider refactoring.

Open

func (ts *tarSum) Read(buf []byte) (int, error) {
    if ts.finished {
        return ts.bufWriter.Read(buf)
    }
    if len(ts.bufData) < len(buf) {

• Read up
  Read up

Method EndpointRecord.Unmarshal has 61 return statements (exceeds 4 allowed).

Open

func (m *EndpointRecord) Unmarshal(dAtA []byte) error {
    l := len(dAtA)
    iNdEx := 0
    for iNdEx < l {
        preIndex := iNdEx

Method Config.CopyStreams has a Cognitive Complexity of 50 (exceeds 20 allowed). Consider refactoring.

Open

func (c *Config) CopyStreams(ctx context.Context, cfg *AttachConfig) <-chan error {
    var group errgroup.Group

    // Connect stdin of container to the attach stdin stream.
    if cfg.Stdin != nil {

• Read up
  Read up

Method linuxParser.validateMountConfigImpl has a Cognitive Complexity of 50 (exceeds 20 allowed). Consider refactoring.

Open

func (p *linuxParser) validateMountConfigImpl(mnt *mount.Mount, validateBindSourceExists bool) error {
    if len(mnt.Target) == 0 {
        return &errMountConfig{mnt, errMissingField("Target")}
    }

• Read up
  Read up

Method Daemon.ProcessEvent has a Cognitive Complexity of 50 (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) ProcessEvent(id string, e libcontainerdtypes.EventType, ei libcontainerdtypes.EventInfo) error {
    c, err := daemon.GetContainer(id)
    if err != nil {
        return errors.Wrapf(err, "could not find container %s", id)
    }

• Read up
  Read up

Controller has 39 methods (exceeds 20 allowed). Consider refactoring.

Open

type Controller struct {
    id               string
    drvRegistry      drvregistry.Networks
    ipamRegistry     drvregistry.IPAMs
    sandboxes        map[string]*Sandbox

File layer_store.go has 630 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package layer // import "github.com/docker/docker/layer"

import (
    "context"
    "errors"

Method PortMapper.MapRange has a Cognitive Complexity of 49 (exceeds 20 allowed). Consider refactoring.

Open

func (pm *PortMapper) MapRange(container net.Addr, hostIP net.IP, hostPortStart, hostPortEnd int, useProxy bool) (host net.Addr, retErr error) {
    pm.lock.Lock()
    defer pm.lock.Unlock()

    var (

• Read up
  Read up

Function withMounts has 152 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func withMounts(daemon *Daemon, daemonCfg *configStore, c *container.Container, ms []container.Mount) coci.SpecOpts {
    return func(ctx context.Context, _ coci.Client, _ *containers.Container, s *coci.Spec) (err error) {
        sort.Sort(mounts(ms))

        mounts := ms

Method NetworkEntry.Unmarshal has 150 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (m *NetworkEntry) Unmarshal(dAtA []byte) error {
    l := len(dAtA)
    iNdEx := 0
    for iNdEx < l {
        preIndex := iNdEx

Method NetworkEvent.Unmarshal has 149 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (m *NetworkEvent) Unmarshal(dAtA []byte) error {
    l := len(dAtA)
    iNdEx := 0
    for iNdEx < l {
        preIndex := iNdEx

Method containerRouter.postContainersCreate has 149 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s *containerRouter) postContainersCreate(ctx context.Context, w http.ResponseWriter, r *http.Request, vars map[string]string) error {
    if err := httputils.ParseForm(r); err != nil {
        return err
    }
    if err := httputils.CheckForJSON(r); err != nil {

File client.go has 623 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package remote // import "github.com/docker/docker/libcontainerd/remote"

import (
    "context"
    "encoding/json"

Method layerDescriptor.Download has a Cognitive Complexity of 48 (exceeds 20 allowed). Consider refactoring.

Open

func (ld *layerDescriptor) Download(ctx context.Context, progressOutput progress.Output) (io.ReadCloser, int64, error) {
    log.G(ctx).Debugf("pulling blob %q", ld.digest)

    var (
        err    error

• Read up
  Read up

Method puller.pullTag has a Cognitive Complexity of 48 (exceeds 20 allowed). Consider refactoring.

Open

func (p *puller) pullTag(ctx context.Context, ref reference.Named, platform *ocispec.Platform) (tagUpdated bool, err error) {
    var (
        tagOrDigest string // Used for logging/progress only
        dgst        digest.Digest
        mt          string

• Read up
  Read up

Method driver.CreateEndpoint has a Cognitive Complexity of 48 (exceeds 20 allowed). Consider refactoring.

Open

func (d *driver) CreateEndpoint(nid, eid string, ifInfo driverapi.InterfaceInfo, epOptions map[string]interface{}) error {
    if ifInfo == nil {
        return errors.New("invalid interface info passed")
    }

• Read up
  Read up

Method imageRouter.postImagesCreate has a Cognitive Complexity of 48 (exceeds 20 allowed). Consider refactoring.

Open

func (ir *imageRouter) postImagesCreate(ctx context.Context, w http.ResponseWriter, r *http.Request, vars map[string]string) error {
    if err := httputils.ParseForm(r); err != nil {
        return err
    }

• Read up
  Read up

Method Daemon.ContainerLogs has a Cognitive Complexity of 48 (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) ContainerLogs(ctx context.Context, containerName string, config *containertypes.LogsOptions) (messages <-chan *backend.LogMessage, isTTY bool, retErr error) {
    lg := log.G(ctx).WithFields(log.Fields{
        "module":    "daemon",
        "method":    "(*Daemon).ContainerLogs",
        "container": containerName,

• Read up
  Read up

Function containerToGRPC has a Cognitive Complexity of 48 (exceeds 20 allowed). Consider refactoring.

Open

func containerToGRPC(c *types.ContainerSpec) (*swarmapi.ContainerSpec, error) {
    containerSpec := &swarmapi.ContainerSpec{
        Image:          c.Image,
        Labels:         c.Labels,
        Command:        c.Command,

• Read up
  Read up