controller

Documentation

Index

• type ProxyController
  • func New(client *kubeclient.Client, proxier *template.Proxier, ...) *ProxyController
  • func (c *ProxyController) HandleEndpoints()
  • func (c *ProxyController) HandleService()
  • func (c *ProxyController) Run(stopCh <-chan struct{}, signalCh <-chan os.Signal)

Types

type ProxyController

type ProxyController struct {
	Proxier       *template.Proxier
	NextService   func() (watch.EventType, *api.Service, error)
	NextEndpoints func() (watch.EventType, *api.Endpoints, error)

	ServiceListConsumed   func() bool
	EndpointsListConsumed func() bool
	// contains filtered or unexported fields
}

ProxyController abstracts the details of watching Services and Endpoints from the Proxy implementation being used.

func New

func New(client *kubeclient.Client, proxier *template.Proxier, resyncPeriod time.Duration) *ProxyController

func (*ProxyController) HandleEndpoints

func (c *ProxyController) HandleEndpoints()

HandleEndpoints handles a single Endpoints event and refreshes the proxy backend.

func (*ProxyController) HandleService

func (c *ProxyController) HandleService()

HandleServices handles a single Service event and refreshes the proxy backend.

func (*ProxyController) Run

func (c *ProxyController) Run(stopCh <-chan struct{}, signalCh <-chan os.Signal)

Run begins watching and syncing.