- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 3,071 for wave (0.77 sec)
-
cmd/background-newdisks-heal-ops.go
h.ID, _ = h.disk.GetDiskID() h.PoolIndex, h.SetIndex, h.DiskIndex = h.disk.GetDiskLoc() } h.mu.Unlock() return h.save(ctx) } // save will unconditionally save the tracker and will be created if not existing. func (h *healingTracker) save(ctx context.Context) error { h.mu.Lock() if h.PoolIndex < 0 || h.SetIndex < 0 || h.DiskIndex < 0 { // Attempt to get location.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.5K bytes - Viewed (0) -
cmd/data-usage-cache.go
} return nil } // Maximum running concurrent saves on server. var maxConcurrentScannerSaves = make(chan struct{}, 4) // save the content of the cache to minioMetaBackgroundOpsBucket with the provided name. // Note that no locking is done when saving. func (d *dataUsageCache) save(ctx context.Context, store objectIO, name string) error { select { case <-ctx.Done(): return ctx.Err()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 34.7K bytes - Viewed (0) -
tests/hooks_test.go
DB.AutoMigrate(&Product{}) p := Product{Code: "Invalid", Price: 100} if DB.Save(&p).Error == nil { t.Fatalf("An error from before create callbacks happened when create with invalid value") } if DB.Where("code = ?", "Invalid").First(&Product{}).Error == nil { t.Fatalf("Should not save record that have errors") } if DB.Save(&Product{Code: "dont_save", Price: 100}).Error == nil {
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Mon Jun 17 03:59:06 UTC 2024 - 16.7K bytes - Viewed (0) -
internal/event/target/nsq.go
if xnet.IsConnRefusedErr(err) { return false, store.ErrNotConnected } return false, err } return true, nil } // Save - saves the events to the store which will be replayed when the nsq connection is active. func (target *NSQTarget) Save(eventData event.Event) error { if target.store != nil { _, err := target.store.Put(eventData) return err } if err := target.init(); err != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 7.1K bytes - Viewed (0) -
internal/event/target/webhook.go
return false, store.ErrNotConnected } return false, err } defer conn.Close() return true, nil } // Save - saves the events to the store if queuestore is configured, // which will be replayed when the webhook connection is active. func (target *WebhookTarget) Save(eventData event.Event) error { if target.store != nil { _, err := target.store.Put(eventData) return err }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.8K bytes - Viewed (0) -
ci/official/installer_wheel.sh
# Extract the package name from the wheel name. That is, extract every character # before the pattern "-py3-" in the wheel name. pkg_name=$(echo "${pure_python_whl}" | awk -F'-py3-' '{print $1}') # Save the current working directory and then switch to the output directory. pushd "${TFCI_OUTPUT_DIR}" # Unpack the wheel to get all the file contents. The pure python wheel we built
Registered: Tue Dec 30 12:39:10 UTC 2025 - Last Modified: Tue Mar 04 22:39:12 UTC 2025 - 3.5K bytes - Viewed (0) -
docs/en/docs/async.md
```Python hl_lines="2" @app.get('/') def results(): results = some_library() return results ``` ---
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sun Aug 31 09:56:21 UTC 2025 - 24K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Protocol.kt
* `INADEQUATE_SECURITY`. */ HTTP_2("h2"), /** * Cleartext HTTP/2 with no "upgrade" round trip. This option requires the client to have prior * knowledge that the server supports cleartext HTTP/2. * * See also [Starting HTTP/2 with Prior Knowledge][rfc_7540_34]. * * [rfc_7540_34]: https://datatracker.ietf.org/doc/html/rfc7540#autoid-10 */
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Jun 23 18:58:57 UTC 2025 - 4.4K bytes - Viewed (0) -
internal/event/target/redis.go
return false, store.ErrNotConnected } return false, pingErr } return true, nil } // Save - saves the events to the store if questore is configured, which will be replayed when the redis connection is active. func (target *RedisTarget) Save(eventData event.Event) error { if target.store != nil { _, err := target.store.Put(eventData) return err }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 9.1K bytes - Viewed (0) -
tests/gaussdb_test.go
} if err := DB.Where("id = $1", yasuo.ID).First(&Yasuo{}).Error; err != nil || yasuo.Name != "jinzhu" { t.Errorf("No error should happen, but got %v", err) } yasuo.Name = "jinzhu1" if err := DB.Save(&yasuo).Error; err != nil { t.Errorf("Failed to update date, got error %v", err) } if err := DB.First(&result, "id = ?", yasuo.ID).Error; err != nil || yasuo.Name != "jinzhu1" {
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Mon Jul 21 02:46:58 UTC 2025 - 6.6K bytes - Viewed (0)