Documentation ¶
Index ¶
- func GetController(pod *v1.Pod) (string, string)
- func GetReadyStr(pod *v1.Pod) string
- func IsReady(pod *v1.Pod) bool
- func RegisterControllerManagerProviders(p func(helper Helper) ControllerManager)
- type ControllerManager
- type Helper
- type PodUpdateListener
- func (l *PodUpdateListener) EnterSilence(pod *v1.Pod)
- func (l *PodUpdateListener) IsPodReady() bool
- func (l *PodUpdateListener) LeaveSilence(pod *v1.Pod)
- func (l *PodUpdateListener) OnPodAdd(obj interface{})
- func (l *PodUpdateListener) OnPodDel(obj interface{})
- func (l *PodUpdateListener) Start()
- func (l *PodUpdateListener) Stop()
- type PodUpdateListenerMasterComponent
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetReadyStr ¶
func RegisterControllerManagerProviders ¶
func RegisterControllerManagerProviders(p func(helper Helper) ControllerManager)
Types ¶
type ControllerManager ¶
type ControllerManager interface { PodHandler() cache.ResourceEventHandler Run(stopCh chan struct{}) IsUnderControl(pod *v1.Pod) bool }
type Helper ¶
type Helper interface { IsPodReady() bool OnPodAdd(obj interface{}) OnPodDel(obj interface{}) EnterSilence(pod *v1.Pod) LeaveSilence(pod *v1.Pod) }
A helper interface for ControllerManager impl
type PodUpdateListener ¶
type PodUpdateListener struct {
// contains filtered or unexported fields
}
func NewPodOperationListener ¶
func NewPodOperationListener(clientset *kubernetes.Clientset) *PodUpdateListener
func (*PodUpdateListener) EnterSilence ¶
func (l *PodUpdateListener) EnterSilence(pod *v1.Pod)
func (*PodUpdateListener) IsPodReady ¶
func (l *PodUpdateListener) IsPodReady() bool
func (*PodUpdateListener) LeaveSilence ¶
func (l *PodUpdateListener) LeaveSilence(pod *v1.Pod)
func (*PodUpdateListener) OnPodAdd ¶
func (l *PodUpdateListener) OnPodAdd(obj interface{})
func (*PodUpdateListener) OnPodDel ¶
func (l *PodUpdateListener) OnPodDel(obj interface{})
func (*PodUpdateListener) Start ¶
func (l *PodUpdateListener) Start()
func (*PodUpdateListener) Stop ¶
func (l *PodUpdateListener) Stop()
type PodUpdateListenerMasterComponent ¶
type PodUpdateListenerMasterComponent struct {
// contains filtered or unexported fields
}
func (*PodUpdateListenerMasterComponent) Start ¶
func (c *PodUpdateListenerMasterComponent) Start()
func (*PodUpdateListenerMasterComponent) Stop ¶
func (c *PodUpdateListenerMasterComponent) Stop()
Click to show internal directories.
Click to hide internal directories.