Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1071 - 1080 of 1,336 for deflate (0.05 seconds)

  1. internal/event/targetlist.go

    func (list *TargetList) Remove(targetIDSet TargetIDSet) {
    	list.Lock()
    	defer list.Unlock()
    
    	for id := range targetIDSet {
    		target, ok := list.targets[id]
    		if ok {
    			target.Close()
    			delete(list.targets, id)
    		}
    	}
    }
    
    // Targets - list all targets
    func (list *TargetList) Targets() []Target {
    	if list == nil {
    		return []Target{}
    	}
    
    	list.RLock()
    	defer list.RUnlock()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  2. internal/event/target/amqp.go

    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    	if err := target.send(eventData, ch, confirms); err != nil {
    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Close - does nothing and available for interface compatibility.
    func (target *AMQPTarget) Close() error {
    	close(target.quitCh)
    	if target.conn != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 21 04:25:07 GMT 2025
    - 10K bytes
    - Click Count (0)
  3. cmd/admin-handlers_test.go

    	// request UID, but 10 different resource names associated with it.
    	var lris []lockRequesterInfo
    	uuid := mustGetUUID()
    	for i := range 10 {
    		resource := fmt.Sprintf("bucket/delete-object-%d", i)
    		lri := lockRequesterInfo{
    			Name:   resource,
    			Writer: true,
    			UID:    uuid,
    			Owner:  owners[i%len(owners)],
    			Group:  true,
    			Quorum: 3,
    		}
    		lris = append(lris, lri)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.9K bytes
    - Click Count (1)
  4. cmd/globals.go

    	globalOperationTimeout       = newDynamicTimeout(10*time.Minute, 5*time.Minute) // default timeout for general ops
    	globalDeleteOperationTimeout = newDynamicTimeout(5*time.Minute, 1*time.Minute)  // default time for delete ops
    
    	globalBucketObjectLockSys *BucketObjectLockSys
    	globalBucketQuotaSys      *BucketQuotaSys
    	globalBucketVersioningSys *BucketVersioningSys
    
    	// Allocated etcd endpoint for config and bucket DNS.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Sep 03 18:23:41 GMT 2024
    - 16.2K bytes
    - Click Count (1)
  5. tests/migrate_test.go

    	ids := make([]int64, 0, len(rows))
    	for _, row := range rows {
    		ids = append(ids, row.ID)
    	}
    	lastID := ids[len(ids)-1]
    
    	if err := DB.Where("id IN (?)", ids).Delete(&AutoIncrementStruct{}).Error; err != nil {
    		t.Fatalf("delete auto_increment_struct fail, err: %v", err)
    	}
    
    	newRow := &AutoIncrementStruct{}
    	if err := DB.Create(newRow).Error; err != nil {
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:49:01 GMT 2026
    - 66.3K bytes
    - Click Count (0)
  6. CHANGELOG/CHANGELOG-1.11.md

    * kubelets are no longer allowed to delete their own Node API object. Prior to 1.11, in rare circumstances related to cloudprovider node ID changes, kubelets would attempt to delete/recreate their Node object at startup. If a legacy kubelet encounters this situation, a cluster admin can remove the Node object: `kubectl delete node/<nodeName>` ([#62818](https://github.com/kubernetes/kubernetes/pull/62818), [@mikedanese](https://g...
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Feb 06 06:04:15 GMT 2020
    - 328.4K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/opensearch/log/cbean/cq/bs/BsUserInfoCQ.java

    import java.util.ArrayList;
    import java.util.Collection;
    
    import org.codelibs.fess.opensearch.log.allcommon.EsAbstractConditionQuery;
    import org.codelibs.fess.opensearch.log.cbean.cq.UserInfoCQ;
    import org.dbflute.cbean.ckey.ConditionKey;
    import org.opensearch.index.query.BoolQueryBuilder;
    import org.opensearch.index.query.CommonTermsQueryBuilder;
    import org.opensearch.index.query.ExistsQueryBuilder;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 20.1K bytes
    - Click Count (0)
  8. docs/pt/docs/tutorial/dependencies/index.md

    ///
    
    ### Importando `Depends` { #import-depends }
    
    {* ../../docs_src/dependencies/tutorial001_an_py310.py hl[3] *}
    
    ### Declarando a dependência, no "dependente" { #declare-the-dependency-in-the-dependant }
    
    Da mesma forma que você utiliza `Body`, `Query`, etc. Como parâmetros de sua *função de operação de rota*, utilize `Depends` com um novo parâmetro:
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:20:43 GMT 2026
    - 10.6K bytes
    - Click Count (0)
  9. docs/zh-hant/docs/tutorial/schema-extra-example.md

    # 宣告請求範例資料 { #declare-request-example-data }
    
    你可以宣告你的應用程式可接收資料的 examples。
    
    以下有數種方式可達成。
    
    ## Pydantic 模型中的額外 JSON Schema 資料 { #extra-json-schema-data-in-pydantic-models }
    
    你可以為 Pydantic 模型宣告 `examples`,它們會加入到產生出的 JSON Schema 中。
    
    {* ../../docs_src/schema_extra_example/tutorial001_py310.py hl[13:24] *}
    
    這些額外資訊會原封不動加入該模型輸出的 JSON Schema,並且會用在 API 文件裡。
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 17:05:38 GMT 2026
    - 8.4K bytes
    - Click Count (0)
  10. src/test/java/org/codelibs/fess/helper/SuggestHelperTest.java

            }
    
            public MockBadWordSettings badword() {
                return new MockBadWordSettings();
            }
        }
    
        private static class MockArraySettings {
            public void delete(String key) {
                // Mock implementation
            }
    
            public void add(String key, String value) {
                // Mock implementation
            }
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 16.3K bytes
    - Click Count (0)
Back to Top