resources

package

Go to main page

Versions in this module

v0

v0.0.7

Mar 3, 2026

v0.0.6

Feb 16, 2026

Changes in this version

type AllocationBreakdown

+ DiskIOBps int64

+ type DiskIOResource struct

+ func NewDiskIOResource(capacity int64, instLister InstanceLister) *DiskIOResource

+ func (d *DiskIOResource) Allocated(ctx context.Context) (int64, error)

+ func (d *DiskIOResource) Capacity() int64

+ func (d *DiskIOResource) Type() ResourceType

type FullResourceStatus

+ DiskIO ResourceStatus

type InstanceAllocation

+ DiskIOBps int64

+ type InstanceUtilizationInfo struct

+ AllocatedMemoryBytes int64

+ AllocatedVcpus int

+ HypervisorPID *int

+ ID string

+ Name string

+ TAPDevice string

type Manager

+ func (m *Manager) ValidateAllocation(ctx context.Context, vcpus int, memoryBytes int64, networkDownloadBps int64, ...) error

type NetworkResource — darwin/amd64

+ func (n *NetworkResource) AvailableFor(ctx context.Context, requested int64) (int64, error)

type ResourceType

+ const ResourceDiskIO

v0.0.5

Jan 16, 2026

Changes in this version

type FullResourceStatus

+ GPU *GPUResourceStatus

+ type GPUResourceStatus struct

+ Devices []devices.PassthroughDevice

+ Mode string

+ Profiles []devices.GPUProfile

+ TotalSlots int

+ UsedSlots int

+ func GetGPUStatus() *GPUResourceStatus

v0.0.4

Jan 12, 2026

Changes in this version

+ func ParseBandwidth(limit string) (int64, error)

+ type AllocationBreakdown struct

+ CPU int

+ DiskBytes int64

+ InstanceID string

+ InstanceName string

+ MemoryBytes int64

+ NetworkDownloadBps int64

+ NetworkUploadBps int64

+ type CPUResource struct

+ func NewCPUResource() (*CPUResource, error)

+ func (c *CPUResource) Allocated(ctx context.Context) (int64, error)

+ func (c *CPUResource) Capacity() int64

+ func (c *CPUResource) SetInstanceLister(lister InstanceLister)

+ func (c *CPUResource) Type() ResourceType

+ type DiskBreakdown struct

+ Images int64

+ OCICache int64

+ Overlays int64

+ Volumes int64

+ type DiskResource struct

+ func NewDiskResource(cfg *config.Config, p *paths.Paths, instLister InstanceLister, ...) (*DiskResource, error)

+ func (d *DiskResource) Allocated(ctx context.Context) (int64, error)

+ func (d *DiskResource) Capacity() int64

+ func (d *DiskResource) GetBreakdown(ctx context.Context) (*DiskBreakdown, error)

+ func (d *DiskResource) Type() ResourceType

+ type FullResourceStatus struct

+ Allocations []AllocationBreakdown

+ CPU ResourceStatus

+ Disk ResourceStatus

+ DiskDetail *DiskBreakdown

+ Memory ResourceStatus

+ Network ResourceStatus

+ type ImageLister interface

+ TotalImageBytes func(ctx context.Context) (int64, error)

+ TotalOCICacheBytes func(ctx context.Context) (int64, error)

+ type InstanceAllocation struct

+ ID string

+ MemoryBytes int64

+ Name string

+ NetworkDownloadBps int64

+ NetworkUploadBps int64

+ OverlayBytes int64

+ State string

+ Vcpus int

+ VolumeBytes int64

+ VolumeOverlayBytes int64

+ type InstanceLister interface

+ ListInstanceAllocations func(ctx context.Context) ([]InstanceAllocation, error)

+ type Manager struct

+ func NewManager(cfg *config.Config, p *paths.Paths) *Manager

+ func (m *Manager) CPUCapacity() int64

+ func (m *Manager) CanAllocate(ctx context.Context, rt ResourceType, amount int64) (bool, error)

+ func (m *Manager) CurrentImageStorageBytes(ctx context.Context) (int64, error)

+ func (m *Manager) DefaultDiskIOBandwidth(vcpus int) (ioBps, burstBps int64)

+ func (m *Manager) DefaultNetworkBandwidth(vcpus int) (downloadBps, uploadBps int64)

+ func (m *Manager) DiskIOCapacity() int64

+ func (m *Manager) GetFullStatus(ctx context.Context) (*FullResourceStatus, error)

+ func (m *Manager) GetOversubRatio(rt ResourceType) float64

+ func (m *Manager) GetStatus(ctx context.Context, rt ResourceType) (*ResourceStatus, error)

+ func (m *Manager) HasSufficientDiskForPull(ctx context.Context) error

+ func (m *Manager) HasSufficientImageStorage(ctx context.Context) error

+ func (m *Manager) Initialize(ctx context.Context) error

+ func (m *Manager) MaxImageStorageBytes() int64

+ func (m *Manager) NetworkCapacity() int64

+ func (m *Manager) SetImageLister(lister ImageLister)

+ func (m *Manager) SetInstanceLister(lister InstanceLister)

+ func (m *Manager) SetVolumeLister(lister VolumeLister)

+ type MemoryResource struct

+ func NewMemoryResource() (*MemoryResource, error)

+ func (m *MemoryResource) Allocated(ctx context.Context) (int64, error)

+ func (m *MemoryResource) Capacity() int64

+ func (m *MemoryResource) SetInstanceLister(lister InstanceLister)

+ func (m *MemoryResource) Type() ResourceType

+ type NetworkResource struct

+ func NewNetworkResource(ctx context.Context, cfg *config.Config, instLister InstanceLister) (*NetworkResource, error)

+ func (n *NetworkResource) Allocated(ctx context.Context) (int64, error)

+ func (n *NetworkResource) Capacity() int64

+ func (n *NetworkResource) Type() ResourceType

+ type Resource interface

+ Allocated func(ctx context.Context) (int64, error)

+ Capacity func() int64

+ Type func() ResourceType

+ type ResourceStatus struct

+ Allocated int64

+ Available int64

+ Capacity int64

+ EffectiveLimit int64

+ OversubRatio float64

+ Source SourceType

+ Type ResourceType

+ type ResourceType string

+ const ResourceCPU

+ const ResourceDisk

+ const ResourceMemory

+ const ResourceNetwork

+ type SourceType string

+ const SourceConfigured

+ const SourceDetected

+ type VolumeLister interface

+ TotalVolumeBytes func(ctx context.Context) (int64, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL