INNER CODE UNIT · Go

func

boz/kail · controller.go:92

func (c *controller) Events() <-chan Event {
	return c.eventch
}

func (c *controller) Done() <-chan struct{} {
	return c.lc.Done()
}

func (c *controller) Close() {
	c.lc.Shutdown(nil)
}

func (c *controller) run(initial []*v1.Pod) {
	defer c.log.Un(c.log.Trace("run"))
	defer c.lc.ShutdownCompleted()

	peventch := c.pods.Events()
	shutdownch := c.lc.ShutdownRequest()

View source record →