machine

Documentation

Index

• func HasMetadata(state *MachineState, metadata map[string][]string) bool
• func IsLocalMachineID(mID string) bool
• type CoreOSMachine
  • func NewCoreOSMachine(static MachineState, um unit.UnitManager) *CoreOSMachine
  • func (m *CoreOSMachine) PeriodicRefresh(interval time.Duration, stop chan bool)
  • func (m *CoreOSMachine) Refresh()
  • func (m *CoreOSMachine) State() (state MachineState)
  • func (m *CoreOSMachine) String() string
• type FakeMachine
  • func (fm *FakeMachine) State() MachineState
• type Machine
• type MachineState
  • func UpdateFreeResources(ms MachineState, reservations map[string]resource.ResourceTuple) MachineState
  • func (ms MachineState) MatchID(ID string) bool
  • func (ms MachineState) ShortID() string

Functions

func HasMetadata

func HasMetadata(state *MachineState, metadata map[string][]string) bool

HasMetadata determine if the Metadata of a given MachineState matches the indicated values.

func IsLocalMachineID

func IsLocalMachineID(mID string) bool

IsLocalMachineID returns whether the given machine ID is equal to that of the local machine

Types

type CoreOSMachine

type CoreOSMachine struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewCoreOSMachine

func NewCoreOSMachine(static MachineState, um unit.UnitManager) *CoreOSMachine

func (*CoreOSMachine) PeriodicRefresh

func (m *CoreOSMachine) PeriodicRefresh(interval time.Duration, stop chan bool)

PeriodicRefresh updates the current state of the CoreOSMachine at the interval indicated. Operation ceases when the provided channel is closed.

func (*CoreOSMachine) Refresh

func (m *CoreOSMachine) Refresh()

Refresh updates the current state of the CoreOSMachine.

func (*CoreOSMachine) State

func (m *CoreOSMachine) State() (state MachineState)

State returns a MachineState object representing the CoreOSMachine's static state overlaid on its dynamic state at the time of execution.

func (*CoreOSMachine) String

func (m *CoreOSMachine) String() string

type FakeMachine

type FakeMachine struct {
	MachineState MachineState
}

func (*FakeMachine) State

func (fm *FakeMachine) State() MachineState

type Machine

type Machine interface {
	State() MachineState
}

type MachineState

type MachineState struct {
	ID       string
	PublicIP string
	Metadata map[string]string
	Version  string

	// The total resources available on the underlying system
	TotalResources resource.ResourceTuple

	// The resoures considered available for scheduling by fleet
	FreeResources resource.ResourceTuple

	// Number of Units loaded into the fleet agent
	LoadedUnits int
}

MachineState represents a point-in-time snapshot of the state of the local host.

func UpdateFreeResources

func UpdateFreeResources(ms MachineState, reservations map[string]resource.ResourceTuple) MachineState

UpdateFreeResources populates the FreeResources of a MachineState, given a map of units to resource reservations, using the following formula: FreeResources = TotalResources - (sum(unit resource reservations) + HostResources)

func (MachineState) MatchID

func (ms MachineState) MatchID(ID string) bool

func (MachineState) ShortID

func (ms MachineState) ShortID() string