fleet

package
v0.14.1 Latest Latest
Warning

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

Go to latest
Published: Oct 23, 2014 License: Apache-2.0, Apache-2.0 Imports: 27 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
}{}

Flags used for Fleet API connectivity

Functions

func NewDataUnit

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

NewDataUnit takes a component type and returns a Fleet unit that is hard-scheduled to a machine ID

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

Jump to

Keyboard shortcuts

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