Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 859 for err (0.02 sec)

  1. internal/s3select/parquet/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
    - 1.4K bytes
    - Viewed (0)
  2. cmd/test-utils_test.go

    	req, err := newTestStreamingRequest(method, urlStr, contentLength, chunkSize, body)
    	if err != nil {
    		return nil, err
    	}
    
    	currTime := UTCNow()
    	signature, err := signStreamingRequest(req, accessKey, secretKey, currTime)
    	if err != nil {
    		return nil, err
    	}
    
    	req, err = assembleStreamingChunks(req, body, chunkSize, secretKey, signature, currTime)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  3. cmd/local-locker_test.go

    			Resources: []string{name},
    			Source:    t.Name(),
    			Owner:     "owner",
    			Quorum:    &quorum,
    		}
    		ok, err := l.RLock(ctx, arg)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if !ok {
    			t.Fatal("did not get read lock")
    		}
    		// RLock twice
    		ok, err = l.RLock(ctx, arg)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if !ok {
    			t.Fatal("did not get write lock")
    		}
    
    		rResources[i] = arg.Resources[0]
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  4. cmd/server-main_test.go

    		t.Run(testcase.config, func(t *testing.T) {
    			sctx := &serverCtxt{}
    			err := mergeServerCtxtFromConfigFile(testcase.config, sctx)
    			if testcase.expectedErr && err == nil {
    				t.Error("expected failure, got success")
    			}
    			if !testcase.expectedErr && err != nil {
    				t.Error("expected success, got failure", err)
    			}
    			if err == nil {
    				if len(sctx.Layout.pools) != 2 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Dec 07 09:33:56 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  5. callbacks.go

    				after := cs[idx]
    
    				if after.before == "" {
    					after.before = c.name
    				}
    
    				if err := sortCallback(after); err != nil {
    					return err
    				}
    
    				if err := sortCallback(c); err != nil {
    					return err
    				}
    			}
    		}
    
    		// if current callback haven't been sorted, append it to last
    		if getRIndex(sorted, c.name) == -1 {
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Tue Mar 26 03:33:36 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  6. internal/crypto/sse-s3.go

    // key.
    func (s3 sses3) UnsealObjectKey(k *kms.KMS, metadata map[string]string, bucket, object string) (key ObjectKey, err error) {
    	if k == nil {
    		return key, Errorf("KMS not configured")
    	}
    	keyID, kmsKey, sealedKey, err := s3.ParseMetadata(metadata)
    	if err != nil {
    		return key, err
    	}
    	unsealKey, err := k.Decrypt(context.TODO(), &kms.DecryptRequest{
    		Name:           keyID,
    		Ciphertext:     kmsKey,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  7. internal/config/storageclass/storage-class_test.go

    		},
    	}
    	for i, tt := range tests {
    		gotSc, err := parseStorageClass(tt.storageClassEnv)
    		if err != nil && tt.expectedError == nil {
    			t.Errorf("Test %d, Expected %s, got %s", i+1, tt.expectedError, err)
    			return
    		}
    		if err == nil && tt.expectedError != nil {
    			t.Errorf("Test %d, Expected %s, got %s", i+1, tt.expectedError, err)
    			return
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 15 23:04:20 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  8. docs/sts/assume-role.go

    	madmClnt, err := madmin.NewWithOptions(stsEndpointURL.Host, mopts)
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	err = madmClnt.ServiceRestart(context.Background())
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	// Use generated credentials to authenticate with MinIO server
    	minioClient, err := minio.New(stsEndpointURL.Host, opts)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Aug 17 01:24:54 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  9. cmd/metacache-server-pool.go

    		}
    		return nil
    	}
    
    	if err != nil {
    		return err
    	}
    
    	if contextCanceled(ctx) {
    		return ctx.Err()
    	}
    
    	for _, err := range errs {
    		if errors.Is(err, io.EOF) {
    			continue
    		}
    		if err == nil || contextCanceled(ctx) || errors.Is(err, context.Canceled) {
    			allAtEOF = false
    			continue
    		}
    		storageLogIf(ctx, err)
    		return err
    	}
    	if allAtEOF {
    		return io.EOF
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  10. internal/kms/config.go

    		}
    		endpoints, err := expandEndpoints(rawEndpoint)
    		if err != nil {
    			return nil, err
    		}
    
    		key, err := kms.ParseAPIKey(env.Get(EnvKMSAPIKey, ""))
    		if err != nil {
    			return nil, err
    		}
    
    		var rootCAs *x509.CertPool
    		if opts != nil && opts.CADir != "" {
    			rootCAs, err = certs.GetRootCAs(opts.CADir)
    			if err != nil {
    				return nil, err
    			}
    		}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 11:46:39 UTC 2024
    - 14.2K bytes
    - Viewed (0)
Back to top