- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 162 for item$ (0.05 sec)
-
pkg/kubelet/util/manager/watch_based_manager.go
c.lock.Lock() defer c.lock.Unlock() if item, ok := c.items[key]; ok { item.refMap[referencedFrom]-- if item.refMap[referencedFrom] == 0 { delete(item.refMap, referencedFrom) } if len(item.refMap) == 0 { // Stop the underlying reflector. item.stop() delete(c.items, key) } } } // key returns key of an object with a given name and namespace.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
cmd/iam-object-store.go
res = make(map[string][]string) ctx, cancel := context.WithCancel(ctx) defer cancel() for item := range listIAMConfigItems(ctx, iamOS.objAPI, iamConfigPrefix+SlashSeparator) { if item.Err != nil { return nil, item.Err } lastIndex := strings.HasPrefix(item.Item, policyDBPrefix) listKey, trimmedItem := splitPath(item.Item, lastIndex) if listKey == iamFormatFile { continue }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 19.5K bytes - Viewed (0) -
pkg/kubelet/util/manager/cache_based_manager.go
// Then Get() is responsible for fetching if needed. s.lock.Lock() defer s.lock.Unlock() item, exists := s.items[key] if !exists { item = &objectStoreItem{ refCount: 0, data: &objectData{}, } s.items[key] = item } item.refCount++ // This will trigger fetch on the next Get() operation. item.data = nil } func (s *objectStore) DeleteReference(namespace, name string, _ types.UID) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 8.3K bytes - Viewed (0) -
docs/en/docs/tutorial/body-multiple-params.md
Let's say you only have a single `item` body parameter from a Pydantic model `Item`. By default, **FastAPI** will then expect its body directly. But if you want it to expect a JSON with a key `item` and inside of it the model contents, as it does when you declare extra body parameters, you can use the special `Body` parameter `embed`: ```Python item: Item = Body(embed=True) ``` as in:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sun Jun 09 02:01:51 UTC 2024 - 7.7K bytes - Viewed (0) -
tests/associations_has_many_test.go
LanguageCode string `gorm:"not null;type:varchar(2)"` } type Item struct { gorm.Model Logo string `gorm:"not null;type:varchar(50)"` Contents []ItemContent `gorm:"foreignKey:ItemID"` } tx := DB.Session(&gorm.Session{}) tx.Migrator().DropTable(&ItemContent{}, &Item{}) tx.AutoMigrate(&ItemContent{}, &Item{}) item := Item{ Logo: "logo", Contents: []ItemContent{
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Jun 12 10:49:45 UTC 2024 - 16K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go
"prefix/ns/pod3": *makeTestStoreElement(makeTestPod("pod3", 6)), } items := make(map[string]storeElement) for _, item := range store.List() { elem := item.(*storeElement) items[elem.Key] = *elem } if !apiequality.Semantic.DeepEqual(expected, items) { t.Errorf("expected %v, got %v", expected, items) } } // Test Replace. store.Replace([]interface{}{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 35.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval.go
} if exists { allItems = append(allItems, item) } } else { allItems = store.List() } buffer.buffer = make([]*watchCacheEvent, len(allItems)) for i, item := range allItems { elem, ok := item.(*storeElement) if !ok { return nil, fmt.Errorf("not a storeElement: %v", elem) } objLabels, objFields, err := getAttrsFunc(elem.Object) if err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
queue int } func (item *WorkChannelItem) Handle() { item.lock.Lock() defer item.lock.Unlock() if item.pause { item.queue++ return } item.out <- struct{}{} } func (item *WorkChannelItem) Hold() { item.lock.Lock() defer item.lock.Unlock() item.pause = true } func (item *WorkChannelItem) Close() { item.lock.Lock() defer item.lock.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/transforms/lower_static_tensor_list.cc
// |item| is expanded to have the same dimension as input_handle and // |index| is expanded to [index, 0, 0, ...] as the indices to input_handle. // On a high level, it's doing something like: // def : Pat<(TensorListSetItem($input_handle, $index, $item)), // (XlaDynamicUpdateSlice($input_handle, ExpandDims($item, 0),
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 11 20:00:43 UTC 2024 - 70.7K bytes - Viewed (0) -
analysis/analysis-api/src/org/jetbrains/kotlin/analysis/api/signatures/KtVariableLikeSignature.kt
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Tue Jun 11 15:45:42 UTC 2024 - 3.8K bytes - Viewed (0)