Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for NIL (0.02 sec)

  1. cmd/warm-backend-gcs.go

    		return nil, errors.New("no bucket name was provided")
    	}
    
    	credsJSON, err := conf.GetCredentialJSON()
    	if err != nil {
    		return nil, err
    	}
    
    	client, err := storage.NewClient(context.Background(),
    		option.WithCredentialsJSON(credsJSON),
    		option.WithScopes(storage.ScopeReadWrite),
    		option.WithUserAgent(fmt.Sprintf("gcs-tier-%s", tier)+SlashSeparator+ReleaseTag),
    	)
    	if err != nil {
    		return nil, err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  2. cmd/warm-backend-minio.go

    	// Validation of credentials
    	if conf.AccessKey == "" || conf.SecretKey == "" {
    		return nil, errors.New("both access and secret keys are required")
    	}
    
    	if conf.Bucket == "" {
    		return nil, errors.New("no bucket name was provided")
    	}
    
    	u, err := url.Parse(conf.Endpoint)
    	if err != nil {
    		return nil, err
    	}
    
    	creds := credentials.NewStaticV4(conf.AccessKey, conf.SecretKey, "")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  3. cmd/warm-backend-azure.go

    	if opts.startOffset < 0 {
    		return nil, InvalidRange{}
    	}
    	resp, err := az.clnt.DownloadStream(ctx, az.Bucket, az.getDest(object), &azblob.DownloadStreamOptions{
    		Range: blob.HTTPRange{Offset: opts.startOffset, Count: opts.length},
    	})
    	if err != nil {
    		return nil, azureToObjectError(err, az.Bucket, az.getDest(object))
    	}
    
    	return resp.Body, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 7K bytes
    - Viewed (0)
  4. cmd/warm-backend-s3.go

    			return nil, s3.ToObjectError(err, object)
    		}
    	}
    	c := &minio.Core{Client: s3.client}
    	// Important to use core primitives here to pass range get options as is.
    	r, _, _, err := c.GetObject(ctx, s3.Bucket, s3.getDest(object), gopts)
    	if err != nil {
    		return nil, s3.ToObjectError(err, object)
    	}
    	return r, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  5. cmd/iam.go

    	if err != nil {
    		return nil, err
    	}
    
    	pdata, err := json.Marshal(d.Policy)
    	if err != nil {
    		return nil, err
    	}
    
    	return &madmin.PolicyInfo{
    		PolicyName: policyName,
    		Policy:     pdata,
    		CreateDate: d.CreateDate,
    		UpdateDate: d.UpdateDate,
    	}, nil
    }
    
    // ListPolicies - lists all canned policies.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  6. cmd/erasure-object.go

    		readQuorum, _, err := objectQuorumFromMeta(ctx, metaArr, errs, er.defaultParityCount)
    		if err != nil {
    			return FileInfo{}, nil, nil, time.Time{}, "", err
    		}
    		if err := reduceReadQuorumErrs(ctx, errs, objectOpIgnoredErrs, readQuorum); err != nil {
    			return FileInfo{}, nil, nil, time.Time{}, "", err
    		}
    		onlineDisks, modTime, etag := listOnlineDisks(disks, metaArr, errs, readQuorum)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  7. cmd/warm-backend.go

    	case madmin.MinIO:
    		d, err = newWarmBackendMinIO(*tier.MinIO, tier.Name)
    	default:
    		return nil, errTierTypeUnsupported
    	}
    	if err != nil {
    		tierLogIf(ctx, err)
    		return nil, errTierInvalidConfig
    	}
    
    	if probe {
    		if err = checkWarmBackend(ctx, d); err != nil {
    			return nil, err
    		}
    	}
    
    	return d, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  8. cmd/erasure-metadata.go

    	mErrs := g.Wait()
    
    	err := reduceWriteQuorumErrs(ctx, mErrs, objectOpIgnoredErrs, quorum)
    	if err != nil && revert {
    		ng := errgroup.WithNErrs(len(disks))
    		for index := range disks {
    			if mErrs[index] != nil {
    				continue
    			}
    			index := index
    			ng.Go(func() error {
    				if disks[index] == nil {
    					return errDiskNotFound
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  9. cmd/erasure-healing-common.go

    				} else {
    					onlineDisks[index] = nil
    				}
    			}
    			return onlineDisks, modTime, etag
    		}
    	}
    
    	// Create a new online disks slice, which have common uuid.
    	for index, t := range modTimes {
    		if partsMetadata[index].IsValid() && t.Equal(modTime) {
    			onlineDisks[index] = disks[index]
    		} else {
    			onlineDisks[index] = nil
    		}
    	}
    
    	return onlineDisks, modTime, ""
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  10. cmd/api-response.go

    	if s == nil {
    		return nil
    	}
    
    	if len(s.Items) == 0 {
    		return nil
    	}
    
    	if err := e.EncodeToken(start); err != nil {
    		return err
    	}
    
    	for _, item := range s.Items {
    		if err := e.Encode(xmlKeyEntry{
    			XMLName: xxml.Name{Local: item.Key},
    			Value:   item.Value,
    		}); err != nil {
    			return err
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 19:27:06 UTC 2024
    - 33.4K bytes
    - Viewed (0)
Back to top