hardware

Documentation

Index

• type DeviceMapping
  • func (dm *DeviceMapping) Hash() string
• type Hardware
  • func NewHardware() (*Hardware, error)
  • func (h *Hardware) AskPlanResources() *sonm.AskPlanResources
  • func (m *Hardware) GPUIDs(gpuResources *sonm.AskPlanGPU) ([]gpu.GPUID, error)
  • func (h *Hardware) Hash() string
  • func (m *Hardware) HashGPU(indexes []uint64) ([]string, error)
  • func (h *Hardware) IntoProto() *sonm.DevicesReply
  • func (h *Hardware) LimitTo(resources *sonm.AskPlanResources) (*Hardware, error)
  • func (h *Hardware) LogicalCPUCount() int
  • func (h *Hardware) ResourcesToBenchmarkMap(resources *sonm.AskPlanResources) (benchmarks map[uint64]*sonm.Benchmark, err error)
  • func (h *Hardware) ResourcesToBenchmarks(resources *sonm.AskPlanResources) (*sonm.Benchmarks, error)
  • func (h *Hardware) SetDevicesFromBenches()
  • func (h *Hardware) SetNetworkIncoming(IPs []string)

Types

type DeviceMapping

type DeviceMapping struct {
	CPU        *sonm.CPUDevice     `json:"cpu"`
	GPU        []*sonm.GPUDevice   `json:"gpu"`
	RAM        hashableRAM         `json:"ram"`
	NetworkIn  uint64              `json:"network_in"`
	NetworkOut uint64              `json:"network_out"`
	Storage    *sonm.StorageDevice `json:"storage"`
	NetFlags   *sonm.NetFlags      `json:"netflags"`
}

DeviceMapping maps hardware capabilities to device description, hashing-friendly

func (*DeviceMapping) Hash

func (dm *DeviceMapping) Hash() string

type Hardware

type Hardware struct {
	CPU     *sonm.CPU     `json:"cpu"`
	GPU     []*sonm.GPU   `json:"gpu"`
	RAM     *sonm.RAM     `json:"ram"`
	Network *sonm.Network `json:"network_in"`
	Storage *sonm.Storage `json:"storage"`
}

Hardware accumulates the finest hardware information about system the worker is running on.

func NewHardware

func NewHardware() (*Hardware, error)

NewHardware returns initial hardware capabilities for Worker's host. Parts of the struct may be filled later by HW-plugins.

func (*Hardware) AskPlanResources

func (h *Hardware) AskPlanResources() *sonm.AskPlanResources

func (*Hardware) GPUIDs

func (m *Hardware) GPUIDs(gpuResources *sonm.AskPlanGPU) ([]gpu.GPUID, error)

func (*Hardware) Hash

func (h *Hardware) Hash() string

func (*Hardware) HashGPU

func (m *Hardware) HashGPU(indexes []uint64) ([]string, error)

func (*Hardware) IntoProto

func (h *Hardware) IntoProto() *sonm.DevicesReply

func (*Hardware) LimitTo

func (h *Hardware) LimitTo(resources *sonm.AskPlanResources) (*Hardware, error)

This one is very similar to ResourcesToBenchmarkMap except it stores corresponding benchmarks in corresponding devices. This can not be simply reused due to MIN splitting algorithm (e.g. GPU mem - in this case it is stored separately) TODO: find a way to refactor all this shit.

func (*Hardware) LogicalCPUCount

func (h *Hardware) LogicalCPUCount() int

LogicalCPUCount returns the number of logical CPUs in the system.

Method is deprecated.

func (*Hardware) ResourcesToBenchmarkMap

func (h *Hardware) ResourcesToBenchmarkMap(resources *sonm.AskPlanResources) (benchmarks map[uint64]*sonm.Benchmark, err error)

func (*Hardware) ResourcesToBenchmarks

func (h *Hardware) ResourcesToBenchmarks(resources *sonm.AskPlanResources) (*sonm.Benchmarks, error)

func (*Hardware) SetDevicesFromBenches

func (h *Hardware) SetDevicesFromBenches()

func (*Hardware) SetNetworkIncoming

func (h *Hardware) SetNetworkIncoming(IPs []string)