- Sort Score
- Num 10 results
- Language All
Results 1071 - 1080 of 1,336 for deflate (0.05 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)