Method Manager.Push has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func (pm *Manager) Push(ctx context.Context, name string, metaHeader http.Header, authConfig *registry.AuthConfig, outStream io.Writer) error {
    p, err := pm.config.Store.GetV2Plugin(name)
    if err != nil {
        return err
    }

• Read up
  Read up

Method tarexporter.legacyLoadImage has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func (l *tarexporter) legacyLoadImage(oldID, sourceDir string, loadedMap map[string]image.ID, progressOutput progress.Output) error {
    if _, loaded := loadedMap[oldID]; loaded {
        return nil
    }
    configPath, err := safePath(sourceDir, filepath.Join(oldID, legacyConfigFileName))

• Read up
  Read up

Method Manager.CreateFromContext has 19 return statements (exceeds 4 allowed).

Open

func (pm *Manager) CreateFromContext(ctx context.Context, tarCtx io.ReadCloser, options *types.PluginCreateOptions) (err error) {
    pm.muGC.RLock()
    defer pm.muGC.RUnlock()

    ref, err := reference.ParseNormalizedNamed(options.RepoName)

Method Resolver.serveDNS has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func (r *Resolver) serveDNS(w dns.ResponseWriter, query *dns.Msg) {
    var (
        resp *dns.Msg
        err  error
    )

• Read up
  Read up

Method driver.createNetwork has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func (d *driver) createNetwork(config *configuration) (bool, error) {
    foundExisting := false
    networkList := d.getNetworks()
    for _, nw := range networkList {
        if config.Parent == nw.config.Parent {

• Read up
  Read up

Method systemRouter.getDiskUsage has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func (s *systemRouter) getDiskUsage(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 systemRouter.getEvents has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func (s *systemRouter) getEvents(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 systemRouter.getInfo has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func (s *systemRouter) getInfo(ctx context.Context, w http.ResponseWriter, r *http.Request, vars map[string]string) error {
    version := httputils.VersionFromContext(ctx)
    info, _, _ := s.collectSystemInfo.Do(ctx, version, func(ctx context.Context) (*system.Info, error) {
        info, err := s.backend.SystemInfo(ctx)
        if err != nil {

• Read up
  Read up

Method networkRouter.findUniqueNetwork has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func (n *networkRouter) findUniqueNetwork(term string) (network.Inspect, error) {
    listByFullName := map[string]network.Inspect{}
    listByPartialID := map[string]network.Inspect{}

    filter := filters.NewArgs(filters.Arg("idOrName", term))

• Read up
  Read up

Function GetTimestamp has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func GetTimestamp(value string, reference time.Time) (string, error) {
    if d, err := time.ParseDuration(value); value != "0" && err == nil {
        return strconv.FormatInt(reference.Add(-d).Unix(), 10), nil
    }

• Read up
  Read up

Function withCgroups has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func withCgroups(daemon *Daemon, daemonCfg *dconfig.Config, c *container.Container) coci.SpecOpts {
    return func(ctx context.Context, _ coci.Client, _ *containers.Container, s *coci.Spec) error {
        var cgroupsPath string
        scopePrefix := "docker"
        parent := "/docker"

• Read up
  Read up

Method ImageService.unleaseSnapshotsFromDeletedConfigs has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func (i *ImageService) unleaseSnapshotsFromDeletedConfigs(ctx context.Context, possiblyDeletedConfigs map[digest.Digest]struct{}) error {
    all, err := i.images.List(ctx)
    if err != nil {
        return errors.Wrap(err, "failed to list images during snapshot lease removal")
    }

• Read up
  Read up

Method executor.Configure has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func (e *executor) Configure(ctx context.Context, node *api.Node) error {
    var ingressNA *api.NetworkAttachment
    attachments := make(map[string]string)

    for _, na := range node.Attachments {

• Read up
  Read up

Method Daemon.containerStart has 19 return statements (exceeds 4 allowed).

Open

func (daemon *Daemon) containerStart(ctx context.Context, daemonCfg *configStore, container *container.Container, checkpoint string, checkpointDir string, resetRestartManager bool) (retErr error) {
    ctx, span := otel.Tracer("").Start(ctx, "daemon.containerStart", trace.WithAttributes(
        attribute.String("container.ID", container.ID),
        attribute.String("container.Name", container.Name)))
    defer span.End()

Method Daemon.cleanupContainer has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) cleanupContainer(container *container.Container, config backend.ContainerRmConfig) error {
    if container.IsRunning() {
        if !config.ForceRemove {
            if state := container.StateString(); state == "paused" {
                return errdefs.Conflict(fmt.Errorf("cannot remove container %q: container is %s and must be unpaused first", container.Name, state))

• Read up
  Read up

Function containerSpecFromGRPC has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func containerSpecFromGRPC(c *swarmapi.ContainerSpec) *types.ContainerSpec {
    if c == nil {
        return nil
    }
    containerSpec := &types.ContainerSpec{

• Read up
  Read up

Function getConflictFreeConfiguration has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func getConflictFreeConfiguration(configFile string, flags *pflag.FlagSet) (*Config, error) {
    b, err := os.ReadFile(configFile)
    if err != nil {
        return nil, err
    }

• Read up
  Read up

Function findConfigurationConflicts has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func findConfigurationConflicts(config map[string]interface{}, flags *pflag.FlagSet) error {
    // 1. Search keys from the file that we don't recognize as flags.
    unknownKeys := make(map[string]interface{})
    for key, value := range config {
        if flag := flags.Lookup(key); flag == nil && !skipValidateOptions[key] {

• Read up
  Read up

Method Sandbox.populateNetworkResources has 68 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (sb *Sandbox) populateNetworkResources(ctx context.Context, ep *Endpoint) error {
    ctx, span := otel.Tracer("").Start(ctx, "libnetwork.Sandbox.populateNetworkResources", trace.WithAttributes(
        attribute.String("endpoint.Name", ep.Name())))
    defer span.End()

Function newAWSLogsClient has 68 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func newAWSLogsClient(info logger.Info, configOpts ...func(*config.LoadOptions) error) (*cloudwatchlogs.Client, error) {
    ctx := context.TODO()
    var region, endpoint *string
    if os.Getenv(regionEnvKey) != "" {
        region = aws.String(os.Getenv(regionEnvKey))