resources

Documentation

Index

• Variables
• func CleanupMachines(ctx context.Context, db *harmonydb.DB) int
• func DiskFree(path string) (uint64, error)
• type Reg
  • func Register(db *harmonydb.DB, hostnameAndPort string) (*Reg, error)
  • func (res *Reg) Shutdown()
• type Resources
• type Storage

Variables

var LOOKS_DEAD_TIMEOUT = 10 * time.Minute // Time w/o minute heartbeats

Functions

func CleanupMachines

func CleanupMachines(ctx context.Context, db *harmonydb.DB) int

func DiskFree

func DiskFree(path string) (uint64, error)

Types

type Reg

type Reg struct {
	Resources
	// contains filtered or unexported fields
}

func Register

func Register(db *harmonydb.DB, hostnameAndPort string) (*Reg, error)

func (*Reg) Shutdown

func (res *Reg) Shutdown()

type Resources

type Resources struct {
	Cpu       int
	Gpu       float64
	Ram       uint64
	MachineID int
	Storage
}

type Storage

type Storage interface {
	HasCapacity() bool

	// This allows some other system to claim space for this task.
	Claim(taskID int) error

	// This allows some other system to consider the task done.
	// It's up to the caller to remove the data, if that applies.
	MarkComplete(taskID int) error
}

Optional Storage management.