dotcloud/docker

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))

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func delDummyLink(linkName string) error {
    // delete the vlan subinterface
    dummyLink, err := ns.NlHandle().LinkByName(linkName)
    if err != nil {
        return fmt.Errorf("failed to find link %s on the Docker host : %v", linkName, err)

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func delDummyLink(linkName string) error {
    // delete the vlan subinterface
    dummyLink, err := ns.NlHandle().LinkByName(linkName)
    if err != nil {
        return fmt.Errorf("failed to find link %s on the Docker host : %v", linkName, err)

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (sr *swarmRouter) getNode(ctx context.Context, w http.ResponseWriter, r *http.Request, vars map[string]string) error {
    node, err := sr.backend.GetNode(vars["id"])
    if err != nil {
        log.G(ctx).WithContext(ctx).WithFields(log.Fields{
            "error":   err,

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (sr *swarmRouter) getTask(ctx context.Context, w http.ResponseWriter, r *http.Request, vars map[string]string) error {
    task, err := sr.backend.GetTask(vars["id"])
    if err != nil {
        log.G(ctx).WithContext(ctx).WithFields(log.Fields{
            "error":   err,

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (c *Cluster) GetNode(input string) (types.Node, error) {
    var node *swarmapi.Node

    if err := c.lockedManagerAction(func(ctx context.Context, state nodeState) error {
        n, err := getNode(ctx, state.controlClient, input)

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (container *Container) CreateConfigSymlinks() error {
    for _, configRef := range container.ConfigReferences {
        if configRef.File == nil {
            continue
        }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (container *Container) CreateSecretSymlinks() error {
    for _, r := range container.SecretReferences {
        if r.File == nil {
            continue
        }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (c *Cluster) GetNetwork(input string) (network.Inspect, error) {
    var nw *swarmapi.Network

    if err := c.lockedManagerAction(func(ctx context.Context, state nodeState) error {
        n, err := getNetwork(ctx, state.controlClient, input)

• Read up
  Read up

Function attemptBindHostPorts has 67 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func attemptBindHostPorts(
    cfg []portBindingReq,
    proto string,
    hostPortStart, hostPortEnd uint16,
    proxyPath string,

Method linuxParser.validateMountConfigImpl has 67 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method controller.Start has 67 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (r *controller) Start(ctx context.Context) error {
    if err := r.checkClosed(); err != nil {
        return err
    }

Function FilterNetworks has 67 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func FilterNetworks(nws []network.Inspect, filter filters.Args) ([]network.Inspect, error) {
    // if filter is empty, return original network list
    if filter.Len() == 0 {
        return nws, nil
    }

Method layerStore.RegisterByGraphID has 67 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (ls *layerStore) RegisterByGraphID(graphID string, parent ChainID, diffID DiffID, tarDataFile string, size int64) (Layer, error) {
    // err is used to hold the error which will always trigger
    // cleanup of creates sources but may not be an error returned
    // to the caller (already exists).
    var err error

Method puller.pullSchema2Layers has 18 return statements (exceeds 4 allowed).

Open

func (p *puller) pullSchema2Layers(ctx context.Context, target distribution.Descriptor, layers []distribution.Descriptor, platform *ocispec.Platform) (id digest.Digest, err error) {
    if _, err := p.config.ImageStore.Get(ctx, target.Digest); err == nil {
        // If the image already exists locally, no need to pull
        // anything.
        return target.Digest, nil

Method Endpoint.sbJoin has 18 return statements (exceeds 4 allowed).

Open

func (ep *Endpoint) sbJoin(ctx context.Context, sb *Sandbox, options ...EndpointOption) (retErr error) {
    ctx, span := otel.Tracer("").Start(ctx, "libnetwork.sbJoin")
    defer span.End()

    n, err := ep.getNetworkFromStore()

Method GossipMessage.Unmarshal has 18 return statements (exceeds 4 allowed).

Open

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

Method driver.Join has 18 return statements (exceeds 4 allowed).

Open

func (d *driver) Join(ctx context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {
    ctx, span := otel.Tracer("").Start(ctx, "libnetwork.drivers.ipvlan.Join", trace.WithAttributes(
        attribute.String("nid", nid),
        attribute.String("eid", eid),
        attribute.String("sboxKey", sboxKey)))

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func (c *Cluster) GetConfig(input string) (types.Config, error) {
    var config *swarmapi.Config

    if err := c.lockedManagerAction(func(ctx context.Context, state nodeState) error {
        s, err := getConfig(ctx, state.controlClient, input)

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func (c *Cluster) GetSecret(input string) (types.Secret, error) {
    var secret *swarmapi.Secret

    if err := c.lockedManagerAction(func(ctx context.Context, state nodeState) error {
        s, err := getSecret(ctx, state.controlClient, input)

• Read up
  Read up