watchdog

Documentation

Index

• func NewWatchdogListWatchFromClient(virtShareDir string, watchdogTimeout int) cache.ListerWatcher
• func WatchdogFileDirectory(baseDir string) string
• func WatchdogFileExists(baseDir string, vm *v1.VirtualMachine) (bool, error)
• func WatchdogFileFromNamespaceName(baseDir string, namespace string, name string) string
• func WatchdogFileIsExpired(timeoutSeconds int, baseDir string, vm *v1.VirtualMachine) (bool, error)
• func WatchdogFileRemove(baseDir string, vm *v1.VirtualMachine) error
• func WatchdogFileUpdate(watchdogFile string) error
• type WatchdogListWatcher
  • func (d *WatchdogListWatcher) List(options k8sv1.ListOptions) (runtime.Object, error)
  • func (d *WatchdogListWatcher) ResultChan() <-chan watch.Event
  • func (d *WatchdogListWatcher) Stop()
  • func (d *WatchdogListWatcher) Watch(options k8sv1.ListOptions) (watch.Interface, error)

Functions

func NewWatchdogListWatchFromClient

func NewWatchdogListWatchFromClient(virtShareDir string, watchdogTimeout int) cache.ListerWatcher

func WatchdogFileDirectory

func WatchdogFileDirectory(baseDir string) string

func WatchdogFileExists

func WatchdogFileExists(baseDir string, vm *v1.VirtualMachine) (bool, error)

func WatchdogFileFromNamespaceName

func WatchdogFileFromNamespaceName(baseDir string, namespace string, name string) string

func WatchdogFileIsExpired

func WatchdogFileIsExpired(timeoutSeconds int, baseDir string, vm *v1.VirtualMachine) (bool, error)

func WatchdogFileRemove

func WatchdogFileRemove(baseDir string, vm *v1.VirtualMachine) error

func WatchdogFileUpdate

func WatchdogFileUpdate(watchdogFile string) error

Types

type WatchdogListWatcher

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

func (*WatchdogListWatcher) List

func (d *WatchdogListWatcher) List(options k8sv1.ListOptions) (runtime.Object, error)

func (*WatchdogListWatcher) ResultChan

func (d *WatchdogListWatcher) ResultChan() <-chan watch.Event

func (*WatchdogListWatcher) Stop

func (d *WatchdogListWatcher) Stop()

func (*WatchdogListWatcher) Watch

func (d *WatchdogListWatcher) Watch(options k8sv1.ListOptions) (watch.Interface, error)