util

Documentation

Index

• func ActiveToSingleStates(active map[string][]UnitState) (map[string]UnitState, error)
• func BuildCloudConfig(dst io.Writer, ip, etcdEndpoint, etcdKeyPrefix string) error
• func RunFleetctl(args ...string) (string, string, error)
• func RunFleetctlWithInput(input string, args ...string) (string, string, error)
• func TempUnit(contents string) (string, error)
• type UnitState
  • func FilterActiveUnits(states []UnitState) (filtered []UnitState)
  • func ParseUnitStates(units []string) (states []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 BuildCloudConfig

func BuildCloudConfig(dst io.Writer, ip, etcdEndpoint, etcdKeyPrefix string) error

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

Types

type UnitState

type UnitState struct {
	Name        string
	ActiveState string
	Machine     string
}

func FilterActiveUnits

func FilterActiveUnits(states []UnitState) (filtered []UnitState)

func ParseUnitStates

func ParseUnitStates(units []string) (states []UnitState)