Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 39 of 39 for StorageAPI (0.2 sec)

  1. cmd/object-api-interface.go

    	CompleteMultipartUpload(ctx context.Context, bucket, object, uploadID string, uploadedParts []CompletePart, opts ObjectOptions) (objInfo ObjectInfo, err error)
    
    	GetDisks(poolIdx, setIdx int) ([]StorageAPI, error) // return the disks belonging to pool and set.
    	SetDriveCounts() []int                              // list of erasure stripe size for each pool in order.
    
    	// Healing operations.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    	case strings.Contains(err.Error(), "server closed idle connection"):
    		return true
    	}
    
    	return false
    }
    
    // Converts network error to storageErr. This function is
    // written so that the storageAPI errors are consistent
    // across network disks.
    func toStorageErr(err error) error {
    	if err == nil {
    		return nil
    	}
    
    	if isNetworkError(err) {
    		return errDiskNotFound
    	}
    
    	switch err.Error() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  3. cmd/data-scanner.go

    	scanMode              madmin.HealScanMode
    
    	weSleep    func() bool
    	shouldHeal func() bool
    
    	disks       []StorageAPI
    	disksQuorum int
    
    	// If set updates will be sent regularly to this channel.
    	// Will not be closed when returned.
    	updates    chan<- dataUsageEntry
    	lastUpdate time.Time
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    func initObjectLayer(ctx context.Context, endpointServerPools EndpointServerPools) (ObjectLayer, []StorageAPI, error) {
    	objLayer, err := newTestObjectLayer(ctx, endpointServerPools)
    	if err != nil {
    		return nil, nil, err
    	}
    
    	var formattedDisks []StorageAPI
    	// Should use the object layer tests for validating cache.
    	if z, ok := objLayer.(*erasureServerPools); ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  5. cmd/object-api-utils.go

    	}
    }
    
    // getDiskInfos returns the disk information for the provided disks.
    // If a disk is nil or an error is returned the result will be nil as well.
    func getDiskInfos(ctx context.Context, disks ...StorageAPI) []*DiskInfo {
    	res := make([]*DiskInfo, len(disks))
    	opts := DiskInfoOptions{}
    	for i, disk := range disks {
    		if disk == nil {
    			continue
    		}
    		if di, err := disk.DiskInfo(ctx, opts); err == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    	}
    
    	if runtime.GOOS == "windows" {
    		// Volname shouldn't have reserved characters in Windows.
    		return !strings.ContainsAny(volname, `\:*?\"<>|`)
    	}
    
    	return true
    }
    
    // xlStorage - implements StorageAPI interface.
    type xlStorage struct {
    	// Indicate of NSScanner is in progress in this disk
    	scanning int32
    
    	drivePath string
    	endpoint  Endpoint
    
    	globalSync bool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  7. cmd/object-api-multipart_test.go

    	z := obj.(*erasureServerPools)
    	er := z.serverPools[0].sets[0]
    
    	erasureDisks := er.getDisks()
    	ridx := rand.Intn(len(erasureDisks))
    
    	z.serverPools[0].erasureDisksMu.Lock()
    	er.getDisks = func() []StorageAPI {
    		erasureDisks[ridx] = newNaughtyDisk(erasureDisks[ridx], nil, errFaultyDisk)
    		return erasureDisks
    	}
    	z.serverPools[0].erasureDisksMu.Unlock()
    
    	uploadIDs = append(uploadIDs, res.UploadID)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 88.8K bytes
    - Viewed (0)
  8. cmd/xl-storage_test.go

    		}
    	}
    
    	// TestXLStorage for permission denied.
    	if runtime.GOOS != globalWindowsOSName {
    		permDeniedDir := createPermDeniedFile(t)
    
    		var xlStoragePermStorage StorageAPI
    		// Initialize xlStorage storage layer for permission denied error.
    		_, err = newLocalXLStorage(permDeniedDir)
    		if err != nil && err != errDiskAccessDenied {
    			t.Fatalf("Unable to initialize xlStorage, %s", err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.9.md

        * --alpha-endpoint-reconciler-type=(master-count, lease, none) (default
        * "master-count"). The original reconciler is 'master-count'. The 'lease'
        * reconciler uses the storageapi and a TTL to keep alive an endpoint within the
        * `kube-apiserver-endpoint` storage namespace. The 'none' reconciler is a noop
        * reconciler that does not do anything. This is useful for self-hosted
        * environments.
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Nov 16 10:46:27 UTC 2021
    - 313.7K bytes
    - Viewed (0)
Back to top