- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for relist (0.1 sec)
-
pkg/kubelet/pleg/generic.go
// error occurs during the inspection, we want PLEG to retry again // in the next relist. To achieve this, we do not update the // associated podRecord of the pod, so that the change will be // detect again in the next relist. // TODO: If many pods changed during the same relist period, // inspecting the pod and getting the PodStatus to update the cache
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
ResourceVersion: rv, } w.eventHandler(wcEvent) } metrics.RecordResourceVersion(w.groupResource.String(), rv) } // List returns list of pointers to <storeElement> objects. func (w *watchCache) List() []interface{} { return w.store.List() } // waitUntilFreshAndBlock waits until cache is at least as fresh as given <resourceVersion>. // NOTE: This function acquired lock and doesn't release it.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go
opts = append([]setupOption{withDefaults}, opts...) for _, opt := range opts { opt(&setupOpts) } server, etcdStorage := newEtcdTestStorage(t, etcd3testing.PathPrefix()) // Inject one list error to make sure we test the relist case. wrappedStorage := &storagetesting.StorageInjectingListErrors{ Interface: etcdStorage, Errors: 1, } config := Config{ Storage: wrappedStorage,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 17K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
func (ssc *StatefulSetController) deletePod(logger klog.Logger, obj interface{}) { pod, ok := obj.(*v1.Pod) // When a delete is dropped, the relist will notice a pod in the store not // in the list, leading to the insertion of a tombstone object which contains // the deleted key/value. Note that this value might be stale. if !ok { tombstone, ok := obj.(cache.DeletedFinalStateUnknown)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
if condition := findConditionByType(list, cType); condition != nil { if condition.Status != status || condition.Reason != reason || condition.Message != message { *condition = *newCondition(cType, status, reason, message, now) return list, true } return list, false } // A condition with that type doesn't exist in the list. if status != v1.ConditionFalse {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
pod := attrs.Pod newAllocatableResource := node.Allocatable.Clone() for _, container := range pod.Spec.Containers { for resource := range container.Resources.Requests { newQuantity, exist := updateResourceMap[resource] if !exist { continue } if newQuantity.Value() < 0 { return fmt.Errorf("Allocation failed") } newAllocatableResource.ScalarResources[resource] = newQuantity.Value()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
klet.kubeletConfiguration = *kubeCfg // Generating the status funcs should be the last thing we do, // since this relies on the rest of the Kubelet having been constructed. klet.setNodeStatusFuncs = klet.defaultNodeStatusFuncs() return klet, nil } type serviceLister interface { List(labels.Selector) ([]*v1.Service, error) } // Kubelet is the main kubelet implementation. type Kubelet struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (1) -
docs/metrics/prometheus/list.md
Shubhendu <******@****.***> 1718317614 +0530
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 43.3K bytes - Viewed (0) -
cmd/storage-rest-client.go
xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/rest" xnet "github.com/minio/pkg/v3/net" xbufio "github.com/philhofer/fwd" "github.com/tinylib/msgp/msgp" ) func isNetworkError(err error) bool { if err == nil { return false } if nerr, ok := err.(*rest.NetworkError); ok { if down := xnet.IsNetworkOrHostDown(nerr.Err, false); down { return true }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.4K bytes - Viewed (0) -
cmd/storage-rest-common.go
Anis Eleuch <******@****.***> 1718034687 +0100
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 2.9K bytes - Viewed (0)