events

Documentation

Index

• func StartRouter(router Router, handler Handler)
• type DockerEventRouter
  • func (de DockerEventRouter) Listen(ctx context.Context) (<-chan events.Message, <-chan error)
• type DockerHandler
  • func NewDockerHandler(opts *DockerHandlerOpts) (*DockerHandler, error)
  • func (dh DockerHandler) GetJobStats(guage *prometheus.GaugeVec) (*prometheus.GaugeVec, error)
  • func (dh DockerHandler) Handle(msg Message)
• type DockerHandlerOpts
• type Handler
• type Message
• type Router
  • func NewEventRouter() (Router, error)

Functions

func StartRouter

func StartRouter(router Router, handler Handler)

StartRouter calls the listener function and takes the interface for testing

Types

type DockerEventRouter

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

DockerEventRouter is the Docker event handler implementation

func (DockerEventRouter) Listen

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

Listen implements the Router interface

type DockerHandler

type DockerHandler struct {
	Crontab *cron.Crontab
}

DockerHandler handles docker messages

func NewDockerHandler

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

NewDockerHandler returns a docker handler with crontab

func (DockerHandler) GetJobStats

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

func (DockerHandler) Handle

func (dh DockerHandler) Handle(msg Message)

Handle implements handler interface

type DockerHandlerOpts

type DockerHandlerOpts struct {
	RancherMode bool
	MetadataURL string
}

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(context.Context) (<-chan events.Message, <-chan error)
}

Router Interface

func NewEventRouter

func NewEventRouter() (Router, error)

NewEventRouter returns the a Docker event handler