Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 162 for item$ (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. analysis/analysis-api/src/org/jetbrains/kotlin/analysis/api/signatures/KtVariableLikeSignature.kt

                // The case where PSI is null is when calling `invoke()` on a variable with functional type, e.g. `x(1)` below:
                //
                //   fun foo(x: (item: Int) -> Unit) { x(1) }
                //   fun bar(x: Function1<@ParameterName("item") Int, Unit>) { x(1) }
                val nameCanBeDeclaredInAnnotation = symbol.psi == null
    
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Tue Jun 11 15:45:42 UTC 2024
    - 3.8K bytes
    - Viewed (0)
Back to top