- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 21 for vertices (0.16 sec)
-
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) -
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 May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics.go
`, Example: ` # Retrieve workload metrics for productpage-v1 workload istioctl experimental metrics productpage-v1 # Retrieve workload metrics for various services with custom duration istioctl experimental metrics productpage-v1 -d 2m # Retrieve workload metrics for various services in the different namespaces istioctl experimental metrics productpage-v1.foo reviews-v1.bar ratings-v1.baz`, // nolint: goimports Aliases: []string{"m"},
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 8.4K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
if len(matchingServices) == 0 && !ignoreUnmeshed { fmt.Fprintf(cmd.OutOrStdout(), "Warning: No Kubernetes Services select pod %s (see https://istio.io/docs/setup/kubernetes/additional-setup/requirements/ )\n", // nolint: lll kname(pod.ObjectMeta)) } // TODO look for port collisions between services targeting this pod kubeClient, err := ctx.CLIClientWithRevision(opts.Revision) if err != nil { return err
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 50.4K bytes - Viewed (0) -
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) -
istioctl/pkg/writer/ztunnel/configdump/connections.go
func (c *ConfigWriter) PrintConnectionsSummary(filter ConnectionsFilter) error { w := c.tabwriter() d := c.ztunnelDump serviceNames := map[string]string{} workloadNames := map[string]string{} for netIP, s := range d.Services { _, ip, _ := strings.Cut(netIP, "/") serviceNames[ip] = s.Hostname } for netIP, s := range d.Workloads { _, ip, _ := strings.Cut(netIP, "/") workloadNames[ip] = s.Name + "." + s.Namespace }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 15:39:28 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/admin-handlers.go
DrivesPerSet: backendInfo.DrivesPerSet, } if pools { poolsInfo, _ = getPoolsInfo(ctx, allDisks) } } domain := globalDomainNames services := madmin.Services{ KMS: fetchKMSStatus(), KMSStatus: fetchKMSStatusV2(ctx), LDAP: ldap, Logger: log, Audit: audit, Notifications: notifyTarget, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
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) -
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) -
istioctl/pkg/util/configdump/workload.go
Addresses []string `json:"addresses"` Ports map[string]int `json:"ports"` } type ZtunnelDump struct { Workloads map[string]*ZtunnelWorkload `json:"by_addr"` Services map[string]*ZtunnelService `json:"by_vip"` Certificates []*CertsDump `json:"certificates"` } type CertsDump struct { Identity string `json:"identity"` State string `json:"state"`
Go - Registered: Wed Apr 10 22:53:08 GMT 2024 - Last Modified: Fri Mar 22 16:24:22 GMT 2024 - 2.1K bytes - Viewed (0)