- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 112 for newTimer (0.18 sec)
-
pkg/printers/internalversion/printers_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 218.6K bytes - Viewed (0) -
pkg/registry/certificates/certificates/strategy_test.go
t.Errorf("object diff: %s", cmp.Diff(obj, tc.expectedObj)) } }) } } 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
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 14:34:53 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/kubelet/stats/host_stats_provider.go
} // rootFsInfoToFsStats is a utility to convert rootFsInfo into statsapi.FsStats func rootFsInfoToFsStats(rootFsInfo *cadvisorapiv2.FsInfo) *statsapi.FsStats { return &statsapi.FsStats{ Time: metav1.NewTime(rootFsInfo.Timestamp), AvailableBytes: &rootFsInfo.Available, CapacityBytes: &rootFsInfo.Capacity, InodesFree: rootFsInfo.InodesFree, Inodes: rootFsInfo.Inodes, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 17:55:59 UTC 2024 - 6.6K bytes - Viewed (0) -
pilot/pkg/config/kube/crd/conversion.go
Name: cfg.Name, Namespace: namespace, ResourceVersion: cfg.ResourceVersion, Labels: cfg.Labels, Annotations: cfg.Annotations, CreationTimestamp: metav1.NewTime(cfg.CreationTimestamp), }, Spec: spec, Status: status, }, nil } // TODO - add special cases for type-to-kind and kind-to-type // conversions with initial-isms. Consider adding additional type
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 18:26:16 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
podWithUIDNameNsSpec("987654321", "oldpod", "foo", spec), } // Make sure the Pods are in the reverse order of creation time. pods[1].CreationTimestamp = metav1.NewTime(time.Now()) pods[0].CreationTimestamp = metav1.NewTime(time.Now().Add(1 * time.Second)) // The newer pod should be rejected. notfittingPod := pods[0] fittingPod := pods[1] kl.podWorkers.(*fakePodWorkers).running = map[types.UID]bool{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go
// update condition crd := inCustomResourceDefinition.DeepCopy() if cond == nil { apiextensionshelpers.RemoveCRDCondition(crd, apiextensionsv1.NonStructuralSchema) } else { cond.LastTransitionTime = metav1.NewTime(time.Now()) apiextensionshelpers.SetCRDCondition(crd, *cond) } _, err = c.crdClient.CustomResourceDefinitions().UpdateStatus(context.TODO(), crd, metav1.UpdateOptions{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go
v1.ResourceMemory: "500", } epochTime = metav1.NewTime(time.Unix(0, 0)) epochTime1 = metav1.NewTime(time.Unix(0, 1)) epochTime2 = metav1.NewTime(time.Unix(0, 2)) epochTime3 = metav1.NewTime(time.Unix(0, 3)) epochTime4 = metav1.NewTime(time.Unix(0, 4)) epochTime5 = metav1.NewTime(time.Unix(0, 5)) epochTime6 = metav1.NewTime(time.Unix(0, 6)) )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/quota/v1/evaluator/core/pods_test.go
now := fakeClock.Now() terminationGracePeriodSeconds := int64(30) deletionTimestampPastGracePeriod := metav1.NewTime(now.Add(time.Duration(terminationGracePeriodSeconds) * time.Second * time.Duration(-2))) deletionTimestampNotPastGracePeriod := metav1.NewTime(fakeClock.Now()) testCases := map[string]struct { pod *api.Pod usage corev1.ResourceList }{ "init container CPU": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.6K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller_test.go
deletedServiceCIDR := makeServiceCIDR("deleted-cidr", "192.168.0.0/24", "2001:db2::/64") deletedServiceCIDR.Finalizers = []string{ServiceCIDRProtectionFinalizer} deletedServiceCIDR.DeletionTimestamp = ptr.To[metav1.Time](metav1.NewTime(now.Add(-deletionGracePeriod - 1*time.Second))) testCases := []struct { name string cidrs []*networkingapiv1alpha1.ServiceCIDR ips []*networkingapiv1alpha1.IPAddress cidrSynced string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 22K bytes - Viewed (0) -
pkg/kubelet/config/config_test.go
podUpdate := CreatePodUpdate(kubetypes.ADD, TestSource, addedPod) channel <- podUpdate expectPodUpdate(t, ch, CreatePodUpdate(kubetypes.ADD, TestSource, addedPod)) // mark this pod as deleted timestamp := metav1.NewTime(time.Now()) deletedPod := CreateValidPod("foo", "new") deletedPod.ObjectMeta.DeletionTimestamp = ×tamp podUpdate = CreatePodUpdate(kubetypes.DELETE, TestSource, deletedPod) channel <- podUpdate
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 17.1K bytes - Viewed (0)