fscache

Documentation

Index

• type PluginWatcher
  • func NewPluginWatcher(dir string) (*PluginWatcher, error)
  • func (w *PluginWatcher) Watch()
• type Watcher
  • func NewWatch(dir string) (*Watcher, error)
  • func (w *Watcher) Watch()

Types

type PluginWatcher

type PluginWatcher struct {
	Cache *sync.Map
	// contains filtered or unexported fields
}

基于云原生的场景，我们其实可以不把插件放到minio等网络存储中，直接本地存储更高效 原因在于：云原生下使用pv来共享目录，多个pod公用共一个pv，再加上路径监听，就可以实现多个pod的插件加载

func NewPluginWatcher

func NewPluginWatcher(dir string) (*PluginWatcher, error)

NewWatch creates a directory watcher and updates the cache when any file changes in that dir

func (*PluginWatcher) Watch

func (w *PluginWatcher) Watch()

Watch watches for when kubelet updates the volume mount content

type Watcher

type Watcher struct {
	Cache *sync.Map
	// contains filtered or unexported fields
}

func NewWatch

func NewWatch(dir string) (*Watcher, error)

NewWatch creates a directory watcher and updates the cache when any file changes in that dir

func (*Watcher) Watch

func (w *Watcher) Watch()

Watch watches for when kubelet updates the volume mount content