gpuscheduler

Dec 13, 2022

Changes in this version

+ type Card struct

Apr 1, 2022

Changes in this version

type CacheAPI

+ GetNodeTileStatus func(cache *Cache, nodeName string) nodeTiles

+ type DescheduledTilesMap map[string][]int

+ type DisabledTilesMap map[string][]int

type MockCacheAPI

+ func (_m *MockCacheAPI) GetNodeTileStatus(cache *Cache, nodeName string) nodeTiles

+ type PreferredTilesMap map[string][]int

Jan 28, 2022

Changes in this version

type CacheAPI

+ AdjustPodResourcesL func(cache *Cache, pod *v1.Pod, adj bool, annotation, nodeName string) error

+ FetchPod func(cache *Cache, podNS, podName string) (*v1.Pod, error)

type MockCacheAPI

+ func (_m *MockCacheAPI) AdjustPodResourcesL(cache *Cache, pod *v1.Pod, adj bool, annotation string, nodeName string) error

+ func (_m *MockCacheAPI) FetchPod(cache *Cache, podNS string, podName string) (*v1.Pod, error)

Jun 18, 2021

Changes in this version

+ const L1

+ const L2

+ const L3

+ const L4

+ const L5

+ type Cache struct

+ func NewCache(client kubernetes.Interface) *Cache

+ type CacheAPI interface

+ FetchNode func(cache *Cache, nodeName string) (*v1.Node, error)

+ GetNodeResourceStatus func(cache *Cache, nodeName string) nodeResources

+ NewCache func(kubernetes.Interface) *Cache

+ type ClientAPI interface

+ GetPod func(clientset kubernetes.Interface, ns, name string) (*v1.Pod, error)

+ InClusterConfig func() (*rest.Config, error)

+ NewForConfig func(*rest.Config) (kubernetes.Interface, error)

+ UpdatePod func(kubernetes.Interface, *v1.Pod) (*v1.Pod, error)

+ type GASExtender struct

+ func NewGASExtender(clientset kubernetes.Interface) *GASExtender

+ func (m *GASExtender) Bind(w http.ResponseWriter, r *http.Request)

+ func (m *GASExtender) Filter(w http.ResponseWriter, r *http.Request)

+ func (m *GASExtender) Prioritize(w http.ResponseWriter, r *http.Request)

+ type InternalCacheAPI interface

+ WaitForCacheSync func(stopCh <-chan struct{}, cacheSyncs ...cache.InformerSynced) bool

+ type MockCacheAPI struct

+ func (_m *MockCacheAPI) FetchNode(cache *Cache, nodeName string) (*v1.Node, error)

+ func (_m *MockCacheAPI) GetNodeResourceStatus(cache *Cache, nodeName string) nodeResources

+ func (_m *MockCacheAPI) NewCache(_a0 kubernetes.Interface) *Cache

+ type MockClientAPI struct

+ func (_m *MockClientAPI) GetPod(clientset kubernetes.Interface, ns string, name string) (*v1.Pod, error)

+ func (_m *MockClientAPI) InClusterConfig() (*rest.Config, error)

+ func (_m *MockClientAPI) NewForConfig(_a0 *rest.Config) (kubernetes.Interface, error)

+ func (_m *MockClientAPI) UpdatePod(_a0 kubernetes.Interface, _a1 *v1.Pod) (*v1.Pod, error)

+ type MockInternalCacheAPI struct

+ func (_m *MockInternalCacheAPI) WaitForCacheSync(stopCh <-chan struct{}, cacheSyncs ...cache.InformerSynced) bool