Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 88 for nowFunc (0.36 sec)

  1. pkg/controller/certificates/authority/authority_test.go

    			want: x509.Certificate{
    				NotBefore:             now,
    				NotAfter:              now.Add(1 * time.Hour),
    				BasicConstraintsValid: true,
    				KeyUsage:              x509.KeyUsageDigitalSignature,
    			},
    		},
    		{
    			name:   "ext key usage",
    			policy: PermissiveSigningPolicy{TTL: time.Hour, Usages: []capi.KeyUsage{"client auth"}, Now: nowFunc},
    			want: x509.Certificate{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 23 19:36:11 UTC 2021
    - 7.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/timing_ratio_histogram.go

    	ratioedOpts := opts.TimingHistogramOpts
    	ratioedOpts.InitialValue /= opts.InitialDenominator
    	th := compbasemetrics.NewTestableTimingHistogram(nowFunc, &ratioedOpts)
    	return &TimingRatioHistogram{
    		Registerable: th,
    		timingRatioHistogramInner: timingRatioHistogramInner{
    			nowFunc:         nowFunc,
    			getGaugeOfRatio: func() Gauge { return th },
    			numerator:       opts.InitialValue,
    			denominator:     opts.InitialDenominator,
    		}}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 03 06:51:04 UTC 2023
    - 8.6K bytes
    - Viewed (0)
  3. callbacks/update.go

    								if field.AutoUpdateTime == schema.UnixNanosecond {
    									value = stmt.DB.NowFunc().UnixNano()
    								} else if field.AutoUpdateTime == schema.UnixMillisecond {
    									value = stmt.DB.NowFunc().UnixMilli()
    								} else if field.AutoUpdateTime == schema.UnixSecond {
    									value = stmt.DB.NowFunc().Unix()
    								} else {
    									value = stmt.DB.NowFunc()
    								}
    								isZero = false
    							}
    
    Registered: Wed Jun 12 16:27:09 UTC 2024
    - Last Modified: Mon Mar 18 05:44:55 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  4. pkg/registry/core/persistentvolume/strategy.go

    	pv := obj.(*api.PersistentVolume)
    	pv.Status = api.PersistentVolumeStatus{}
    
    	if utilfeature.DefaultFeatureGate.Enabled(features.PersistentVolumeLastPhaseTransitionTime) {
    		pv.Status.Phase = api.VolumePending
    		now := NowFunc()
    		pv.Status.LastPhaseTransitionTime = &now
    	}
    }
    
    func (persistentvolumeStrategy) Validate(ctx context.Context, obj runtime.Object) field.ErrorList {
    	persistentvolume := obj.(*api.PersistentVolume)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 03:58:36 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/grpc_service.go

    	return func(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {
    		start := NowFunc()
    		respErr := invoker(ctx, method, req, reply, cc, opts...)
    		elapsed := NowFunc().Sub(start)
    		metrics.RecordKMSOperationLatency(providerName, method, elapsed, respErr)
    		return respErr
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 23:18:16 UTC 2023
    - 4.6K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. staging/src/k8s.io/apiserver/pkg/registry/generic/storage_decorator.go

    	resourcePrefix string,
    	keyFunc func(obj runtime.Object) (string, error),
    	newFunc func() runtime.Object,
    	newListFunc func() runtime.Object,
    	getAttrsFunc storage.AttrFunc,
    	trigger storage.IndexerFuncs,
    	indexers *cache.Indexers) (storage.Interface, factory.DestroyFunc, error) {
    	return NewRawStorage(config, newFunc, newListFunc, resourcePrefix)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 2.2K bytes
    - Viewed (0)
Back to top