silence

package
v0.0.0-...-f49aa48 Latest Latest
Warning

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

Go to latest
Published: Apr 29, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetController

func GetController(pod *v1.Pod) (string, string)

func GetReadyStr

func GetReadyStr(pod *v1.Pod) string

func IsReady

func IsReady(pod *v1.Pod) bool

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 (*PodUpdateListenerMasterComponent) Stop

Jump to

Keyboard shortcuts

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