Search Options

Results per page
Sort
Preferred Languages
Advance

Results 641 - 650 of 1,105 for errC (0.02 sec)

  1. cni/pkg/plugin/plugin.go

    			}
    			err = errors.New(msg)
    		}
    		if err != nil {
    			log.Errorf("istio-cni cmdAdd error: %v", err)
    		}
    	}()
    
    	conf, err := parseConfig(args.StdinData)
    	if err != nil {
    		log.Errorf("istio-cni cmdAdd failed to parse config %v %v", string(args.StdinData), err)
    		return err
    	}
    
    	// Create a kube client
    	client, err := newK8sClient(*conf)
    	if err != nil {
    		return err
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Aug 14 19:36:19 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  2. prepare_stmt.go

    	stmt, err := db.prepare(ctx, db.ConnPool, false, query)
    	if err == nil {
    		result, err = stmt.ExecContext(ctx, args...)
    		if errors.Is(err, driver.ErrBadConn) {
    			db.Mux.Lock()
    			defer db.Mux.Unlock()
    			go stmt.Close()
    			delete(db.Stmts, query)
    		}
    	}
    	return result, err
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  3. cmd/object-handlers.go

    		return
    	}
    
    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    	object, err := unescapePath(vars["object"])
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	opts, err := getOpts(ctx, r, bucket, object)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	getObjectInfo := objectAPI.GetObjectInfo
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  4. istioctl/pkg/version/version.go

    		if flag.Name == "short" {
    			err := flag.Value.Set("true")
    			if err != nil {
    				fmt.Fprintf(os.Stdout, "set flag %q as true failed due to error %v", flag.Name, err)
    			}
    		}
    		if flag.Name == "remote" {
    			err := flag.Value.Set("true")
    			if err != nil {
    				fmt.Fprintf(os.Stdout, "set flag %q as true failed due to error %v", flag.Name, err)
    			}
    		}
    	})
    	return versionCmd
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 21:11:35 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  5. internal/config/policy/plugin/config.go

    	}
    
    	pluginURL := getCfg(URL)
    	if pluginURL == "" {
    		return args, nil
    	}
    
    	u, err := xnet.ParseHTTPURL(pluginURL)
    	if err != nil {
    		return args, err
    	}
    
    	enableHTTP2 := false
    	if v := getCfg(EnableHTTP2); v != "" {
    		enableHTTP2, err = config.ParseBool(v)
    		if err != nil {
    			return args, err
    		}
    	}
    	httpSettings.EnableHTTP2 = enableHTTP2
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  6. cmd/handler-utils_test.go

    func TestIsValidLocationConstraint(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    		t.Fatal(err)
    	}
    
    	// Corrupted XML
    	malformedReq := &http.Request{
    		Body:          io.NopCloser(bytes.NewReader([]byte("<>"))),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  7. istioctl/pkg/authz/authz.go

    	}
    	defer func() {
    		if err := file.Close(); err != nil {
    			log.Errorf("failed to close %s: %s", filename, err)
    		}
    	}()
    	data, err := io.ReadAll(file)
    	if err != nil {
    		return nil, err
    	}
    
    	envoyConfig := &configdump.Wrapper{}
    	if err := envoyConfig.UnmarshalJSON(data); err != nil {
    		return nil, fmt.Errorf("failed to unmarshal proxy config: %s", err)
    	}
    	return envoyConfig, nil
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 5K bytes
    - Viewed (0)
  8. internal/http/request-recorder.go

    }
    
    // Read reads from the internal reader and counts/save the body in the memory
    func (r *RequestRecorder) Read(p []byte) (n int, err error) {
    	n, err = r.Reader.Read(p)
    	r.bytesRead += n
    
    	if r.LogBody {
    		r.buf.Write(p[:n])
    	}
    	if err != nil {
    		return n, err
    	}
    	return n, err
    }
    
    // Size returns the body size if the currently read object
    func (r *RequestRecorder) Size() int {
    	return r.bytesRead
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 12 21:37:19 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  9. cmd/erasure-heal_test.go

    		}
    
    		// create some test data
    		setup, err := newErasureTestSetup(t, test.dataBlocks, test.disks-test.dataBlocks, test.blocksize)
    		if err != nil {
    			t.Fatalf("Test %d: failed to setup Erasure environment: %v", i, err)
    		}
    		disks := setup.disks
    		erasure, err := NewErasure(context.Background(), test.dataBlocks, test.disks-test.dataBlocks, test.blocksize)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  10. istioctl/pkg/precheck/precheck.go

    	if minor <= 21 {
    		// ENHANCED_RESOURCE_SCOPING
    		if err := checkPilot(cli, ctx.IstioNamespace(), &messages); err != nil {
    			return nil, err
    		}
    	}
    	if minor <= 21 {
    		if err := checkPassthroughTargetPorts(cli, &messages); err != nil {
    			return nil, err
    		}
    		if err := checkTracing(cli, &messages); err != nil {
    			return nil, err
    		}
    	}
    	return messages, nil
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 02:31:32 UTC 2024
    - 15.3K bytes
    - Viewed (0)
Back to top