- Sort Score
- Result 10 results
- Languages All
Results 271 - 280 of 441 for record (0.24 sec)
-
cmd/peer-rest-server.go
buf := bytes.NewBuffer(grid.GetByteBuffer()) enc := json.NewEncoder(buf) tmpEvt := struct{ Records []event.Event }{[]event.Event{{}}} for { select { case <-ctx.Done(): grid.PutByteBuffer(buf.Bytes()) return nil case ev := <-ch: buf.Reset() tmpEvt.Records[0] = ev if err := enc.Encode(tmpEvt); err != nil { peersLogOnceIf(ctx, err, "event: Encode failed") continue
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 53.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt
private var lastTimestampNs: Long? = null /** Confirm that the thread does not hold a lock on `lock` during the callback. */ fun forbidLock(lock: Any) { forbiddenLocks.add(lock) } /** * Removes recorded events up to (and including) an event is found whose class equals [eventClass] * and returns it. */ fun <T : CallEvent> removeUpToEvent(eventClass: Class<T>): T { val fullEventSequence = eventSequence.toList()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
} return nil } return err } func (c *esClientV7) updateEntry(ctx context.Context, index string, key string, eventData event.Event) error { doc := map[string]interface{}{ "Records": []event.Event{eventData}, } var buf bytes.Buffer enc := json.NewEncoder(&buf) err := enc.Encode(doc) if err != nil { return err } res, err := c.Index( index, &buf,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 15K bytes - Viewed (0) -
build-logic/buildquality/build.gradle.kts
plugins { id("gradlebuild.build-logic.kotlin-dsl-gradle-plugin") } description = "Provides plugins to configure quality checks (incubating report, CodeNarc, et al)" dependencies { implementation("gradlebuild:basics") implementation(projects.cleanup) implementation(projects.documentation) implementation(projects.integrationTesting) implementation(projects.performanceTesting) implementation(projects.profiling)
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Sep 11 14:21:47 UTC 2024 - 1.1K bytes - Viewed (0) -
docs/de/docs/advanced/websockets.md
Sie können Binär-, Text- und JSON-Daten empfangen und senden. ## Es ausprobieren Wenn Ihre Datei `main.py` heißt, führen Sie Ihre Anwendung so aus: <div class="termy"> ```console $ uvicorn main:app --reload <span style="color: green;">INFO</span>: Uvicorn running on http://127.0.0.1:8000 (Press CTRL+C to quit) ``` </div>
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 6.9K bytes - Viewed (0) -
docs/zh-hant/docs/fastapi-cli.md
## `fastapi dev` 執行 `fastapi dev` 會啟動開發模式。 預設情況下,**auto-reload** 功能是啟用的,當你對程式碼進行修改時,伺服器會自動重新載入。這會消耗較多資源,並且可能比禁用時更不穩定。因此,你應該只在開發環境中使用此功能。它也會在 IP 位址 `127.0.0.1` 上監聽,這是用於你的機器與自身通訊的 IP 位址(`localhost`)。 ## `fastapi run` 執行 `fastapi run` 會以生產模式啟動 FastAPI。 預設情況下,**auto-reload** 功能是禁用的。它也會在 IP 位址 `0.0.0.0` 上監聽,表示會監聽所有可用的 IP 地址,這樣任何能與該機器通訊的人都可以公開存取它。這通常是你在生產環境中運行應用程式的方式,例如在容器中運行時。
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Oct 18 12:12:01 UTC 2024 - 6.1K bytes - Viewed (0) -
internal/s3select/genmessage.go
buf.WriteByte(7) buf.Write([]byte{0, 24}) buf.WriteString("application/octet-stream") buf.WriteByte(11) buf.WriteString(":event-type") buf.WriteByte(7) buf.Write([]byte{0, 7}) buf.WriteString("Records") fmt.Println(buf.Bytes()) } // Continuation Message // ==================== // Header specification // -------------------- // Continuation messages contain two headers, as follows:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 19 01:35:22 UTC 2021 - 4.4K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.11.md
* Fix for kube-dns returns NXDOMAIN when not yet synced with apiserver. * Don't generate empty record for externalName service. * Add validation for upstreamNameserver port. * Update go version to 1.9.3.
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Thu Feb 06 06:04:15 UTC 2020 - 328.4K bytes - Viewed (0) -
dbflute_fess/dfprop/documentMap.dfprop
# You can set LoadDataReverse settings. # This property is valid when the property 'recordLimit' is set. # Elements of this map are as below: # o recordLimit: The limit of records to output. Minus means no limit. (NotRequired - Default '') # o isReplaceSchemaDirectUse: Does it output the data to playsql directly? (NotRequired - Default false)
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sat Oct 31 23:35:14 UTC 2015 - 9.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
private var lastTimestampNs: Long? = null /** Confirm that the thread does not hold a lock on `lock` during the callback. */ fun forbidLock(lock: Any) { forbiddenLocks.add(lock) } /** * Removes recorded events up to (and including) an event is found whose class equals [eventClass] * and returns it. */ fun <T : ConnectionEvent> removeUpToEvent(eventClass: Class<T>): T { val fullEventSequence = eventSequence.toList()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.6K bytes - Viewed (0)