events

Dec 10, 2016

Changes in this version

+ func NewDockerClient() (*client.Client, error)

+ type DockerEventsProcessor struct

+ func NewDockerEventsProcessor(poolSize int) *DockerEventsProcessor

+ func (de *DockerEventsProcessor) Process() error

+ type EventRouter struct

+ func NewEventRouter(bufferSize int, workerPoolSize int, dockerClient *client.Client, ...) (*EventRouter, error)

+ func (e *EventRouter) Start() error

+ func (e *EventRouter) Stop() error

+ type Handler interface

+ Handle func(*events.Message) error

+ type SendToRancherHandler struct

+ func (h *SendToRancherHandler) Handle(event *events.Message) error

+ type SimpleDockerClient interface

+ ContainerInspect func(context context.Context, id string) (types.ContainerJSON, error)