Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 859 for err (0.03 sec)

  1. internal/bucket/lifecycle/delmarker-expiration_test.go

    			var dexp DelMarkerExpiration
    			var fail bool
    			err := xml.Unmarshal([]byte(test.xml), &dexp)
    			if test.err == nil {
    				if err != nil {
    					fail = true
    				}
    			} else {
    				if err == nil {
    					fail = true
    				}
    				if test.err.Error() != err.Error() {
    					fail = true
    				}
    			}
    			if fail {
    				t.Fatalf("Expected %v but got %v", test.err, err)
    			}
    		})
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 1.6K 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. cmd/lock-rest-client_test.go

    	// These should not be connectable.
    	endpoint, err := NewEndpoint("http://localhost:9876")
    	if err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    	endpointLocal, err := NewEndpoint("http://localhost:9012")
    	if err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    	endpointLocal.IsLocal = true
    
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 2K bytes
    - Viewed (0)
  4. 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)
  5. cmd/endpoint-ellipses.go

    						if err := endpointsList.add(ep); err != nil {
    							return layout, err
    						}
    					}
    				}
    			case ellipses.HasEllipses(arg):
    				patterns, err := ellipses.FindEllipsesPatterns(arg)
    				if err != nil {
    					return layout, err
    				}
    				for _, exp := range patterns.Expand() {
    					if err := endpointsList.add(strings.Join(exp, "")); err != nil {
    						return layout, err
    					}
    				}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  6. docs/sts/custom-token-identity.go

    		opts = append(opts, cr.CustomTokenValidityOpt(expiryDuration))
    	}
    
    	// Initialize
    	li, err := cr.NewCustomTokenCredentials(stsEndpoint, token, roleArn, opts...)
    	if err != nil {
    		log.Fatalf("Error initializing CustomToken Identity: %v", err)
    	}
    
    	v, err := li.Get()
    	if err != nil {
    		log.Fatalf("Error retrieving STS credentials: %v", err)
    	}
    
    	if displayCreds {
    		fmt.Println("Only displaying credentials:")
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 27 00:58:09 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  7. cmd/lock-rest-client.go

    	r, err := h.Call(ctx, c.connection, args)
    	if err != nil {
    		return false, err
    	}
    	defer h.PutResponse(r)
    	ok = r.Code == dsync.RespOK
    	switch r.Code {
    	case dsync.RespLockConflict, dsync.RespLockNotFound, dsync.RespOK:
    	// no error
    	case dsync.RespLockNotInitialized:
    		err = errLockNotInitialized
    	default:
    		err = errors.New(r.Err)
    	}
    	return ok, err
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  8. cmd/xl-storage_unix_test.go

    	// Initialize a new xlStorage layer.
    	disk, err := newLocalXLStorage(tmpPath)
    	if err != nil {
    		t.Fatalf("Initializing xlStorage failed with %s.", err)
    	}
    
    	// Attempt to create a volume to verify the permissions later.
    	// MakeVol creates 0777.
    	if err = disk.MakeVol(context.Background(), testCase.volName); err != nil {
    		t.Fatalf("Creating a volume failed with %s expected to pass.", err)
    	}
    
    	// Stat to get permissions bits.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 25 19:37:26 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  9. internal/http/dial_dnscache.go

    		host, port, err := net.SplitHostPort(addr)
    		if err != nil {
    			return nil, err
    		}
    
    		if net.ParseIP(host) != nil {
    			// For IP only setups there is no need for DNS lookups.
    			return baseDialCtx(ctx, "tcp", addr)
    		}
    
    		ips, err := lookupHost(ctx, host)
    		if err != nil {
    			return nil, err
    		}
    
    		for _, ip := range ips {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 03 19:30:51 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  10. internal/kms/secret-key_test.go

    )
    
    func TestSingleKeyRoundtrip(t *testing.T) {
    	KMS, err := ParseSecretKey("my-key:eEm+JI9/q4JhH8QwKvf3LKo4DEBl6QbfvAl1CAbMIv8=")
    	if err != nil {
    		t.Fatalf("Failed to initialize KMS: %v", err)
    	}
    
    	key, err := KMS.GenerateKey(context.Background(), &GenerateKeyRequest{Name: "my-key"})
    	if err != nil {
    		t.Fatalf("Failed to generate key: %v", err)
    	}
    	plaintext, err := KMS.Decrypt(context.TODO(), &DecryptRequest{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top