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/rancherio/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)
• type DockerEventsProcessor
  • func NewDockerEventsProcessor(poolSize int) *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 SendToRancherHandler
  • func (h *SendToRancherHandler) Handle(event *docker.APIEvents) error
• type SimpleDockerClient
• type StartHandler
  • func (h *StartHandler) Handle(event *docker.APIEvents) error

Constants

const RancherDns = "io.rancher.container.dns"

const RancherDomain = "rancher.internal"

const RancherIPEnvKey = "RANCHER_IP="

const RancherIPLabelKey = "io.rancher.container.ip"

const RancherNameserver = "169.254.169.250"

const RancherSystemLabelKey = "io.rancher.container.system"

Functions

func NewDockerClient

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

Types

type DockerEventsProcessor

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

func NewDockerEventsProcessor

func NewDockerEventsProcessor(poolSize int) *DockerEventsProcessor

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 SendToRancherHandler

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

func (*SendToRancherHandler) Handle

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

type SimpleDockerClient

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

type StartHandler

type StartHandler struct {
	Client            SimpleDockerClient
	ContainerStateDir string
}

func (*StartHandler) Handle

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