Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for filtered (0.2 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

    	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:
    				return nil
    			}
    		}
    	}
    	return sys.pubsub.Subscribe(madmin.LogMaskAll, subCh, doneCh, filter)
    }
    
    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. internal/bucket/lifecycle/lifecycle.go

    }
    
    // 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 {
    			continue
    		}
    		if !strings.HasPrefix(obj.Name, rule.GetPrefix()) {
    			continue
    		}
    		if !rule.Filter.TestTags(obj.UserTags) {
    			continue
    		}
    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)
  4. cmd/batch-handlers.go

    	hasTags := len(r.Flags.Filter.Tags) != 0
    	isMetadata := len(r.Flags.Filter.Metadata) != 0
    	isStorageClassOnly := len(r.Flags.Filter.Metadata) == 1 && strings.EqualFold(r.Flags.Filter.Metadata[0].Key, xhttp.AmzStorageClass)
    
    	skip := func(oi ObjectInfo) (ok bool) {
    		if r.Flags.Filter.OlderThan > 0 && time.Since(oi.ModTime) < r.Flags.Filter.OlderThan {
    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)
  5. cmd/metacache-set.go

    		// Sanity check, should not happen.
    		o.FilterPrefix = ""
    	}
    }
    
    // filter will apply the options and return the number of objects requested by the limit.
    // Will return io.EOF if there are no more entries with the same filter.
    // The last entry can be used as a marker to resume the listing.
    func (r *metacacheReader) filter(o listPathOptions) (entries metaCacheEntriesSorted, err error) {
    	// Forward to prefix, if any
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  6. cmd/object-api-interface.go

    	NoAuditLog     bool // Only set for decom, rebalance, to avoid double audits.
    }
    
    // WalkOptions provides filtering, marker and other Walk() specific options.
    type WalkOptions struct {
    	Filter       func(info FileInfo) bool // return WalkFilter returns 'true/false'
    	Marker       string                   // set to skip until this object
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  7. cmd/sts-handlers.go

    	// with multiple peer certificates. However, we can only accept
    	// a single client certificate. Otherwise, the certificate to
    	// policy mapping would be ambiguous.
    	// However, we can filter all CA certificates and only check
    	// whether they client has sent exactly one (non-CA) leaf certificate.
    	peerCertificates := make([]*x509.Certificate, 0, len(r.TLS.PeerCertificates))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 21:31:13 GMT 2024
    - 34.7K bytes
    - Viewed (2)
  8. internal/bucket/lifecycle/lifecycle_test.go

    			{
    				Status:     "Enabled",
    				Filter:     Filter{Prefix: Prefix{string: "prefix-1", set: true}},
    				Expiration: Expiration{Days: ExpirationDays(3)},
    			},
    			{
    				Status:     "Enabled",
    				Filter:     Filter{Prefix: Prefix{string: "prefix-1", set: true}},
    				Expiration: Expiration{Date: midnightTS},
    			},
    			{
    				Status:                      "Enabled",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 53.2K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/rule_test.go

    				<Expiration>
    					<Days>365</Days>
    				</Expiration>
                                <Status>Enabled</Status>
    	                    </Rule>`,
    			expectedErr: errXMLNotWellFormed,
    		},
    		{
    			inputXML: `<Rule>
    				<ID>Rule with a tag and DelMarkerExpiration</ID>
    				<Filter><Tag><Key>k1</Key><Value>v1</Value></Tag></Filter>
    				<DelMarkerExpiration>
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  10. cmd/data-scanner.go

    //
    // The leaves are "compacted" based on a number of properties.
    // A compacted leaf contains the totals of all files beneath it.
    //
    // A leaf is only scanned once every dataUsageUpdateDirCycles,
    // rarer if the bloom filter for the path is clean and no lifecycles are applied.
    // Skipped leaves have their totals transferred from the previous cycle.
    //
    // When selected there is a one in healObjectSelectProb that any object will be chosen for heal scan.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 47.6K bytes
    - Viewed (0)
Back to top