services

Documentation

Overview

Package services watchs for services annotations.

Index

• type Controller
  • func NewController(conf *config.KnpConfig, w worker.Worker) *Controller
  • func (c *Controller) Start(wg *sync.WaitGroup)
  • func (c *Controller) Stop()

Types

type Controller

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

Controller are started in a persistent goroutine at program launch, and are responsible for watching resources, and for calling worker when those resources changes.

func NewController

func NewController(conf *config.KnpConfig, w worker.Worker) *Controller

NewController creates and initialize the service controller

func (*Controller) Start

func (c *Controller) Start(wg *sync.WaitGroup)

Start initialize and launch a controller. The sync.WaitGroup argument is expected to be aknowledged (Done()) at controller termination, when Stop() is called.

func (*Controller) Stop

func (c *Controller) Stop()

Stop ends a controller and notify the controller's WaitGroup