Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 16 for ctx (0.02 seconds)

  1. cmd/bucket-handlers.go

    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrObjectLockConfigurationNotAllowed), r.URL)
    		} else {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		}
    		return
    	}
    
    	updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, objectLockConfig, configData)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  2. cmd/erasure-server-pool.go

    			return ListObjectsInfo{}, err
    		}
    		if contextCanceled(ctx) {
    			return ListObjectsInfo{}, ctx.Err()
    		}
    	}
    	return listFn(ctx, opts, maxKeys)
    }
    
    func (z *erasureServerPools) ListMultipartUploads(ctx context.Context, bucket, prefix, keyMarker, uploadIDMarker, delimiter string, maxUploads int) (ListMultipartsInfo, error) {
    	if err := checkListMultipartArgs(ctx, bucket, prefix, keyMarker, uploadIDMarker, delimiter); err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  3. cmd/iam.go

    	case <-ctx.Done():
    		return nil, ctx.Err()
    	}
    }
    
    // ListUsers - list all users.
    func (sys *IAMSys) ListUsers(ctx context.Context) (map[string]madmin.UserInfo, error) {
    	if !sys.Initialized() {
    		return nil, errServerNotInitialized
    	}
    	select {
    	case <-sys.configLoaded:
    		return sys.store.GetUsers(), nil
    	case <-ctx.Done():
    		return nil, ctx.Err()
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 76.5K bytes
    - Click Count (0)
  4. cmd/erasure-object.go

    	}
    	return false
    }
    
    func readAllXL(ctx context.Context, disks []StorageAPI, bucket, object string, readData, inclFreeVers bool) ([]FileInfo, []error) {
    	rawFileInfos, errs := readAllRawFileInfo(ctx, disks, bucket, object, readData)
    	return pickLatestQuorumFilesInfo(ctx, rawFileInfos, errs, bucket, object, readData, inclFreeVers)
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  5. cmd/xl-storage.go

    	for i, fiv := range versions {
    		if contextCanceled(ctx) {
    			errs[i] = ctx.Err()
    			continue
    		}
    		errs[i] = s.deleteVersions(ctx, volume, fiv.Name, fiv.Versions...)
    		diskHealthCheckOK(ctx, errs[i])
    	}
    
    	return errs
    }
    
    func (s *xlStorage) cleanupTrashImmediateCallers(ctx context.Context) {
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case entry := <-s.immediatePurge:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  6. cmd/iam-store.go

    	loadMappedPolicies(ctx context.Context, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy]) error
    	saveIAMConfig(ctx context.Context, item any, path string, opts ...options) error
    	loadIAMConfig(ctx context.Context, item any, path string) error
    	deleteIAMConfig(ctx context.Context, path string) error
    	savePolicyDoc(ctx context.Context, policyName string, p PolicyDoc) error
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 87.1K bytes
    - Click Count (0)
  7. cmd/admin-handlers-users.go

    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errIAMActionNotAllowed), r.URL)
    		return
    	}
    
    	if err := globalIAMSys.DeleteUser(ctx, accessKey, true); err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	replLogIf(ctx, globalSiteReplicationSys.IAMChangeHook(ctx, madmin.SRIAMItem{
    		Type: madmin.SRIAMItemIAMUser,
    		IAMUser: &madmin.SRIAMUser{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 90.6K bytes
    - Click Count (0)
  8. cmd/batch-handlers.go

    		default:
    			writeErrorResponseJSON(ctx, w, toAPIError(ctx, errors.New("job ID format unrecognized")), r.URL)
    			return
    		}
    	}
    
    	ri := &batchJobInfo{}
    	if err := ri.load(ctx, objectAPI, req); err != nil {
    		if !errors.Is(err, errNoSuchJob) {
    			batchLogIf(ctx, err)
    		}
    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 63.5K bytes
    - Click Count (1)
  9. cmd/test-utils_test.go

    }
    
    func prepareErasureSets32(ctx context.Context) (ObjectLayer, []string, error) {
    	return prepareErasure(ctx, 32)
    }
    
    func prepareErasure(ctx context.Context, nDisks int) (ObjectLayer, []string, error) {
    	fsDirs, err := getRandomDisks(nDisks)
    	if err != nil {
    		return nil, nil, err
    	}
    	obj, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, fsDirs...))
    	if err != nil {
    		removeRoots(fsDirs)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (0)
  10. cmd/admin-handlers-users_test.go

    	err = s.adm.RemoveUser(ctx, accessKey)
    	if err != nil {
    		c.Fatalf("user could not be deleted: %v", err)
    	}
    
    	err = s.adm.RemoveCannedPolicy(ctx, policy1)
    	if err != nil {
    		c.Fatalf("policy del err: %v", err)
    	}
    
    	err = s.adm.RemoveCannedPolicy(ctx, policy2)
    	if err != nil {
    		c.Fatalf("policy del err: %v", err)
    	}
    }
    
    func (s *TestSuiteIAM) TestPolicyCreate(c *check) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 50.6K bytes
    - Click Count (0)
Back to Top