kubernetes/vendor/github.com/google/cadvisor/devicemapper/thin_pool_watcher.go

type ThinPoolWatcher …

// NewThinPoolWatcher returns a new ThinPoolWatcher for the given devicemapper
// thin pool name and metadata device or an error.
func NewThinPoolWatcher(poolName, metadataDevice string) (*ThinPoolWatcher, error) { … }

// Start starts the ThinPoolWatcher.
func (w *ThinPoolWatcher) Start() { … }

// Stop stops the ThinPoolWatcher.
func (w *ThinPoolWatcher) Stop() { … }

// GetUsage gets the cached usage value of the given device.
func (w *ThinPoolWatcher) GetUsage(deviceID string) (uint64, error) { … }

const reserveMetadataMessage …

const releaseMetadataMessage …

// Refresh performs a `thin_ls` of the pool being watched and refreshes the
// cached data with the result.
func (w *ThinPoolWatcher) Refresh() error { … }

const thinPoolDmsetupStatusHeldMetadataRoot …

const thinPoolDmsetupStatusMinFields …

// checkReservation checks to see whether the thin device is currently holding
// userspace metadata.
func (w *ThinPoolWatcher) checkReservation(poolName string) (bool, error) { … }