Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 83 for ruleset (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 May 05 19:28:20 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 May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 8.8K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top