csiplugin

README

csiplugin

A volman plugin for CSI(Container Storage Interface) node plugins

Documentation

Index

• func NewCsiPlugin(plugin csi.NodeClient, pluginSpec volman.PluginSpec, grpcShim grpcshim.Grpc, ...) volman.Plugin
• func NewCsiPluginWithInvoker(invoker invoker.Invoker, bgInvoker BackgroundInvoker, plugin csi.NodeClient, ...) volman.Plugin
• func WriteSpec(logger lager.Logger, pluginsDirectory string, spec CsiPluginSpec) error
• type BackgroundInvoker
  • func NewBackgroundInvoker(useExec execshim.Exec) BackgroundInvoker
• type CsiPluginSpec
  • func ReadSpec(logger lager.Logger, specFile string) (*CsiPluginSpec, error)
• type OsHelper

Functions

func NewCsiPlugin

func NewCsiPlugin(plugin csi.NodeClient, pluginSpec volman.PluginSpec, grpcShim grpcshim.Grpc, csiShim csishim.Csi, osShim osshim.Os, csiMountRootDir string, oshelper OsHelper) volman.Plugin

func NewCsiPluginWithInvoker

func NewCsiPluginWithInvoker(invoker invoker.Invoker, bgInvoker BackgroundInvoker, plugin csi.NodeClient, pluginSpec volman.PluginSpec, grpcShim grpcshim.Grpc, csiShim csishim.Csi, osShim osshim.Os, csiMountRootDir string, oshelper OsHelper) volman.Plugin

func WriteSpec

func WriteSpec(logger lager.Logger, pluginsDirectory string, spec CsiPluginSpec) error

Types

type BackgroundInvoker

type BackgroundInvoker interface {
	Invoke(env dockerdriver.Env, executable string, cmdArgs []string, waitFor string, timeout time.Duration) error
}

func NewBackgroundInvoker

func NewBackgroundInvoker(useExec execshim.Exec) BackgroundInvoker

type CsiPluginSpec

type CsiPluginSpec struct {
	Name    string `json:-`
	Address string `json:address`
}

func ReadSpec

func ReadSpec(logger lager.Logger, specFile string) (*CsiPluginSpec, error)

type OsHelper

type OsHelper interface {
	Umask(mask int) (oldmask int)
}