machines

Documentation

Index

• func CalculateDynamicNtxGpu(requestedResource, usedResource interface{}) (actualNtx float64)
• func CalculateStaticNtxGpu(depReq models.DeploymentRequest) (estimatedNtx float64)
• func DeploymentRequest(ctx, reqCtx context.Context, w http.ResponseWriter, r *http.Request) error
• func FilterPeers(depReq models.DeploymentRequest, node host.Host) []models.PeerData
• func RequestService(ctx context.Context, depReq models.DeploymentRequest) (*fundingRespToSPD, error)
• type AvailableResource
• type GpuInfo
• type IP
• type Machines
• type Peer
• type PeerInfo

Functions

func CalculateDynamicNtxGpu

func CalculateDynamicNtxGpu(requestedResource, usedResource interface{}) (actualNtx float64)

CalculateDynamicNtxGpu works on the statistics/resource-usage reported by the job which could be different than the actual requested.

func CalculateStaticNtxGpu

func CalculateStaticNtxGpu(depReq models.DeploymentRequest) (estimatedNtx float64)

func DeploymentRequest

func DeploymentRequest(ctx, reqCtx context.Context, w http.ResponseWriter, r *http.Request) error

func FilterPeers

func FilterPeers(depReq models.DeploymentRequest, node host.Host) []models.PeerData

FilterPeers searches for available compute providers given specific parameters in depReq.

func RequestService

func RequestService(ctx context.Context, depReq models.DeploymentRequest) (*fundingRespToSPD, error)

Types

type AvailableResource

type AvailableResource struct {
	CpuNo     int     `json:"cpu_no"`
	CpuHz     int     `json:"cpu_hz"`
	PriceCpu  float64 `json:"price_cpu"`
	Ram       int     `json:"ram"`
	PriceRam  float64 `json:"price_ram"`
	Vcpu      int     `json:"vcpu"`
	Disk      float64 `json:"disk"`
	PriceDisk float64 `json:"price_disk"`
}

type GpuInfo

type GpuInfo struct {
	Name string `json:"name,omitempty"`
	Vram string `json:"vram,omitempty"`
}

type IP

type IP []any

1. Machines Index

type Machines

type Machines map[string]Peer

type Peer

type Peer struct {
	PeerInfo             PeerInfo          `json:"peer_info,omitempty"`
	IPAddr               IP                `json:"ip_addr,omitempty"`
	AvailableResources   AvailableResource `json:"available_resources,omitempty"`
	TokenomicsAdress     string            `json:"tokenomics_adress,omitempty"`
	TokenomicsBlockchain string            `json:"tokenomics_blockchain,omitempty"`
	HasGpu               string            `json:"has_gpu,omitempty"`
	AllowCardano         string            `json:"allow_cardano,omitempty"`
	GpuInfo              GpuInfo           `json:"gpu_info,omitempty"`
	Timestamp            uint32            `json:"timestamp,omitempty"`
}

type PeerInfo

type PeerInfo struct {
	NodeID    string `json:"nodeID,omitempty"`
	Key       string `json:"key,omitempty"`
	Mid       string `json:"mid,omitempty"`
	PublicKey string `json:"public_key,omitempty"`
	Address   IP     `json:"_address,omitempty"`
}