vollocal

package
v0.0.0-...-bcd8266 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 8, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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
	SyncInterval time.Duration
}

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL