events

README

A Note on testing from a Mac

Some of these tests actualy spin up containers and use nsenter to manipulate IPs. In a typical Mac/b2d setup, the won't pass out of the box. There's some setup you need to do:

boot2docker ssh
cp /Users/PATH/TO/PROJECT/host-api/src/github.com/rancher/host-api/scripts/lib/net-util.sh .
cp /Users/PATH/TO/PROJECT/python-agent/vendor/nsenter .
vi net-util.sh # change /bin/bash to /bin/sh. b2d doesnt have bash. This is a hack but works
cp net-util.sh nsenter /usr/local/bin/
sudo mkdir /host
sudo ln -s /proc/ /host/proc

TODO Write a script for this

Documentation

Index

• Constants
• func NewDockerClient() (*docker.Client, error)
• func Watch(poolSize int, nm *network.Manager, bw *binexec.Watcher, disableDNSSetup bool) error
• type DockerEventsProcessor
  • func (de *DockerEventsProcessor) Process() error
• type EventRouter
  • func NewEventRouter(bufferSize int, workerPoolSize int, dockerClient *docker.Client, ...) (*EventRouter, error)
  • func (e *EventRouter) Start() error
  • func (e *EventRouter) Stop() error
• type Handler
• type NetworkManagerHandler
  • func (h *NetworkManagerHandler) Handle(event *docker.APIEvents) error
• type SimpleDockerClient
• type StartHandler
  • func (h *StartHandler) Handle(event *docker.APIEvents) error

Constants

const (
	RancherNameserver  = "169.254.169.250"
	RancherDNS         = "io.rancher.container.dns"
	RancherDNSPriority = "io.rancher.container.dns.priority"
	RancherNetwork     = "io.rancher.container.network"
	CNILabel           = "io.rancher.cni.network"
)

Functions

func NewDockerClient

func NewDockerClient() (*docker.Client, error)

func Watch

func Watch(poolSize int, nm *network.Manager, bw *binexec.Watcher, disableDNSSetup bool) error

Types

type DockerEventsProcessor

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

func (*DockerEventsProcessor) Process

func (de *DockerEventsProcessor) Process() error

type EventRouter

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

func NewEventRouter

func NewEventRouter(bufferSize int, workerPoolSize int, dockerClient *docker.Client,
	handlers map[string][]Handler) (*EventRouter, error)

func (*EventRouter) Start

func (e *EventRouter) Start() error

func (*EventRouter) Stop

func (e *EventRouter) Stop() error

type Handler

type Handler interface {
	Handle(*docker.APIEvents) error
}

type NetworkManagerHandler

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

func (*NetworkManagerHandler) Handle

func (h *NetworkManagerHandler) Handle(event *docker.APIEvents) error

type SimpleDockerClient

type SimpleDockerClient interface {
	InspectContainer(id string) (*docker.Container, error)
}

type StartHandler

type StartHandler struct {
	Client SimpleDockerClient
}

func (*StartHandler) Handle

func (h *StartHandler) Handle(event *docker.APIEvents) error