platform

Documentation

Index

• func CheckMachine(m Machine) error
• func EnableSelinux(m Machine) error
• func InstallFile(in io.Reader, m Machine, to string) error
• func Manhole(m Machine) error
• func ReadFile(m Machine, path string) (io.ReadCloser, error)
• func Reboot(m Machine) error
• func StreamJournal(m Machine) error
• func TransferFile(src Machine, srcPath string, dst Machine, dstPath string) error
• type BaseCluster
  • func NewBaseCluster(basename string) (*BaseCluster, error)
  • func NewBaseClusterWithDialer(basename string, dialer network.Dialer) (*BaseCluster, error)
  • func (bc *BaseCluster) AddMach(m Machine)
  • func (bc *BaseCluster) DelMach(m Machine)
  • func (bc *BaseCluster) Destroy() error
  • func (bc *BaseCluster) GetDiscoveryURL(size int) (string, error)
  • func (bc *BaseCluster) Keys() ([]*agent.Key, error)
  • func (bc *BaseCluster) Machines() []Machine
  • func (bc *BaseCluster) Name() string
  • func (bc *BaseCluster) PasswordSSHClient(ip string, user string, password string) (*ssh.Client, error)
  • func (bc *BaseCluster) SSH(m Machine, cmd string) ([]byte, error)
  • func (bc *BaseCluster) SSHClient(ip string) (*ssh.Client, error)
• type Cluster
• type Machine
  • func NewMachines(c Cluster, userdatas []string) ([]Machine, error)
• type Options

Functions

func CheckMachine

func CheckMachine(m Machine) error

CheckMachine tests a machine for various error conditions such as ssh being available and no systemd units failing at the time ssh is reachable. It also ensures the remote system is running CoreOS.

TODO(mischief): better error messages.

func EnableSelinux

func EnableSelinux(m Machine) error

Enable SELinux on a machine (skip on machines without SELinux support)

func InstallFile

func InstallFile(in io.Reader, m Machine, to string) error

InstallFile copies data from in to the path to on m.

func Manhole

func Manhole(m Machine) error

Manhole connects os.Stdin, os.Stdout, and os.Stderr to an interactive shell session on the Machine m. Manhole blocks until the shell session has ended. If os.Stdin does not refer to a TTY, Manhole returns immediately with a nil error.

func ReadFile

func ReadFile(m Machine, path string) (io.ReadCloser, error)

ReadFile returns a io.ReadCloser that streams the requested file. The caller should close the reader when finished.

func Reboot

func Reboot(m Machine) error

Reboots a machine and blocks until the system to be accessible by SSH again. It will return an error if the machine is not accessible after a timeout.

func StreamJournal

func StreamJournal(m Machine) error

StreamJournal streams the remote system's journal to stdout.

func TransferFile

func TransferFile(src Machine, srcPath string, dst Machine, dstPath string) error

Copy a file between two machines in a cluster.

Types

type BaseCluster

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

func NewBaseCluster

func NewBaseCluster(basename string) (*BaseCluster, error)

func NewBaseClusterWithDialer

func NewBaseClusterWithDialer(basename string, dialer network.Dialer) (*BaseCluster, error)

func (*BaseCluster) AddMach

func (bc *BaseCluster) AddMach(m Machine)

func (*BaseCluster) DelMach

func (bc *BaseCluster) DelMach(m Machine)

func (*BaseCluster) Destroy

func (bc *BaseCluster) Destroy() error

Destroy destroys each machine in the cluster and closes the SSH agent.

func (*BaseCluster) GetDiscoveryURL

func (bc *BaseCluster) GetDiscoveryURL(size int) (string, error)

XXX(mischief): i don't really think this belongs here, but it completes the interface we've established.

func (*BaseCluster) Keys

func (bc *BaseCluster) Keys() ([]*agent.Key, error)

func (*BaseCluster) Machines

func (bc *BaseCluster) Machines() []Machine

func (*BaseCluster) Name

func (bc *BaseCluster) Name() string

func (*BaseCluster) PasswordSSHClient

func (bc *BaseCluster) PasswordSSHClient(ip string, user string, password string) (*ssh.Client, error)

func (*BaseCluster) SSH

func (bc *BaseCluster) SSH(m Machine, cmd string) ([]byte, error)

func (*BaseCluster) SSHClient

func (bc *BaseCluster) SSHClient(ip string) (*ssh.Client, error)

type Cluster

type Cluster interface {
	// NewMachine creates a new CoreOS machine.
	NewMachine(config string) (Machine, error)

	// Machines returns a slice of the active machines in the Cluster.
	Machines() []Machine

	// GetDiscoveryURL returns a new etcd discovery URL.
	GetDiscoveryURL(size int) (string, error)

	// Destroy terminates each machine in the cluster and frees any other
	// associated resources.
	Destroy() error
}

Cluster represents a cluster of CoreOS machines within a single platform.

type Machine

type Machine interface {
	// ID returns the plaform-specific machine identifier.
	ID() string

	// IP returns the machine's public IP.
	IP() string

	// PrivateIP returns the machine's private IP.
	PrivateIP() string

	// SSHClient establishes a new SSH connection to the machine.
	SSHClient() (*ssh.Client, error)

	// PasswordSSHClient establishes a new SSH connection using the provided credentials.
	PasswordSSHClient(user string, password string) (*ssh.Client, error)

	// SSH runs a single command over a new SSH connection.
	SSH(cmd string) ([]byte, error)

	// Destroy terminates the machine and frees associated resources.
	Destroy() error
}

Machine represents a CoreOS instance.

func NewMachines

func NewMachines(c Cluster, userdatas []string) ([]Machine, error)

NewMachines spawns len(userdatas) instances in cluster c, with each instance passed the respective userdata.

type Options

type Options struct {
	BaseName string
}

Options contains the base options for all clusters.