Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 187 for ruleset (0.18 sec)

  1. cni/pkg/iptables/iptables.go

    	// Append our rules here
    	builder := cfg.appendHostRules(hostSNATIP, hostSNATIPV6)
    
    	log.Info("Adding host netnamespace iptables rules")
    
    	if err := cfg.executeCommands(builder); err != nil {
    		log.Errorf("failed to add host netnamespace iptables rules: %v", err)
    		return err
    	}
    	return nil
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue May 07 19:54:50 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  2. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 53.2K bytes
    - Viewed (0)
  3. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  4. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 8.8K bytes
    - Viewed (0)
  5. cmd/site-replication.go

    		} else {
    			rMap[id] = rl
    		}
    	}
    
    	var rules []lifecycle.Rule
    	for _, rule := range rMap {
    		rules = append(rules, rule)
    	}
    
    	// no rules, return
    	if len(rules) == 0 {
    		return []byte{}, nil
    	}
    
    	// get final list for write
    	finalLcCfg := lifecycle.Lifecycle{
    		XMLName:         xmlName,
    		Rules:           rules,
    		ExpiryUpdatedAt: &updatedAt,
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  6. cmd/bucket-replication.go

    			rd.Replicate = true
    			return
    		}
    		// For existing object reset - this condition is needed
    		rd.Replicate = tgtStatus == ""
    		return
    	}
    	if resetID == "" || resetBeforeDate.Equal(timeSentinel) { // no reset in progress
    		return
    	}
    
    	// if already replicated, return true if a new reset was requested.
    	splits := strings.SplitN(rs, ";", 2)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  7. istioctl/pkg/admin/istiodconfig_test.go

    	type args struct {
    		ctrzClient      *ControlzClient
    		reset           bool
    		outputLogLevel  string
    		stackTraceLevel string
    		outputFormat    string
    	}
    	tests := []struct {
    		name string
    		args args
    		want *istiodConfigLog
    	}{
    		{
    			name: "given --reset flag return reset command",
    			args: args{
    				ctrzClient:      ctrzClient,
    				reset:           true,
    				outputLogLevel:  "",
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 6.2K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/net.go

    	}
    	// pod is removed from the mesh, but is still running. remove iptables rules
    	log.Debugf("calling DeleteInpodRules.")
    	if err := s.netnsRunner(openNetns, func() error { return s.iptablesConfigurator.DeleteInpodRules() }); err != nil {
    		log.Errorf("failed to delete inpod rules %v", err)
    		return fmt.Errorf("failed to delete inpod rules %w", err)
    	}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
  9. cmd/batch-expire.go

    			}
    		}
    		return err
    	}
    
    	if len(r.Rules) > maxBatchRules {
    		return batchExpireJobError{
    			Code:           "InvalidArgument",
    			Description:    "Too many rules. Batch expire job can't have more than 100 rules",
    			HTTPStatusCode: http.StatusBadRequest,
    		}
    	}
    
    	for _, rule := range r.Rules {
    		if err := rule.Validate(); err != nil {
    			return batchExpireJobError{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 21K bytes
    - Viewed (1)
  10. cni/pkg/nodeagent/server.go

    	}
    
    	// Create hostprobe rules now, in the host netns
    	// Later we will reuse this same configurator inside the pod netns for adding other rules
    	iptablesConfigurator.DeleteHostRules()
    
    	if err := iptablesConfigurator.CreateHostRulesForHealthChecks(&HostProbeSNATIP, &HostProbeSNATIPV6); err != nil {
    		return nil, fmt.Errorf("error initializing the host rules for health checks: %w", err)
    	}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
Back to top