- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 77 for diskfis (1.98 sec)
-
cmd/bucket-policy-handlers_test.go
t.Fatalf("want 1 ok, got %d", ok) } if errs != n-1 { t.Fatalf("want %d errors, got %d", n-1, errs) } } // Wrapper for calling Put Bucket Policy HTTP handler tests for both Erasure multiple disks and single node setup. func TestPutBucketPolicyHandler(t *testing.T) { ExecObjectLayerAPITest(ExecObjectLayerAPITestArgs{t: t, objAPITest: testPutBucketPolicyHandler, endpoints: []string{"PutBucketPolicy"}}) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 32.9K bytes - Viewed (0) -
cmd/metacache-entries.go
dst := make(metaCacheEntries, len(m)) copy(dst, m) return dst } type metadataResolutionParams struct { dirQuorum int // Number if disks needed for a directory to 'exist'. objQuorum int // Number of disks needed for an object to 'exist'. // An optimization request only an 'n' amount of versions from xl.meta // to avoid resolving all versions to figure out the latest 'version'
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 04:34:26 UTC 2024 - 24K bytes - Viewed (0) -
pkg/volume/portworx/portworx.go
volName string podUID types.UID // Unique id of the PD, used to find the disk resource in the provider. volumeID string // Utility interface that provides API calls to the provider to attach/detach disks. manager portworxManager // Mounter interface that provides system calls to mount the global path to the pod local path. mounter mount.Interface plugin *portworxVolumePlugin volume.MetricsProvider }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 13.6K bytes - Viewed (0) -
cmd/post-policy_test.go
t.Errorf("Test %s: Failed to stop post policy handler from writing to minioMetaBucket", instanceType) } } } } // Wrapper for calling TestPostPolicyBucketHandler tests for both Erasure multiple disks and single node setup. func TestPostPolicyBucketHandler(t *testing.T) { ExecObjectLayerTest(t, testPostPolicyBucketHandler) } // testPostPolicyBucketHandler - Tests validate post policy handler uploading objects.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 30.2K bytes - Viewed (0) -
cmd/globals.go
ShutdownTimeout time.Duration IdleTimeout time.Duration ReadHeaderTimeout time.Duration MaxIdleConnsPerHost int SendBufSize, RecvBufSize int CrossDomainXML string // The layout of disks as interpreted Layout disksLayout } var ( // Global user opts context globalServerCtxt serverCtxt // Indicates if the running minio server is distributed setup. globalIsDistErasure = false
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/bucket-lifecycle.go
// The restore operation could be in one of the following states, // - in progress (no content on MinIO's disks yet) // - completed // - completed but expired (again, no content on MinIO's disks) func (r restoreObjStatus) OnDisk() bool { if expiry, ok := r.Expiry(); ok && time.Now().UTC().Before(expiry) { // completed return true }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 33.3K bytes - Viewed (0) -
cmd/server-main.go
logger.Fatal(err, "invalid --logrorate-dir option") } }) // Always load ENV variables from files first. loadEnvVarsFromFiles() // Handle all server command args and build the disks layout bootstrapTrace("serverHandleCmdArgs", func() { err := buildServerCtxt(ctx, &globalServerCtxt) logger.FatalIf(err, "Unable to prepare the list of endpoints") serverHandleCmdArgs(globalServerCtxt) })
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 15:12:57 UTC 2024 - 34.5K bytes - Viewed (1) -
pkg/volume/fc/fc.go
type fcDisk struct { volName string podUID types.UID wwns []string lun string wwids []string plugin *fcPlugin // Utility interface that provides API calls to the provider to attach/detach disks. manager diskManager // io handler interface io ioHandler volume.MetricsNil } func (fc *fcDisk) GetPath() string { // safe to use PodVolumeDir now: volume teardown occurs before pod is cleaned up
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 17.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/non_csi.go
// GCE instances can have up to 16 PD volumes attached. defaultMaxGCEPDVolumes = 16 // defaultMaxAzureDiskVolumes defines the maximum number of PD Volumes for Azure. // Larger Azure VMs can actually have much more disks attached. // TODO We should determine the max based on VM size defaultMaxAzureDiskVolumes = 16 // ebsVolumeFilterType defines the filter name for ebsVolumeFilter. ebsVolumeFilterType = "EBS"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 30 23:00:56 UTC 2023 - 19.6K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
"k8s.io/kubernetes/test/utils/ktesting" ) const ( intreePDUniqueNamePrefix = "kubernetes.io/gce-pd/" csiPDUniqueNamePrefix = "kubernetes.io/csi/pd.csi.storage.gke.io^projects/UNSPECIFIED/zones/UNSPECIFIED/disks/" ) func createADC(t testing.TB, tCtx ktesting.TContext, fakeKubeClient *fake.Clientset, informerFactory informers.SharedInformerFactory, plugins []volume.VolumePlugin) *attachDetachController {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0)