- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 50 for storageapi (0.19 sec)
-
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) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 7.6K 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
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
healingTrackerFilename = ".healing.bin" ) //go:generate msgp -file $GOFILE -unexported // healingTracker is used to persist healing information during a heal. type healingTracker struct { disk StorageAPI `msg:"-"` mu *sync.RWMutex `msg:"-"` ID string PoolIndex int SetIndex int DiskIndex int Path string Endpoint string Started time.Time LastUpdate time.Time
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 15:12:32 UTC 2024 - 14.5K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/node_authorizer.go
resourceClaimResource = resourceapi.Resource("resourceclaims") vaResource = storageapi.Resource("volumeattachments") svcAcctResource = api.Resource("serviceaccounts") leaseResource = coordapi.Resource("leases") csiNodeResource = storageapi.Resource("csinodes") )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 16K bytes - Viewed (0) -
cmd/naughty-disk_test.go
type naughtyDisk struct { // The real disk disk StorageAPI // Programmed errors: API call number => error to return errors map[int]error // The error to return when no error value is programmed defaultErr error // The current API call number callNR int // Data protection mu sync.Mutex } func newNaughtyDisk(d StorageAPI, errs map[int]error, defaultErr error) *naughtyDisk {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 9.4K bytes - Viewed (0) -
cmd/prepare-storage.go
// time. additionally make sure to close all the disks used in this attempt. func connectLoadInitFormats(verboseLogging bool, firstDisk bool, storageDisks []StorageAPI, endpoints Endpoints, poolCount, setCount, setDriveCount int, deploymentID string) (format *formatErasureV3, err error) { // Attempt to load all `format.json` from all disks.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun May 19 08:06:49 UTC 2024 - 11.1K bytes - Viewed (0) -
cmd/storage-rest-server.go
) func getStorageViaEndpoint(endpoint Endpoint) StorageAPI { globalLocalDrivesMu.RLock() defer globalLocalDrivesMu.RUnlock() if len(globalLocalSetDrives) == 0 { return globalLocalDrivesMap[endpoint.String()] } return globalLocalSetDrives[endpoint.PoolIdx][endpoint.SetIdx][endpoint.DiskIdx] } func (s *storageRESTServer) getStorage() StorageAPI { return getStorageViaEndpoint(s.endpoint) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 44.8K bytes - Viewed (0) -
cmd/globals.go
// List of local drives to this node, this is only set during server startup, // and is only mutated by HealFormat. Hold globalLocalDrivesMu to access. globalLocalDrives []StorageAPI globalLocalDrivesMap = make(map[string]StorageAPI) globalLocalDrivesMu sync.RWMutex globalDriveMonitoring = env.Get("_MINIO_DRIVE_ACTIVE_MONITORING", config.EnableOn) == config.EnableOn // Is MINIO_CI_CD set? globalIsCICD bool
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 16.4K bytes - Viewed (0) -
cmd/erasure-metadata.go
} // writeUniqueFileInfo - writes unique `xl.meta` content for each disk concurrently. func writeUniqueFileInfo(ctx context.Context, disks []StorageAPI, origbucket, bucket, prefix string, files []FileInfo, quorum int) ([]StorageAPI, error) { g := errgroup.WithNErrs(len(disks)) // Start writing `xl.meta` to all disks in parallel. for index := range disks { index := index g.Go(func() error {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.4K bytes - Viewed (0) -
cmd/erasure-heal_test.go
readers[i] = newBitrotReader(disk, nil, "testbucket", "testobject", shardFilesize, test.algorithm, bitrotWriterSum(writers[i]), erasure.ShardSize()) } // setup stale disks for the test case staleDisks := make([]StorageAPI, len(disks)) copy(staleDisks, disks) for j := 0; j < len(staleDisks); j++ { if j < test.offDisks { readers[j] = nil } else { staleDisks[j] = nil } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 7.9K bytes - Viewed (0)