- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for vertices (0.17 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)