Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for UpdateObjectCount (0.2 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/etcd3/metrics/metrics.go

    		legacyregistry.MustRegister(listStorageNumSelectorEvals)
    		legacyregistry.MustRegister(listStorageNumReturned)
    		legacyregistry.MustRegister(decodeErrorCounts)
    	})
    }
    
    // UpdateObjectCount sets the apiserver_storage_object_counts metric.
    func UpdateObjectCount(resourcePrefix string, count int64) {
    	objectCounts.WithLabelValues(resourcePrefix).Set(float64(count))
    }
    
    // RecordEtcdRequest updates and sets the etcd_request_duration_seconds,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 21:15:32 UTC 2024
    - 11K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/etcd3/metrics/metrics_test.go

    apiserver_storage_objects{resource="bar"} -1
    `,
    		},
    	}
    
    	for _, test := range testCases {
    		t.Run(test.desc, func(t *testing.T) {
    			defer registry.Reset()
    			UpdateObjectCount(test.resource, test.count)
    			if err := testutil.GatherAndCompare(registry, strings.NewReader(test.want), testedMetrics); err != nil {
    				t.Fatal(err)
    			}
    		})
    	}
    }
    
    type fakeEtcdMonitor struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 21:15:32 UTC 2024
    - 10.2K bytes
    - Viewed (0)
Back to top