Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for unfiltered (0.35 sec)

  1. cmd/bucket-targets.go

    	m := make(map[string]epHealth, len(sys.hc))
    	for k, v := range sys.hc {
    		m[k] = v
    	}
    	return m
    }
    
    // ListTargets lists bucket targets across tenant or for individual bucket, and returns
    // results filtered by arnType
    func (sys *BucketTargetSys) ListTargets(ctx context.Context, bucket, arnType string) (targets []madmin.BucketTarget) {
    	h := sys.healthStats()
    
    	if bucket != "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  2. cmd/consolelogger.go

    		if p != nil {
    			lg, ok := p.(log.Info)
    			if ok && lg.SendLog(node, logKind) {
    				lastN[cnt%last] = lg
    				cnt++
    			}
    		}
    	})
    	sys.RUnlock()
    	// send last n console log messages in order filtered by node
    	if cnt > 0 {
    		for i := 0; i < last; i++ {
    			entry := lastN[(cnt+i)%last]
    			if (entry == log.Info{}) {
    				continue
    			}
    			select {
    			case subCh <- entry:
    			case <-doneCh:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  3. cmd/batch-expire.go

    	)
    	for result := range results {
    		// Apply filter to find the matching rule to apply expiry
    		// actions accordingly.
    		// nolint:gocritic
    		if result.IsLatest {
    			// send down filtered entries to be deleted using
    			// DeleteObjects method
    			if len(toDel) > 10 { // batch up to 10 objects/versions to be expired simultaneously.
    				xfer := make([]expireObjInfo, len(toDel))
    				copy(xfer, toDel)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 21K bytes
    - Viewed (1)
  4. cmd/object-api-utils.go

    	if metadata[xhttp.AmzStorageClass] == storageclass.STANDARD {
    		delete(metadata, xhttp.AmzStorageClass)
    	}
    	return metadata
    }
    
    // cleanMetadataKeys takes keyNames to be filtered
    // and returns a new map with all the entries with keyNames removed.
    func cleanMetadataKeys(metadata map[string]string, keyNames ...string) map[string]string {
    	newMeta := make(map[string]string, len(metadata))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
  5. cmd/metacache-walk.go

    			}
    			// Skip all other files.
    		}
    
    		// Process in sort order.
    		sort.Strings(entries)
    		dirStack := make([]string, 0, 5)
    		prefix = "" // Remove prefix after first level as we have already filtered the list.
    		if len(forward) > 0 {
    			// Conservative forwarding. Entries may be either objects or prefixes.
    			for i, entry := range entries {
    				if entry >= forward || strings.HasPrefix(forward, entry) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  6. internal/bucket/lifecycle/lifecycle.go

    		for _, otherRule := range otherRules {
    			if lc.Rules[i].ID == otherRule.ID {
    				return errLifecycleDuplicateID
    			}
    		}
    	}
    	return nil
    }
    
    // FilterRules returns the rules filtered by the status, prefix and tags
    func (lc Lifecycle) FilterRules(obj ObjectOpts) []Rule {
    	if obj.Name == "" {
    		return nil
    	}
    	var rules []Rule
    	for _, rule := range lc.Rules {
    		if rule.Status == Disabled {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 17.5K bytes
    - Viewed (0)
  7. internal/bucket/replication/replication_test.go

    		}
    		for i := range got {
    			if got[i].Destination.ARN != tc.ExpectedRules[i].Destination.ARN || got[i].Priority != tc.ExpectedRules[i].Priority {
    				t.Fatalf("Expected order of filtered rules to be identical: `%v`, got: `%v`", tc.ExpectedRules, got)
    			}
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 32.5K bytes
    - Viewed (0)
  8. cmd/bucket-handlers.go

    				IsOwner:         owner,
    				ObjectName:      "",
    				Claims:          cred.Claims,
    			}) {
    				bucketsInfo[n] = bucketInfo
    				n++
    			}
    		}
    		bucketsInfo = bucketsInfo[:n]
    		// No buckets can be filtered return access denied error.
    		if len(bucketsInfo) == 0 {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    			return
    		}
    	}
    
    	// Generate response.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
Back to top