Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for rulesets (0.25 sec)

  1. cmd/admin-handlers_test.go

    	return &adminErasureTestBed{
    		erasureDirs: erasureDirs,
    		objLayer:    objLayer,
    		router:      adminRouter,
    		done:        cancel,
    	}, nil
    }
    
    // TearDown - method that resets the test bed for subsequent unit
    // tests to start afresh.
    func (atb *adminErasureTestBed) TearDown() {
    	atb.done()
    	removeRoots(atb.erasureDirs)
    	resetTestGlobals()
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  2. internal/bucket/lifecycle/lifecycle_test.go

    		t.Fatal(err)
    	}
    
    	ruleSet := make(map[string]struct{})
    	for _, rule := range lc.Rules {
    		ruleBytes, err := xml.Marshal(rule)
    		if err != nil {
    			t.Fatal(err)
    		}
    		ruleSet[string(ruleBytes)] = struct{}{}
    	}
    	for _, rule := range lc1.Rules {
    		ruleBytes, err := xml.Marshal(rule)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if _, ok := ruleSet[string(ruleBytes)]; !ok {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 09 06:41:22 GMT 2024
    - 45.6K bytes
    - Viewed (0)
  3. cmd/http-stats.go

    }
    
    func (st *HTTPStats) addRequestsInQueue(i int32) {
    	atomic.AddInt32(&st.s3RequestsInQueue, i)
    }
    
    func (st *HTTPStats) incS3RequestsIncoming() {
    	// Golang automatically resets to zero if this overflows
    	atomic.AddUint64(&st.s3RequestsIncoming, 1)
    }
    
    // Converts http stats into struct to be sent back to the client.
    func (st *HTTPStats) toServerHTTPStats(toLowerKeys bool) ServerHTTPStats {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 11.4K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    			if !v.hasEnded() {
    				v.stop()
    			}
    		}
    		globalBackgroundHealState.Unlock()
    	}
    }
    
    // sets globalIAMSys to `nil`.
    func resetGlobalIAMSys() {
    	globalIAMSys = nil
    }
    
    // Resets all the globals used modified in tests.
    // Resetting ensures that the changes made to globals by one test doesn't affect others.
    func resetTestGlobals() {
    	// set globalObjectAPI to `nil`.
    	resetGlobalObjectAPI()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:06:57 GMT 2024
    - 75.7K bytes
    - Viewed (0)
  5. internal/store/batch.go

    	if b.isFull() {
    		return ErrBatchFull
    	}
    
    	if _, ok := b.items[key]; !ok {
    		b.keys = append(b.keys, key)
    	}
    	b.items[key] = item
    
    	return nil
    }
    
    // GetAll fetches the items and resets the batch
    // Returned items are not referenced by the batch
    func (b *Batch[K, T]) GetAll() (orderedKeys []K, orderedItems []T, err error) {
    	b.Lock()
    	defer b.Unlock()
    
    	orderedKeys = append([]K(nil), b.keys...)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 2.5K bytes
    - Viewed (0)
Back to top