Function newProxy has 11 return statements (exceeds 4 allowed).

Open

func newProxy(config ProxyConfig) (p Proxy, err error) {
    ipv := ip4
    if config.HostIP.To4() == nil {
        ipv = ip6
    }

Method driver.DeleteNetwork has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func (d *driver) DeleteNetwork(nid string) error {
    n := d.network(nid)
    if n == nil {
        return fmt.Errorf("network id %s not found", nid)
    }

• Read up
  Read up

Method cnmNetworkAllocator.allocatePools has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func (na *cnmNetworkAllocator) allocatePools(n *api.Network) (map[string]string, error) {
    ipam, dName, dOptions, err := na.resolveIPAM(n)
    if err != nil {
        return nil, err
    }

• Read up
  Read up

Method Service.Search has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func (s *Service) Search(ctx context.Context, searchFilters filters.Args, term string, limit int, authConfig *registry.AuthConfig, headers map[string][]string) ([]registry.SearchResult, error) {
    if err := searchFilters.Validate(acceptedSearchFilterTags); err != nil {
        return nil, err
    }

• Read up
  Read up

Method client.processEventStream has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func (c *client) processEventStream(ctx context.Context, ns string) {
    // Create a new context specifically for this subscription.
    // The context must be cancelled to cancel the subscription.
    // In cases where we have to restart event stream processing,
    //   we'll need the original context b/c this one will be cancelled

• Read up
  Read up

Function skipPlugin has 11 return statements (exceeds 4 allowed).

Open

func skipPlugin(dAtA []byte) (n int, err error) {
    l := len(dAtA)
    iNdEx := 0
    depth := 0
    for iNdEx < l {

Function skipEntry has 11 return statements (exceeds 4 allowed).

Open

func skipEntry(dAtA []byte) (n int, err error) {
    l := len(dAtA)
    iNdEx := 0
    depth := 0
    for iNdEx < l {

Method Cluster.GetServices has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func (c *Cluster) GetServices(options types.ServiceListOptions) ([]swarm.Service, error) {
    c.mu.RLock()
    defer c.mu.RUnlock()

    state := c.currentNodeState()

• Read up
  Read up

Method follow.Do has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func (fl *follow) Do(ctx context.Context, f *os.File, read logPos) {
    fl.log = log.G(ctx).WithFields(log.Fields{
        "module": "logger",
        "file":   f.Name(),
    })

• Read up
  Read up

Function ServiceSpecToGRPC has 11 return statements (exceeds 4 allowed).

Open

func ServiceSpecToGRPC(s types.ServiceSpec) (swarmapi.ServiceSpec, error) {
    name := s.Name
    if name == "" {
        name = namesgenerator.GetRandomName(0)
    }

Method Daemon.ContainerStats has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) ContainerStats(ctx context.Context, prefixOrName string, config *backend.ContainerStatsConfig) error {
    ctr, err := daemon.GetContainer(prefixOrName)
    if err != nil {
        return err
    }

• Read up
  Read up

Method splunkLogger.tryPostMessages has 11 return statements (exceeds 4 allowed).

Open

func (l *splunkLogger) tryPostMessages(ctx context.Context, messages []*splunkMessage) error {
    if len(messages) == 0 {
        return nil
    }
    var buffer bytes.Buffer

Method pluginAdapterWithRead.ReadLogs has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func (a *pluginAdapterWithRead) ReadLogs(ctx context.Context, config ReadConfig) *LogWatcher {
    watcher := NewLogWatcher()

    go func() {
        defer close(watcher.Msg)

• Read up
  Read up

Method ImageService.ImageDelete has 11 return statements (exceeds 4 allowed).

Open

func (i *ImageService) ImageDelete(ctx context.Context, imageRef string, force, prune bool) ([]imagetypes.DeleteResponse, error) {
    start := time.Now()
    records := []imagetypes.DeleteResponse{}

    img, err := i.GetImage(ctx, imageRef, backend.GetImageOpts{})

Function setResourcesInSpec has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func setResourcesInSpec(c *container.Container, s *specs.Spec, isHyperV bool) {
    // In s.Windows.Resources
    cpuShares := uint16(c.HostConfig.CPUShares)
    cpuMaximum := uint16(c.HostConfig.CPUPercent) * 100
    cpuCount := uint64(c.HostConfig.CPUCount)

• Read up
  Read up

Method ImageService.GetImage has 11 return statements (exceeds 4 allowed).

Open

func (i *ImageService) GetImage(ctx context.Context, refOrID string, options backend.GetImageOpts) (retImg *image.Image, retErr error) {
    defer func() {
        if retErr != nil || retImg == nil || options.Platform == nil {
            return
        }

Function FrozenImagesLinux has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func FrozenImagesLinux(ctx context.Context, client client.APIClient, images ...string) error {
    ctx, span := otel.Tracer("").Start(ctx, "LoadFrozenImages")
    defer span.End()

    var loadImages []struct{ srcName, destName string }

• Read up
  Read up

Method networkConfiguration.UnmarshalJSON has 52 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (ncfg *networkConfiguration) UnmarshalJSON(b []byte) error {
    var (
        err  error
        nMap map[string]interface{}
    )

Function installCommonConfigFlags has 52 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func installCommonConfigFlags(conf *config.Config, flags *pflag.FlagSet) {
    var (
        allowNonDistributable = opts.NewNamedListOptsRef("allow-nondistributable-artifacts", &conf.AllowNondistributableArtifacts, registry.ValidateIndexName)
        registryMirrors       = opts.NewNamedListOptsRef("registry-mirrors", &conf.Mirrors, registry.ValidateMirror)
        insecureRegistries    = opts.NewNamedListOptsRef("insecure-registries", &conf.InsecureRegistries, registry.ValidateIndexName)

Method imageRouter.getImagesJSON has 52 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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