- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 85 for ingr (0.06 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/integrator.go
igr.Lock() defer igr.Unlock() return igr.getResultsLocked() } func (igr *integrator) Reset() IntegratorResults { igr.Lock() defer igr.Unlock() results := igr.getResultsLocked() igr.moments = Moments{} igr.min = igr.x igr.max = igr.x return results } func (igr *integrator) getResultsLocked() (results IntegratorResults) { igr.updateLocked() results.Min, results.Max = igr.min, igr.max
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 17:37:20 UTC 2022 - 5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/integrator_test.go
"time" testclock "k8s.io/utils/clock/testing" ) func TestIntegrator(t *testing.T) { now := time.Now() clk := testclock.NewFakeClock(now) igr := NewNamedIntegrator(clk, "testee") igr.Add(3) clk.Step(time.Second) results := igr.GetResults() rToo := igr.Reset() if e := (IntegratorResults{Duration: time.Second.Seconds(), Average: 3, Deviation: 0, Min: 0, Max: 3}); !e.Equal(&results) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 27 21:11:44 UTC 2022 - 1.6K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/topology_manager_test.go
&mockHintProvider{}, &mockHintProvider{}, &mockHintProvider{}, }, }, } mngr := manager{} mngr.scope = NewContainerScope(NewNonePolicy()) for _, tc := range tcases { for _, hp := range tc.hp { mngr.AddHintProvider(hp) } if len(tc.hp) != len(mngr.scope.(*containerScope).hintProviders) { t.Errorf("error") } } } func TestAdmit(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 13:04:32 UTC 2023 - 13.8K bytes - Viewed (0) -
test/typeparam/cons.go
import "fmt" // Overriding the predeclare "any", so it can be used as a type constraint or a type // argument type any interface{} type Function[a, b any] interface { Apply(x a) b } type incr struct{ n int } func (this incr) Apply(x int) int { return x + this.n } type pos struct{} func (this pos) Apply(x int) bool { return x > 0 } type compose[a, b, c any] struct { f Function[a, b]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 21 23:41:49 UTC 2022 - 2K bytes - Viewed (0) -
tests/fuzz/kube_ingress_fuzzer.go
func FuzzConvertIngressVirtualService(data []byte) int { f := fuzz.NewConsumer(data) ing := knetworking.Ingress{} err := f.GenerateStruct(&ing) if err != nil { return 0 } service := &corev1.Service{} cfgs := map[string]*config.Config{} serviceLister, teardown := newServiceLister(service) defer teardown() ingress.ConvertIngressVirtualService(ing, "mydomain", cfgs, serviceLister) return 1 }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 15 16:18:19 UTC 2023 - 1.9K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/status.go
} func (s *StatusSyncer) enqueueAll() { for _, ing := range s.ingresses.List(metav1.NamespaceAll, labels.Everything()) { s.queue.AddObject(ing) } } func (s *StatusSyncer) Reconcile(key types.NamespacedName) error { log := statusLog.WithLabels("ingress", key) ing := s.ingresses.Get(key.Name, key.Namespace) if ing == nil { log.Debugf("ingress removed, no action") return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.9K bytes - Viewed (0) -
tests/integration/security/sds_ingress/ingress_test.go
ingressutil.IngressCredentialA, false) ing := inst.IngressFor(t.Clusters().Default()) if ing == nil { t.Skip() } tlsContextA := ingressutil.TLSContext{CaCert: ingressutil.CaCertA} tlsContextB := ingressutil.TLSContext{CaCert: ingressutil.CaCertB} // Verify the call works ingressutil.SendRequestOrFail(t, ing, host, credName, ingressutil.TLS, tlsContextA,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 32.7K bytes - Viewed (0) -
pkg/registry/networking/ingress/storage/storage_test.go
if err != nil { t.Fatalf("Unexpected error: %v", err) } ing := ingStart.DeepCopy() ing.Status.LoadBalancer.Ingress = []networking.IngressLoadBalancerIngress{ { IP: defaultLoadBalancer, }, } _, _, err = statusStorage.Update(ctx, ing.Name, rest.DefaultUpdatedObjectInfo(ing), rest.ValidateAllObjectFunc, rest.ValidateAllObjectUpdateFunc, false, &metav1.UpdateOptions{}) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 15 09:01:21 UTC 2023 - 8.4K bytes - Viewed (0) -
pkg/apis/networking/validation/validation_test.go
tweakIngress func(ing *networking.Ingress) expectErrsOnFields []string }{ "empty path (implementation specific)": { tweakIngress: func(ing *networking.Ingress) { ing.Spec.Rules[0].IngressRuleValue.HTTP.Paths[0].Path = "" }, expectErrsOnFields: []string{}, }, "valid path": { tweakIngress: func(ing *networking.Ingress) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 73.3K bytes - Viewed (0) -
tests/integration/security/sds_ingress/util/util.go
func SendRequestOrFail(ctx framework.TestContext, ing ingress.Instance, host string, path string, callType CallType, tlsCtx TLSContext, exRsp ExpectedResponse, ) { doSendRequestsOrFail(ctx, ing, host, path, callType, tlsCtx, exRsp, false /* useHTTP3 */) } func SendQUICRequestsOrFail(ctx framework.TestContext, ing ingress.Instance, host string, path string,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 25 05:12:36 UTC 2023 - 20.2K bytes - Viewed (0)