events

Documentation

Index

• func StartRouter(router Router)
• type DockerEventRouter
  • func (de DockerEventRouter) Listen() (<-chan events.Message, <-chan error)
• type DockerHandler
  • func NewDockerHandler() *DockerHandler
  • func (dh DockerHandler) Handle(msg Message)
• type Handler
• type Message
• type Router
  • func NewEventRouter() (Router, error)

Functions

func StartRouter

func StartRouter(router Router)

StartRouter calls the listener function and takes the interface for testing

Types

type DockerEventRouter

type DockerEventRouter struct {
	DockerClient *client.Client
}

DockerEventRouter is the Docker event handler implementation

func (DockerEventRouter) Listen

func (de DockerEventRouter) Listen() (<-chan events.Message, <-chan error)

Listen implements the Router interface

type DockerHandler

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

DockerHandler handles docker messages

func NewDockerHandler

func NewDockerHandler() *DockerHandler

NewDockerHandler returns a docker handler with crontab

func (DockerHandler) Handle

func (dh DockerHandler) Handle(msg Message)

Handle implements handler interface

type Handler

type Handler interface {
	Handle(Message)
}

Handler handles messages

type Message

type Message *events.Message

Message is a message from an event stream

type Router

type Router interface {
	Listen() (<-chan events.Message, <-chan error)
}

Router Interface

func NewEventRouter

func NewEventRouter() (Router, error)

NewEventRouter returns the a Docker event handler