fleet

Documentation

Index

• Variables
• func NewUnit(component string, templatePaths []string, decorate bool) (uf *unit.UnitFile, err error)
• type FleetClient
  • func NewClient(cb config.Backend) (*FleetClient, error)
  • func (c *FleetClient) Create(targets []string, wg *sync.WaitGroup, out, ew io.Writer)
  • func (c *FleetClient) Destroy(targets []string, wg *sync.WaitGroup, out, ew io.Writer)
  • func (c *FleetClient) Dock(target string, cmd []string) error
  • func (c *FleetClient) Journal(target string) (err error)
  • func (c *FleetClient) ListUnitFiles() (err error)
  • func (c *FleetClient) ListUnits() (err error)
  • func (c *FleetClient) RollingRestart(component string, wg *sync.WaitGroup, out, ew io.Writer)
  • func (c *FleetClient) SSH(name string) error
  • func (c *FleetClient) SSHExec(name, cmd string) error
  • func (c *FleetClient) Scale(component string, requested int, wg *sync.WaitGroup, out, ew io.Writer)
  • func (c *FleetClient) Start(targets []string, wg *sync.WaitGroup, out, ew io.Writer)
  • func (c *FleetClient) Status(target string) (err error)
  • func (c *FleetClient) Stop(targets []string, wg *sync.WaitGroup, out, ew io.Writer)
  • 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
	SSHTimeout            float64
}{}

Flags used for Fleet API connectivity

Functions

func NewUnit

func NewUnit(component string, templatePaths []string, decorate bool) (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
	// contains filtered or unexported fields
}

FleetClient used to wrap Fleet API calls

func NewClient

func NewClient(cb config.Backend) (*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, out, ew io.Writer)

Create schedules unit files for the given components.

func (*FleetClient) Destroy

func (c *FleetClient) Destroy(targets []string, wg *sync.WaitGroup, out, ew io.Writer)

Destroy units for a given target

func (*FleetClient) Dock

func (c *FleetClient) Dock(target string, cmd []string) error

Dock connects to the appropriate host and runs 'docker exec -it'.

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) RollingRestart

func (c *FleetClient) RollingRestart(component string, wg *sync.WaitGroup, out, ew io.Writer)

RollingRestart for instance units

func (*FleetClient) SSH

func (c *FleetClient) SSH(name string) error

SSH opens an interactive shell to a machine in the cluster

func (*FleetClient) SSHExec

func (c *FleetClient) SSHExec(name, cmd string) error

func (*FleetClient) Scale

func (c *FleetClient) Scale(
	component string, requested int, wg *sync.WaitGroup, out, ew io.Writer)

Scale creates or destroys units to match the desired number

func (*FleetClient) Start

func (c *FleetClient) Start(targets []string, wg *sync.WaitGroup, out, ew io.Writer)

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, out, ew io.Writer)

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