events

Documentation

Index

• Constants
• func NewDockerClient(useDockerConnectEnvVars bool) (*docker.Client, error)
• func ProcessDockerEvents(poolSize int) 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 StartHandler
  • func (h *StartHandler) Handle(event *docker.APIEvents) error
• type StartHandlerDockerClient

Constants

const RancherIPKey = "RANCHER_IP="

Functions

func NewDockerClient

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

func ProcessDockerEvents

func ProcessDockerEvents(poolSize int) error

Types

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 StartHandler

type StartHandler struct {
	Client StartHandlerDockerClient
}

func (*StartHandler) Handle

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

type StartHandlerDockerClient

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