Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for UpdateList (0.13 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/api_object_versioner.go

    	}
    	versionString := ""
    	if resourceVersion != 0 {
    		versionString = strconv.FormatUint(resourceVersion, 10)
    	}
    	accessor.SetResourceVersion(versionString)
    	return nil
    }
    
    // UpdateList implements Versioner
    func (a APIObjectVersioner) UpdateList(obj runtime.Object, resourceVersion uint64, nextKey string, count *int64) error {
    	if resourceVersion == 0 {
    		return fmt.Errorf("illegal resource version from storage: %d", resourceVersion)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 11 15:19:32 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/helper/SearchLogHelper.java

                    entity.setId(userInfo.getId());
                    entity.setCreatedAt(userInfo.getCreatedAt());
                    updateList.add(entity);
                    insertList.remove(entity);
                });
                userInfoBhv.batchInsert(insertList);
                userInfoBhv.batchUpdate(updateList);
                searchLogList.stream().forEach(searchLog -> {
                    searchLog.getUserInfo().ifPresent(userInfo -> {
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/interfaces.go

    	// cannot be updated correctly. May return nil if the requested object does not need metadata
    	// from database.
    	UpdateObject(obj runtime.Object, resourceVersion uint64) error
    	// UpdateList sets the resource version into an API list object. Returns an error if the object
    	// cannot be updated correctly. May return nil if the requested object does not need metadata from
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 07:53:48 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go

    		if opts.Predicate.Empty() {
    			c := int64(getResp.Count - opts.Predicate.Limit)
    			remainingItemCount = &c
    		}
    		return s.versioner.UpdateList(listObj, uint64(withRev), next, remainingItemCount)
    	}
    
    	// no continuation
    	return s.versioner.UpdateList(listObj, uint64(withRev), "", nil)
    }
    
    // growSlice takes a slice value and grows its capacity up
    // to the maximum of the passed sizes or maxCapacity, whichever
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go

    	}
    	// currentStorageRV is taken from resp.Header.Revision (int64)
    	// and cast to uint64, so it is safe to do reverse
    	// at some point we should unify the interface but that
    	// would require changing  Versioner.UpdateList
    	return int64(currentStorageRV), nil
    }
    
    // isInitialEventsEndBookmarkRequired since there is no way to directly set
    // opts.ProgressNotify from the API and the etcd3 impl doesn't support
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 25 10:26:38 UTC 2023
    - 18.9K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    			listVal.Index(i).Set(reflect.ValueOf(o).Elem())
    		}
    	}
    	span.AddEvent("Filtered items", attribute.Int("count", listVal.Len()))
    	if c.versioner != nil {
    		if err := c.versioner.UpdateList(listObj, readResourceVersion, "", nil); err != nil {
    			return err
    		}
    	}
    	metrics.RecordListCacheMetrics(c.resourcePrefix, indexUsed, len(objs), listVal.Len())
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
Back to top