Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for fakecache (0.13 sec)

  1. pkg/kubelet/container/testing/fake_cache.go

    	"k8s.io/kubernetes/pkg/kubelet/container"
    )
    
    type fakeCache struct {
    	runtime container.Runtime
    }
    
    func NewFakeCache(runtime container.Runtime) container.Cache {
    	return &fakeCache{runtime: runtime}
    }
    
    func (c *fakeCache) Get(id types.UID) (*container.PodStatus, error) {
    	return c.runtime.GetPodStatus(context.Background(), id, "", "")
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 08 14:36:16 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  2. pkg/kubelet/pod_workers_test.go

    	realPodWorkers := newPodWorkers(
    		realPodSyncer,
    		fakeRecorder, queue.NewBasicWorkQueue(&clock.RealClock{}), time.Second, time.Second, fakeCache)
    	fakePodWorkers := &fakePodWorkers{
    		syncPodFn: kubeletForFakeWorkers.SyncPod,
    		cache:     fakeCache,
    		t:         t,
    	}
    
    	tests := []struct {
    		pod       *v1.Pod
    		mirrorPod *v1.Pod
    	}{
    		{
    			&v1.Pod{},
    			&v1.Pod{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  3. pkg/scheduler/schedule_one_test.go

    	"k8s.io/kubernetes/pkg/scheduler/framework/plugins/volumebinding"
    	frameworkruntime "k8s.io/kubernetes/pkg/scheduler/framework/runtime"
    	internalcache "k8s.io/kubernetes/pkg/scheduler/internal/cache"
    	fakecache "k8s.io/kubernetes/pkg/scheduler/internal/cache/fake"
    	internalqueue "k8s.io/kubernetes/pkg/scheduler/internal/queue"
    	"k8s.io/kubernetes/pkg/scheduler/profile"
    	st "k8s.io/kubernetes/pkg/scheduler/testing"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  4. pkg/scheduler/internal/cache/fake/fake_cache.go

    Mengjiao Liu <******@****.***> 1679485684 +0800
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  5. src/runtime/mpagecache.go

    import (
    	"runtime/internal/sys"
    	"unsafe"
    )
    
    const pageCachePages = 8 * unsafe.Sizeof(pageCache{}.cache)
    
    // pageCache represents a per-p cache of pages the allocator can
    // allocate from without a lock. More specifically, it represents
    // a pageCachePages*pageSize chunk of memory with 0 or more free
    // pages in it.
    type pageCache struct {
    	base  uintptr // base address of the chunk
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Apr 19 14:30:00 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  6. src/runtime/mpagecache_test.go

    	"testing"
    )
    
    func checkPageCache(t *testing.T, got, want PageCache) {
    	if got.Base() != want.Base() {
    		t.Errorf("bad pageCache base: got 0x%x, want 0x%x", got.Base(), want.Base())
    	}
    	if got.Cache() != want.Cache() {
    		t.Errorf("bad pageCache bits: got %016x, want %016x", got.Base(), want.Base())
    	}
    	if got.Scav() != want.Scav() {
    		t.Errorf("bad pageCache scav: got %016x, want %016x", got.Scav(), want.Scav())
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Dec 06 19:16:48 UTC 2021
    - 10.8K bytes
    - Viewed (0)
  7. security/pkg/nodeagent/cache/secretcache_test.go

    	pkiutil "istio.io/istio/security/pkg/pki/util"
    )
    
    func TestWorkloadAgentGenerateSecret(t *testing.T) {
    	fakeCACli, err := mock.NewMockCAClient(time.Hour, true)
    	var got, want []byte
    	if err != nil {
    		t.Fatalf("Error creating Mock CA client: %v", err)
    	}
    	sc := createCache(t, fakeCACli, func(resourceName string) {}, security.Options{WorkloadRSAKeySize: 2048})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 22:12:28 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  8. src/cmd/internal/objfile/disasm.go

    type CachedFile struct {
    	FileName string
    	Lines    [][]byte
    }
    
    // FileCache is a simple LRU cache of file contents.
    type FileCache struct {
    	files  *list.List
    	maxLen int
    }
    
    // NewFileCache returns a FileCache which can contain up to maxLen cached file contents.
    func NewFileCache(maxLen int) *FileCache {
    	return &FileCache{
    		files:  list.New(),
    		maxLen: maxLen,
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Sep 20 02:13:02 UTC 2022
    - 10.5K bytes
    - Viewed (0)
  9. src/runtime/export_test.go

    // Expose pageCache for testing.
    type PageCache pageCache
    
    const PageCachePages = pageCachePages
    
    func NewPageCache(base uintptr, cache, scav uint64) PageCache {
    	return PageCache(pageCache{base: base, cache: cache, scav: scav})
    }
    func (c *PageCache) Empty() bool   { return (*pageCache)(c).empty() }
    func (c *PageCache) Base() uintptr { return (*pageCache)(c).base }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:50:53 UTC 2024
    - 46.1K bytes
    - Viewed (0)
  10. pilot/pkg/config/aggregate/config.go

    	if err != nil {
    		return nil, err
    	}
    	return &storeCache{
    		ConfigStore: store,
    		caches:      caches,
    	}, nil
    }
    
    // MakeCache creates an aggregate config store cache from several config store
    // caches.
    func MakeCache(caches []model.ConfigStoreController) (model.ConfigStoreController, error) {
    	return MakeWriteableCache(caches, nil)
    }
    
    type store struct {
    	// schemas is the unified
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 26 01:14:27 UTC 2023
    - 5.4K bytes
    - Viewed (0)
Back to top