filesystem

Documentation

Index

• type Server
  • func NewServer(workingDirs []string, hostAPI filesystem.API) (*Server, error)
  • func (s *Server) CreateSymlink(ctx context.Context, request *internal.CreateSymlinkRequest, ...) (*internal.CreateSymlinkResponse, error)
  • func (s *Server) GetWorkingDirs() []string
  • func (s *Server) IsMountPoint(ctx context.Context, request *internal.IsMountPointRequest, ...) (*internal.IsMountPointResponse, error)
  • func (s *Server) IsSymlink(ctx context.Context, request *internal.IsSymlinkRequest, ...) (*internal.IsSymlinkResponse, 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) PathValid(ctx context.Context, path string) (bool, error)
  • func (s *Server) Rmdir(ctx context.Context, request *internal.RmdirRequest, ...) (*internal.RmdirResponse, error)
  • func (s *Server) RmdirContents(ctx context.Context, request *internal.RmdirContentsRequest, ...) (*internal.RmdirContentsResponse, error)
  • func (s *Server) ValidatePluginPath(path string) error
  • func (s *Server) VersionedAPIs() []*srvtypes.VersionedAPI

Types

type Server

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

func NewServer

func NewServer(workingDirs []string, hostAPI filesystem.API) (*Server, error)

func (*Server) CreateSymlink

func (s *Server) CreateSymlink(ctx context.Context, request *internal.CreateSymlinkRequest, version apiversion.Version) (*internal.CreateSymlinkResponse, error)

func (*Server) GetWorkingDirs

func (s *Server) GetWorkingDirs() []string

func (*Server) IsMountPoint

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

func (*Server) IsSymlink

func (s *Server) IsSymlink(ctx context.Context, request *internal.IsSymlinkRequest, version apiversion.Version) (*internal.IsSymlinkResponse, 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) PathValid

func (s *Server) PathValid(ctx context.Context, path string) (bool, error)

PathValid checks if the given path is accessible.

func (*Server) Rmdir

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

func (*Server) RmdirContents

func (s *Server) RmdirContents(ctx context.Context, request *internal.RmdirContentsRequest, version apiversion.Version) (*internal.RmdirContentsResponse, error)

func (*Server) ValidatePluginPath

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

ValidatePluginPath - Validates the path is compatible with the 'kubelet path' restrictions.

func (*Server) VersionedAPIs

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