- Sort Score
- Num 10 results
- Language All
Results 711 - 720 of 880 for resync (0.07 seconds)
-
docs/zh/docs/tutorial/first-steps.md
这是一个 Python 函数。 每当 **FastAPI** 接收一个使用 `GET` 方法访问 URL「`/`」的请求时这个函数会被调用。 在这个例子中,它是一个 `async` 函数。 --- 你也可以将其定义为常规函数而不使用 `async def`: {* ../../docs_src/first_steps/tutorial003_py310.py hl[7] *} /// note 如果你不知道两者的区别,请查阅 [并发: *赶时间吗?*](../async.md#in-a-hurry)。 /// ### 步骤 5:返回内容 { #step-5-return-the-content }Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 17:06:37 GMT 2026 - 13.3K bytes - Click Count (0) -
cmd/bucket-replication-utils_gen.go
case "lst": z.LastUpdate, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "LastUpdate") return } case "id": z.ResyncID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "ResyncID") return } case "rdt": z.ResyncBeforeDate, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "ResyncBeforeDate") return
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 59.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
} @Override public void run() { InterruptibleTask<?> localTask = task; if (localTask != null) { localTask.run(); } /* * In the Async case, we may have called setFuture(pendingFuture), in which case afterDone() * won't have been called yet. */ this.task = null; } @Override protected void afterDone() { super.afterDone();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 5.5K bytes - Click Count (0) -
cmd/bitrot-streaming.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "bytes" "context" "errors" "hash" "io" "sync" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/ringbuffer" ) // Calculates bitrot in chunks and writes the hash into the stream.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jan 17 19:19:30 GMT 2025 - 6.2K bytes - Click Count (0) -
docs/en/docs/advanced/custom-response.md
### `StreamingResponse` { #streamingresponse } Takes an async generator or a normal generator/iterator (a function with `yield`) and streams the response body. {* ../../docs_src/custom_response/tutorial007_py310.py hl[3,16] *} /// note | Technical DetailsCreated: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 11K bytes - Click Count (0) -
cmd/bucket-replication-metrics.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "fmt" "sync" "sync/atomic" "time" "github.com/rcrowley/go-metrics" ) //go:generate msgp -file $GOFILE const ( // beta is the weight used to calculate exponential moving average
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 15 12:04:40 GMT 2024 - 14.2K bytes - Click Count (0) -
docs/tr/docs/advanced/custom-response.md
### `StreamingResponse` { #streamingresponse } Bir async generator veya normal generator/iterator (içinde `yield` olan bir fonksiyon) alır ve response body’yi stream eder. {* ../../docs_src/custom_response/tutorial007_py310.py hl[3,16] *} /// note | Teknik DetaylarCreated: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 07:53:17 GMT 2026 - 11.9K bytes - Click Count (0) -
docs/ru/llm-prompt.md
* mount (noun): точка монтирования / mount (keep in English if it's a FastAPI keyword) * plugin: плагин * plug-in: плагин * full stack: full stack (do not translate) * full-stack: full-stack (do not translate) * loop (as in async loop): цикл событий * Machine Learning: Машинное обучение * Deep Learning: Глубокое обучение * callback hell: callback hell (clarify as `ад обратных вызовов`) * on the fly: на лету
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Jan 22 07:07:05 GMT 2026 - 6.5K bytes - Click Count (0) -
cmd/bootstrap-peer-server.go
clnts := newBootstrapRESTClients(endpointServerPools, gm) var onlineServers int var offlineEndpoints []error var incorrectConfigs []error var retries int var mu sync.Mutex for onlineServers < len(clnts)/2 { var wg sync.WaitGroup wg.Add(len(clnts)) onlineServers = 0 for _, clnt := range clnts { go func(clnt *bootstrapRESTClient) { defer wg.Done()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Oct 01 22:13:18 GMT 2024 - 8.4K bytes - Click Count (0) -
build-tools-internal/src/main/groovy/elasticsearch.build-scan.gradle
"to:${System.currentTimeMillis() + TimeUnit.MILLISECONDS.convert(5, TimeUnit.MINUTES)}))" } } // Jenkins-specific build scan metadata if (jenkinsUrl) { // Disable async upload in CI to ensure scan upload completes before CI agent is terminated uploadInBackground = false // Parse job name in the case of matrix buildsCreated: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Wed Jul 21 20:40:34 GMT 2021 - 4.6K bytes - Click Count (0)