appcontroller

Documentation

Index

• type Controller
  • func New(log *logrus.Entry, namespace string, spaceSpec deccov1beta2.SpaceSpec, ...) *Controller
  • func (ctl *Controller) Start()
  • func (ctl *Controller) Stop()
• type InternalController
  • func NewInternalController(namespace string, spaceSpec deccov1beta2.SpaceSpec, stopCh chan interface{}) *InternalController
  • func (ctl *InternalController) GetItemList() (rv string, items []watcher.Item, err error)
  • func (c *InternalController) GetItemType() string
  • func (c *InternalController) InitCRD() error
  • func (ctl *InternalController) InitItem(item watcher.Item) watcher.ManagedItem
  • func (c *InternalController) LogEvent(evType kwatch.EventType, item watcher.Item)
  • func (c *InternalController) PeriodicTask(itemMap map[string]watcher.ManagedItem)
  • func (c *InternalController) Run() error
  • func (c *InternalController) StartWatchRequest(watchVersion string) (*http.Response, error)
  • func (c *InternalController) UnmarshalItem(evType kwatch.EventType, data []byte) (watcher.Item, string, error)

Types

type Controller

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

func New

func New(
	log *logrus.Entry,
	namespace string,
	spaceSpec deccov1beta2.SpaceSpec,
	wg *sync.WaitGroup,
) *Controller

func (*Controller) Start

func (ctl *Controller) Start()

func (*Controller) Stop

func (ctl *Controller) Stop()

type InternalController

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

func NewInternalController

func NewInternalController(
	namespace string,
	spaceSpec deccov1beta2.SpaceSpec,
	stopCh chan interface{},
) *InternalController

func (*InternalController) GetItemList

func (ctl *InternalController) GetItemList() (rv string, items []watcher.Item, err error)

func (*InternalController) GetItemType

func (c *InternalController) GetItemType() string

func (*InternalController) InitCRD

func (c *InternalController) InitCRD() error

func (*InternalController) InitItem

func (ctl *InternalController) InitItem(item watcher.Item) watcher.ManagedItem

func (*InternalController) LogEvent

func (c *InternalController) LogEvent(evType kwatch.EventType, item watcher.Item)

func (*InternalController) PeriodicTask

func (c *InternalController) PeriodicTask(itemMap map[string]watcher.ManagedItem)

func (*InternalController) Run

func (c *InternalController) Run() error

func (*InternalController) StartWatchRequest

func (c *InternalController) StartWatchRequest(
	watchVersion string,
) (*http.Response, error)

func (*InternalController) UnmarshalItem

func (c *InternalController) UnmarshalItem(
	evType kwatch.EventType,
	data []byte,
) (watcher.Item, string, error)