Method bridgeNetwork.addPortMappings has 122 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (n *bridgeNetwork) addPortMappings(
    ctx context.Context,
    epAddrV4, epAddrV6 *net.IPNet,
    cfg []types.PortBinding,
    defHostIP net.IP,

Method ImageService.ExportImage has 119 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (i *ImageService) ExportImage(ctx context.Context, names []string, platform *ocispec.Platform, outStream io.Writer) error {
    pm := i.matchRequestedOrDefault(platforms.OnlyStrict, platform)

    opts := []archive.ExportOpt{
        archive.WithSkipNonDistributableBlobs(),

Function containerSpecFromGRPC has 119 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method driver.CreateNetwork has a Cognitive Complexity of 41 (exceeds 20 allowed). Consider refactoring.

Open

func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {
    var (
        networkName   string
        interfaceName string
        staleNetworks []string

• Read up
  Read up

Method View.transform has a Cognitive Complexity of 41 (exceeds 20 allowed). Consider refactoring.

Open

func (v *View) transform(ctr *Container) *Snapshot {
    health := container.NoHealthcheck
    if ctr.Health != nil {
        health = ctr.Health.Status()
    }

• Read up
  Read up

Method networkRouter.getNetwork has a Cognitive Complexity of 41 (exceeds 20 allowed). Consider refactoring.

Open

func (n *networkRouter) getNetwork(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 LocalRegistry.Scan has a Cognitive Complexity of 41 (exceeds 20 allowed). Consider refactoring.

Open

func (l *LocalRegistry) Scan() ([]string, error) {
    var names []string
    dirEntries, err := os.ReadDir(l.socketsPath)
    if err != nil && !os.IsNotExist(err) {
        return nil, errors.Wrap(err, "error reading dir entries")

• Read up
  Read up

Method driver.CreateEndpoint has 118 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (d *driver) CreateEndpoint(ctx context.Context, nid, eid string, ifInfo driverapi.InterfaceInfo, epOptions map[string]interface{}) error {
    ctx, span := otel.Tracer("").Start(ctx, fmt.Sprintf("libnetwork.drivers.windows_%s.CreateEndpoint", d.name), trace.WithAttributes(
        attribute.String("nid", nid),
        attribute.String("eid", eid)))
    defer span.End()

Method PartialLogEntryMetadata.Unmarshal has 118 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method NodeEvent.Unmarshal has 117 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

swarmRouter has 30 methods (exceeds 20 allowed). Consider refactoring.

Open

func (sr *swarmRouter) initCluster(ctx context.Context, w http.ResponseWriter, r *http.Request, vars map[string]string) error {
    var req types.InitRequest
    if err := httputils.ReadJSON(r, &req); err != nil {
        return err
    }

Method driver.CreateNetwork has 116 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {
    if _, err := d.getNetwork(id); err == nil {
        return types.ForbiddenErrorf("network %s exists", id)
    }

Function splitConfigRootFSFromTar has a Cognitive Complexity of 40 (exceeds 20 allowed). Consider refactoring.

Open

func splitConfigRootFSFromTar(in io.ReadCloser, config *[]byte) io.ReadCloser {
    pr, pw := io.Pipe()
    go func() {
        tarReader := tar.NewReader(in)
        tarWriter := tar.NewWriter(pw)

• Read up
  Read up

Method Controller.handleKeyChange has a Cognitive Complexity of 40 (exceeds 20 allowed). Consider refactoring.

Open

func (c *Controller) handleKeyChange(keys []*types.EncryptionKey) error {
    drvEnc := discoverapi.DriverEncryptionUpdate{}

    agent := c.getAgent()
    if agent == nil {

• Read up
  Read up

Method ImageService.resolveImage has a Cognitive Complexity of 40 (exceeds 20 allowed). Consider refactoring.

Open

func (i *ImageService) resolveImage(ctx context.Context, refOrID string) (containerdimages.Image, error) {
    parsed, err := reference.ParseAnyReference(refOrID)
    if err != nil {
        return containerdimages.Image{}, errdefs.InvalidParameter(err)
    }

• Read up
  Read up

Function WithDevices has a Cognitive Complexity of 40 (exceeds 20 allowed). Consider refactoring.

Open

func WithDevices(daemon *Daemon, c *container.Container) coci.SpecOpts {
    return func(ctx context.Context, _ coci.Client, _ *containers.Container, s *coci.Spec) error {
        // Build lists of devices allowed and created within the container.
        var devs []specs.LinuxDevice
        devPermissions := s.Linux.Resources.Devices

• Read up
  Read up

Method View.transform has 114 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (v *View) transform(ctr *Container) *Snapshot {
    health := container.NoHealthcheck
    if ctr.Health != nil {
        health = ctr.Health.Status()
    }

Method Daemon.ProcessEvent has 114 lines of code (exceeds 50 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)
    }

Method ImageService.Images has 113 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (i *ImageService) Images(ctx context.Context, opts imagetypes.ListOptions) ([]*imagetypes.Summary, error) {
    if err := opts.Filters.Validate(acceptedImageFilterTags); err != nil {
        return nil, err
    }

Daemon has 29 methods (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) NetworkControllerEnabled() bool {
    return daemon.netController != nil
}