Files
wehub-resource-sync e0e362d700
SDK Tests / changes (push) Successful in 2m29s
Real E2E Tests / changes (push) Successful in 2m29s
Deploy Docs Pages / build (push) Has been cancelled
Deploy Docs Pages / deploy (push) Has been cancelled
Real E2E Tests / JavaScript E2E (docker bridge) (push) Has been cancelled
Real E2E Tests / Python E2E (docker bridge) (push) Has been cancelled
Real E2E Tests / Java E2E (docker bridge) (push) Has been cancelled
Real E2E Tests / C# E2E (docker bridge) (push) Has been cancelled
Real E2E Tests / Go E2E (docker bridge) (push) Has been cancelled
Real E2E Tests / Real E2E CI (push) Has been cancelled
SDK Tests / SDK CI (push) Has been cancelled
SDK Tests / CLI Tests (push) Has been cancelled
SDK Tests / Python SDK Quality (code-interpreter) (push) Has been cancelled
SDK Tests / Python SDK Quality (sandbox) (push) Has been cancelled
SDK Tests / Python SDK Tests (code-interpreter) (push) Has been cancelled
SDK Tests / JavaScript SDK Quality And Tests (code-interpreter) (push) Has been cancelled
SDK Tests / JavaScript SDK Quality And Tests (sandbox) (push) Has been cancelled
SDK Tests / Python SDK Tests (sandbox) (push) Has been cancelled
SDK Tests / CLI Quality (push) Has been cancelled
SDK Tests / Kotlin SDK Quality And Tests (sandbox) (push) Has been cancelled
SDK Tests / Kotlin SDK Quality And Tests (code-interpreter) (push) Has been cancelled
SDK Tests / C# SDK Quality And Tests (code-interpreter) (push) Has been cancelled
SDK Tests / C# SDK Quality And Tests (sandbox) (push) Has been cancelled
SDK Tests / Go SDK Quality And Tests (push) Has been cancelled
chore: import upstream snapshot with attribution
2026-07-13 13:39:33 +08:00

96 lines
2.2 KiB
Go

// Copyright 2025 Alibaba Group Holding Ltd.
//
// 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 requeueduration
import (
"fmt"
"sync"
"time"
)
// DurationStore can store a duration map for multiple workloads
type DurationStore struct {
store sync.Map
}
func (dm *DurationStore) Push(key string, newDuration time.Duration) {
value, _ := dm.store.LoadOrStore(key, &Duration{})
requeueDuration, ok := value.(*Duration)
if !ok {
dm.store.Delete(key)
return
}
requeueDuration.Update(newDuration)
}
func (dm *DurationStore) Pop(key string) time.Duration {
value, ok := dm.store.Load(key)
if !ok {
return 0
}
defer dm.store.Delete(key)
requeueDuration, ok := value.(*Duration)
if !ok {
return 0
}
return requeueDuration.Get()
}
// Duration helps calculate the shortest non-zore duration to requeue
type Duration struct {
sync.Mutex
duration time.Duration
message string
}
func (rd *Duration) Update(newDuration time.Duration) {
rd.Lock()
defer rd.Unlock()
if newDuration > 0 {
if rd.duration <= 0 || newDuration < rd.duration {
rd.duration = newDuration
}
}
}
func (rd *Duration) UpdateWithMsg(newDuration time.Duration, format string, args ...interface{}) {
rd.Lock()
defer rd.Unlock()
if newDuration > 0 {
if rd.duration <= 0 || newDuration < rd.duration {
rd.duration = newDuration
rd.message = fmt.Sprintf(format, args...)
}
}
}
func (rd *Duration) Merge(rd2 *Duration) {
rd2.Lock()
defer rd2.Unlock()
rd.UpdateWithMsg(rd2.duration, "%s", rd2.message)
}
func (rd *Duration) Get() time.Duration {
rd.Lock()
defer rd.Unlock()
return rd.duration
}
func (rd *Duration) GetWithMsg() (time.Duration, string) {
rd.Lock()
defer rd.Unlock()
return rd.duration, rd.message
}