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(ctx context.Context) error
  • func (checker *PVHealthConditionChecker) CheckControllerVolumeStatus(ctx context.Context, 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(ctx context.Context) error

CheckControllerListVolumeStatuses checks volumes health condition by ListVolumes

func (*PVHealthConditionChecker) CheckControllerVolumeStatus

func (checker *PVHealthConditionChecker) CheckControllerVolumeStatus(ctx context.Context, pv *v1.PersistentVolume) error

CheckControllerVolumeStatus checks volume status in controller 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