Search Options

Results per page
Sort
Preferred Languages
Advance

Results 351 - 360 of 858 for err (0.02 sec)

  1. internal/dsync/dsync-client_test.go

    	buf, err := args.MarshalMsg(nil)
    	if err != nil {
    		return false, err
    	}
    	body := bytes.NewReader(buf)
    	respBody, err := restClient.rest.Call(context.Background(), method,
    		url.Values{}, body, body.Size())
    	defer xhttp.DrainBody(respBody)
    
    	switch toLockError(err) {
    	case nil:
    		return true, nil
    	case errLockConflict, errLockNotFound:
    		return false, nil
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 20 17:36:09 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  2. internal/grid/grid_test.go

    		st, err := remoteConn.NewStream(ctx, handler, []byte(testPayload))
    		errFatal(err)
    		clientCanceled := make(chan time.Time, 1)
    		err = nil
    		go func(t *testing.T) {
    			for resp := range st.responses {
    				t.Log("got resp:", string(resp.Msg), "err:", resp.Err)
    				if err != nil {
    					t.Log("ERROR: got second error:", resp.Err, "first:", err)
    					continue
    				}
    				err = resp.Err
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  3. internal/logger/logrotate.go

    	oldLgFile := w.f.Name()
    	r, err := os.Open(oldLgFile)
    	if err != nil {
    		return err
    	}
    	defer r.Close()
    
    	gw, err := os.Create(oldLgFile + ".gz")
    	if err != nil {
    		return err
    	}
    	defer gw.Close()
    
    	var wc io.WriteCloser
    	wc = gzip.NewWriter(gw)
    	if _, err = io.Copy(wc, r); err != nil {
    		return err
    	}
    
    	if err = wc.Close(); err != nil {
    		return err
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  4. cmd/erasure-healing-common_test.go

    		},
    	}
    
    	bucket := "bucket"
    	err = obj.MakeBucket(ctx, "bucket", MakeBucketOptions{})
    	if err != nil {
    		t.Fatalf("Failed to make a bucket %v", err)
    	}
    
    	object := "object"
    	data := bytes.Repeat([]byte("a"), smallFileThreshold*32)
    	z := obj.(*erasureServerPools)
    
    	erasureDisks, err := z.GetDisks(0, 0)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	for i, test := range testCases {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  5. internal/config/identity/openid/provider/keycloak.go

    	req, err := http.NewRequest(http.MethodPost, k.oeConfig.TokenEndpoint, strings.NewReader(values.Encode()))
    	if err != nil {
    		return err
    	}
    	req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
    
    	resp, err := k.client.Do(req)
    	if err != nil {
    		return err
    	}
    	defer resp.Body.Close()
    
    	var accessToken Token
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Jul 14 18:12:07 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  6. cmd/admin-handlers-pools.go

    		return
    	}
    
    	rs, err := rebalanceStatus(ctx, pools)
    	if err != nil {
    		if errors.Is(err, errRebalanceNotStarted) || errors.Is(err, errConfigNotFound) {
    			writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAdminRebalanceNotStarted), r.URL)
    			return
    		}
    		adminLogIf(ctx, fmt.Errorf("failed to fetch rebalance status: %w", err))
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 28 00:22:30 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  7. internal/s3select/sql/errors.go

    	statusCode int
    	cause      error
    }
    
    func (err *s3Error) Cause() error {
    	return err.cause
    }
    
    func (err *s3Error) ErrorCode() string {
    	return err.code
    }
    
    func (err *s3Error) ErrorMessage() string {
    	return err.message
    }
    
    func (err *s3Error) HTTPStatusCode() int {
    	return err.statusCode
    }
    
    func (err *s3Error) Error() string {
    	return err.message
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.6K bytes
    - Viewed (0)
  8. internal/etag/etag_test.go

    }
    
    func TestEqual(t *testing.T) {
    	for i, test := range equalTests {
    		A, err := Parse(test.A)
    		if err != nil {
    			t.Fatalf("Test %d: %v", i, err)
    		}
    		B, err := Parse(test.B)
    		if err != nil {
    			t.Fatalf("Test %d: %v", i, err)
    		}
    		if equal := Equal(A, B); equal != test.Equal {
    			t.Fatalf("Test %d: got %v - want %v", i, equal, test.Equal)
    		}
    	}
    }
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 12.6K bytes
    - Viewed (0)
  9. docs/extensions/s3zip/examples/minio-go/main.go

    	if err != nil {
    		log.Fatalln(err)
    	}
    	_, err = io.Copy(os.Stdout, rd)
    	if err != nil {
    		log.Fatalln(err)
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 14 18:04:14 UTC 2021
    - 694 bytes
    - Viewed (0)
  10. docs/debugging/s3-check-md5/main.go

    		}
    	}
    
    	u, err := url.Parse(endpoint)
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	secure := strings.EqualFold(u.Scheme, "https")
    	transport, err := minio.DefaultTransport(secure)
    	if err != nil {
    		log.Fatalln(err)
    	}
    	if insecure {
    		// skip TLS verification
    		transport.TLSClientConfig.InsecureSkipVerify = true
    	}
    
    	s3Client, err := minio.New(u.Host, &minio.Options{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Feb 17 01:15:57 UTC 2024
    - 6.3K bytes
    - Viewed (0)
Back to top