releaser

Documentation

Overview

Package releaser is an automatic PV reclaimer.

Index

• Constants
• func New(ctx context.Context, kubeClientSet kubernetes.Interface, ...) controller.Controller
• type Releaser
  • func (r *Releaser) Run(threadiness int, stopCh <-chan struct{}) error
  • func (r *Releaser) Stop()

Constants

const (
	AgentName = "reclaimable-pv-releaser"

	AnnotationBaseName        = AgentName + ".kubernetes.io"
	AnnotationControllerIdKey = "controller-id"
	AnnotationControllerId    = AnnotationBaseName + "/" + AnnotationControllerIdKey

	Released          = "Released"
	MessagePVReleased = "PV released successfully"

	MessageReleasePV = "error releasing PV %s: %s"
	ErrReleasePV     = "ErrReleasePV"
)

Functions

func New

func New(
	ctx context.Context,
	kubeClientSet kubernetes.Interface,
	namespace,
	controllerId string,
) controller.Controller

Types

type Releaser

type Releaser struct {
	controller.BasicController

	SCLister storagelisters.StorageClassLister

	PVLister corelisters.PersistentVolumeLister
	PVSynced cache.InformerSynced
	PVQueue  workqueue.RateLimitingInterface
	// contains filtered or unexported fields
}

func (*Releaser) Run

func (r *Releaser) Run(threadiness int, stopCh <-chan struct{}) error

func (*Releaser) Stop

func (r *Releaser) Stop()