- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 150 for newFunc (0.16 sec)
-
callbacks/create_test.go
Email: "email", Age: 18, }, { ID: 2, Name: "bob", Email: "email", Age: 19, }, } stmt := &gorm.Statement{ DB: &gorm.DB{ Config: &gorm.Config{ NowFunc: func() time.Time { return time.Time{} }, }, Statement: &gorm.Statement{ Settings: sync.Map{}, Schema: s, }, }, ReflectValue: reflect.ValueOf(dest), Dest: dest, }
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Mon Mar 18 05:48:42 UTC 2024 - 1.4K bytes - Viewed (0) -
pkg/registry/certificates/certificates/strategy_test.go
} }) } } func TestStatusUpdate(t *testing.T) { now := metav1.Now() later := metav1.NewTime(now.Add(time.Hour)) nowFunc = func() metav1.Time { return now } defer func() { nowFunc = metav1.Now }() tests := []struct { name string newObj *certapi.CertificateSigningRequest oldObj *certapi.CertificateSigningRequest
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 14:34:53 UTC 2024 - 7.6K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.29.md
- If a watch with the `progressNotify` option set is to be created, and the registry hasn't provided a `newFunc`, return an error. ([#120212](https://github.com/kubernetes/kubernetes/pull/120212), [@p0lyn0mial](https://github.com/p0lyn0mial)) [SIG API Machinery]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 03:42:38 UTC 2024 - 324.5K bytes - Viewed (0) -
pkg/registry/certificates/certificates/strategy.go
retval = append(retval, i) } } return retval } // nowFunc allows overriding for unit tests var nowFunc = metav1.Now // populateConditionTimestamps sets LastUpdateTime and LastTransitionTime in newCSR if missing func populateConditionTimestamps(newCSR, oldCSR *certificates.CertificateSigningRequest) { now := nowFunc() for i := range newCSR.Status.Conditions {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 18 21:41:43 UTC 2022 - 11.4K bytes - Viewed (0) -
src/runtime/runtime.go
name string inc atomic.Pointer[func()] } func (g *godebugInc) IncNonDefault() { inc := g.inc.Load() if inc == nil { newInc := godebugNewIncNonDefault.Load() if newInc == nil { return } inc = new(func()) *inc = (*newInc)(g.name) if raceenabled { racereleasemerge(unsafe.Pointer(&g.inc)) } if !g.inc.CompareAndSwap(nil, inc) { inc = g.inc.Load() } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:47 UTC 2024 - 9.9K bytes - Viewed (0) -
soft_delete.go
} func (sd SoftDeleteDeleteClause) MergeClause(*clause.Clause) { } func (sd SoftDeleteDeleteClause) ModifyStatement(stmt *Statement) { if stmt.SQL.Len() == 0 && !stmt.Statement.Unscoped { curTime := stmt.DB.NowFunc() stmt.AddClause(clause.Set{{Column: clause.Column{Name: sd.Field.DBName}, Value: curTime}}) stmt.SetColumn(sd.Field.DBName, curTime, true) if stmt.Schema != nil {
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Feb 01 06:40:55 UTC 2023 - 4.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/sparsecore/embedding_sequencing.cc
auto caller = MakeFuncCaller(builder, module.getLoc(), new_func, inputs); Block* block = new_func.addEntryBlock(); for (Operation* op : topological_order) op->moveBefore(block, block->end()); // Replace the 'inputs' values with the new function's arguments. for (auto p : llvm::zip(inputs, new_func.getArguments())) replaceAllUsesInRegionWith(std::get<0>(p), std::get<1>(p),
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 39.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/envelope.go
// key ID related error codes for metrics errKeyIDOKCode ErrCodeKeyID = "ok" errKeyIDEmptyCode ErrCodeKeyID = "empty" errKeyIDTooLongCode ErrCodeKeyID = "too_long" ) // NowFunc is exported so tests can override it. var NowFunc = time.Now type StateFunc func() (State, error) type ErrCodeKeyID string type State struct { Transformer value.Transformer EncryptedObject kmstypes.EncryptedObject
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 00:23:50 UTC 2023 - 18.7K bytes - Viewed (0) -
pkg/kubelet/nodestatus/setters_test.go
"Diff: %s", cmp.Diff(expectNode, node)) }) } } func TestReadyCondition(t *testing.T) { now := time.Now() before := now.Add(-time.Second) nowFunc := func() time.Time { return now } withCapacity := &v1.Node{ Status: v1.NodeStatus{ Capacity: v1.ResourceList{ v1.ResourceCPU: *resource.NewMilliQuantity(2000, resource.DecimalSI),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 21:47:24 UTC 2024 - 76.1K bytes - Viewed (0) -
pkg/registry/core/persistentvolume/storage/storage_test.go
hostPathType := new(api.HostPathType) *hostPathType = api.HostPathType(pathType) return hostPathType } func validNewPersistentVolume(name string) *api.PersistentVolume { now := persistentvolume.NowFunc() pv := &api.PersistentVolume{ ObjectMeta: metav1.ObjectMeta{ Name: name, }, Spec: api.PersistentVolumeSpec{ Capacity: api.ResourceList{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 7.4K bytes - Viewed (0)