- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for ruleData (0.13 sec)
-
pkg/proxy/iptables/proxier_test.go
func parseIPTablesData(ruleData string) (map[string][]string, error) { // Split ruleData at the "COMMIT" lines; given valid input, this will result in // one element for each table plus an extra empty element (since the ruleData // should end with a "COMMIT" line). rawTables := strings.Split(strings.TrimPrefix(ruleData, "\n"), "COMMIT\n") nTables := len(rawTables) - 1
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 249.9K bytes - Viewed (0) -
pkg/proxy/nftables/helpers_test.go
rule = "" } } } return false } // tracePacket determines what would happen to a packet with the given sourceIP, destIP, // and destPort, given the indicated iptables ruleData. nodeIPs are the local node IPs (for // rules matching "local"). (The protocol value should be lowercase as in nftables // rules, not uppercase as in corev1.) //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 09:57:47 UTC 2024 - 48.5K bytes - Viewed (0) -
cmd/site-replication.go
// copy the non transition details of the rule ruleData, err := xml.Marshal(rule.CloneNonTransition()) if err != nil { return info, errSRBackendIssue(err) } allRules[rule.ID] = madmin.ILMExpiryRule{ILMRule: string(ruleData), Bucket: bucket, UpdatedAt: updatedAt} } } } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/rule.go
} func matchPolicyRuleNonResourceURL(policyRuleRequestURLs []string, requestPath string) bool { for _, rulePath := range policyRuleRequestURLs { if rulePath == flowcontrol.NonResourceAll || rulePath == requestPath { return true } rulePrefix := strings.TrimSuffix(rulePath, "*") if !strings.HasSuffix(rulePrefix, "/") { rulePrefix = rulePrefix + "/" }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/audit/validation/validation.go
var allErrs field.ErrorList allErrs = append(allErrs, validateOmitStages(policy.OmitStages, field.NewPath("omitStages"))...) rulePath := field.NewPath("rules") for i, rule := range policy.Rules { allErrs = append(allErrs, validatePolicyRule(rule, rulePath.Index(i))...) } return allErrs } func validatePolicyRule(rule audit.PolicyRule, fldPath *field.Path) field.ErrorList { var allErrs field.ErrorList
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 15 14:13:07 UTC 2019 - 4.6K bytes - Viewed (0) -
pkg/apis/batch/validation/validation.go
} if len(rule.OnPodConditions) > 0 { allErrs = append(allErrs, validatePodFailurePolicyRuleOnPodConditions(rule.OnPodConditions, rulePath.Child("onPodConditions"))...) } if rule.OnExitCodes != nil && len(rule.OnPodConditions) > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 16:43:24 UTC 2024 - 51.2K bytes - Viewed (0)