- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,016 for nfound (0.12 sec)
-
pilot/pkg/model/sidecar.go
// We only merge if the found service is in the same namespace as the one we're trying to add copied := foundSvc.svc.DeepCopy() for _, p := range s.Ports { found := false for _, osp := range copied.Ports { if p.Port == osp.Port { found = true break } } if !found { copied.Ports = append(copied.Ports, p) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 20:32:23 UTC 2024 - 38.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/waypoints.go
} else if tt, found := gatewayClass.Labels[constants.AmbientWaypointForTrafficTypeLabel]; found { // Check for a declared traffic type that is allowed to pass through the Waypoint's GatewayClass trafficType = tt } // Check for a declared traffic type that is allowed to pass through the Waypoint if tt, found := gateway.Labels[constants.AmbientWaypointForTrafficTypeLabel]; found {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:28 UTC 2024 - 11.1K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder_test.go
if vo := xdstest.ExtractListener(model.VirtualOutboundListenerName, listeners); vo == nil { t.Fatalf("expect virtual listener, found %s", listeners[0].Name) } vi := xdstest.ExtractListener(model.VirtualInboundListenerName, listeners) if vi == nil { t.Fatalf("expect virtual inbound listener, found %s", listeners[0].Name) } byListenerName := map[string]int{} for _, fc := range vi.FilterChains {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 24.7K bytes - Viewed (0) -
pkg/kubelet/types/types.go
containers := p.Spec.InitContainers statuses := []v1.ContainerStatus{} for _, container := range containers { if status, found := statusMap[container.Name]; found { statuses = append(statuses, *status) } } return statuses } // Reservation represents reserved resources for non-pod components. type Reservation struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 13:13:22 UTC 2024 - 3.5K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/binutils/binutils.go
// On MacOS only, also looks for gobjdump with least preference. // Accepts a list of paths and returns: // a string with path to the preferred objdump binary if found, // or an empty string if not found; // a boolean if any acceptable objdump was found; // a boolean indicating if it is an LLVM objdump. func findObjdump(paths []string) (string, bool, bool) { objdumpNames := []string{"llvm-objdump", "objdump"}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 22.3K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_test.go
listeners := buildListeners(t, proxy, port) found := hasListenerOrFilterChainForPort(listeners, port) if tc.expectListener { if !found { t.Fatalf("expected listener on port %d, but not found", port) } } else { if found { t.Fatalf("expected no listener on port %d, but found found one", port) } } } }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 93.6K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
s.queue.Add(o) })) return s } // GetPodIfAmbient looks up a pod. It returns: // * An error if the pod cannot be found // * nil if the pod is found, but does not have ambient enabled // * the pod, if it is found and ambient is enabled func (s *InformerHandlers) GetPodIfAmbient(podName, podNamespace string) (*corev1.Pod, error) { ns := s.namespaces.Get(podNamespace, "") if ns == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_inbound.go
} return listeners } // inboundVirtualListener builds the virtual inbound listener. func (lb *ListenerBuilder) inboundVirtualListener(chains []*listener.FilterChain) *listener.Listener { actualWildcards, _ := getWildcardsAndLocalHost(lb.node.GetIPMode()) // Build the "virtual" inbound listener. This will capture all inbound redirected traffic and contains:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 35.1K bytes - Viewed (0) -
cmd/signature-v4-utils.go
if !slices.Contains(signedHeaders, "host") { return nil, ErrUnsignedHeaders } extractedSignedHeaders := make(http.Header) for _, header := range signedHeaders { // `host` will not be found in the headers, can be found in r.Host. // but its always necessary that the list of signed headers containing host in it. val, ok := reqHeaders[http.CanonicalHeaderKey(header)] if !ok { // try to set headers from Query String
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 9.1K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
clusters: map[string][]string{ "inbound|8080||": nil, "inbound|8081||": nil, "inbound|8082||": nil, "inbound|8083||": nil, }, telemetry: map[string][]string{ "inbound|8080||": {string(service.Hostname)}, "inbound|8081||": {string(service.Hostname)}, "inbound|8082||": {string(serviceAlt.Hostname)}, "inbound|8083||": {string(serviceAlt.Hostname)}, }, }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0)