util

Documentation

Index

• 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 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 active units to their target machines.

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
	JobState    string
	ActiveState string
	Machine     string
}