manager

Documentation

Index

• type CommonResourceEventHandler
  • func NewCommonResourceEventHandler(events chan watch.Event) *CommonResourceEventHandler
  • func (c *CommonResourceEventHandler) OnAdd(obj interface{}, _ bool)
  • func (c *CommonResourceEventHandler) OnDelete(obj interface{})
  • func (c *CommonResourceEventHandler) OnUpdate(_, newObj interface{})
• type DeviceManager
  • func NewDeviceManager(si cache.SharedIndexInformer) (*DeviceManager, error)
  • func (dmm *DeviceManager) Events() chan watch.Event
• type DeviceModelManager
  • func NewDeviceModelManager(si cache.SharedIndexInformer) (*DeviceModelManager, error)
  • func (dmm *DeviceModelManager) Events() chan watch.Event
• type Manager

Types

type CommonResourceEventHandler

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

CommonResourceEventHandler can be used by configmapManager and podManager

func NewCommonResourceEventHandler

func NewCommonResourceEventHandler(events chan watch.Event) *CommonResourceEventHandler

NewCommonResourceEventHandler create CommonResourceEventHandler used by configmapManager and podManager

func (*CommonResourceEventHandler) OnAdd

func (c *CommonResourceEventHandler) OnAdd(obj interface{}, _ bool)

OnAdd handle Add event

func (*CommonResourceEventHandler) OnDelete

func (c *CommonResourceEventHandler) OnDelete(obj interface{})

OnDelete handle Delete event

func (*CommonResourceEventHandler) OnUpdate

func (c *CommonResourceEventHandler) OnUpdate(_, newObj interface{})

OnUpdate handle Update event

type DeviceManager

type DeviceManager struct {

	// Device, key is device.Namespace+"/"+device.Name, value is *v1beta1.Device{}
	Device sync.Map
	// contains filtered or unexported fields
}

DeviceManager is a manager watch device change event

func NewDeviceManager

func NewDeviceManager(si cache.SharedIndexInformer) (*DeviceManager, error)

NewDeviceManager create DeviceManager from config

func (*DeviceManager) Events

func (dmm *DeviceManager) Events() chan watch.Event

Events return a channel, can receive all device event

type DeviceModelManager

type DeviceModelManager struct {

	// DeviceModel, key is DeviceModel.Namespace+"/"+deviceModel.Name, value is *v1beta1.DeviceModel{}
	DeviceModel sync.Map
	// contains filtered or unexported fields
}

DeviceModelManager is a manager watch DeviceModel change event

func NewDeviceModelManager

func NewDeviceModelManager(si cache.SharedIndexInformer) (*DeviceModelManager, error)

NewDeviceModelManager create DeviceModelManager from config

func (*DeviceModelManager) Events

func (dmm *DeviceModelManager) Events() chan watch.Event

Events return a channel, can receive all DeviceModel event

type Manager

type Manager interface {
	Events() chan watch.Event
}

Manager define the interface of a Manager, configmapManager and podManager implement it