recover

Documentation

Index

• Constants
• func Enabled() bool
• func Register(mgr manager.Manager, ctx config.RunningContext) error
• type FuseRecover
  • func NewFuseRecover(kubeClient client.Client, recorder record.EventRecorder, ...) (*FuseRecover, error)
  • func (r *FuseRecover) Start(ctx context.Context) error

Constants

const (
	FuseRecoveryPeriod      = "RECOVER_FUSE_PERIOD"
	RecoverWarningThreshold = "REVOCER_WARNING_THRESHOLD"
)

Functions

func Enabled

func Enabled() bool

Enabled checks if the fuse recover should be enabled.

func Register

func Register(mgr manager.Manager, ctx config.RunningContext) error

Register initializes the fuse recover and registers it to the controller manager.

Types

type FuseRecover

type FuseRecover struct {
	mount.SafeFormatAndMount
	KubeClient client.Client
	ApiReader  client.Reader
	// KubeletClient *kubelet.KubeletClient
	Recorder record.EventRecorder
	// contains filtered or unexported fields
}

func NewFuseRecover

func NewFuseRecover(kubeClient client.Client, recorder record.EventRecorder, apiReader client.Reader, locks *utils.VolumeLocks) (*FuseRecover, error)

func (*FuseRecover) Start

func (r *FuseRecover) Start(ctx context.Context) error