events

Sep 7, 2017

Changes in this version

type DockerEventRouter

+ Handler Handler

type DockerHandler

+ Crontab *cron.Crontab

+ func (dh DockerHandler) GetJobStats(guage *prometheus.GaugeVec) (*prometheus.GaugeVec, error)

+ type DockerHandlerOpts struct

+ MetadataURL string

+ RancherMode bool

Feb 13, 2017

Changes in this version

+ func StartRouter(router Router)

+ type DockerEventRouter struct

+ DockerClient *client.Client

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

+ type DockerHandler struct

+ func NewDockerHandler() *DockerHandler

+ func (dh DockerHandler) Handle(msg Message)

+ type Handler interface

+ Handle func(Message)

+ type Message *events.Message

+ type Router interface

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

+ func NewEventRouter() (Router, error)