Documentation
¶
Index ¶
- Constants
- type BaseNode
- type BaseNodeDependence
- type CapacityManager
- type GenericNodeDependence
- type GenericNodeProvider
- func (gnp *GenericNodeProvider) ConfigureNode(ctx context.Context, name string) *v1.Node
- func (gnp *GenericNodeProvider) Ping(ctx context.Context) error
- func (gnp *GenericNodeProvider) RefreshNodeStatus(ctx context.Context, nodeStatus *v1.NodeStatus) bool
- func (gnp *GenericNodeProvider) SetStatusUpdateCallback(ctx context.Context, f func(*v1.Node))
- type K8sNodeDependence
- type K8sNodeProvider
- func (knp *K8sNodeProvider) ConfigureNode(ctx context.Context, name string) *v1.Node
- func (knp *K8sNodeProvider) Ping(ctx context.Context) error
- func (knp *K8sNodeProvider) RefreshNodeStatus(ctx context.Context, nodeStatus *v1.NodeStatus) bool
- func (knp *K8sNodeProvider) SetStatusUpdateCallback(ctx context.Context, cb func(*v1.Node))
Constants ¶
View Source
const ( MemoryPressureThreshold = 0.9 // 90% DiskPressureThreshold = 95 // 95% DiskOutMinFreeSize = 100 * 1024 * 1024 // 100MB DiskOutMinFreeInode = 1000 // 1000 inodes )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseNodeDependence ¶
type BaseNodeDependence struct {
Runtime string
Namespace string
Address string
CapacityManager *CapacityManager
}
type CapacityManager ¶
type CapacityManager struct {
// contains filtered or unexported fields
}
func NewCapacityManager ¶
func NewCapacityManager(cfg *config.CapacityCfg, rootDir string, localCapacity bool) (*CapacityManager, error)
func (*CapacityManager) Allocatable ¶
func (pa *CapacityManager) Allocatable() v1.ResourceList
func (*CapacityManager) Capacity ¶
func (pa *CapacityManager) Capacity() v1.ResourceList
Capacity returns a resource list containing the capacity limits.
type GenericNodeDependence ¶
type GenericNodeDependence struct {
BaseNodeDependence
RootDir string
}
type GenericNodeProvider ¶
type GenericNodeProvider struct {
*BaseNode
// contains filtered or unexported fields
}
func NewGenericNodeProvider ¶
func NewGenericNodeProvider(dep *GenericNodeDependence) *GenericNodeProvider
func (*GenericNodeProvider) ConfigureNode ¶
func (*GenericNodeProvider) RefreshNodeStatus ¶
func (gnp *GenericNodeProvider) RefreshNodeStatus(ctx context.Context, nodeStatus *v1.NodeStatus) bool
func (*GenericNodeProvider) SetStatusUpdateCallback ¶
func (gnp *GenericNodeProvider) SetStatusUpdateCallback(ctx context.Context, f func(*v1.Node))
type K8sNodeDependence ¶
type K8sNodeDependence struct {
BaseNodeDependence
BkClient clientset.Interface
BkNamespace string
}
type K8sNodeProvider ¶
type K8sNodeProvider struct {
*BaseNode
// contains filtered or unexported fields
}
func NewK8sNodeProvider ¶
func NewK8sNodeProvider(dep *K8sNodeDependence) *K8sNodeProvider
func (*K8sNodeProvider) ConfigureNode ¶
func (*K8sNodeProvider) RefreshNodeStatus ¶
func (knp *K8sNodeProvider) RefreshNodeStatus(ctx context.Context, nodeStatus *v1.NodeStatus) bool
func (*K8sNodeProvider) SetStatusUpdateCallback ¶
func (knp *K8sNodeProvider) SetStatusUpdateCallback(ctx context.Context, cb func(*v1.Node))
Source Files
Click to show internal directories.
Click to hide internal directories.