Documentation ¶
Index ¶
- type Interface
- type K8sMetadata
- type MockResource
- func (m *MockResource) Collect(chan<- prometheus.Metric)
- func (m *MockResource) Describe(chan<- *prometheus.Desc)
- func (m *MockResource) DisableOfflineSchedule() error
- func (m *MockResource) EnableOfflineSchedule() error
- func (m *MockResource) GetOfflineJobs() ([]types.OfflineJobs, error)
- func (m *MockResource) KillOfflineJob(conflictingResource v1.ResourceName)
- func (m *MockResource) Name() string
- func (m *MockResource) Run(stopCh <-chan struct{})
- func (m *MockResource) SyncNodeResource(event *types.ResourceUpdateEvent) error
- type OfflineK8sData
- type OfflineOnK8sCommonData
- type OfflineYarnData
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Interface ¶
type Interface interface { // SyncNodeResource receive event to update offline resource capacity timely SyncNodeResource(event *types.ResourceUpdateEvent) error // contains filtered or unexported methods }
Interface is the manager used to update offline resource capacity
func NewOfflineOnK8sManager ¶
func NewOfflineOnK8sManager(config types.NodeResourceConfig, predictor predict.Interface, conflict conflict.Manager, offlineData interface{}) Interface
NewOfflineOnK8sManager new an instance for node resource manager
type K8sMetadata ¶
K8sMetadata describe meta data for k8s type
type MockResource ¶
MockResource mock Resource manager
func (*MockResource) Collect ¶
func (m *MockResource) Collect(chan<- prometheus.Metric)
Collect mock function
func (*MockResource) Describe ¶
func (m *MockResource) Describe(chan<- *prometheus.Desc)
Describe mock function
func (*MockResource) DisableOfflineSchedule ¶
func (m *MockResource) DisableOfflineSchedule() error
DisableOfflineSchedule mock function
func (*MockResource) EnableOfflineSchedule ¶
func (m *MockResource) EnableOfflineSchedule() error
EnableOfflineSchedule mock function
func (*MockResource) GetOfflineJobs ¶
func (m *MockResource) GetOfflineJobs() ([]types.OfflineJobs, error)
GetOfflineJobs mock function
func (*MockResource) KillOfflineJob ¶
func (m *MockResource) KillOfflineJob(conflictingResource v1.ResourceName)
KillOfflineJob mock function
func (*MockResource) SyncNodeResource ¶
func (m *MockResource) SyncNodeResource(event *types.ResourceUpdateEvent) error
SyncNodeResource mock function
type OfflineK8sData ¶
type OfflineK8sData struct { OfflineOnK8sCommonData // node informer NodeInformer cache.SharedIndexInformer }
OfflineK8sData describe options needed for k8s offline type
type OfflineOnK8sCommonData ¶
type OfflineOnK8sCommonData struct { // container state StStore statestore.StateStore // k8s client Client kubernetes.Interface // pod informer PodInformer cache.SharedIndexInformer // checkpointManager CheckpointManager *checkpoint.NodeResourceCheckpointManager }
OfflineOnK8sCommonData describe common data for offline jobs on k8s, including yarn on k8s
type OfflineYarnData ¶
type OfflineYarnData struct {
OfflineOnK8sCommonData
}
OfflineYarnData describes options needed for yarn type
Source Files ¶
Click to show internal directories.
Click to hide internal directories.