node

Documentation

Index

• type Node
  • func GetNode(sock *gotalk.Sock) Node
  • func (node Node) UpdateResourceAvailable(r Resource)
  • func (node Node) UpdateResourceUsed(r Resource)
• type Nodes
  • func (nodes *Nodes) GetAvailableNodes() []*Node
• type Resource

Types

type Node

type Node struct {
	Sock              *gotalk.Sock
	ResourceAvailable Resource
	ResourceUsed      Resource
	IsNew             bool
	TTL               time.Duration
	// contains filtered or unexported fields
}

func GetNode

func GetNode(sock *gotalk.Sock) Node

adds a sock to a Nodes

func (Node) UpdateResourceAvailable

func (node Node) UpdateResourceAvailable(r Resource)

func (Node) UpdateResourceUsed

func (node Node) UpdateResourceUsed(r Resource)

type Nodes

type Nodes struct {
	Nodes []Node
	// contains filtered or unexported fields
}

func (*Nodes) GetAvailableNodes

func (nodes *Nodes) GetAvailableNodes() []*Node

type Resource

type Resource struct {
	// Resources available in Node
	// Can be set by a user
	Cores int8  `json:"cores"` // number of corers
	Mem   int16 `json:"mem"`   // Memory in MB
}