Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager interface { // Name show module name Name() string // Run start main loop Run(stop <-chan struct{}) // UpdateEvent receive event to notify manager to isolate offline resources UpdateEvent(event *types.ResourceUpdateEvent) error }
Manager is the manager used to isolate offline resources
func NewQosK8sManager ¶
func NewQosK8sManager(config types.ResourceIsolateConfig, stStore statestore.StateStore, predict predict.Interface, podInformer cache.SharedIndexInformer, conflict conflict.Manager, onlineInterface online.Interface) Manager
NewQosK8sManager create k8s qos manager
type QosK8sManager ¶
type QosK8sManager struct { types.ResourceIsolateConfig // contains filtered or unexported fields }
QosK8sManager sets quota limit for offline jobs, limited on: - online job on k8s - offline job on k8s - offline jon yarn on k8s
func (*QosK8sManager) Run ¶
func (q *QosK8sManager) Run(stop <-chan struct{})
Run start the main loop and isolate offline resources periodically
func (*QosK8sManager) UpdateEvent ¶
func (q *QosK8sManager) UpdateEvent(event *types.ResourceUpdateEvent) error
UpdateEvent accept event notification to update offline resource timely
func (*QosK8sManager) UpdateResource ¶
func (q *QosK8sManager) UpdateResource()
UpdateResource calling kinds of resource managers to isolate offline resources
Click to show internal directories.
Click to hide internal directories.