Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 102 for rules (0.15 sec)

  1. internal/event/rules.go

    		rulesCopy[pattern] = targetIDSet.Clone()
    	}
    
    	return rulesCopy
    }
    
    // Union - returns union with given rules as new rules.
    func (rules Rules) Union(rules2 Rules) Rules {
    	nrules := rules.Clone()
    
    	for pattern, targetIDSet := range rules2 {
    		nrules[pattern] = nrules[pattern].Union(targetIDSet)
    	}
    
    	return nrules
    }
    
    // Difference - returns difference with given rules as new rules.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  2. internal/event/rules_test.go

    	rulesCase2 := make(Rules)
    	rules2Case2 := make(Rules)
    	rules2Case2.Add(NewPattern("*", ""), TargetID{"1", "webhook"})
    	expectedResultCase2 := make(Rules)
    	expectedResultCase2.Add(NewPattern("*", ""), TargetID{"1", "webhook"})
    
    	rulesCase3 := make(Rules)
    	rulesCase3.Add(NewPattern("", "*"), TargetID{"1", "webhook"})
    	rules2Case3 := make(Rules)
    	expectedResultCase3 := make(Rules)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 8.8K bytes
    - Viewed (0)
  3. internal/bucket/replication/replication.go

    			continue
    		}
    		if rule.Filter.TestTags(obj.UserTags) {
    			rules = append(rules, rule)
    		}
    	}
    	sort.Slice(rules, func(i, j int) bool {
    		return rules[i].Priority > rules[j].Priority && rules[i].Destination.String() == rules[j].Destination.String()
    	})
    
    	return rules
    }
    
    // GetDestination returns destination bucket and storage class.
    func (c Config) GetDestination() Destination {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  4. internal/bucket/lifecycle/lifecycle.go

    	}
    	var rules []Rule
    	for _, rule := range lc.Rules {
    		if rule.Status == Disabled {
    			continue
    		}
    		if !strings.HasPrefix(obj.Name, rule.GetPrefix()) {
    			continue
    		}
    		if !obj.DeleteMarker && !rule.Filter.TestTags(obj.UserTags) {
    			continue
    		}
    		if !obj.DeleteMarker && !rule.Filter.BySize(obj.Size) {
    			continue
    		}
    		rules = append(rules, rule)
    	}
    	return rules
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 09 06:41:22 GMT 2024
    - 17K bytes
    - Viewed (0)
  5. cmd/batch-expire_gen.go

    				return
    			}
    		case "Rules":
    			var zb0002 uint32
    			zb0002, err = dc.ReadArrayHeader()
    			if err != nil {
    				err = msgp.WrapError(err, "Rules")
    				return
    			}
    			if cap(z.Rules) >= int(zb0002) {
    				z.Rules = (z.Rules)[:zb0002]
    			} else {
    				z.Rules = make([]BatchJobExpireFilter, zb0002)
    			}
    			for za0001 := range z.Rules {
    				err = z.Rules[za0001].DecodeMsg(dc)
    				if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Dec 02 10:51:33 GMT 2023
    - 19.8K bytes
    - Viewed (0)
  6. cni/pkg/iptables/iptables_linux.go

    		inpodMarkRule.Mark = InpodTProxyMark
    		inpodMarkRule.Mask = InpodTProxyMask
    		inpodMarkRule.Priority = 32764
    		rules = append(rules, inpodMarkRule)
    	}
    
    	for _, rule := range rules {
    		log.Debugf("Iterating netlink rule : %+v", rule)
    		if err := f(rule); err != nil {
    			return fmt.Errorf("failed to configure netlink rule: %w", err)
    		}
    	}
    
    	return nil
    }
    
    func AddLoopbackRoutes(cfg *Config) error {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.3K bytes
    - Viewed (0)
  7. internal/bucket/lifecycle/lifecycle_test.go

    					rules[5],
    				},
    			},
    			opts: ObjectOpts{
    				IsLatest: true,
    				UserTags: "key1=val1",
    				Name:     "obj-1",
    				Size:     1*humanize.MiByte - 1,
    			},
    			hasRules: true,
    		},
    		{ // PUT version with size based filters
    			lc: Lifecycle{
    				Rules: []Rule{
    					rules[1],
    					rules[2],
    					rules[3],
    					rules[4],
    					rules[5],
    				},
    			},
    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)
  8. internal/bucket/replication/replication_test.go

    		{ObjectOpts{Name: "xyz/c3test", DeleteMarker: true, OpType: DeleteReplicationType}, cfgs[2], true},                                      // 24. matches rule 2 - DeleteMarker replication allowed by rule
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 32.5K bytes
    - Viewed (0)
  9. cmd/bucket-lifecycle-handlers.go

    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Create a map of updated set of rules in request
    	updatedRules := make(map[string]lifecycle.Rule, len(bucketLifecycle.Rules))
    	for _, rule := range bucketLifecycle.Rules {
    		updatedRules[rule.ID] = rule
    	}
    
    	// Get list of rules for the bucket from disk
    	meta, err := globalBucketMetadataSys.GetConfigFromDisk(ctx, bucket)
    	if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Nov 21 17:48:06 GMT 2023
    - 7K bytes
    - Viewed (0)
  10. cni/pkg/plugin/plugin_dryrun_test.go

    			if err != nil {
    				log.Fatalf("Cannot read generated IPTables rule file: %v", err)
    			}
    			generatedRules := getRules(generated)
    
    			refreshGoldens(t, tt.golden, generatedRules)
    
    			// Compare generated iptables rule with golden files.
    			golden, err := os.ReadFile(tt.golden)
    			if err != nil {
    				log.Fatalf("Cannot read golden rule file: %v", err)
    			}
    			goldenRules := getRules(golden)
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 8.4K bytes
    - Viewed (0)
Back to top