diff --git a/go.mod b/go.mod index 426794266..3dfa52fcd 100644 --- a/go.mod +++ b/go.mod @@ -46,7 +46,7 @@ require ( gopkg.in/square/go-jose.v2 v2.2.2 k8s.io/api v0.0.0-20210806000319-499b6f90564c k8s.io/apimachinery v0.0.0-20210805051055-f7769293e6f1 - k8s.io/client-go v0.0.0-20210806000600-0f5acb8c39dd + k8s.io/client-go v0.0.0-20210806201705-b7569257b24f k8s.io/component-base v0.0.0-20210806040719-3cb663ee50af k8s.io/klog/v2 v2.9.0 k8s.io/kube-openapi v0.0.0-20210421082810-95288971da7e @@ -59,6 +59,6 @@ require ( replace ( k8s.io/api => k8s.io/api v0.0.0-20210806000319-499b6f90564c k8s.io/apimachinery => k8s.io/apimachinery v0.0.0-20210805051055-f7769293e6f1 - k8s.io/client-go => k8s.io/client-go v0.0.0-20210806000600-0f5acb8c39dd + k8s.io/client-go => k8s.io/client-go v0.0.0-20210806201705-b7569257b24f k8s.io/component-base => k8s.io/component-base v0.0.0-20210806040719-3cb663ee50af ) diff --git a/go.sum b/go.sum index 33ffe86cb..18c72035c 100644 --- a/go.sum +++ b/go.sum @@ -784,8 +784,8 @@ k8s.io/api v0.0.0-20210806000319-499b6f90564c h1:/TwdwBIiHSFv2VnETc8qgoi/skGGBo1 k8s.io/api v0.0.0-20210806000319-499b6f90564c/go.mod h1:9J6nkHavSazyXmPeuA4f1YO9Ztdjw7nDibPjT4P+wsY= k8s.io/apimachinery v0.0.0-20210805051055-f7769293e6f1 h1:cVpwhaGeh/tNPBeYbFff3tjx5AxwG5zwImhz+eusG3k= k8s.io/apimachinery v0.0.0-20210805051055-f7769293e6f1/go.mod h1:O3oNtNadZdeOMxHFVxOreoznohCpy0z6mocxbZr7oJ0= -k8s.io/client-go v0.0.0-20210806000600-0f5acb8c39dd h1:rJtT7gZ4LkZG+xtM6/iJvnzOx5XW+fNicRxMOYT0u/w= -k8s.io/client-go v0.0.0-20210806000600-0f5acb8c39dd/go.mod h1:AptIKtgqoSsdZsOhDruqHKBn7GeBrnbH5CgVkI7tpYU= +k8s.io/client-go v0.0.0-20210806201705-b7569257b24f h1:8pr9GYE4bhZ9ylhgAMIqDcwUwYI81lw8l3cXX430XLI= +k8s.io/client-go v0.0.0-20210806201705-b7569257b24f/go.mod h1:AptIKtgqoSsdZsOhDruqHKBn7GeBrnbH5CgVkI7tpYU= k8s.io/component-base v0.0.0-20210806040719-3cb663ee50af h1:TvSosXU6sV/t6L77kj/UEyYFTzmLdxRnKIOJN5UcAls= k8s.io/component-base v0.0.0-20210806040719-3cb663ee50af/go.mod h1:68YquEVTuJRDLUMJsRvsUyaFu7wBQnbVZlAV1oMkH58= k8s.io/gengo v0.0.0-20200413195148-3a45101e95ac/go.mod h1:ezvh/TsK7cY6rbqRK0oQQ8IAqLxYwwyPxAX1Pzy0ii0= diff --git a/pkg/util/flowcontrol/apf_filter.go b/pkg/util/flowcontrol/apf_filter.go index 8d914e796..f9a287eab 100644 --- a/pkg/util/flowcontrol/apf_filter.go +++ b/pkg/util/flowcontrol/apf_filter.go @@ -21,14 +21,15 @@ import ( "strconv" "time" - "k8s.io/apimachinery/pkg/util/clock" "k8s.io/apiserver/pkg/server/mux" "k8s.io/apiserver/pkg/util/flowcontrol/counter" fq "k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing" + fairqueuingclock "k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/clock" fqs "k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset" "k8s.io/apiserver/pkg/util/flowcontrol/metrics" kubeinformers "k8s.io/client-go/informers" "k8s.io/klog/v2" + utilclock "k8s.io/utils/clock" flowcontrol "k8s.io/api/flowcontrol/v1beta1" flowcontrolclient "k8s.io/client-go/kubernetes/typed/flowcontrol/v1beta1" @@ -83,7 +84,7 @@ func New( requestWaitLimit time.Duration, ) Interface { grc := counter.NoOp{} - clk := clock.RealClock{} + clk := fairqueuingclock.RealEventClock{} return NewTestable(TestableConfig{ Name: "Controller", Clock: clk, @@ -104,7 +105,7 @@ type TestableConfig struct { Name string // Clock to use in timing deliberate delays - Clock clock.PassiveClock + Clock utilclock.PassiveClock // AsFieldManager is the string to use in the metadata for // server-side apply. Normally this is diff --git a/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go b/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go index 957417d61..cd9fda988 100644 --- a/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go +++ b/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go @@ -23,12 +23,11 @@ import ( "sync" "time" - "k8s.io/utils/clock" - "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/apiserver/pkg/util/flowcontrol/counter" "k8s.io/apiserver/pkg/util/flowcontrol/debug" fq "k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing" + fairqueuingclock "k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/clock" "k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/promise" "k8s.io/apiserver/pkg/util/flowcontrol/metrics" fqrequest "k8s.io/apiserver/pkg/util/flowcontrol/request" @@ -48,7 +47,7 @@ const nsTimeFmt = "2006-01-02 15:04:05.000000000" // queueSetFactory makes QueueSet objects. type queueSetFactory struct { counter counter.GoRoutineCounter - clock clock.PassiveClock + clock fairqueuingclock.EventClock } // `*queueSetCompleter` implements QueueSetCompleter. Exactly one of @@ -71,7 +70,7 @@ type queueSetCompleter struct { // not end in "Locked" either acquires the lock or does not care about // locking. type queueSet struct { - clock clock.PassiveClock + clock fairqueuingclock.EventClock counter counter.GoRoutineCounter estimatedServiceTime float64 obsPair metrics.TimedObserverPair @@ -121,7 +120,7 @@ type queueSet struct { } // NewQueueSetFactory creates a new QueueSetFactory object -func NewQueueSetFactory(c clock.PassiveClock, counter counter.GoRoutineCounter) fq.QueueSetFactory { +func NewQueueSetFactory(c fairqueuingclock.EventClock, counter counter.GoRoutineCounter) fq.QueueSetFactory { return &queueSetFactory{ counter: counter, clock: c,