spacecontroller

Documentation

Index

• type Controller
  • func New(clustConfig *restclient.Config, kubeApi *kubernetes.Clientset) *Controller
  • func (ctl *Controller) GetItemList() (rv string, items []watcher.Item, err error)
  • func (c *Controller) GetItemType() string
  • func (c *Controller) InitCRD() error
  • func (c *Controller) InitItem(item watcher.Item) watcher.ManagedItem
  • func (c *Controller) LogEvent(evType kwatch.EventType, item watcher.Item)
  • func (c *Controller) PeriodicTask(itemMap map[string]watcher.ManagedItem)
  • func (c *Controller) Run() error
  • func (c *Controller) StartWatchRequest(watchVersion string) (*http.Response, error)
  • func (c *Controller) UnmarshalItem(evType kwatch.EventType, data []byte) (watcher.Item, string, error)
• type SpaceInfo
  • func (spcInfo *SpaceInfo) Delete()
  • func (spcInfo *SpaceInfo) Name() string
  • func (spcInfo *SpaceInfo) Stop()
  • func (spcInfo *SpaceInfo) Update(item watcher.Item)

Types

type Controller

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

func New

func New(
	clustConfig *restclient.Config,
	kubeApi *kubernetes.Clientset,
) *Controller

func (*Controller) GetItemList

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

func (*Controller) GetItemType

func (c *Controller) GetItemType() string

func (*Controller) InitCRD

func (c *Controller) InitCRD() error

func (*Controller) InitItem

func (c *Controller) InitItem(item watcher.Item) watcher.ManagedItem

func (*Controller) LogEvent

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

func (*Controller) PeriodicTask

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

func (*Controller) Run

func (c *Controller) Run() error

func (*Controller) StartWatchRequest

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

func (*Controller) UnmarshalItem

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

type SpaceInfo

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

func (*SpaceInfo) Delete

func (spcInfo *SpaceInfo) Delete()

func (*SpaceInfo) Name

func (spcInfo *SpaceInfo) Name() string

func (*SpaceInfo) Stop

func (spcInfo *SpaceInfo) Stop()

func (*SpaceInfo) Update

func (spcInfo *SpaceInfo) Update(item watcher.Item)