Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 286 for namespace_b (0.15 sec)

  1. pkg/test/framework/components/echo/common/deployment/namespace.go

    	namespaces, err := namespace.GetAll(t)
    	if err != nil {
    		return fmt.Errorf("failed retrieving list of namespaces: %v", err)
    	}
    
    	// Restrict egress from this namespace to only those endpoints in the same Echos.
    	cfg := t.ConfigIstio().New()
    	cfg.Eval(ns.Name(), map[string]any{
    		"Namespaces": namespaces,
    	}, `
    apiVersion: networking.istio.io/v1alpha3
    kind: Sidecar
    metadata:
      name: restrict-to-namespace
    spec:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 20 16:01:31 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  2. istioctl/pkg/waypoint/waypoint.go

    }
    
    func getNamespace(kubeClient kube.CLIClient, ns string) (*corev1.Namespace, error) {
    	nsObj, err := kubeClient.Kube().CoreV1().Namespaces().Get(context.Background(), ns, metav1.GetOptions{})
    	if errors.IsNotFound(err) {
    		return nil, fmt.Errorf("namespace: %s not found", ns)
    	} else if err != nil {
    		return nil, fmt.Errorf("failed to get namespace %s: %v", ns, err)
    	}
    	return nsObj, nil
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 15:59:33 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/ambient/waypoints.go

    	}
    
    	// try fetching the namespace-defined waypoint
    	namespace := ptr.OrEmpty[*v1.Namespace](krt.FetchOne[*v1.Namespace](ctx, Namespaces, krt.FilterKey(o.Namespace)))
    	// this probably should never be nil. How would o exist in a namespace we know nothing about? maybe edge case of starting the controller or ns delete?
    	if namespace != nil {
    		// toss isNone, we don't need to know /why/ we got nil
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 18:02:28 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  4. pkg/test/framework/components/echo/deployment/builder.go

    	// Only the first per-cluster entry for a given config should have a non-nil ref.
    	refs []*echo.Instance
    	// namespaces caches namespaces by their prefix; used for converting Static namespace from configs into actual
    	// namespaces
    	namespaces map[string]namespace.Instance
    	// the set of injection templates for each cluster
    	templates map[string]sets.String
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 12K bytes
    - Viewed (0)
  5. tests/integration/ambient/waypoint_test.go

          namespaces:
            from: Same
      - name: {{.Service}}-svc
        hostname: {{.Service}}.{{.Namespace}}.svc
        port: {{.Port}}
        protocol: HTTP
        allowedRoutes:
          namespaces:
            from: Same
      - name: {{.Service}}-namespace
        hostname: {{.Service}}.{{.Namespace}}
        port: {{.Port}}
        protocol: HTTP
        allowedRoutes:
          namespaces:
            from: Same
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/kube/controller/ambient/services.go

    }
    
    func (a *index) serviceEntryServiceBuilder(
    	Waypoints krt.Collection[Waypoint],
    	Namespaces krt.Collection[*v1.Namespace],
    ) krt.TransformationMulti[*networkingclient.ServiceEntry, model.ServiceInfo] {
    	return func(ctx krt.HandlerContext, s *networkingclient.ServiceEntry) []model.ServiceInfo {
    		waypoint := fetchWaypointForService(ctx, Waypoints, Namespaces, s.ObjectMeta)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 12:29:55 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/cni-watcher_test.go

    	pluginServer := startCniPluginServer(ctx, "/tmp/test.sock", handlers, dpServer)
    
    	// label the namespace
    	labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":"%s"}}}`,
    		constants.DataplaneModeLabel, constants.DataplaneModeAmbient))
    	_, err := client.Kube().CoreV1().Namespaces().Patch(ctx, ns.Name,
    		types.MergePatchType, labelsPatch, metav1.PatchOptions{})
    	assert.NoError(t, err)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 21:31:35 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  8. pkg/kubelet/userns/userns_manager.go

    	lock sync.Mutex
    }
    
    // UserNamespace holds the configuration for the user namespace.
    type userNamespace struct {
    	// UIDs mappings for the user namespace.
    	UIDMappings []idMapping `json:"uidMappings"`
    	// GIDs mappings for the user namespace.
    	GIDMappings []idMapping `json:"gidMappings"`
    }
    
    // Pod user namespace mapping
    type idMapping struct {
    	// Required.
    	HostId uint32 `json:"hostId"`
    	// Required.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  9. pilot/pkg/config/kube/gateway/conversion.go

    		return nil
    	}
    	namespaces := []string{}
    	for _, ns := range r.Namespaces {
    		if ls.Matches(toNamespaceSet(ns.Name, ns.Labels)) {
    			namespaces = append(namespaces, ns.Name)
    		}
    	}
    	// Ensure stable order
    	sort.Strings(namespaces)
    	return namespaces
    }
    
    func nilOrEqual(have *string, expected string) bool {
    	return have == nil || *have == expected
    }
    
    func humanReadableJoin(ss []string) string {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/kube/conversion.go

    			serviceaccounts = append(serviceaccounts, kubeToIstioServiceAccount(ksa, svc.Namespace, mesh))
    		}
    	}
    	if svc.Annotations[annotation.NetworkingExportTo.Name] != "" {
    		namespaces := strings.Split(svc.Annotations[annotation.NetworkingExportTo.Name], ",")
    		exportTo = sets.NewWithLength[visibility.Instance](len(namespaces))
    		for _, ns := range namespaces {
    			exportTo.Insert(visibility.Instance(ns))
    		}
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 9.4K bytes
    - Viewed (0)
Back to top