- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NewExpiring (0.33 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/cache/expiring.go
*/ package cache import ( "container/heap" "sync" "time" "k8s.io/utils/clock" ) // NewExpiring returns an initialized expiring cache. func NewExpiring() *Expiring { return NewExpiringWithClock(clock.RealClock{}) } // NewExpiringWithClock is like NewExpiring but allows passing in a custom // clock for testing. func NewExpiringWithClock(clock clock.Clock) *Expiring { return &Expiring{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 22 15:51:23 UTC 2023 - 5.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/cache/expiring_test.go
import ( "context" "math/rand" "sync" "testing" "time" "github.com/google/uuid" testingclock "k8s.io/utils/clock/testing" ) func TestExpiringCache(t *testing.T) { cache := NewExpiring() if result, ok := cache.Get("foo"); ok || result != nil { t.Errorf("Expected null, false, got %#v, %v", result, ok) } record1 := "bob" record2 := "alice" // when empty, record is stored
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 22 15:51:23 UTC 2023 - 7.3K bytes - Viewed (0)