scalar2

Documentation

Index

• Constants
• func InitScalars(kube *kuber.Kube, observer_ *kuber.Observer, dryRun bool)
• type OOMKillsProcessor
  • func NewOOMKillsProcessor(kube *kuber.Kube, observer_ *kuber.Observer, timeout time.Duration, ...) *OOMKillsProcessor
  • func (p *OOMKillsProcessor) Start()
  • func (p *OOMKillsProcessor) Stop()
  • func (p *OOMKillsProcessor) Submit(pod corev1.Pod) error
• type Pod
  • func (p *Pod) GetAPIVersion() string
  • func (p *Pod) GetKind() string
• type PodProcessor
• type ScannerListener
  • func NewScannerListener(observer_ *kuber.Observer) *ScannerListener
  • func (sl *ScannerListener) AddPodListener(processor PodProcessor)
  • func (sl *ScannerListener) Start()
  • func (sl *ScannerListener) Stop()

Constants

const OOMKilledReason = "OOMKilled"

Functions

func InitScalars

func InitScalars(
	kube *kuber.Kube,
	observer_ *kuber.Observer,
	dryRun bool,
)

Types

type OOMKillsProcessor

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

func NewOOMKillsProcessor

func NewOOMKillsProcessor(
	kube *kuber.Kube,
	observer_ *kuber.Observer,
	timeout time.Duration,
	dryRun bool,
) *OOMKillsProcessor

func (*OOMKillsProcessor) Start

func (p *OOMKillsProcessor) Start()

func (*OOMKillsProcessor) Stop

func (p *OOMKillsProcessor) Stop()

func (*OOMKillsProcessor) Submit

func (p *OOMKillsProcessor) Submit(pod corev1.Pod) error

type Pod

type Pod struct {
	corev1.Pod
}

func (*Pod) GetAPIVersion

func (p *Pod) GetAPIVersion() string

func (*Pod) GetKind

func (p *Pod) GetKind() string

type PodProcessor

type PodProcessor interface {
	Submit(pod corev1.Pod) error
}

type ScannerListener

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

func NewScannerListener

func NewScannerListener(
	observer_ *kuber.Observer,
) *ScannerListener

func (*ScannerListener) AddPodListener

func (sl *ScannerListener) AddPodListener(processor PodProcessor)

func (*ScannerListener) Start

func (sl *ScannerListener) Start()

func (*ScannerListener) Stop

func (sl *ScannerListener) Stop()