Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for conceal (0.15 sec)

  1. cmd/peer-rest-server.go

    // (only the config that are of concern to minio)
    func (s *peerRESTServer) GetSysConfigHandler(_ *grid.MSS) (*grid.JSON[madmin.SysConfig], *grid.RemoteErr) {
    	info := madmin.GetSysConfig(context.Background(), globalLocalNodeName)
    	return madminSysConfig.NewJSONWith(&info), nil
    }
    
    // GetSysServicesHandler - returns system services information.
    // (only the services that are of concern to minio)
    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)
  2. cmd/test-utils_test.go

    		setObjectLayer(newObjectLayerFn())
    		cancel()
    		removeRoots(fsDirs)
    	}
    }
    
    // ExecObjectLayerTestWithDirs - executes object layer tests.
    // Creates single node and Erasure ObjectLayer instance and runs test for both the layers.
    func ExecObjectLayerTestWithDirs(t TestErrHandler, objTest objTestTypeWithDirs) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	if localMetacacheMgr != nil {
    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)
  3. cmd/sts-handlers_test.go

    				runAllIAMSTSTests(testCase, &check{t, testCase.serverType})
    			},
    		)
    	}
    }
    
    func (s *TestSuiteIAM) TestSTSServiceAccountsWithUsername(c *check) {
    	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    	defer cancel()
    
    	bucket := "dillon-bucket"
    	err := s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{})
    	if err != nil {
    		c.Fatalf("bucket create error: %v", err)
    	}
    
    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)
  4. cmd/erasure-server-pool.go

    	// Updates must be closed before we return.
    	defer xioutil.SafeClose(updates)
    
    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    	var results []dataUsageCache
    	var firstErr error
    
    	allBuckets, err := z.ListBuckets(ctx, BucketOptions{})
    	if err != nil {
    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)
  5. cmd/iam.go

    	sys.iamRefreshInterval = iamRefreshInterval
    	// Initialize IAM store
    	sys.initStore(objAPI, etcdClient)
    	sys.Unlock()
    
    	retryCtx, cancel := context.WithCancel(ctx)
    
    	// Indicate to our routine to exit cleanly upon return.
    	defer cancel()
    
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	// Migrate storage format if needed.
    	for {
    		// Migrate IAM configuration, if necessary.
    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)
  6. cmd/erasure-object.go

    		Healing:  false,
    	}
    
    	mrfCheck := make(chan FileInfo)
    	defer xioutil.SafeClose(mrfCheck)
    
    	var rw sync.Mutex
    
    	// Ask for all disks first;
    	go func() {
    		ctx, cancel := context.WithCancel(ctx)
    		defer cancel()
    
    		wg := sync.WaitGroup{}
    		for i, disk := range disks {
    			if disk == nil {
    				done <- false
    				continue
    			}
    			if !disk.IsOnline() {
    				done <- false
    				continue
    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)
  7. cmd/batch-handlers.go

    	}
    	return nil
    }
    
    // delete canceler from the map, cancel job if requested
    func (j *BatchJobPool) canceler(jobID string, cancel bool) error {
    	if j == nil {
    		return errInvalidArgument
    	}
    	j.jmu.Lock()
    	defer j.jmu.Unlock()
    	if canceler, ok := j.jobCancelers[jobID]; ok {
    		if cancel {
    			canceler()
    		}
    	}
    	delete(j.jobCancelers, jobID)
    	return nil
    }
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
Back to top