- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for Sets (0.13 sec)
-
cmd/erasure-server-pool.go
// Return the disks belonging to the poolIdx, and setIdx. func (z *erasureServerPools) GetDisks(poolIdx, setIdx int) ([]StorageAPI, error) { if poolIdx < len(z.serverPools) && setIdx < len(z.serverPools[poolIdx].sets) { return z.serverPools[poolIdx].sets[setIdx].getDisks(), nil } return nil, fmt.Errorf("Matching pool %s, set %s not found", humanize.Ordinal(poolIdx+1), humanize.Ordinal(setIdx+1)) } // Return the count of disks in each pool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/test-utils_test.go
return nil, nil, err } // Wait up to 10 seconds for disks to come online. pools := obj.(*erasureServerPools) t := time.Now() for _, pool := range pools.serverPools { for _, sets := range pool.erasureDisks { for _, s := range sets { if !s.IsLocal() { for { if s.IsOnline() { break } time.Sleep(100 * time.Millisecond) if time.Since(t) > 10*time.Second {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/iam-store.go
if err != nil { return err } } else { bootstrapTraceMsg("loading policy documents") if err := store.loadPolicyDocs(ctx, newCache.iamPolicyDocsMap); err != nil { return err } // Sets default canned policies, if none are set. setDefaultCannedPolicies(newCache.iamPolicyDocsMap) if store.getUsersSysType() == MinIOUsersSysType { bootstrapTraceMsg("loading regular users")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/iam.go
if !sys.Initialized() { return nil, errServerNotInitialized } return sys.store.ListPolicyDocs(ctx, bucketName) } // SetPolicy - sets a new named policy. func (sys *IAMSys) SetPolicy(ctx context.Context, policyName string, p policy.Policy) (time.Time, error) { if !sys.Initialized() { return time.Time{}, errServerNotInitialized }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/sts-handlers_test.go
s.RestartIAMSuite(c) } // SetUpLDAPWithNonNormalizedBaseDN - expects to setup an LDAP test server using // the test LDAP container and canned data from // https://github.com/minio/minio-ldap-testing // // Sets up non-normalized base DN configuration for testing. func (s *TestSuiteIAM) SetUpLDAPWithNonNormalizedBaseDN(c *check, serverAddr string) { ctx, cancel := context.WithTimeout(context.Background(), testDefaultTimeout)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
if err != nil { // Failed to create NewMultipartUpload, abort. t.Fatalf("%s : %s", instanceType, err.Error()) } 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 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 77.1K bytes - Viewed (0) -
cmd/peer-rest-server.go
if err := storageServerRequestValidate(r); err != nil { s.writeErrorResponse(w, err) return false } return true } // GetBandwidth gets the bandwidth for the buckets requested. func (s *peerRESTServer) GetBandwidth(params *grid.URLValues) (*bandwidth.BucketBandwidthReport, *grid.RemoteErr) { buckets := params.Values().Get("buckets")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
tests/migrate_test.go
DB.Save(GetUser("joins-args-db", Config{Pets: 2})) if err := DB.Migrator().CreateView("invalid_users_pets", gorm.ViewOption{Query: nil}); err != gorm.ErrSubQueryRequired { t.Fatalf("no view should be created, got %v", err) } query := DB.Model(&User{}). Select("users.id as users_id, users.name as users_name, pets.id as pets_id, pets.name as pets_name").
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Mar 18 11:24:16 GMT 2024 - 56.2K bytes - Viewed (0) -
cmd/api-errors.go
func getAPIError(code APIErrorCode) APIError { if apiErr, ok := errorCodes[code]; ok { return apiErr } return errorCodes.ToAPIErr(ErrInternalError) } // getErrorResponse gets in standard error and resource value and // provides a encodable populated response values func getAPIErrorResponse(ctx context.Context, err APIError, resource, requestID, hostID string) APIErrorResponse {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (7) -
istioctl/pkg/describe/describe.go
"istio.io/istio/pkg/kube/inject" "istio.io/istio/pkg/kube/labels" "istio.io/istio/pkg/log" "istio.io/istio/pkg/maps" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/url" "istio.io/istio/pkg/util/sets" "istio.io/istio/pkg/wellknown" ) type myProtoValue struct { *structpb.Value } const ( k8sSuffix = ".svc." + constants.DefaultClusterLocalDomain printLevel0 = 0 printLevel1 = 3
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 50.4K bytes - Viewed (0)