registry_checker

Documentation

Index

• func EqualObjects(a, b interface{}) bool
• func ExtractContainerInfos(image string, obj interface{}) []store.ContainerInfo
• func ExtractImages(obj interface{}) []string
• func ExtractPullSecretRefs(kubeClient *kubernetes.Clientset, obj interface{}) (ret []string)
• func GetImagesFromCronJob(obj interface{}) ([]string, error)
• func GetImagesFromDaemonSet(obj interface{}) ([]string, error)
• func GetImagesFromDeployment(obj interface{}) ([]string, error)
• func GetImagesFromStatefulSet(obj interface{}) ([]string, error)
• func IsAbsent(err error) bool
• func IsAuthnFail(err error) bool
• func IsAuthzFail(err error) bool
• func IsOldRegistry(err error) bool
• type ControllerIndexers
  • func (ci ControllerIndexers) GetContainerInfosForImage(image string) (ret []store.ContainerInfo)
  • func (ci ControllerIndexers) GetKeychainForImage(kubeClient *kubernetes.Clientset, image string) *keychain
  • func (ci ControllerIndexers) GetKeysByIndex(image string) (ret []string)
  • func (ci ControllerIndexers) GetObjectsByIndex(image string) (ret []interface{})
• type RegistryChecker
  • func NewRegistryChecker(stopCh <-chan struct{}, kubeClient *kubernetes.Clientset, skipVerify bool, ...) *RegistryChecker
  • func (rc *RegistryChecker) Check(imageName string) store.AvailabilityMode
  • func (rc *RegistryChecker) Collect(ch chan<- prometheus.Metric)
  • func (rc *RegistryChecker) Describe(_ chan<- *prometheus.Desc)
  • func (rc RegistryChecker) Tick()

Functions

func EqualObjects

func EqualObjects(a, b interface{}) bool

func ExtractContainerInfos

func ExtractContainerInfos(image string, obj interface{}) []store.ContainerInfo

func ExtractImages

func ExtractImages(obj interface{}) []string

func ExtractPullSecretRefs

func ExtractPullSecretRefs(kubeClient *kubernetes.Clientset, obj interface{}) (ret []string)

func GetImagesFromCronJob

func GetImagesFromCronJob(obj interface{}) ([]string, error)

func GetImagesFromDaemonSet

func GetImagesFromDaemonSet(obj interface{}) ([]string, error)

func GetImagesFromDeployment

func GetImagesFromDeployment(obj interface{}) ([]string, error)

func GetImagesFromStatefulSet

func GetImagesFromStatefulSet(obj interface{}) ([]string, error)

func IsAbsent

func IsAbsent(err error) bool

func IsAuthnFail

func IsAuthnFail(err error) bool

func IsAuthzFail

func IsAuthzFail(err error) bool

func IsOldRegistry

func IsOldRegistry(err error) bool

Types

type ControllerIndexers

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

func (ControllerIndexers) GetContainerInfosForImage

func (ci ControllerIndexers) GetContainerInfosForImage(image string) (ret []store.ContainerInfo)

func (ControllerIndexers) GetKeychainForImage

func (ci ControllerIndexers) GetKeychainForImage(kubeClient *kubernetes.Clientset, image string) *keychain

func (ControllerIndexers) GetKeysByIndex

func (ci ControllerIndexers) GetKeysByIndex(image string) (ret []string)

func (ControllerIndexers) GetObjectsByIndex

func (ci ControllerIndexers) GetObjectsByIndex(image string) (ret []interface{})

type RegistryChecker

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

func NewRegistryChecker

func NewRegistryChecker(
	stopCh <-chan struct{},
	kubeClient *kubernetes.Clientset,
	skipVerify bool,
	ignoredImages []regexp.Regexp,
	specificNamespace string,
	defaultRegistry string,
) *RegistryChecker

func (*RegistryChecker) Check

func (rc *RegistryChecker) Check(imageName string) store.AvailabilityMode

func (*RegistryChecker) Collect

func (rc *RegistryChecker) Collect(ch chan<- prometheus.Metric)

Collect implements prometheus.Collector.

func (*RegistryChecker) Describe

func (rc *RegistryChecker) Describe(_ chan<- *prometheus.Desc)

Describe implements prometheus.Collector.

func (RegistryChecker) Tick

func (rc RegistryChecker) Tick()