- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for getMetrics (0.48 sec)
-
pkg/kubelet/server/stats/volume_stat_calculator_test.go
} } // Fake volume/metrics provider var _ volume.Volume = &fakeVolume{} type fakeVolume struct{} func (v *fakeVolume) GetPath() string { return "" } func (v *fakeVolume) GetMetrics() (*volume.Metrics, error) { return expectedMetrics(), nil } func expectedMetrics() *volume.Metrics { vMetrics := &volume.Metrics{ Available: resource.NewQuantity(available, resource.BinarySI),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 9.6K bytes - Viewed (0) -
pkg/config/mesh/mesh_test.go
if err != nil { t.Fatal(err) } if got.DefaultConfig.Tracing.GetZipkin() != nil { t.Error("Failed to override tracing") } if len(got.DefaultProviders.GetMetrics()) != 0 { t.Errorf("default providers deep merge failed, got %v", got.DefaultProviders.GetMetrics()) } if !cmp.Equal(getExtensionProviders(got.ExtensionProviders), []string{"prometheus", "stackdriver", "envoy", "sd"}, protocmp.Transform()) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 11.7K bytes - Viewed (0) -
pilot/pkg/model/telemetry.go
if len(metrics) == 0 { for _, dp := range mesh.GetDefaultProviders().GetMetrics() { // Insert the default provider. It has no overrides; presence of the key is sufficient to // get the filter created. providers[dp] = map[tpb.WorkloadMode]map[string]metricOverride{} } } providerNames := mesh.GetDefaultProviders().GetMetrics() for _, m := range metrics { names := getProviderNames(m.Providers)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 18:14:09 UTC 2024 - 35.2K bytes - Viewed (0) -
pkg/volume/volume.go
MetricsProvider } // MetricsProvider exposes metrics (e.g. used,available space) related to a // Volume. type MetricsProvider interface { // GetMetrics returns the Metrics for the Volume. Maybe expensive for // some implementations. GetMetrics() (*Metrics, error) } // Metrics represents the used and available bytes of the Volume. type Metrics struct { // The time at which these stats were updated.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 11.8K bytes - Viewed (0) -
cmd/metrics-realtime.go
} func collectRemoteMetrics(ctx context.Context, types madmin.MetricType, opts collectMetricsOpts) (m madmin.RealtimeMetrics) { if !globalIsDistErasure { return } all := globalNotificationSys.GetMetrics(ctx, types, opts) for _, remote := range all { m.Merge(&remote) } return m
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 05:16:24 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/volume/emptydir/empty_dir_test.go
t.Errorf("Unexpected error finding expected empty directory usage on tmpfs: %v", err) } // TODO(pwittroc): Move this into a reusable testing utility metrics, err := mounter.GetMetrics() if err != nil { t.Errorf("Unexpected error when calling GetMetrics %v", err) } if e, a := expectedEmptyDirUsage.Value(), metrics.Used.Value(); e != a { t.Errorf("Unexpected value for empty directory; expected %v, got %v", e, a) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 30.7K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
health *diskHealthTracker healthCheck bool metricsCache *cachevalue.Cache[DiskMetrics] diskCtx context.Context diskCancel context.CancelFunc } func (p *xlStorageDiskIDCheck) getMetrics() DiskMetrics { p.metricsCache.InitOnce(5*time.Second, cachevalue.Opts{}, func(ctx context.Context) (DiskMetrics, error) { diskMetric := DiskMetrics{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.4K bytes - Viewed (0) -
cmd/notification.go
} for index, err := range g.Wait() { if err != nil { sys.addNodeErr(&reply[index], sys.peerClients[index], err) } } return reply } // GetMetrics - Get metrics from all peers. func (sys *NotificationSys) GetMetrics(ctx context.Context, t madmin.MetricType, opts collectMetricsOpts) []madmin.RealtimeMetrics { reply := make([]madmin.RealtimeMetrics, len(sys.peerClients))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 44.9K bytes - Viewed (0) -
cmd/peer-rest-client.go
resp, err := getMemInfoRPC.Call(ctx, client.gridConn(), grid.NewMSS()) return resp.ValueOrZero(), err } // GetMetrics - fetch metrics from a remote node. func (client *peerRESTClient) GetMetrics(ctx context.Context, t madmin.MetricType, opts collectMetricsOpts) (info madmin.RealtimeMetrics, err error) { values := make(url.Values)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 26.1K bytes - Viewed (0) -
cmd/kube-proxy/app/server_test.go
gotMetrics := addressFromDeprecatedFlags(testCases[i].metricsBindAddress, testCases[i].metricsPort) errFn := func(name, except, got string) { t.Errorf("case %s: expected %v, got %v", name, except, got) } if gotHealthz != testCases[i].expHealthz { errFn(testCases[i].name, testCases[i].expHealthz, gotHealthz) } if gotMetrics != testCases[i].expMetrics {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 32.3K bytes - Viewed (0)