fleet

Documentation

Index

• Variables
• func IsNotFound(err error) bool
• type Event
• type FleetConfig
  • func DefaultConfig() FleetConfig
• type FleetTunnel
  • func NewTunnel(config FleetConfig) (*FleetTunnel, error)
  • func (f *FleetTunnel) Cat(unitName string) (string, error)
  • func (f *FleetTunnel) Destroy(events chan Event, unitNames ...string) error
  • func (f *FleetTunnel) List() ([]string, error)
  • func (f *FleetTunnel) Start(events chan Event, units UnitDataList) error
  • func (f *FleetTunnel) Status() (StatusMap, error)
  • func (f *FleetTunnel) Stop(events chan Event, unitNames ...string) (StopStats, error)
• type StatusMap
  • func (s StatusMap) Get(unitName string) (string, bool)
• type StopStats
• type UnitData
• type UnitDataList

Variables

var (
	NotFoundError = errgo.New("not found")
)

Functions

func IsNotFound

func IsNotFound(err error) bool

Types

type Event

type Event struct {
	UnitName string
	Message  string
}

type FleetConfig

type FleetConfig struct {
	Tunnel                string
	SSHUserName           string
	SSHTimeout            time.Duration
	StrictHostKeyChecking bool
	KnownHostsFile        string
	CAFile                string
	CertFile              string
	KeyFile               string
	EndPoint              string
	RequestTimeout        time.Duration
	EtcdKeyPrefix         string
	NoBlock               bool
	BlockAttempts         int
}

func DefaultConfig

func DefaultConfig() FleetConfig

type FleetTunnel

type FleetTunnel struct {
	FleetConfig
	// contains filtered or unexported fields
}

func NewTunnel

func NewTunnel(config FleetConfig) (*FleetTunnel, error)

func (*FleetTunnel) Cat

func (f *FleetTunnel) Cat(unitName string) (string, error)

func (*FleetTunnel) Destroy

func (f *FleetTunnel) Destroy(events chan Event, unitNames ...string) error

func (*FleetTunnel) List

func (f *FleetTunnel) List() ([]string, error)

func (*FleetTunnel) Start

func (f *FleetTunnel) Start(events chan Event, units UnitDataList) error

func (*FleetTunnel) Status

func (f *FleetTunnel) Status() (StatusMap, error)

func (*FleetTunnel) Stop

func (f *FleetTunnel) Stop(events chan Event, unitNames ...string) (StopStats, error)

type StatusMap

type StatusMap struct {
	// contains filtered or unexported fields
}

func (StatusMap) Get

func (s StatusMap) Get(unitName string) (string, bool)

type StopStats

type StopStats struct {
	StoppedUnits       int
	StoppedGlobalUnits int
}

type UnitData

type UnitData interface {
	Name() string
	Content() string
}

type UnitDataList

type UnitDataList interface {
	Len() int
	Get(index int) UnitData
}