Versions in this module Expand all Collapse all v0 v0.2.0 Feb 21, 2022 Changes in this version + func StartLeaseControllerErrExit(ctx context.Context, kubeClient kubernetes.Interface, ...) v0.1.0 Jan 5, 2022 Changes in this version + type HealthyChecker struct + func NewHealthyChecker(intervalWaitService time.Duration, stop <-chan struct{}) *HealthyChecker + func (hc *HealthyChecker) CheckHealth(interval time.Duration) <-chan struct{} + func (hc *HealthyChecker) CheckHealthBlock() + type HostGpuInfoChecker struct + func NewHostGpuInfoChecker(checkInterval time.Duration, stop <-chan struct{}) (*HostGpuInfoChecker, error) + func (gic *HostGpuInfoChecker) GetGpuInfoChan() <-chan *NodeGpuInfo + func (gic *HostGpuInfoChecker) Start() error + type PodWatcher struct + func NewPodWatcher(kubeclient kubernetes.Interface, stop <-chan struct{}) (*PodWatcher, error) + func (pw *PodWatcher) GetRemoveChan() <-chan *PodResourceUpdate + func (pw *PodWatcher) GetSyncChan() <-chan struct{} + func (pw *PodWatcher) Start() error + type ServerDSController struct + func NewServerDSController(cacert []byte, goonChan <-chan struct{}, removeChan <-chan *PodResourceUpdate, ...) (*ServerDSController, error) + func (dsc *ServerDSController) Start() error