scalar

Documentation

Index

• Constants
• func InitScalars(logger *log.Logger, scanner *scanner.Scanner, kube *kuber.Kube, dryRun bool)
• type ContainerProcessor
• type IdentifiedContainer
• type OOMKillsProcessor
  • func NewOOMKillsProcessor(logger *log.Logger, kube *kuber.Kube, timeout time.Duration, dryRun bool) *OOMKillsProcessor
  • func (p *OOMKillsProcessor) Applicable(container IdentifiedContainer) bool
  • func (p *OOMKillsProcessor) Start()
  • func (p *OOMKillsProcessor) Stop()
  • func (p *OOMKillsProcessor) Submit(container IdentifiedContainer) error
• type ScannerListener
  • func NewScannerListener(logger *log.Logger, scanner *scanner.Scanner) *ScannerListener
  • func (sl *ScannerListener) AddContainerListener(processor ContainerProcessor)
  • func (sl *ScannerListener) Start()
  • func (sl *ScannerListener) Stop()

Constants

const OOMKilledReason = "OOMKilled"

Functions

func InitScalars

func InitScalars(
	logger *log.Logger,
	scanner *scanner.Scanner,
	kube *kuber.Kube,
	dryRun bool,
)

Types

type ContainerProcessor

type ContainerProcessor interface {
	Submit(status IdentifiedContainer) error
	Applicable(status IdentifiedContainer) bool
}

type IdentifiedContainer

type IdentifiedContainer struct {
	Container   scanner.Container
	Service     scanner.Service
	Application scanner.Application
	Status      kv1.ContainerStatus
}

type OOMKillsProcessor

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

func NewOOMKillsProcessor

func NewOOMKillsProcessor(
	logger *log.Logger,
	kube *kuber.Kube,
	timeout time.Duration,
	dryRun bool,
) *OOMKillsProcessor

func (*OOMKillsProcessor) Applicable

func (p *OOMKillsProcessor) Applicable(container IdentifiedContainer) bool

func (*OOMKillsProcessor) Start

func (p *OOMKillsProcessor) Start()

func (*OOMKillsProcessor) Stop

func (p *OOMKillsProcessor) Stop()

func (*OOMKillsProcessor) Submit

func (p *OOMKillsProcessor) Submit(container IdentifiedContainer) error

type ScannerListener

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

func NewScannerListener

func NewScannerListener(
	logger *log.Logger,
	scanner *scanner.Scanner,
) *ScannerListener

func (*ScannerListener) AddContainerListener

func (sl *ScannerListener) AddContainerListener(processor ContainerProcessor)

func (*ScannerListener) Start

func (sl *ScannerListener) Start()

func (*ScannerListener) Stop

func (sl *ScannerListener) Stop()