From 721036c908bfa46e1fef77f1c672fd7bb8845efb Mon Sep 17 00:00:00 2001 From: Madhav Jivrajani Date: Tue, 21 Sep 2021 15:53:43 +0530 Subject: [PATCH] migrate k8s.io/apimachinery/util/clock -> k8s.io/utils/clock Signed-off-by: Madhav Jivrajani Kubernetes-commit: fed2ec99c652550ed4a8c00b7cfc6c93abbc4ade --- tools/record/event.go | 2 +- tools/record/event_test.go | 10 +++++----- tools/record/events_cache.go | 2 +- 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/tools/record/event.go b/tools/record/event.go index 55d86ee1..4b61d005 100644 --- a/tools/record/event.go +++ b/tools/record/event.go @@ -25,13 +25,13 @@ import ( "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" - "k8s.io/apimachinery/pkg/util/clock" utilruntime "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/apimachinery/pkg/watch" restclient "k8s.io/client-go/rest" "k8s.io/client-go/tools/record/util" ref "k8s.io/client-go/tools/reference" "k8s.io/klog/v2" + "k8s.io/utils/clock" ) const maxTriesPerEvent = 12 diff --git a/tools/record/event_test.go b/tools/record/event_test.go index 78dd3d39..f003b1d3 100644 --- a/tools/record/event_test.go +++ b/tools/record/event_test.go @@ -29,11 +29,11 @@ import ( "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" k8sruntime "k8s.io/apimachinery/pkg/runtime" - "k8s.io/apimachinery/pkg/util/clock" "k8s.io/apimachinery/pkg/util/strategicpatch" "k8s.io/client-go/kubernetes/scheme" restclient "k8s.io/client-go/rest" ref "k8s.io/client-go/tools/reference" + "k8s.io/utils/clock" testclocks "k8s.io/utils/clock/testing" ) @@ -110,7 +110,7 @@ func TestNonRacyShutdown(t *testing.T) { // in a goroutine. caster := NewBroadcasterForTests(0) - clock := clock.NewFakeClock(time.Now()) + clock := testclocks.NewFakeClock(time.Now()) recorder := recorderWithFakeClock(v1.EventSource{Component: "eventTest"}, caster, clock) var wg sync.WaitGroup @@ -374,7 +374,7 @@ func TestEventf(t *testing.T) { eventBroadcaster := NewBroadcasterForTests(0) sinkWatcher := eventBroadcaster.StartRecordingToSink(&testEvents) - clock := clock.NewFakeClock(time.Now()) + clock := testclocks.NewFakeClock(time.Now()) recorder := recorderWithFakeClock(v1.EventSource{Component: "eventTest"}, eventBroadcaster, clock) for index, item := range table { clock.Step(1 * time.Second) @@ -619,7 +619,7 @@ func TestEventfNoNamespace(t *testing.T) { eventBroadcaster := NewBroadcasterForTests(0) sinkWatcher := eventBroadcaster.StartRecordingToSink(&testEvents) - clock := clock.NewFakeClock(time.Now()) + clock := testclocks.NewFakeClock(time.Now()) recorder := recorderWithFakeClock(v1.EventSource{Component: "eventTest"}, eventBroadcaster, clock) for index, item := range table { @@ -907,7 +907,7 @@ func TestMultiSinkCache(t *testing.T) { } eventBroadcaster := NewBroadcasterForTests(0) - clock := clock.NewFakeClock(time.Now()) + clock := testclocks.NewFakeClock(time.Now()) recorder := recorderWithFakeClock(v1.EventSource{Component: "eventTest"}, eventBroadcaster, clock) sinkWatcher := eventBroadcaster.StartRecordingToSink(&testEvents) diff --git a/tools/record/events_cache.go b/tools/record/events_cache.go index d818f923..4f041e8f 100644 --- a/tools/record/events_cache.go +++ b/tools/record/events_cache.go @@ -27,10 +27,10 @@ import ( v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - "k8s.io/apimachinery/pkg/util/clock" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/strategicpatch" "k8s.io/client-go/util/flowcontrol" + "k8s.io/utils/clock" ) const (