recover

Documentation

Index

• Constants
• func Enabled() bool
• func Register(mgr manager.Manager, config config.Config) 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"
)

Functions

func Enabled

func Enabled() bool

Enabled checks if the fuse recover should be enabled.

func Register

func Register(mgr manager.Manager, config config.Config) 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) (*FuseRecover, error)

func (*FuseRecover) Start

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