runners

Documentation

Index

• func NewDeviceCheck(dm *deviceManager.DeviceManager) manager.Runnable
• func NewGRPCRunner(srv *grpc.Server, sockFile string, leaderElection bool) manager.Runnable
• func NewNodeStorageResourceReconciler(mgr manager.Manager, dm *deviceManager.DeviceManager) manager.Runnable
• func NewTroubleShoot(dm *deviceManager.DeviceManager) manager.Runnable
• type Checker
  • func NewChecker(check func() error, interval time.Duration) Checker

Functions

func NewDeviceCheck

func NewDeviceCheck(dm *deviceManager.DeviceManager) manager.Runnable

func NewGRPCRunner

func NewGRPCRunner(srv *grpc.Server, sockFile string, leaderElection bool) manager.Runnable

NewGRPCRunner creates controller-runtime's manager.Runnable for a gRPC server. The server will listen on UNIX domain socket at sockFile. If leaderElection is true, the server will run only when it is elected as leader.

func NewNodeStorageResourceReconciler

func NewNodeStorageResourceReconciler(
	mgr manager.Manager,
	dm *deviceManager.DeviceManager,
) manager.Runnable

func NewTroubleShoot

func NewTroubleShoot(dm *deviceManager.DeviceManager) manager.Runnable

Types

type Checker

type Checker interface {
	manager.Runnable
	Ready() (bool, error)
}

Checker is the interface to check plugin readiness.

func NewChecker

func NewChecker(check func() error, interval time.Duration) Checker

NewChecker creates controller-runtime's manager.Runnable to run health check function periodically at given interval.