vollocal

Documentation

Index

• func NewLocalClient(logger lager.Logger, registry volman.PluginRegistry, ...) volman.Manager
• func NewPluginRegistry() volman.PluginRegistry
• func NewPluginRegistryWith(initialMap map[string]volman.Plugin) volman.PluginRegistry
• func NewServer(logger lager.Logger, metronClient loggingclient.IngressClient, ...) (volman.Manager, ifrit.Runner)
• type DriverConfig
  • func NewDriverConfig() DriverConfig
• type MountPurger
  • func NewMountPurger(logger lager.Logger, registry volman.PluginRegistry) MountPurger
• type Syncer
  • func NewSyncer(logger lager.Logger, registry volman.PluginRegistry, ...) *Syncer
  • func NewSyncerWithShims(logger lager.Logger, registry volman.PluginRegistry, ...) *Syncer
  • func (p *Syncer) Run(signals <-chan os.Signal, ready chan<- struct{}) error
  • func (p *Syncer) Runner() ifrit.Runner

Functions

func NewLocalClient

func NewLocalClient(logger lager.Logger, registry volman.PluginRegistry, metronClient loggingclient.IngressClient, clock clock.Clock) volman.Manager

func NewPluginRegistry

func NewPluginRegistry() volman.PluginRegistry

func NewPluginRegistryWith

func NewPluginRegistryWith(initialMap map[string]volman.Plugin) volman.PluginRegistry

func NewServer

func NewServer(logger lager.Logger, metronClient loggingclient.IngressClient, config DriverConfig) (volman.Manager, ifrit.Runner)

Types

type DriverConfig

type DriverConfig struct {
	DriverPaths     []string
	CSIPaths        []string
	SyncInterval    time.Duration
	CSIMountRootDir string
}

func NewDriverConfig

func NewDriverConfig() DriverConfig

type MountPurger

type MountPurger interface {
	Runner() ifrit.Runner
	PurgeMounts(logger lager.Logger) error
}

func NewMountPurger

func NewMountPurger(logger lager.Logger, registry volman.PluginRegistry) MountPurger

type Syncer

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

func NewSyncer

func NewSyncer(logger lager.Logger, registry volman.PluginRegistry, discoverer []volman.Discoverer, scanInterval time.Duration, clock clock.Clock) *Syncer

func NewSyncerWithShims

func NewSyncerWithShims(logger lager.Logger, registry volman.PluginRegistry, discoverer []volman.Discoverer, scanInterval time.Duration, clock clock.Clock) *Syncer

func (*Syncer) Run

func (p *Syncer) Run(signals <-chan os.Signal, ready chan<- struct{}) error

func (*Syncer) Runner

func (p *Syncer) Runner() ifrit.Runner