Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 87 for Se (0.02 sec)

  1. pilot/pkg/serviceregistry/serviceentry/util_test.go

    	}
    	currSes := map[types.NamespacedName]*config.Config{
    		{Namespace: "default", Name: "se-2"}: {},
    		{Namespace: "default", Name: "se-4"}: {},
    		{Namespace: "default", Name: "se-5"}: {},
    	}
    
    	expectedUnselected := map[types.NamespacedName]*config.Config{
    		{Namespace: "default", Name: "se-1"}: {},
    		{Namespace: "default", Name: "se-3"}: {},
    	}
    	unSelected := difference(oldSes, currSes)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jan 17 22:32:10 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/serviceentry/util.go

    	for key := range old {
    		if _, ok := curr[key]; !ok {
    			out = append(out, key)
    		}
    	}
    
    	return out
    }
    
    func isDNSTypeServiceEntry(se *networking.ServiceEntry) bool {
    	if se == nil {
    		return false
    	}
    	return se.Resolution == networking.ServiceEntry_DNS || se.Resolution == networking.ServiceEntry_DNS_ROUND_ROBIN
    }
    
    // count the number of elements in the map value. The value is []any type.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go

    			}
    
    			w.WorkloadName, w.WorkloadType = se.Name, workloadapi.WorkloadType_POD // XXX(shashankram): HACK to impersonate pod
    			w.CanonicalName, w.CanonicalRevision = kubelabels.CanonicalService(se.Labels, w.WorkloadName)
    
    			setTunnelProtocol(se.Labels, se.Annotations, w)
    			res = append(res, model.WorkloadInfo{Workload: w, Labels: se.Labels, Source: kind.WorkloadEntry, CreationTime: se.CreationTimestamp.Time})
    		}
    		return res
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 16:51:29 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/serviceentry/conversion.go

    	}
    
    	if len(svc.Attributes.LabelSelectors) > 0 {
    		se.WorkloadSelector = &networking.WorkloadSelector{Labels: svc.Attributes.LabelSelectors}
    	}
    
    	// Based on networking.istio.io/exportTo annotation
    	for k := range svc.Attributes.ExportTo {
    		// k is Private or Public
    		se.ExportTo = append(se.ExportTo, string(k))
    	}
    
    	if svc.MeshExternal {
    		se.Location = networking.ServiceEntry_MESH_EXTERNAL // 0 - default
    	} else {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  5. src/internal/xcoff/file.go

    		case U802TOCMAGIC:
    			se := new(SymEnt32)
    			if err := binary.Read(sr, binary.BigEndian, se); err != nil {
    				return nil, err
    			}
    			numaux = int(se.Nnumaux)
    			sym.SectionNumber = int(se.Nscnum)
    			sym.StorageClass = int(se.Nsclass)
    			sym.Value = uint64(se.Nvalue)
    			needAuxFcn = se.Ntype&SYM_TYPE_FUNC != 0 && numaux > 1
    			zeroes := binary.BigEndian.Uint32(se.Nname[:4])
    			if zeroes != 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 12 14:42:29 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/kube/controller/serviceexportcache.go

    	se := controllers.Extract[*unstructured.Unstructured](obj)
    	if se == nil {
    		return nil
    	}
    
    	switch event {
    	case model.EventAdd, model.EventDelete:
    		ec.updateXDS(se)
    	default:
    		// Don't care about updates.
    	}
    	return nil
    }
    
    func (ec *serviceExportCacheImpl) updateXDS(se metav1.Object) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  7. internal/s3select/csv/args.go

    				break
    			}
    			return err
    		}
    
    		if se, ok := t.(xml.StartElement); ok {
    			tagName := se.Name.Local
    			switch tagName {
    			case "AllowQuotedRecordDelimiter":
    				var b bool
    				if err = d.DecodeElement(&b, &se); err != nil {
    					return err
    				}
    				args.AllowQuotedRecordDelimiter = b
    			default:
    				var s string
    				if err = d.DecodeElement(&s, &se); err != nil {
    					return err
    				}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  8. src/net/error_unix.go

    // license that can be found in the LICENSE file.
    
    //go:build unix || js || wasip1
    
    package net
    
    import "syscall"
    
    func isConnError(err error) bool {
    	if se, ok := err.(syscall.Errno); ok {
    		return se == syscall.ECONNRESET || se == syscall.ECONNABORTED
    	}
    	return false
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 11 20:54:12 UTC 2023
    - 382 bytes
    - Viewed (0)
  9. pilot/pkg/serviceregistry/kube/controller/ambient/services_test.go

    )
    
    func TestServiceEntryServices(t *testing.T) {
    	cases := []struct {
    		name   string
    		inputs []any
    		se     *networkingclient.ServiceEntry
    		result []*workloadapi.Service
    	}{
    		{
    			name:   "DNS service entry with address",
    			inputs: []any{},
    			se: &networkingclient.ServiceEntry{
    				ObjectMeta: metav1.ObjectMeta{
    					Name:      "name",
    					Namespace: "ns",
    				},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 12:29:55 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  10. pkg/config/analysis/analyzers/serviceentry/protocoladdresses.go

    	})
    }
    
    func (serviceEntry *ProtocolAddressesAnalyzer) analyzeProtocolAddresses(r *resource.Instance, ctx analysis.Context, metaDNSAutoAllocated bool) {
    	se := r.Message.(*v1alpha3.ServiceEntry)
    	if se.Addresses == nil && !metaDNSAutoAllocated {
    		for index, port := range se.Ports {
    			if port.Protocol == "" || port.Protocol == "TCP" {
    				message := msg.NewServiceEntryAddressesRequired(r)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 01 01:34:15 UTC 2023
    - 2.5K bytes
    - Viewed (0)
Back to top