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
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.