Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for vertices (0.35 sec)

  1. cni/pkg/iptables/iptables.go

    // via the nodeIP
    // - kubelet (node-local healthchecks, which we do not capture)
    // - kube-proxy (fowarded/proxied traffic from LoadBalancer-backed services, potentially with public IPs, which we must capture)
    func (cfg *IptablesConfigurator) CreateHostRulesForHealthChecks(hostSNATIP, hostSNATIPV6 *netip.Addr) error {
    	// Append our rules here
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue May 07 19:54:50 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  2. istioctl/pkg/ztunnelconfig/ztunnelconfig.go

    		Use:   "service",
    		Short: "Retrieves services for the specified Ztunnel pod.",
    		Long:  `Retrieve information about services for the Ztunnel instance.`,
    		Example: `  # Retrieve summary about services configuration for a randomly chosen ztunnel.
      istioctl x ztunnel-config services
    
      # Retrieve full certificate dump of workloads for a given Ztunnel instance.
      istioctl x ztunnel-config services <ztunnel-name[.namespace]> -o json
    `,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 01 13:11:40 GMT 2024
    - 22.2K bytes
    - Viewed (0)
  3. istioctl/pkg/precheck/precheck.go

    	// In 1.22, we remove the default tracing config which points to zipkin.istio-system
    	// This has no effect for users, unless they have this service.
    	svc, err := cli.Kube().CoreV1().Services("istio-system").Get(context.Background(), "zipkin", metav1.GetOptions{})
    	if err != nil && !kerrors.IsNotFound(err) {
    		return err
    	}
    	if err != nil {
    		// not found
    		return nil
    	}
    	// found
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 02:57:30 GMT 2024
    - 19.3K bytes
    - Viewed (0)
  4. istioctl/pkg/workload/workload.go

    		p := strings.Split(ingressSvc, ".")
    		ingressNs := istioNamespace
    		if len(p) == 2 {
    			ingressSvc = p[0]
    			ingressNs = p[1]
    		}
    		ingress, err := kubeClient.Kube().CoreV1().Services(ingressNs).Get(context.Background(), ingressSvc, metav1.GetOptions{})
    		if err == nil {
    			if ingress.Status.LoadBalancer.Ingress != nil && len(ingress.Status.LoadBalancer.Ingress) > 0 {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Apr 17 20:06:41 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  5. cmd/server-main.go

    	})
    
    	// Configure server.
    	bootstrapTrace("configureServer", func() {
    		handler, err := configureServerHandler(globalEndpoints)
    		if err != nil {
    			logger.Fatal(config.ErrUnexpectedError(err), "Unable to configure one of server's RPC services")
    		}
    		// Allow grid to start after registering all services.
    		xioutil.SafeClose(globalGridStart)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
  6. cmd/notification.go

    	for index, err := range g.Wait() {
    		if err != nil {
    			sys.addNodeErr(&reply[index], sys.peerClients[index], err)
    		}
    	}
    	return reply
    }
    
    // GetSysServices - Get information about system services
    // (only the services that are of concern to minio)
    func (sys *NotificationSys) GetSysServices(ctx context.Context) []madmin.SysServices {
    	reply := make([]madmin.SysServices, len(sys.peerClients))
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  7. istioctl/pkg/kubeinject/kubeinject.go

    	client := http.Client{
    		Timeout: time.Second * 5,
    		Transport: &http.Transport{
    			TLSClientConfig: tlsClientConfig,
    		},
    	}
    	if cc.Service != nil {
    		svc, err := e.client.Kube().CoreV1().Services(cc.Service.Namespace).Get(context.Background(), cc.Service.Name, metav1.GetOptions{})
    		if err != nil {
    			return nil, err
    		}
    		namespace, selector, err := polymorphichelpers.SelectorsForObject(svc)
    		if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 29 02:29:02 GMT 2024
    - 21.6K bytes
    - Viewed (0)
  8. istioctl/pkg/describe/describe_test.go

    			wantException:  true, // "istioctl experimental describe pod not-a-pod" should fail
    		},
    		{ // case 8 unknown service
    			args:           strings.Split("service not-a-service", " "),
    			expectedString: "services \"not-a-service\" not found",
    			wantException:  true, // "istioctl experimental describe service not-a-service" should fail
    		},
    		{
    			k8sConfigs: []runtime.Object{
    				&corev1.Service{
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Mar 28 09:54:01 GMT 2024
    - 30.4K bytes
    - Viewed (0)
Back to top