filesystem

Documentation

Index

• type API
• type Server
  • func NewServer(kubeletCSIPluginsPath string, kubeletPodPath string, hostAPI API) (*Server, error)
  • func (s *Server) IsMountPoint(ctx context.Context, request *internal.IsMountPointRequest, ...) (*internal.IsMountPointResponse, error)
  • func (s *Server) LinkPath(ctx context.Context, request *internal.LinkPathRequest, ...) (*internal.LinkPathResponse, error)
  • func (s *Server) Mkdir(ctx context.Context, request *internal.MkdirRequest, ...) (*internal.MkdirResponse, error)
  • func (s *Server) PathExists(ctx context.Context, request *internal.PathExistsRequest, ...) (*internal.PathExistsResponse, error)
  • func (s *Server) Rmdir(ctx context.Context, request *internal.RmdirRequest, ...) (*internal.RmdirResponse, error)
  • func (s *Server) ValidatePluginPath(path string) error
  • func (s *Server) VersionedAPIs() []*srvtypes.VersionedAPI

Types

type API

type API interface {
	PathExists(path string) (bool, error)
	Mkdir(path string) error
	Rmdir(path string, force bool) error
	LinkPath(tgt string, src string) error
	IsMountPoint(path string) (bool, error)
}

type Server

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

func NewServer

func NewServer(kubeletCSIPluginsPath string, kubeletPodPath string, hostAPI API) (*Server, error)

func (*Server) IsMountPoint

func (s *Server) IsMountPoint(ctx context.Context, request *internal.IsMountPointRequest, version apiversion.Version) (*internal.IsMountPointResponse, error)

func (*Server) LinkPath

func (s *Server) LinkPath(ctx context.Context, request *internal.LinkPathRequest, version apiversion.Version) (*internal.LinkPathResponse, error)

func (*Server) Mkdir

func (s *Server) Mkdir(ctx context.Context, request *internal.MkdirRequest, version apiversion.Version) (*internal.MkdirResponse, error)

func (*Server) PathExists

func (s *Server) PathExists(ctx context.Context, request *internal.PathExistsRequest, version apiversion.Version) (*internal.PathExistsResponse, error)

PathExists checks if the given path exists on the host.

func (*Server) Rmdir

func (s *Server) Rmdir(ctx context.Context, request *internal.RmdirRequest, version apiversion.Version) (*internal.RmdirResponse, error)

func (*Server) ValidatePluginPath

func (s *Server) ValidatePluginPath(path string) error

ValidatePluginPath - Validates the path is compatible with the 'plugin path' restrictions. Note: The reason why we cannot reuse the validatePathWindows directly from other parts of the library is that it seems internal.PLUGIN was not usable from outside the internal path tree.

func (*Server) VersionedAPIs

func (s *Server) VersionedAPIs() []*srvtypes.VersionedAPI