- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 87 for Se (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
pilot/pkg/serviceregistry/kube/controller/serviceexportcache.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.5K bytes - Viewed (0) -
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) -
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) -
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) -
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)