- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 634 for epmetrics (0.21 sec)
-
pkg/volume/metrics_nil_test.go
func TestMetricsNilSupportsMetrics(t *testing.T) { metrics := &MetricsNil{} supported := metrics.SupportsMetrics() if supported { t.Error("Expected no support for metrics") } } func TestMetricsNilGetCapacity(t *testing.T) { metrics := &MetricsNil{} actual, err := metrics.GetMetrics() expected := &Metrics{} if *actual != *expected { t.Errorf("Expected empty Metrics, actual %v", *actual) } if err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 20 15:10:23 UTC 2021 - 1.1K bytes - Viewed (0) -
cmd/metrics-v3-cluster-health.go
"Count of online drives in the cluster") healthDrivesCountMD = NewGaugeMD(healthDrivesCount, "Count of all drives in the cluster") ) // loadClusterHealthDriveMetrics - `MetricsLoaderFn` for cluster storage drive metrics // such as online, offline and total drives. func loadClusterHealthDriveMetrics(ctx context.Context, m MetricValues, c *metricsCache, ) error { clusterDriveMetrics, _ := c.clusterDriveMetrics.Get()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Mar 10 09:15:15 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/volume/metrics_cached.go
// See MetricsProvider.GetMetrics func (md *cachedMetrics) GetMetrics() (*Metrics, error) { md.once.cache(func() error { md.resultMetrics, md.resultError = md.wrapped.GetMetrics() return md.resultError }) return md.resultMetrics, md.resultError } // Copied from sync.Once but we don't want to cache the results if there is an // error type cacheOnce struct { m sync.Mutex done uint32 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 16 11:12:06 UTC 2022 - 1.9K bytes - Viewed (0) -
pkg/volume/metrics_nil.go
// Metrics. It serves as a placeholder for Volumes that do not yet support // metrics. type MetricsNil struct{} // SupportsMetrics returns false for the MetricsNil type. func (*MetricsNil) SupportsMetrics() bool { return false } // GetMetrics returns an empty Metrics and an error. // See MetricsProvider.GetMetrics func (*MetricsNil) GetMetrics() (*Metrics, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 20 15:10:23 UTC 2021 - 1.1K bytes - Viewed (0) -
pkg/kubelet/stats/host_stats_provider_fake.go
} return result, nil } type fakeMetricsDu struct { fakeStats *volume.Metrics } // NewFakeMetricsDu inserts fake statistics when asked for metrics func NewFakeMetricsDu(path string, stats *volume.Metrics) volume.MetricsProvider { return &fakeMetricsDu{fakeStats: stats} } func (f *fakeMetricsDu) GetMetrics() (*volume.Metrics, error) { if f.fakeStats == nil { return nil, fmt.Errorf("no stats provided") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 17:57:17 UTC 2024 - 3.9K bytes - Viewed (0) -
hack/verify-generated-stable-metrics.sh
# See the License for the specific language governing permissions and # limitations under the License. # This script runs to ensure that we do not violate metric stability # policies. # Usage: `hack/verify-generated-stable-metrics.sh`. set -o errexit set -o nounset set -o pipefail KUBE_ROOT=$(dirname "${BASH_SOURCE[0]}")/.. source "${KUBE_ROOT}/test/instrumentation/stability-utils.sh"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 05 18:48:48 UTC 2021 - 928 bytes - Viewed (0) -
cmd/metrics-v3-cluster-notification.go
) // loadClusterNotificationMetrics - `MetricsLoaderFn` for cluster notification metrics. func loadClusterNotificationMetrics(_ context.Context, m MetricValues, _ *metricsCache) error { if globalEventNotifier == nil { return nil } nstats := globalEventNotifier.targetList.Stats()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Apr 24 04:10:35 UTC 2024 - 2.2K bytes - Viewed (0) -
tensorflow/compat_template.__init__.py
setattr(_current_module, "enable_v2_behavior", enable_v2_behavior) # Add module aliases _losses = _KerasLazyLoader( globals(), submodule="losses", name="losses", mode="v2") _metrics = _KerasLazyLoader( globals(), submodule="metrics", name="metrics", mode="v2") _optimizers = _KerasLazyLoader( globals(), submodule="optimizers", name="optimizers", mode="v2") _initializers = _KerasLazyLoader(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jan 23 02:14:00 UTC 2024 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/dispatcher.go
Binding: binding, PolicyDecision: decision, }) celmetrics.Metrics.ObserveRejection(ctx, decision.Elapsed, definition.Name, binding.Name, "active") case admissionregistrationv1.Audit: publishValidationFailureAnnotation(binding, i, decision, versionedAttr) celmetrics.Metrics.ObserveAudit(ctx, decision.Elapsed, definition.Name, binding.Name, "active")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 14.4K bytes - Viewed (0) -
manifests/charts/istiod-remote/templates/configmap.yaml
{{ $prom := include "default-prometheus" . | eq "true" }} {{ $sdMetrics := include "default-sd-metrics" . | eq "true" }} {{ $sdLogs := include "default-sd-logs" . | eq "true" }} {{- if or $prom $sdMetrics $sdLogs }} defaultProviders: {{- if or $prom $sdMetrics }} metrics: {{ if $prom }}- prometheus{{ end }} {{ if and $sdMetrics $sdLogs }}- stackdriver{{ end }} {{- end }}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 18:16:49 UTC 2024 - 4.9K bytes - Viewed (0)