local

Documentation

Index

• Variables
• func MakeConfigDrive(userdata *conf.Conf, outputDir string) (string, error)
• type Dnsmasq
  • func NewDnsmasq() (*Dnsmasq, error)
  • func (dm *Dnsmasq) Destroy()
  • func (dm *Dnsmasq) GetInterface(bridge string) (in *Interface)
• type Interface
• type LocalCluster
  • func (lc *LocalCluster) Destroy()
  • func (lc *LocalCluster) GetDiscoveryURL(size int) (string, error)
  • func (lc *LocalCluster) GetNsHandle() netns.NsHandle
  • func (lc *LocalCluster) GetOmahaHostPort() (string, error)
  • func (lc *LocalCluster) NewCommand(name string, arg ...string) exec.Cmd
  • func (lc *LocalCluster) NewTap(bridge string) (*TunTap, error)
• type LocalFlight
  • func NewLocalFlight(opts *platform.Options, platformName platform.Name) (*LocalFlight, error)
  • func (lf *LocalFlight) Destroy()
  • func (lf *LocalFlight) NewCluster(rconf *platform.RuntimeConfig) (*LocalCluster, error)
• type OmahaWrapper
  • func (o OmahaWrapper) Destroy()
• type Segment
• type SimpleEtcd
  • func NewSimpleEtcd() (*SimpleEtcd, error)
  • func (se *SimpleEtcd) Destroy()
• type SimpleHTTP
  • func (s *SimpleHTTP) Serve() error
• type TunTap
  • func AddLinkTap(name string) (*TunTap, error)
  • func AddLinkTun(name string) (*TunTap, error)
  • func (tt *TunTap) Attrs() *netlink.LinkAttrs
  • func (tt *TunTap) Type() string

Variables

var (
	// ErrIPClash is raised when a generated IP lives in an existing
	// root network namespace
	ErrIPClash = errors.New("IP lives in a host network")

	// ErrIncorrectSeed is raised when the seed used to generate veth pair
	// is in an incorrect format
	ErrIncorrectSeed = errors.New("seed must be a positive 2 bytes value")
)

Functions

func MakeConfigDrive

func MakeConfigDrive(userdata *conf.Conf, outputDir string) (string, error)

MakeConfigDrive creates a config drive directory tree under outputDir and returns the path to the top level directory.

Types

type Dnsmasq

type Dnsmasq struct {
	Segments []*Segment
	// contains filtered or unexported fields
}

func NewDnsmasq

func NewDnsmasq() (*Dnsmasq, error)

func (*Dnsmasq) Destroy

func (dm *Dnsmasq) Destroy()

func (*Dnsmasq) GetInterface

func (dm *Dnsmasq) GetInterface(bridge string) (in *Interface)

type Interface

type Interface struct {
	HardwareAddr net.HardwareAddr
	DHCPv4       []net.IPNet
	DHCPv6       []net.IPNet
}

type LocalCluster

type LocalCluster struct {
	destructor.MultiDestructor
	*platform.BaseCluster

	OmahaServer OmahaWrapper
	// contains filtered or unexported fields
}

func (*LocalCluster) Destroy

func (lc *LocalCluster) Destroy()

func (*LocalCluster) GetDiscoveryURL

func (lc *LocalCluster) GetDiscoveryURL(size int) (string, error)

func (*LocalCluster) GetNsHandle

func (lc *LocalCluster) GetNsHandle() netns.NsHandle

func (*LocalCluster) GetOmahaHostPort

func (lc *LocalCluster) GetOmahaHostPort() (string, error)

func (*LocalCluster) NewCommand

func (lc *LocalCluster) NewCommand(name string, arg ...string) exec.Cmd

func (*LocalCluster) NewTap

func (lc *LocalCluster) NewTap(bridge string) (*TunTap, error)

type LocalFlight

type LocalFlight struct {
	destructor.MultiDestructor
	*platform.BaseFlight
	Dnsmasq    *Dnsmasq
	SimpleEtcd *SimpleEtcd
	NTPServer  *ntp.Server
	// contains filtered or unexported fields
}

func NewLocalFlight

func NewLocalFlight(opts *platform.Options, platformName platform.Name) (*LocalFlight, error)

func (*LocalFlight) Destroy

func (lf *LocalFlight) Destroy()

func (*LocalFlight) NewCluster

func (lf *LocalFlight) NewCluster(rconf *platform.RuntimeConfig) (*LocalCluster, error)

type OmahaWrapper

type OmahaWrapper struct {
	*omaha.TrivialServer
}

OmahaWrapper wraps the omaha trivial server to log any errors returned by destroy and doesn't return anything instead

func (OmahaWrapper) Destroy

func (o OmahaWrapper) Destroy()

type Segment

type Segment struct {
	BridgeName string
	BridgeIf   *Interface
	Interfaces []*Interface

	// Listener holds the unique TCP socket
	// created to ensure uniqueness of IP
	// it has to be closed once the kola instance
	// has terminated
	Listener net.Listener
	// contains filtered or unexported fields
}

type SimpleEtcd

type SimpleEtcd struct {
	Port int
	// contains filtered or unexported fields
}

SimpleEtcd provides a single node etcd server.

func NewSimpleEtcd

func NewSimpleEtcd() (*SimpleEtcd, error)

func (*SimpleEtcd) Destroy

func (se *SimpleEtcd) Destroy()

type SimpleHTTP

type SimpleHTTP struct{}

SimpleHTTP provides a single http server.

func (*SimpleHTTP) Serve

func (s *SimpleHTTP) Serve() error

type TunTap

type TunTap struct {
	*netlink.LinkAttrs
	*os.File
}

Tun/Tap device that is compatible with the netlink library.

func AddLinkTap

func AddLinkTap(name string) (*TunTap, error)

func AddLinkTun

func AddLinkTun(name string) (*TunTap, error)

func (*TunTap) Attrs

func (tt *TunTap) Attrs() *netlink.LinkAttrs

func (*TunTap) Type

func (tt *TunTap) Type() string