- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 83 for ruleset (0.15 sec)
-
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) -
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) -
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) -
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) -
docs/debugging/pprofgoparser/main.go
f, err := os.Open(path) if err != nil { return nil, err } bf := bytes.Buffer{} save := func(s string) { bf.WriteString(s + "\n") } reset := func() { bf.Reset() } ret := make(map[time.Duration][]string) s := bufio.NewScanner(f) s.Split(bufio.ScanLines) var ( t time.Duration skip, record bool ) for s.Scan() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 06 11:43:16 GMT 2024 - 3.4K bytes - Viewed (0) -
cmd/local-locker_gen_test.go
if buf.Len() > m { t.Log("WARNING: TestEncodeDecodelocalLockMap Msgsize() is inaccurate") } vn := localLockMap{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v) err = msgp.NewReader(&buf).Skip() if err != nil { t.Error(err) } } func BenchmarkEncodelocalLockMap(b *testing.B) { v := localLockMap{} var buf bytes.Buffer
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 6.7K bytes - Viewed (0) -
internal/s3select/simdj/reader_amd64_test.go
} if !bytes.Equal(gotB.Bytes(), wantB.Bytes()) { t.Errorf("CSV output mismatch.\nwant: %s(%x)\ngot: %s(%x)", wantB.String(), wantB.Bytes(), gotB.String(), gotB.Bytes()) } gotB.Reset() wantB.Reset() err = rec.WriteJSON(&gotB) if err != nil { t.Error(err) } err = want.WriteJSON(&wantB) if err != nil { t.Error(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 3.9K bytes - Viewed (0) -
cmd/tier-journal_gen_test.go
m := v.Msgsize() if buf.Len() > m { t.Log("WARNING: TestEncodeDecodejentry Msgsize() is inaccurate") } vn := jentry{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v) err = msgp.NewReader(&buf).Skip() if err != nil { t.Error(err) } } func BenchmarkEncodejentry(b *testing.B) { v := jentry{} var buf bytes.Buffer msgp.Encode(&buf, &v)
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jun 03 21:26:51 GMT 2021 - 4.3K bytes - Viewed (0) -
internal/dsync/lock-args_gen_test.go
m := v.Msgsize() if buf.Len() > m { t.Log("WARNING: TestEncodeDecodeLockArgs Msgsize() is inaccurate") } vn := LockArgs{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v) err = msgp.NewReader(&buf).Skip() if err != nil { t.Error(err) } } func BenchmarkEncodeLockArgs(b *testing.B) { v := LockArgs{} var buf bytes.Buffer
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 4.4K bytes - Viewed (0) -
internal/s3select/csv/record.go
func (r *Record) Set(name string, value *sql.Value) (sql.Record, error) { r.columnNames = append(r.columnNames, name) r.csvRecord = append(r.csvRecord, value.CSVString()) return r, nil } // Reset data in record. func (r *Record) Reset() { if len(r.columnNames) > 0 { r.columnNames = r.columnNames[:0] } if len(r.csvRecord) > 0 { r.csvRecord = r.csvRecord[:0] } for k := range r.nameIndexMap {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Sep 13 00:00:59 GMT 2022 - 4.1K bytes - Viewed (0)