Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 27 of 27 for newFunc (0.22 sec)

  1. pkg/registry/core/persistentvolume/strategy_test.go

    	)
    }
    
    func TestStatusUpdate(t *testing.T) {
    	now := metav1.Now()
    	origin := metav1.NewTime(now.Add(time.Hour))
    	later := metav1.NewTime(now.Add(time.Hour * 2))
    	NowFunc = func() metav1.Time { return now }
    	defer func() {
    		NowFunc = metav1.Now
    	}()
    	tests := []struct {
    		name        string
    		fg          bool
    		oldObj      *api.PersistentVolume
    		newObj      *api.PersistentVolume
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 11K bytes
    - Viewed (0)
  2. pkg/kubelet/nodestatus/setters.go

    func MemoryPressureCondition(nowFunc func() time.Time, // typically Kubelet.clock.Now
    	pressureFunc func() bool, // typically Kubelet.evictionManager.IsUnderMemoryPressure
    	recordEventFunc func(eventType, event string), // typically Kubelet.recordNodeStatusEvent
    ) Setter {
    	return func(ctx context.Context, node *v1.Node) error {
    		currentTime := metav1.NewTime(nowFunc())
    		var condition *v1.NodeCondition
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 12:12:04 UTC 2024
    - 30.5K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. callbacks/create.go

    				}
    			}
    			return called
    		})
    	}
    }
    
    // ConvertToCreateValues convert to create values
    func ConvertToCreateValues(stmt *gorm.Statement) (values clause.Values) {
    	curTime := stmt.DB.NowFunc()
    
    	switch value := stmt.Dest.(type) {
    	case map[string]interface{}:
    		values = ConvertMapToValuesForCreate(stmt, value)
    	case *map[string]interface{}:
    		values = ConvertMapToValuesForCreate(stmt, *value)
    Registered: Wed Jun 12 16:27:09 UTC 2024
    - Last Modified: Mon Apr 08 03:29:55 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  6. tests/create_test.go

    }
    
    func TestCreateWithNowFuncOverride(t *testing.T) {
    	user := User{Name: "CreateUserTimestampOverride"}
    	curTime := now.MustParse("2016-01-01")
    
    	NEW := DB.Session(&gorm.Session{
    		NowFunc: func() time.Time {
    			return curTime
    		},
    	})
    
    	NEW.Save(&user)
    
    	AssertEqual(t, user.CreatedAt, curTime)
    	AssertEqual(t, user.UpdatedAt, curTime)
    
    	var newUser User
    Registered: Wed Jun 12 16:27:09 UTC 2024
    - Last Modified: Tue Mar 19 03:50:28 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go

    	// we start the timer before we make the network call because kmsv2PluginWriteDEKSourceMaxTTL is meant to be the upper bound
    	expirationTimestamp := envelopekmsv2.NowFunc().Add(kmsv2PluginWriteDEKSourceMaxTTL)
    
    	// dynamically check if we want to use KDF seed to derive DEKs or just a single DEK
    	// this gate can only change during tests, but the check is cheap enough to always make
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 16 16:56:39 UTC 2024
    - 41.2K bytes
    - Viewed (0)
Back to top