appcontroller

package
v1.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 23, 2020 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL