fleet

package
v1.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 11, 2015 License: Apache-2.0, Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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 added in v1.10.0

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 added in v1.9.0

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

RollingRestart for instance units

func (*FleetClient) SSH added in v1.8.0

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

SSH opens an interactive shell to a machine in the cluster

func (*FleetClient) SSHExec added in v1.9.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL