controller

Documentation

Index

• type APIReflectorsController
• type ApiController
• type Controller
  • func NewApiController(homeClient, foreignClient kubernetes.Interface, ...) *Controller
  • func (c *Controller) CacheManager() storage.CacheManagerReaderAdder
  • func (c *Controller) SetInformingFunc(api apiReflection.ApiType, handler func(interface{}))
  • func (c *Controller) StartController()
  • func (c *Controller) StopController() error
  • func (c *Controller) StopReflection(restart bool)
• type IncomingAPIReflectorsController
  • func NewIncomingReflectorsController(homeClient, foreignClient kubernetes.Interface, cacheManager *storage.Manager, ...) IncomingAPIReflectorsController
• type IncomingReflectorsController
  • func (c *IncomingReflectorsController) SetInforming(api apimgmt.ApiType, handler func(interface{}))
  • func (c *IncomingReflectorsController) Start()
• type OutGoingAPIReflectorsController
  • func NewOutgoingReflectorsController(homeClient, foreignClient kubernetes.Interface, cacheManager *storage.Manager, ...) OutGoingAPIReflectorsController
• type OutgoingReflectorsController
  • func (c *OutgoingReflectorsController) Start()
• type ReflectorsController
  • func (c *ReflectorsController) DispatchEvent(event apimgmt.ApiEvent)
  • func (c *ReflectorsController) Stop()
• type SpecializedAPIReflectorsController

Types

type APIReflectorsController

type APIReflectorsController interface {
	Stop()
	DispatchEvent(event apimgmt.ApiEvent)
}

type ApiController

type ApiController interface {
	SetInformingFunc(apiReflection.ApiType, func(interface{}))
	CacheManager() storage.CacheManagerReaderAdder
	StartController()
	StopController() error
	StopReflection(restart bool)
}

type Controller

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

func NewApiController

func NewApiController(homeClient, foreignClient kubernetes.Interface, mapper namespacesMapping.MapperController, opts map[options.OptionKey]options.Option, tepReady chan struct{}) *Controller

func (*Controller) CacheManager

func (c *Controller) CacheManager() storage.CacheManagerReaderAdder

func (*Controller) SetInformingFunc

func (c *Controller) SetInformingFunc(api apiReflection.ApiType, handler func(interface{}))

func (*Controller) StartController

func (c *Controller) StartController()

func (*Controller) StopController

func (c *Controller) StopController() error

func (*Controller) StopReflection

func (c *Controller) StopReflection(restart bool)

type IncomingAPIReflectorsController

type IncomingAPIReflectorsController interface {
	APIReflectorsController
	SpecializedAPIReflectorsController

	SetInforming(api apimgmt.ApiType, handler func(interface{}))
	// contains filtered or unexported methods
}

func NewIncomingReflectorsController

func NewIncomingReflectorsController(homeClient, foreignClient kubernetes.Interface, cacheManager *storage.Manager,
	outputChan chan apimgmt.ApiEvent,
	namespaceNatting namespacesMapping.MapperController,
	opts map[options.OptionKey]options.Option) IncomingAPIReflectorsController

type IncomingReflectorsController

type IncomingReflectorsController struct {
	*ReflectorsController
}

func (*IncomingReflectorsController) SetInforming

func (c *IncomingReflectorsController) SetInforming(api apimgmt.ApiType, handler func(interface{}))

func (*IncomingReflectorsController) Start

func (c *IncomingReflectorsController) Start()

type OutGoingAPIReflectorsController

type OutGoingAPIReflectorsController interface {
	APIReflectorsController
	SpecializedAPIReflectorsController
	// contains filtered or unexported methods
}

func NewOutgoingReflectorsController

func NewOutgoingReflectorsController(homeClient, foreignClient kubernetes.Interface, cacheManager *storage.Manager,
	outputChan chan apimgmt.ApiEvent,
	namespaceNatting namespacesMapping.MapperController,
	opts map[options.OptionKey]options.Option) OutGoingAPIReflectorsController

type OutgoingReflectorsController

type OutgoingReflectorsController struct {
	*ReflectorsController
}

func (*OutgoingReflectorsController) Start

func (c *OutgoingReflectorsController) Start()

type ReflectorsController

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

func (*ReflectorsController) DispatchEvent

func (c *ReflectorsController) DispatchEvent(event apimgmt.ApiEvent)

func (*ReflectorsController) Stop

func (c *ReflectorsController) Stop()

type SpecializedAPIReflectorsController

type SpecializedAPIReflectorsController interface {
	Start()
}