csi_handler

Documentation

Index

• type CSIHandler
  • func NewCSIPVHandler(conn *grpc.ClientConn) CSIHandler
• type PVHealthConditionChecker
  • func NewPVHealthConditionChecker(name string, conn *grpc.ClientConn, kClient kubernetes.Interface, ...) *PVHealthConditionChecker
  • func (checker *PVHealthConditionChecker) CheckControllerListVolumeStatuses() error
  • func (checker *PVHealthConditionChecker) CheckControllerVolumeStatus(pv *v1.PersistentVolume) error
  • func (checker *PVHealthConditionChecker) CheckNodeVolumeStatus(kubeletRootPath string, supportStageUnstage bool, pv *v1.PersistentVolume, ...) error
  • func (checker *PVHealthConditionChecker) GetVolumeHandle(pv *v1.PersistentVolume) (string, error)
• type VolumeConditionResult
  • func (vcr *VolumeConditionResult) GetAbnormal() bool
  • func (vcr *VolumeConditionResult) GetMessage() string

Types

type CSIHandler

type CSIHandler interface {
	ControllerListVolumeConditions(ctx context.Context) (map[string]*VolumeConditionResult, error)

	ControllerGetVolumeCondition(ctx context.Context, volumeID string) (*VolumeConditionResult, error)

	NodeGetVolumeCondition(ctx context.Context, volumeID string, volumePath string, volumeStagingPath string) (*VolumeConditionResult, error)
}

CSIHandler is for calling rpc interfaces

func NewCSIPVHandler

func NewCSIPVHandler(conn *grpc.ClientConn) CSIHandler

type PVHealthConditionChecker

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

PVHealthConditionChecker is for checking pv health condition

func NewPVHealthConditionChecker

func NewPVHealthConditionChecker(name string, conn *grpc.ClientConn, kClient kubernetes.Interface, timeout time.Duration,
	pvcLister corelisters.PersistentVolumeClaimLister, pvLister corelisters.PersistentVolumeLister, eventInformer coreinformers.EventInformer, recorder record.EventRecorder) *PVHealthConditionChecker

NewPVHealthConditionChecker returns an instance of PVHealthConditionChecker

func (*PVHealthConditionChecker) CheckControllerListVolumeStatuses

func (checker *PVHealthConditionChecker) CheckControllerListVolumeStatuses() error

CheckControllerListVolumeStatuses checks volumes health condition by ListVolumes

func (*PVHealthConditionChecker) CheckControllerVolumeStatus

func (checker *PVHealthConditionChecker) CheckControllerVolumeStatus(pv *v1.PersistentVolume) error

CheckControllerVolumeStatus checks volume status in controller side

func (*PVHealthConditionChecker) CheckNodeVolumeStatus

func (checker *PVHealthConditionChecker) CheckNodeVolumeStatus(kubeletRootPath string, supportStageUnstage bool, pv *v1.PersistentVolume, pod *v1.Pod) error

CheckNodeVolumeStatus checks volume status in node side

func (*PVHealthConditionChecker) GetVolumeHandle

func (checker *PVHealthConditionChecker) GetVolumeHandle(pv *v1.PersistentVolume) (string, error)

GetVolumeHandle returns the volume handle of the pv

type VolumeConditionResult

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

func (*VolumeConditionResult) GetAbnormal

func (vcr *VolumeConditionResult) GetAbnormal() bool

func (*VolumeConditionResult) GetMessage

func (vcr *VolumeConditionResult) GetMessage() string