autoresizer

Documentation

Index

• Constants
• func ListResizePolicies(cli client.Client) ([]hwameistorv1alpha1.ResizePolicy, error)
• func NumericToLVMBytes(bytes int64) int64
• func StartResizePolicyEventHandler(cli client.Client, runtimeCache runtimecache.Cache)
• func StartResizePolicyEventHandlerV2(cli client.Client, q workqueue.RateLimitingInterface, ...)
• type AutoResizer
  • func NewAutoResizer(cli client.Client, ctx context.Context) *AutoResizer
  • func (r *AutoResizer) Start()
• type Hooker
  • func NewHooker(cli client.Client, ctx context.Context) *Hooker
  • func (h *Hooker) Start()
• type PVCAttacher
  • func NewPVCAttacher(cli client.Client, q workqueue.RateLimitingInterface) *PVCAttacher
  • func (a *PVCAttacher) Start(stopCh <-chan struct{})
  • func (a *PVCAttacher) StartPVCInformer(cli client.Client, ctx context.Context)
• type ResizePolicyChain
• type ResizePolicyWorker
  • func NewResizePolicyWorker(cli client.Client, resizePolicy *hwameistorv1alpha1.ResizePolicy) *ResizePolicyWorker
  • func (w *ResizePolicyWorker) Select(pvc *corev1.PersistentVolumeClaim) (*Selection, error)
• type Selection
• type SelectionType

Constants

const (
	PVCResizePolicyAnnotationName = "hwameistor.io/resize-policyName"
	PVCResizePolicyAnnotationKey  = "hwameistor.io/resizepolicy"
)

Functions

func ListResizePolicies

func ListResizePolicies(cli client.Client) ([]hwameistorv1alpha1.ResizePolicy, error)

func NumericToLVMBytes

func NumericToLVMBytes(bytes int64) int64

func StartResizePolicyEventHandler

func StartResizePolicyEventHandler(cli client.Client, runtimeCache runtimecache.Cache)

func StartResizePolicyEventHandlerV2

func StartResizePolicyEventHandlerV2(cli client.Client, q workqueue.RateLimitingInterface, runtimeCache runtimecache.Cache)

Types

type AutoResizer

type AutoResizer struct {
	Client  client.Client
	Context context.Context
}

func NewAutoResizer

func NewAutoResizer(cli client.Client, ctx context.Context) *AutoResizer

func (*AutoResizer) Start

func (r *AutoResizer) Start()

type Hooker

type Hooker struct {
	Client  client.Client
	Context context.Context
}

func NewHooker

func NewHooker(cli client.Client, ctx context.Context) *Hooker

func (*Hooker) Start

func (h *Hooker) Start()

type PVCAttacher

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

func NewPVCAttacher

func NewPVCAttacher(cli client.Client, q workqueue.RateLimitingInterface) *PVCAttacher

func (*PVCAttacher) Start

func (a *PVCAttacher) Start(stopCh <-chan struct{})

func (*PVCAttacher) StartPVCInformer

func (a *PVCAttacher) StartPVCInformer(cli client.Client, ctx context.Context)

type ResizePolicyChain

type ResizePolicyChain struct {
	Name  string
	Lock  sync.Mutex
	Chain []*hwameistorv1alpha1.ResizePolicy
}

type ResizePolicyWorker

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

func NewResizePolicyWorker

func NewResizePolicyWorker(cli client.Client, resizePolicy *hwameistorv1alpha1.ResizePolicy) *ResizePolicyWorker

func (*ResizePolicyWorker) Select

func (w *ResizePolicyWorker) Select(pvc *corev1.PersistentVolumeClaim) (*Selection, error)

type Selection

type Selection struct {
	Selected bool
	Type     SelectionType
}

type SelectionType

type SelectionType string

const (
	PVCSelector          SelectionType = "pvcSelector"
	NamespaceSelector    SelectionType = "namespaceSelector"
	StorageClassSelector SelectionType = "storageClassSelector"
)