Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 87 for Se (0.03 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/dispatcher.go

    		tmp := do
    		do = func() { wd.ValidatingWebhookTracker.Track(tmp) }
    	}
    	do()
    	if err != nil {
    		var status *apierrors.StatusError
    		if se, ok := err.(*apierrors.StatusError); ok {
    			status = se
    		} else {
    			status = apierrors.NewBadRequest("error calling webhook")
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 23 20:24:12 UTC 2023
    - 13K bytes
    - Viewed (0)
  2. src/crypto/x509/verify.go

    type SystemRootsError struct {
    	Err error
    }
    
    func (se SystemRootsError) Error() string {
    	msg := "x509: failed to load system roots and no roots provided"
    	if se.Err != nil {
    		return msg + "; " + se.Err.Error()
    	}
    	return msg
    }
    
    func (se SystemRootsError) Unwrap() error { return se.Err }
    
    // errNotParsed is returned when a certificate without ASN.1 contents is
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:58:39 UTC 2024
    - 35.7K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/ambient/helpers.go

    }
    
    // name format: <cluster>/<group>/<kind>/<namespace>/<name></section-name>
    // section name should be the WE address, which needs to be stable across SE updates (it is assumed WE addresses are unique)
    func (a *index) generateServiceEntryUID(svcEntryNamespace, svcEntryName, addr string) string {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Mar 22 20:35:23 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  4. pilot/pkg/model/gateway.go

    		portNumber, _, _ := ParseGatewayRDSRouteName(r)
    		if _, f := pm[portNumber]; !f {
    			pm[portNumber] = sets.New[int]()
    		}
    		for _, se := range s {
    			if se.Port == nil {
    				continue
    			}
    			pm[portNumber].Insert(int(se.Port.Number))
    		}
    	}
    	return pm
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 26K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/controller.go

    	// Add the ServiceExport info.
    	for _, se := range c.exports.ExportedServices() {
    		mcsService := outMap[se.namespacedName]
    		mcsService.Cluster = c.Cluster()
    		mcsService.Name = se.namespacedName.Name
    		mcsService.Namespace = se.namespacedName.Namespace
    		mcsService.Exported = true
    		mcsService.Discoverability = se.discoverability
    		outMap[se.namespacedName] = mcsService
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go

    		tmp := do
    		do = func() { wd.MutatingWebhookTracker.Track(tmp) }
    	}
    	do()
    	if err != nil {
    		var status *apierrors.StatusError
    		if se, ok := err.(*apierrors.StatusError); ok {
    			status = se
    		} else {
    			status = apierrors.NewBadRequest("error calling webhook")
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  7. src/cmd/internal/obj/mips/obj0.go

    	for p := p0; ; p = p.Link {
    		s[0].p = *p
    		c.markregused(&s[0])
    		if p == pe {
    			break
    		}
    		s = s[1:]
    	}
    	se := s
    
    	for i := cap(sch) - cap(se); i >= 0; i-- {
    		s = sch[i:]
    		if s[0].p.Mark&DELAY == 0 {
    			continue
    		}
    		if -cap(s) < -cap(se) {
    			if !conflict(&s[0], &s[1]) {
    				continue
    			}
    		}
    
    		var t []Sch
    		var j int
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 21 19:28:53 UTC 2023
    - 30.6K bytes
    - Viewed (0)
  8. src/fmt/scan.go

    	panic(scanError{errors.New(err)})
    }
    
    func (s *ss) Token(skipSpace bool, f func(rune) bool) (tok []byte, err error) {
    	defer func() {
    		if e := recover(); e != nil {
    			if se, ok := e.(scanError); ok {
    				err = se.err
    			} else {
    				panic(e)
    			}
    		}
    	}()
    	if f == nil {
    		f = notSpace
    	}
    	s.buf = s.buf[:0]
    	tok = s.token(skipSpace, f)
    	return
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 21:56:20 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  9. pilot/pkg/networking/apigen/apigen.go

    			Resource: protoconv.MessageToAny(b),
    		})
    	}
    
    	// TODO: MeshConfig, current dynamic ProxyConfig (for this proxy), Networks
    
    	if w.TypeUrl == gvk.ServiceEntry.String() {
    		// Include 'synthetic' SE - but without the endpoints. Used to generate CDS, LDS.
    		// EDS is pass-through.
    		svcs := proxy.SidecarScope.Services()
    		for _, s := range svcs {
    			// Ignore services that are result of conversion from ServiceEntry.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Oct 05 19:01:38 UTC 2023
    - 5K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_workloadentry_test.go

    	s := newAmbientTestServer(t, testC, testNW)
    
    	s.addServiceEntry(t, "se.istio.io", []string{"240.240.23.45"}, "se1", testNS, map[string]string{"app": "a"}, []string{"127.0.0.1", "127.0.0.2"})
    	s.assertWorkloads(t, "", workloadapi.WorkloadStatus_HEALTHY, "se1")
    	s.assertEvent(t, s.seIPXdsName("se1", "127.0.0.1"), s.seIPXdsName("se1", "127.0.0.2"), "ns1/se.istio.io")
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 01:04:50 UTC 2024
    - 15.6K bytes
    - Viewed (0)
Back to top