Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewExpiring (0.33 sec)

  1. 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)
  2. 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)
Back to top