Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 441 for record (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top