- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 262 for now (0.01 seconds)
-
cmd/signature-v4_test.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 10.5K bytes - Click Count (0) -
schema/field_test.go
user = tests.User{ Model: gorm.Model{ ID: 10, CreatedAt: time.Now(), UpdatedAt: time.Now(), DeletedAt: gorm.DeletedAt{Time: time.Now(), Valid: true}, }, Name: "valuer_and_setter", Age: 18, Birthday: tests.Now(), Active: true, } reflectValue = reflect.ValueOf(&user) ) // test valuer values := map[string]interface{}{Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sat Feb 19 09:02:53 GMT 2022 - 12.7K bytes - Click Count (0) -
internal/bucket/lifecycle/lifecycle.go
} // Eval returns the lifecycle event applicable now. func (lc Lifecycle) Eval(obj ObjectOpts) Event { return lc.eval(obj, time.Now().UTC(), 0) } // eval returns the lifecycle event applicable at the given now. If now is the // zero value of time.Time, it returns the upcoming lifecycle event. func (lc Lifecycle) eval(obj ObjectOpts, now time.Time, remainingVersions int) Event { var events []Event
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Apr 03 06:45:06 GMT 2025 - 18.2K bytes - Click Count (0) -
internal/grid/benchmark_test.go
defer cancel() b.ReportAllocs() b.SetBytes(int64(len(payload) * 2)) b.ResetTimer() t := time.Now() var ops int64 var lat int64 b.SetParallelism(par) b.RunParallel(func(pb *testing.PB) { rng := rand.New(rand.NewSource(time.Now().UnixNano())) n := 0 var latency int64 managers := grid.Managers hosts := grid.Hosts for pb.Next() {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.5K bytes - Click Count (0) -
internal/lru/lru.go
func (c *LRU[K, V]) Add(key K, value V) (evicted bool) { c.mu.Lock() defer c.mu.Unlock() now := time.Now() // Check for existing item if ent, ok := c.items[key]; ok { c.evictList.MoveToFront(ent) c.removeFromBucket(ent) // remove the entry from its current bucket as expiresAt is renewed ent.Value = value ent.ExpiresAt = now.Add(c.ttl) c.addToBucket(ent) return false } // Add new item
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Fri Apr 25 08:22:26 GMT 2025 - 12.5K bytes - Click Count (0) -
cmd/data-scanner_test.go
t.Fatalf("Failed to marshal versioning config: %v", err) } bucket := "bucket" now := time.Now() meta := BucketMetadata{ Name: bucket, Created: now, LifecycleConfigXML: []byte(lcXML), VersioningConfigXML: vcfgXML, VersioningConfigUpdatedAt: now, LifecycleConfigUpdatedAt: now, lifecycleConfig: lc, versioningConfig: &vcfg, }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12K bytes - Click Count (0) -
cmd/erasure-server-pool-rebalance.go
case rebalErr := <-doneCh: quit = true notify = true now := time.Now() var status rebalStatus switch { case errors.Is(rebalErr, context.Canceled): status = rebalStopped traceMsg = fmt.Sprintf("stopped at %s", now) case rebalErr == nil: status = rebalCompleted traceMsg = fmt.Sprintf("completed at %s", now) default: status = rebalFailedCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 28.7K bytes - Click Count (0) -
docs/en/docs/tutorial/sql-databases.md
<img src="/img/tutorial/sql-databases/image01.png"> </div> ## Update the App with Multiple Models { #update-the-app-with-multiple-models } Now let's **refactor** this app a bit to increase **security** and **versatility**. If you check the previous app, in the UI you can see that, up to now, it lets the client decide the `id` of the `Hero` to create. 😱
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Tue Dec 02 05:06:56 GMT 2025 - 15.8K bytes - Click Count (0) -
internal/grid/grid_test.go
start := time.Now() resp, err := remoteConn.Request(t.Context(), handlerTest, []byte(testPayload)) errFatal(err) if string(resp) != testPayload { t.Errorf("want %q, got %q", testPayload, string(resp)) } t.Log("Roundtrip:", time.Since(start)) }) t.Run("localToRemoteErr", func(t *testing.T) { const testPayload = "Hello Grid World!" start := time.Now()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 36.1K bytes - Click Count (0) -
internal/config/identity/plugin/config.go
ticker := time.NewTicker(healthCheckInterval) defer ticker.Stop() for { select { case <-ticker.C: now := time.Now() isConnected := o.checkConnectivity(o.shutdownCtx) if isConnected { o.serviceMetrics.setConnSuccess(now) } else { o.serviceMetrics.setConnFailure(now) } case <-o.shutdownCtx.Done(): return } } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 13.3K bytes - Click Count (0)