Last updated: 2024-11-07 21:05:02.600253 File source: link on GitLab
resources deals with resource management for the machine. This includes calculation of available resources for new jobs or bid requests.
Here is quick overview of the contents of this pacakge:
README: Current file which is aimed towards developers who wish to use and modify the DMS functionality.
init: Contains the initialization of the package.
resource_manager: Contains the resource manager which is responsible for managing the resources of dms.
system_specs_linux: Contains the implementation of the SystemSpecs interface for linux.
system_specs_amd64_darwin: Contains the implementation of the SystemSpecs interface for amd64 darwin.
system_specs_arm64_darwin: Contains the implementation of the SystemSpecs interface for arm64 darwin.
usage_monitor: Contains the implementation of the UsageMonitor interface.
store: Contains the implementation of the store for the resource manager.
All files with *_test.go contains unit tests for the corresponding functionality.
The class diagram for the resources package is shown below.
Source file
Rendered from source file
Manager Interface
The interface methods are explained below.
AllocateResources
signature: AllocateResources(context.Context, ResourceAllocation) error
input: Context
output (error): Error message
AllocateResources allocates the resources to the job.
DeallocateResources
signature: DeallocateResources(context.Context, string) error
input: Context
output (error): Error message
DeallocateResources deallocates the resources from the job.
GetTotalAllocation
signature: GetTotalAllocation() (Resources, error)
input: Context
output: types.Resource
output (error): Error message
GetTotalAllocation returns the total resources allocated to the jobs.
GetFreeResources
signature: GetFreeResources() (FreeResources, error)
input: None
output: FreeResources
output (error): Error message
GetFreeResources returns the available resources in the allocation pool.
GetOnboardedResources
signature: GetOnboardedResources(context.Context) (OnboardedResources, error)
input: Context
output: OnboardedResources
output (error): Error message
GetOnboardedResources returns the resources onboarded to dms.
UpdateOnboardedResources
signature: UpdateOnboardedResources(context.Context, OnboardedResources) error
input: Context
input: OnboardedResources
output (error): Error message
UpdateOnboardedResources updates the resources onboarded to dms.
SystemSpecs
signature: SystemSpecs() types.SystemSpecs
input: None
output: types.SystemSpecs instance
output (error): None
SystemSpecs returns the types.SystemSpecs instance.
UsageMonitor
signature: UsageMonitor() types.UsageMonitor
input: None
output: types.UsageMonitor instance
output (error): None
UsageMonitor returns the types.UsageMonitor instance.
SystemSpecs Interface
This interface defines the methods to get the system specifications of the machine. These methods are explained below.
GetMachineResources
signature: GetMachineResources(context.Context) (MachineResources, error)
input: Context
output: MachineResources
output (error): Error message
GetMachineResources returns the resources available on the machine.
This interface defines methods to monitor the system usage. The methods are explained below.
GetUsage
signature: GetUsage(context.Context) (types.Resource, error)
input: Context
output: types.Resource
output (error): Error message
GetUsage returns the resources currently used by the machine.
types.Resources: resources defined for the machine.
types.AvailableResources: resources onboarded to Nunet.
types.FreeResources: resources currently available for new jobs.
types.ResourceAllocation: resources allocated to a job.
types.MachineResources: resources available on the machine.
types.GPUVendor: GPU vendors available on the machine.
types.GPU: GPU details.
types.GPUs: A slice of GPU.
types.CPU: CPU details.
types.RAM: RAM details.
types.Disk: Disk details.
types.NetworkInfo: Network details.