/
githubmirror
/
kubernetes
Обзор
Документация
Войти
/
githubmirror
/
kubernetes
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
pkg/kubelet/util/queue/work_queue.go
68 строк
2 KB
wojtekt
Migrate to k8s.io/utils/clock in pkg/kubelet
10 сен 2021, 13:20
10 сен 2021, 13:20
53ce79a
Код
Авторство
О чём код?
/* Copyright 2015 The Kubernetes Authors. Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package queue import ( "sync" "time" "k8s.io/apimachinery/pkg/types" "k8s.io/utils/clock" ) // WorkQueue allows queuing items with a timestamp. An item is // considered ready to process if the timestamp has expired. type WorkQueue interface { // GetWork dequeues and returns all ready items. GetWork() []types.UID // Enqueue inserts a new item or overwrites an existing item. Enqueue(item types.UID, delay time.Duration) } type basicWorkQueue struct { clock clock.Clock lock sync.Mutex queue map[types.UID]time.Time } var _ WorkQueue = &basicWorkQueue{} // NewBasicWorkQueue returns a new basic WorkQueue with the provided clock func NewBasicWorkQueue(clock clock.Clock) WorkQueue { queue := make(map[types.UID]time.Time) return &basicWorkQueue{queue: queue, clock: clock} } func (q *basicWorkQueue) GetWork() []types.UID { q.lock.Lock() defer q.lock.Unlock() now := q.clock.Now() var items []types.UID for k, v := range q.queue { if v.Before(now) { items = append(items, k) delete(q.queue, k) } } return items } func (q *basicWorkQueue) Enqueue(item types.UID, delay time.Duration) { q.lock.Lock() defer q.lock.Unlock() q.queue[item] = q.clock.Now().Add(delay) }