events

package

v0.5.0 Latest Latest Go to latest Published: Mar 7, 2018 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func StartRouter(router Router, handler Handler)

StartRouter calls the listener function and takes the interface for testing

type DockerEventRouter struct {
	DockerClient *client.Client
	Handler      Handler
}

DockerEventRouter is the Docker event handler implementation

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

Listen implements the Router interface

type DockerHandler struct {
	Crontab *cron.Crontab
}

DockerHandler handles docker messages

func NewDockerHandler(opts *DockerHandlerOpts) (*DockerHandler, error)

NewDockerHandler returns a docker handler with crontab

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

func (dh DockerHandler) Handle(msg Message)

Handle implements handler interface

type DockerHandlerOpts struct {
	RancherMode bool
	MetadataURL string
}

type Handler interface {
	Handle(Message)
}

Handler handles messages

type Message *events.Message

Message is a message from an event stream

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

Router Interface

func NewEventRouter() (Router, error)

NewEventRouter returns the a Docker event handler