Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for vertices (0.17 sec)

  1. istioctl/pkg/writer/ztunnel/configdump/policies.go

    	if wf.Namespace != "" {
    		if !strings.EqualFold(pol.Namespace, wf.Namespace) {
    			return false
    		}
    	}
    
    	return true
    }
    
    // PrintServiceSummary prints a summary of the relevant services in the config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintPolicySummary(filter PolicyFilter) error {
    	w := c.tabwriter()
    	zDump := c.ztunnelDump
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 2.5K bytes
    - Viewed (0)
  2. istioctl/pkg/completion/completion.go

    	client, err := ctx.CLIClient()
    	if err != nil {
    		return nil, err
    	}
    	ns := ctx.NamespaceOrDefault(ctx.Namespace())
    	serviceList, err := client.Kube().CoreV1().Services(ns).List(context.Background(), metav1.ListOptions{})
    	if err != nil {
    		return nil, err
    	}
    
    	var serviceNameList []string
    	for _, service := range serviceList.Items {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  3. 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 *netip.Addr) error {
    	// Append our rules here
    	builder := cfg.appendHostRules(hostSNATIP)
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 01:42:30 GMT 2024
    - 19.2K bytes
    - Viewed (0)
  4. 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 ztunnel-config services
    
      # Retrieve full certificate dump of workloads for a given Ztunnel instance.
      istioctl ztunnel-config services <ztunnel-name[.namespace]> -o json
    `,
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Apr 22 15:39:28 GMT 2024
    - 22.2K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/ztunnel/configdump/api.go

    	Action    string             `json:"action"`
    	Rules     [][][]*PolicyMatch `json:"rules"`
    }
    
    type ZtunnelDump struct {
    	Workloads     map[string]*ZtunnelWorkload `json:"workloads"`
    	Services      map[string]*ZtunnelService  `json:"services"`
    	Policies      map[string]*ZtunnelPolicy   `json:"policies"`
    	Certificates  []*CertsDump                `json:"certificates"`
    	WorkloadState map[string]WorkloadState    `json:"workloadState"`
    }
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Apr 22 15:39:28 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  6. 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 Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 02:57:30 GMT 2024
    - 19.3K bytes
    - Viewed (0)
  7. internal/s3select/message.go

    	// https://github.com/aws/aws-sdk-java/blob/master/aws-java-sdk-s3/src/main/java/com/amazonaws/services/s3/internal/eventstreaming/MessageDecoder.java#L26
    	// but we must make sure there is always space to add 256 bytes:
    	// https://github.com/aws/aws-sdk-java/blob/master/aws-java-sdk-s3/src/main/java/com/amazonaws/services/s3/model/SelectObjectContentEventStream.java#L197
    	maxRecordMessageLength = (128 << 10) - 256
    )
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Aug 30 15:26:43 GMT 2022
    - 15.2K bytes
    - Viewed (0)
  8. 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 Apr 24 22:53:08 GMT 2024
    - Last Modified: Wed Apr 17 20:06:41 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/ztunnel/configdump/services.go

    			return false
    		}
    	}
    
    	return true
    }
    
    // PrintServiceSummary prints a summary of the relevant services in the config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintServiceSummary(filter ServiceFilter) error {
    	w := c.tabwriter()
    	zDump := c.ztunnelDump
    
    	svcs := slices.Filter(maps.Values(zDump.Services), filter.Verify)
    	slices.SortFunc(svcs, func(a, b *ZtunnelService) int {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  10. istioctl/pkg/writer/ztunnel/configdump/workload.go

    	return nil
    }
    
    func waypointName(wl *ZtunnelWorkload, services map[string]*ZtunnelService) string {
    	if wl.Waypoint == nil {
    		return "None"
    	}
    
    	if svc, ok := services[wl.Waypoint.Destination]; ok {
    		return svc.Name
    	}
    
    	return "NA" // Shouldn't normally reach here
    }
    
    func serviceWaypointName(svc *ZtunnelService, services map[string]*ZtunnelService) string {
    	if svc.Waypoint == nil {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 4K bytes
    - Viewed (0)
Back to top