mirror of
https://github.com/vee1e/kubeedge.git
synced 2026-09-01 18:27:38 +00:00
27 lines
697 B
Go
27 lines
697 B
Go
package manager
|
|
|
|
import (
|
|
"k8s.io/apimachinery/pkg/watch"
|
|
"k8s.io/client-go/tools/cache"
|
|
)
|
|
|
|
// NodesManager manage all events of nodes by SharedInformer
|
|
type NodesManager struct {
|
|
events chan watch.Event
|
|
}
|
|
|
|
// Events return the channel save events from watch nodes change
|
|
func (nm *NodesManager) Events() chan watch.Event {
|
|
return nm.events
|
|
}
|
|
|
|
// NewNodesManager create NodesManager by kube clientset and namespace
|
|
func NewNodesManager(si cache.SharedIndexInformer) (*NodesManager, error) {
|
|
events := make(chan watch.Event)
|
|
rh := NewCommonResourceEventHandler(events, nil)
|
|
if _, err := si.AddEventHandler(rh); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &NodesManager{events: events}, nil
|
|
}
|