d8dfun/virtual-kubelet
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Remove old pod notification stuff

Browse Source 
These are no longer used since we started using the k8s client's queue.
This commit is contained in:
Brian Goff
2018-12-10 13:40:21 -08:00
parent ee2735541a
commit 616d12ed76
1 changed files with 0 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
vkubelet/vkubelet.go
View File

@@ -29,7 +29,6 @@ type Server struct {
provider providers.Provider provider providers.Provider
resourceManager *manager.ResourceManager resourceManager *manager.ResourceManager
podSyncWorkers int podSyncWorkers int
podCh chan *podNotification
podInformer corev1informers.PodInformer podInformer corev1informers.PodInformer
} }
@@ -54,11 +53,6 @@ type APIConfig struct {
Addr string Addr string
} }
type podNotification struct {
pod *corev1.Pod
ctx context.Context
}
// New creates a new virtual-kubelet server. // New creates a new virtual-kubelet server.
func New(ctx context.Context, cfg Config) (s *Server, retErr error) { func New(ctx context.Context, cfg Config) (s *Server, retErr error) {
s = &Server{ s = &Server{
@@ -69,7 +63,6 @@ func New(ctx context.Context, cfg Config) (s *Server, retErr error) {
resourceManager: cfg.ResourceManager, resourceManager: cfg.ResourceManager,
provider: cfg.Provider, provider: cfg.Provider,
podSyncWorkers: cfg.PodSyncWorkers, podSyncWorkers: cfg.PodSyncWorkers,
podCh: make(chan *podNotification, cfg.PodSyncWorkers),
podInformer: cfg.PodInformer, podInformer: cfg.PodInformer,
} }