Documentation
¶
Overview ¶
Package runtime
Package runtime ¶
Package runtime
Index ¶
- func NewContainerRuntime(runtimeType string, cmd string, logger *logs.Logger) (cm api.ContainerManager, err error)
- type Manager
- type ResourceControl
- func (rc *ResourceControl) ContainerResourceStats(ID string) (stats *api.ResourceStats, err error)
- func (rc *ResourceControl) ContainerResources(ID string) (resource *api.Resource, err error)
- func (rc *ResourceControl) FrozenContainer(ID string) error
- func (rc *ResourceControl) GetDefaultResourceConfig() *runtimeapi.ResourceConfig
- func (rc *ResourceControl) GetResourceConfigByReadableMemory(memoryStr string) (config *runtimeapi.ResourceConfig, err error)
- func (rc *ResourceControl) GetTotalResources() *api.FuncletResource
- func (rc *ResourceControl) HasSufficientResources(o *ResourceOption, containerNum int) (has bool, err error)
- func (rc *ResourceControl) ThawContainer(ID string) error
- func (rc *ResourceControl) UpdateContainerResource(ID string, config *runtimeapi.ResourceConfig) error
- type ResourceManager
- type ResourceOption
- type RuntimeManagerInterface
- type RuntimeManagerParameters
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewContainerRuntime ¶
Types ¶
type Manager ¶
type Manager struct {
ResourceManager
api.ContainerManager
}
type ResourceControl ¶
type ResourceControl struct {
Options *ResourceOption
// contains filtered or unexported fields
}
func (*ResourceControl) ContainerResourceStats ¶
func (rc *ResourceControl) ContainerResourceStats(ID string) (stats *api.ResourceStats, err error)
func (*ResourceControl) ContainerResources ¶
func (rc *ResourceControl) ContainerResources(ID string) (resource *api.Resource, err error)
func (*ResourceControl) FrozenContainer ¶
func (rc *ResourceControl) FrozenContainer(ID string) error
func (*ResourceControl) GetDefaultResourceConfig ¶
func (rc *ResourceControl) GetDefaultResourceConfig() *runtimeapi.ResourceConfig
func (*ResourceControl) GetResourceConfigByReadableMemory ¶
func (rc *ResourceControl) GetResourceConfigByReadableMemory(memoryStr string) (config *runtimeapi.ResourceConfig, err error)
func (*ResourceControl) GetTotalResources ¶
func (rc *ResourceControl) GetTotalResources() *api.FuncletResource
func (*ResourceControl) HasSufficientResources ¶
func (rc *ResourceControl) HasSufficientResources(o *ResourceOption, containerNum int) (has bool, err error)
HasSufficientResources check the total resource is sufficient
func (*ResourceControl) ThawContainer ¶
func (rc *ResourceControl) ThawContainer(ID string) error
func (*ResourceControl) UpdateContainerResource ¶
func (rc *ResourceControl) UpdateContainerResource(ID string, config *runtimeapi.ResourceConfig) error
type ResourceManager ¶
type ResourceManager interface {
// HasSufficientResources
HasSufficientResources(o *ResourceOption, containerNum int) (has bool, err error)
// GetDefaultResourceConfig
GetDefaultResourceConfig() *runtimeapi.ResourceConfig
// GetResourceConfigByReadableMemory
GetResourceConfigByReadableMemory(memoryStr string) (config *runtimeapi.ResourceConfig, err error)
// GetTotalResources
GetTotalResources() *api.FuncletResource
// FrozenContainer
FrozenContainer(ID string) error
// ThawContainer
ThawContainer(ID string) error
// ContainerResources
ContainerResources(ID string) (resource *api.Resource, err error)
// ContainerResourceStats
ContainerResourceStats(ID string) (stats *api.ResourceStats, err error)
// UpdateContainerResource
UpdateContainerResource(ID string, config *runtimeapi.ResourceConfig) error
}
func NewResourceManager ¶
func NewResourceManager(o *ResourceOption, containerNum int) (rm ResourceManager, err error)
type ResourceOption ¶
type ResourceOption struct {
CgroupRootPath string
TotalMemory string
TotalCPUs float64
ReservedMemory string
ReservedCPUs float64
MemLimits string
CPURequests float64
CPULimits float64
}
func NewResourceOption ¶
func NewResourceOption() *ResourceOption
func (*ResourceOption) AddFlags ¶
func (s *ResourceOption) AddFlags(fs *pflag.FlagSet)
type RuntimeManagerInterface ¶
type RuntimeManagerInterface interface {
api.ContainerManager
ResourceManager
}
func NewRuntimeManager ¶
func NewRuntimeManager(p *RuntimeManagerParameters) (rm RuntimeManagerInterface, err error)
type RuntimeManagerParameters ¶
type RuntimeManagerParameters struct {
ContainerNum int
RuntimeCmd string
Option *ResourceOption
Logger *logs.Logger
}
Click to show internal directories.
Click to hide internal directories.