- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 6,658 for makeWE (0.22 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)