Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 6,658 for makeWE (0.22 sec)

  1. plugin/pkg/admission/eventratelimit/admission.go

    	}
    
    	eventRateLimitAdmission := &Plugin{
    		Handler:        admission.NewHandler(admission.Create, admission.Update),
    		limitEnforcers: limitEnforcers,
    	}
    
    	return eventRateLimitAdmission, nil
    }
    
    // Validate makes admission decisions while enforcing event rate limits
    func (a *Plugin) Validate(ctx context.Context, attr admission.Attributes, o admission.ObjectInterfaces) (err error) {
    	// ignore all operations that do not correspond to an Event kind
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 14 15:26:57 UTC 2021
    - 3.6K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/mock/discovery_test.go

    	})
    	HelloInstanceV0 := MakeIP(HelloService, 0)
    
    	if HelloInstanceV0 != "10.1.1.0" {
    		t.Fatalf("MakeIP() can not handle ip4 address.")
    	}
    
    	HelloService1 := MakeService(ServiceArgs{
    		Hostname:        "hello.default.svc.cluster.local",
    		Address:         "asa",
    		ServiceAccounts: []string{},
    		ClusterID:       "cluster-1",
    	})
    	HelloInstanceV1 := MakeIP(HelloService1, 0)
    	if HelloInstanceV1 != "" {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jan 09 17:33:49 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  3. pkg/kube/inject/template.go

    	if err != nil {
    		log.Warnf("Unable to marshal %v: %v", v, err)
    		return "{}"
    	}
    
    	return ba
    }
    
    // Rather than dump the entire proxy config, we remove fields that are default
    // This makes the pod spec much smaller
    // This is not comprehensive code, but nothing will break if this misses some fields
    func cleanProxyConfig(msg proto.Message) proto.Message {
    	originalProxyConfig, ok := msg.(*meshconfig.ProxyConfig)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Nov 16 02:12:03 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  4. src/cmd/vendor/golang.org/x/tools/internal/typeparams/free.go

    package typeparams
    
    import (
    	"go/types"
    
    	"golang.org/x/tools/internal/aliases"
    )
    
    // Free is a memoization of the set of free type parameters within a
    // type. It makes a sequence of calls to [Free.Has] for overlapping
    // types more efficient. The zero value is ready for use.
    //
    // NOTE: Adapted from go/types/infer.go. If it is later exported, factor.
    type Free struct {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  5. src/text/template/template.go

    	}
    	return nt
    }
    
    // init guarantees that t has a valid common structure.
    func (t *Template) init() {
    	if t.common == nil {
    		c := new(common)
    		c.tmpl = make(map[string]*Template)
    		c.parseFuncs = make(FuncMap)
    		c.execFuncs = make(map[string]reflect.Value)
    		t.common = c
    	}
    }
    
    // Clone returns a duplicate of the template, including all associated
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 20:57:51 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  6. src/cmd/vendor/golang.org/x/tools/go/analysis/unitchecker/unitchecker.go

    		GoVersion: cfg.GoVersion,
    	}
    	info := &types.Info{
    		Types:      make(map[ast.Expr]types.TypeAndValue),
    		Defs:       make(map[*ast.Ident]types.Object),
    		Uses:       make(map[*ast.Ident]types.Object),
    		Implicits:  make(map[ast.Node]types.Object),
    		Instances:  make(map[*ast.Ident]types.Instance),
    		Scopes:     make(map[ast.Node]*types.Scope),
    		Selections: make(map[*ast.SelectorExpr]*types.Selection),
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 03 02:38:00 UTC 2024
    - 13K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/conversion/converter.go

    			}
    		}
    	}
    	return c.converter.Convert(in, toGVK.GroupVersion())
    }
    
    // safeConverterWrapper is a wrapper over an unsafe object converter that makes copy of the input and then delegate to the unsafe converter.
    type safeConverterWrapper struct {
    	unsafe runtime.ObjectConvertor
    }
    
    var _ runtime.ObjectConvertor = &safeConverterWrapper{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  8. src/cmd/vendor/github.com/google/pprof/profile/merge.go

    		for i, v := range src.Value {
    			ss.Value[i] += v
    		}
    		return ss
    	}
    
    	// Make new sample.
    	s := &Sample{
    		Location: make([]*Location, len(src.Location)),
    		Value:    make([]int64, len(src.Value)),
    		Label:    make(map[string][]string, len(src.Label)),
    		NumLabel: make(map[string][]int64, len(src.NumLabel)),
    		NumUnit:  make(map[string][]string, len(src.NumLabel)),
    	}
    	for i, l := range src.Location {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Feb 16 15:19:53 UTC 2024
    - 17K bytes
    - Viewed (0)
  9. pkg/istio-agent/xds_proxy_delta.go

    		upstreamError:     make(chan error), // can be produced by recv and send
    		downstreamError:   make(chan error), // can be produced by recv and send
    		deltaRequestsChan: channels.NewUnbounded[*discovery.DeltaDiscoveryRequest](),
    		// Allow a buffer of 1. This ensures we queue up at most 2 (one in process, 1 pending) responses before forwarding.
    		deltaResponsesChan: make(chan *discovery.DeltaDiscoveryResponse, 1),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 04 20:29:08 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  10. src/net/http/triv.go

    	helloRequests.Add(1)
    	io.WriteString(w, "hello, world!\n")
    }
    
    // Simple counter server. POSTing to it will set the value.
    type Counter struct {
    	mu sync.Mutex // protects n
    	n  int
    }
    
    // This makes Counter satisfy the [expvar.Var] interface, so we can export
    // it directly.
    func (ctr *Counter) String() string {
    	ctr.mu.Lock()
    	defer ctr.mu.Unlock()
    	return strconv.Itoa(ctr.n)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 3.2K bytes
    - Viewed (0)
Back to top