controller

Documentation

Index

• type Controller
• type EtcdController
  • func NewEtcdController(kconfig, wType string, period int, cache cache.Store, ...) (*EtcdController, error)
  • func (ctrl *EtcdController) AddEvent(obj interface{})
  • func (ctrl *EtcdController) DeleteEvent(obj interface{})
  • func (ctrl *EtcdController) Resynced() bool
  • func (ctrl *EtcdController) RunController(stopCh <-chan struct{}) error
  • func (ctrl *EtcdController) StopController()
  • func (ctrl *EtcdController) UpdateEvent(oldObj, newObj interface{})
• type ZkClient
• type ZkController
  • func NewZkController(zkHost []string, path string, period int, cache cache.Store, ...) (*ZkController, error)
  • func (ctrl *ZkController) Resynced() bool
  • func (ctrl *ZkController) RunController(stopCh <-chan struct{}) error
  • func (ctrl *ZkController) StopController()

Types

type Controller

type Controller interface {
	RunController(stopCh <-chan struct{}) error
	StopController()
}

Controller xxx

type EtcdController

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

EtcdController xxx

func NewEtcdController

func NewEtcdController(kconfig, wType string, period int, cache cache.Store,
	eventFunc *clientGoCache.ResourceEventHandlerFuncs) (*EtcdController, error)

NewEtcdController create controller according Store, Decoder end EventFuncs

func (*EtcdController) AddEvent

func (ctrl *EtcdController) AddEvent(obj interface{})

AddEvent xxx

func (*EtcdController) DeleteEvent

func (ctrl *EtcdController) DeleteEvent(obj interface{})

DeleteEvent xxx

func (*EtcdController) Resynced

func (ctrl *EtcdController) Resynced() bool

Resynced check controller is under resynced

func (*EtcdController) RunController

func (ctrl *EtcdController) RunController(stopCh <-chan struct{}) error

RunController running controller, create goroutine watch kube-api data

func (*EtcdController) StopController

func (ctrl *EtcdController) StopController()

StopController stop controller event, clean all data

func (*EtcdController) UpdateEvent

func (ctrl *EtcdController) UpdateEvent(oldObj, newObj interface{})

UpdateEvent xxx

type ZkClient

type ZkClient interface {
	Close()
	Get(path string) ([]byte, *zk.Stat, error)
	GetW(path string) ([]byte, *zk.Stat, <-chan zk.Event, error)
	Children(path string) ([]string, *zk.Stat, error)
	ChildrenW(path string) ([]string, *zk.Stat, <-chan zk.Event, error)
	Exists(path string) (bool, error)
	ExistsW(path string) (bool, *zk.Stat, <-chan zk.Event, error)
}

ZkClient interface to define zk operation interface is only use for dependency injection

type ZkController

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

ZkController xxx

func NewZkController

func NewZkController(zkHost []string, path string, period int, cache cache.Store, decoder bcsSchedulerUtil.Decoder,
	eventFunc *clientGoCache.ResourceEventHandlerFuncs) (*ZkController, error)

NewZkController create controller according Store, Decoder end EventFuncs

func (*ZkController) Resynced

func (ctrl *ZkController) Resynced() bool

Resynced check controller is under resynced

func (*ZkController) RunController

func (ctrl *ZkController) RunController(stopCh <-chan struct{}) error

RunController running controller, create goroutine watch zookeeper data

func (*ZkController) StopController

func (ctrl *ZkController) StopController()

StopController stop controller event, clean all data