fleet

Documentation

Index

• Variables
• func NewUnit(component string) (uf *unit.UnitFile, err error)
• type FleetClient
  • func NewClient() (*FleetClient, error)
  • func (c *FleetClient) Create(targets []string, wg *sync.WaitGroup, outchan chan string, errchan chan error)
  • func (c *FleetClient) Destroy(targets []string, wg *sync.WaitGroup, outchan chan string, errchan chan error)
  • func (c *FleetClient) GetLocaljobs() sort.StringSlice
  • func (c *FleetClient) Journal(target string) (err error)
  • func (c *FleetClient) ListUnitFiles() (err error)
  • func (c *FleetClient) ListUnits() (err error)
  • func (c *FleetClient) Scale(component string, requested int, wg *sync.WaitGroup, outchan chan string, ...)
  • func (c *FleetClient) Start(targets []string, wg *sync.WaitGroup, outchan chan string, errchan chan error)
  • func (c *FleetClient) Status(target string) (err error)
  • func (c *FleetClient) Stop(targets []string, wg *sync.WaitGroup, outchan chan string, errchan chan error)
  • func (c *FleetClient) Units(target string) (units []string, err error)

Variables

var Flags = struct {
	Debug                 bool
	Version               bool
	Endpoint              string
	EtcdKeyPrefix         string
	EtcdKeyFile           string
	EtcdCertFile          string
	EtcdCAFile            string
	UseAPI                bool
	KnownHostsFile        string
	StrictHostKeyChecking bool
	Tunnel                string
	RequestTimeout        float64
}{}

Flags used for Fleet API connectivity

Functions

func NewUnit

func NewUnit(component string) (uf *unit.UnitFile, err error)

NewUnit takes a component type and returns a Fleet unit that includes the relevant systemd service template

Types

type FleetClient

type FleetClient struct {
	Fleet client.API
}

FleetClient used to wrap Fleet API calls

func NewClient

func NewClient() (*FleetClient, error)

NewClient returns a client used to communicate with Fleet using the Registry API

func (*FleetClient) Create

func (c *FleetClient) Create(
	targets []string, wg *sync.WaitGroup, outchan chan string, errchan chan error)

Create schedules a new unit for the given component

func (*FleetClient) Destroy

func (c *FleetClient) Destroy(targets []string, wg *sync.WaitGroup, outchan chan string, errchan chan error)

Destroy units for a given target

func (*FleetClient) GetLocaljobs

func (c *FleetClient) GetLocaljobs() sort.StringSlice

func (*FleetClient) Journal

func (c *FleetClient) Journal(target string) (err error)

Journal prints the systemd journal of target unit(s)

func (*FleetClient) ListUnitFiles

func (c *FleetClient) ListUnitFiles() (err error)

ListUnitFiles prints all Deis-related unit files to Stdout

func (*FleetClient) ListUnits

func (c *FleetClient) ListUnits() (err error)

ListUnits prints all Deis-related units to Stdout

func (*FleetClient) Scale

func (c *FleetClient) Scale(
	component string, requested int, wg *sync.WaitGroup, outchan chan string, errchan chan error)

Scale creates or destroys units to match the desired number

func (*FleetClient) Start

func (c *FleetClient) Start(targets []string, wg *sync.WaitGroup, outchan chan string, errchan chan error)

Start units and wait for their desiredState

func (*FleetClient) Status

func (c *FleetClient) Status(target string) (err error)

Status prints the systemd status of target unit(s)

func (*FleetClient) Stop

func (c *FleetClient) Stop(targets []string, wg *sync.WaitGroup, outchan chan string, errchan chan error)

Stop units and wait for their desiredState

func (*FleetClient) Units

func (c *FleetClient) Units(target string) (units []string, err error)

Units returns a list of units filtered by target