- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 115 for Resource (4.34 sec)
-
cmd/metrics-resource.go
lastDriveStatsRefresh time.Time ) // PeerResourceMetrics represents the resource metrics // retrieved from a peer, along with errors if any type PeerResourceMetrics struct { Metrics map[MetricSubsystem]ResourceMetrics Errors []string } // ResourceMetrics is a map of unique key identifying // a resource metric (e.g. reads_per_sec_{node}_{drive}) // to its data type ResourceMetrics map[string]ResourceMetric
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug.go
// Gather the statuses before printing so they may be sorted mappedResp := map[string]string{} for id, dr := range drs { for _, resource := range dr.Resources { if s.InternalDebugAllIstiod { mappedResp[id] = string(resource.Value) + "\n" } else { _, _ = s.Writer.Write(resource.Value) _, _ = s.Writer.Write([]byte("\n")) } } } if len(mappedResp) > 0 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.9K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
} return nil } func ObjectToInstance(c controllers.Object) *resource.Instance { return &resource.Instance{ Origin: &legacykube.Origin{ Type: kubetypes.GvkFromObject(c), FullName: resource.FullName{ Namespace: resource.Namespace(c.GetNamespace()), Name: resource.LocalName(c.GetName()), }, ResourceVersion: resource.Version(c.GetResourceVersion()), Ref: nil,
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) -
istioctl/pkg/checkinject/checkinject.go
cmd := &cobra.Command{ Use: "check-inject [<type>/]<name>[.<namespace>]", Short: "Check the injection status or inject-ability of a given resource, explains why it is (or will be) injected or not", Long: ` Checks associated resources of the given resource, and running webhooks to examine whether the pod can be or will be injected or not.`, Example: ` # Check the injection status of a pod
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 9.3K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
if err != nil { return nil, fmt.Errorf("could not get XDS from the agent pod %q: %v", pod.Name, err) } for _, resource := range response.GetResources() { switch resource.GetTypeUrl() { case "type.googleapis.com/envoy.service.status.v3.ClientConfig": clientConfig := xdsstatus.ClientConfig{} err := resource.UnmarshalTo(&clientConfig) if err != nil { return nil, err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
cmd/metrics-v3-system-cpu.go
cpuNiceVal := math.Round(ts.Nice/tot*100*100) / 100 m.Set(sysCPUNice, cpuNiceVal) cpuStealVal := math.Round(ts.Steal/tot*100*100) / 100 m.Set(sysCPUSteal, cpuStealVal) // metrics-resource.go runs a job to collect resource metrics including their Avg values and // stores them in resourceMetricsMap. We can use it to get the Avg values of CPU idle and IOWait. cpuResourceMetrics, found := resourceMetricsMap[cpuSubsystem] if found {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 3K bytes - Viewed (0) -
istioctl/pkg/version/version.go
return func() (*[]istioVersion.ProxyInfo, error) { pi := []istioVersion.ProxyInfo{} for _, resource := range (*xdsResponse).Resources { switch resource.TypeUrl { case "type.googleapis.com/envoy.config.core.v3.Node": node := core.Node{} err := resource.UnmarshalTo(&node) if err != nil { return nil, fmt.Errorf("could not unmarshal Node: %w", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.3K bytes - Viewed (0) -
istioctl/pkg/wait/wait_test.go
watch.(addObject).Add(object) } } return true, watch, nil }) k.Dynamic().Resource(gvr.VirtualService).Namespace("default").Create(context.Background(), newUnstructured("networking.istio.io/v1alpha3", "virtualservice", "default", "foo", int64(1)), metav1.CreateOptions{}) k.Dynamic().Resource(gvr.VirtualService).Namespace("default").Create(context.Background(),
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 6.8K bytes - Viewed (1) -
cmd/sts-handlers_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
w := new(tabwriter.Writer).Init(s.Writer, 0, 8, 5, ' ', 0) _, _ = fmt.Fprintln(w, "NAME\tCLUSTER\tCDS\tLDS\tEDS\tRDS\tECDS\tISTIOD\tVERSION") for _, dr := range drs { for _, resource := range dr.Resources { clientConfig := xdsstatus.ClientConfig{} err := resource.UnmarshalTo(&clientConfig) if err != nil { return nil, nil, fmt.Errorf("could not unmarshal ClientConfig: %w", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0)