- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 40 for StorageAPI (0.24 sec)
-
cmd/erasure-object.go
return objInfo, wquorum, nil } // Similar to rename but renames data from srcEntry to dstEntry at dataDir func renameData(ctx context.Context, disks []StorageAPI, srcBucket, srcEntry string, metadata []FileInfo, dstBucket, dstEntry string, writeQuorum int) ([]StorageAPI, []byte, string, error) { g := errgroup.WithNErrs(len(disks)) fvID := mustGetUUID() for index := range disks { metadata[index].SetTierFreeVersionID(fvID)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/xl-storage_windows_test.go
} dir := t.TempDir() // Instantiate posix object to manage a disk fs, err := newLocalXLStorage(dir) if err != nil { t.Fatal(err) } // Create volume to use in conjunction with other StorageAPI's file API(s) err = fs.MakeVol(context.Background(), "voldir") if err != nil { t.Fatal(err) } for i, test := range testCases { t.Run(fmt.Sprint(i), func(t *testing.T) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Nov 29 06:35:16 GMT 2023 - 2.8K bytes - Viewed (0) -
cmd/storage-interface.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "io" "time" "github.com/minio/madmin-go/v3" ) // StorageAPI interface. type StorageAPI interface { // Stringified version of disk. String() string // Storage operations. // Returns true if disk is online and its valid i.e valid format.json.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.9K bytes - Viewed (0) -
cmd/erasure-multipart.go
continue } wg.Add(1) go func(disk StorageAPI) { defer wg.Done() disk.Delete(ctx, bucket, prefix, DeleteOptions{ Recursive: true, Immediate: false, }) }(disk) } wg.Wait() } // Remove the old multipart uploads on the given disk. func (er erasureObjects) cleanupStaleUploadsOnDisk(ctx context.Context, disk StorageAPI, expiry time.Duration) { drivePath := disk.Endpoint().Path
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cmd/erasure-sets.go
continue } diskMap[disk.Endpoint()] = disk } } return diskMap } // Initializes a new StorageAPI from the endpoint argument, returns // StorageAPI and also `format` which exists on the disk. func connectEndpoint(endpoint Endpoint) (StorageAPI, *formatErasureV3, error) { disk, err := newStorageAPI(endpoint, storageOpts{ cleanUp: false, healthCheck: false, })
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5) -
cmd/peer-s3-server.go
buckets = append(buckets, BucketInfo{ Name: v.Name, Deleted: v.Created, }) } } return buckets, nil } func cloneDrives(drives []StorageAPI) []StorageAPI { newDrives := make([]StorageAPI, len(drives)) copy(newDrives, drives) return newDrives } func getBucketInfoLocal(ctx context.Context, bucket string, opts BucketOptions) (BucketInfo, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 8.4K bytes - Viewed (0) -
cmd/bitrot.go
return } func newBitrotWriter(disk StorageAPI, origvolume, volume, filePath string, length int64, algo BitrotAlgorithm, shardSize int64) io.Writer { if algo == HighwayHash256S { return newStreamingBitrotWriter(disk, origvolume, volume, filePath, length, algo, shardSize) } return newWholeBitrotWriter(disk, volume, filePath, algo, shardSize) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.6K bytes - Viewed (0) -
cmd/erasure-metadata-utils_test.go
// Tests caclculating disk count. func TestDiskCount(t *testing.T) { testCases := []struct { disks []StorageAPI diskCount int }{ // Test case - 1 { disks: []StorageAPI{&xlStorage{}, &xlStorage{}, &xlStorage{}, &xlStorage{}}, diskCount: 4, }, // Test case - 2 { disks: []StorageAPI{nil, &xlStorage{}, &xlStorage{}, &xlStorage{}}, diskCount: 3, }, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/bitrot-streaming.go
// Similar to CloseWithError on pipes we always return nil. return nil }} } // Returns streaming bitrot writer implementation. func newStreamingBitrotWriter(disk StorageAPI, origvolume, volume, filePath string, length int64, algo BitrotAlgorithm, shardSize int64) io.Writer { r, w := io.Pipe() h := algo.New() bw := &streamingBitrotWriter{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/object-api-common.go
type storageOpts struct { cleanUp bool healthCheck bool } // Depending on the disk type network or local, initialize storage API. func newStorageAPI(endpoint Endpoint, opts storageOpts) (storage StorageAPI, err error) { if endpoint.IsLocal { storage, err := newXLStorage(endpoint, opts.cleanUp) if err != nil { return nil, err } return newXLStorageDiskIDCheck(storage, opts.healthCheck), nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 2.1K bytes - Viewed (0)