util

Documentation

Index

• func ActiveToSingleStates(active map[string][]UnitState) (map[string]UnitState, error)
• func RunFleetctl(args ...string) (string, string, error)
• func RunFleetctlWithInput(input string, args ...string) (string, string, error)
• func TempUnit(contents string) (string, error)
• func WaitForNActiveUnits(fleetctl fleetfunc, count int) (map[string][]UnitState, error)
• func WaitForNMachines(fleetctl fleetfunc, count int) ([]string, error)
• type UnitState

Functions

func ActiveToSingleStates

func ActiveToSingleStates(active map[string][]UnitState) (map[string]UnitState, error)

ActiveToSingleStates takes a map of active states (such as that returned by WaitForNActiveUnits) and ensures that each unit has at most a single active state. It returns a mapping of unit name to a single UnitState.

func RunFleetctl

func RunFleetctl(args ...string) (string, string, error)

func RunFleetctlWithInput

func RunFleetctlWithInput(input string, args ...string) (string, string, error)

func TempUnit

func TempUnit(contents string) (string, error)

tempUnit creates a local unit file with the given contents, returning the name of the file

func WaitForNActiveUnits

func WaitForNActiveUnits(fleetctl fleetfunc, count int) (map[string][]UnitState, error)

WaitForNActiveUnits polls fleet for up to 15s, exiting when N units are found to be in an active state. It returns a map of unit name to a list of active UnitStates for that unit

func WaitForNMachines

func WaitForNMachines(fleetctl fleetfunc, count int) ([]string, error)

Wait up to 10s to find the specified number of machines, retrying periodically.

Types

type UnitState

type UnitState struct {
	Name        string
	ActiveState string
	Machine     string
}