cmd

Documentation

Index

• Constants
• func NewCmdMount(streams genericclioptions.IOStreams) *cobra.Command
• func Readlink(fsys fs.FS, name string) (string, error)
• type Executor
• type LinuxStat_t
• type MountOptions
  • func NewMountOptions(streams genericclioptions.IOStreams) *MountOptions
  • func (o *MountOptions) Complete(c *cobra.Command, args []string) error
  • func (o *MountOptions) RunMount(ctx context.Context) error
• type PodDirEntry
  • func (e *PodDirEntry) Info() (fs.FileInfo, error)
  • func (e *PodDirEntry) IsDir() bool
  • func (e *PodDirEntry) Name() string
  • func (e *PodDirEntry) Type() fs.FileMode
• type PodExecutor
  • func (e *PodExecutor) Run(ctx context.Context, command []string) ([]byte, error)
  • func (e *PodExecutor) RunRead(ctx context.Context, command []string) (io.ReadCloser, error)
• type PodFS
  • func (f *PodFS) Open(name string) (fs.File, error)
  • func (f *PodFS) ReadDir(name string) ([]fs.DirEntry, error)
  • func (f *PodFS) Readlink(name string) (string, error)
  • func (f *PodFS) Stat(name string) (fs.FileInfo, error)
  • func (f *PodFS) Sub(dir string) (fs.FS, error)
• type PodFile
  • func (f *PodFile) Close() error
  • func (f *PodFile) Read(b []byte) (int, error)
  • func (f *PodFile) Stat() (fs.FileInfo, error)
• type PodFileInfo
  • func (i *PodFileInfo) IsDir() bool
  • func (i *PodFileInfo) ModTime() time.Time
  • func (i *PodFileInfo) Mode() fs.FileMode
  • func (i *PodFileInfo) Name() string
  • func (i *PodFileInfo) Size() int64
  • func (i *PodFileInfo) Sys() interface{}
• type PodFuseNode
  • func (n *PodFuseNode) Getattr(ctx context.Context, f fusefs.FileHandle, out *fuse.AttrOut) syscall.Errno
  • func (f *PodFuseNode) Link(ctx context.Context, target fusefs.InodeEmbedder, name string, ...) (node *fusefs.Inode, errno syscall.Errno)
  • func (n *PodFuseNode) Lookup(ctx context.Context, name string, out *fuse.EntryOut) (*fusefs.Inode, syscall.Errno)
  • func (f *PodFuseNode) Mkdir(ctx context.Context, name string, mode uint32, out *fuse.EntryOut) (*fusefs.Inode, syscall.Errno)
  • func (f *PodFuseNode) Mknod(ctx context.Context, name string, mode uint32, dev uint32, out *fuse.EntryOut) (*fusefs.Inode, syscall.Errno)
  • func (f *PodFuseNode) Open(ctx context.Context, flags uint32) (fh fusefs.FileHandle, fuseFlags uint32, errno syscall.Errno)
  • func (f *PodFuseNode) Read(ctx context.Context, h fusefs.FileHandle, dest []byte, off int64) (fuse.ReadResult, syscall.Errno)
  • func (n *PodFuseNode) Readdir(ctx context.Context) (fusefs.DirStream, syscall.Errno)
  • func (f *PodFuseNode) Readlink(ctx context.Context) ([]byte, syscall.Errno)
  • func (f *PodFuseNode) Release(ctx context.Context, h fusefs.FileHandle) syscall.Errno
  • func (n *PodFuseNode) Setattr(ctx context.Context, f fusefs.FileHandle, in *fuse.SetAttrIn, ...) syscall.Errno
  • func (f *PodFuseNode) Symlink(ctx context.Context, target, name string, out *fuse.EntryOut) (node *fusefs.Inode, errno syscall.Errno)
  • func (f *PodFuseNode) Unlink(ctx context.Context, name string) syscall.Errno
• type ReadlinkFS
• type RemoteCommandErr
  • func (e *RemoteCommandErr) Error() string

Constants

const (
	// NOTE Assume that the remote pod run on linux
	S_IFBLK  = 0x6000
	S_IFCHR  = 0x2000
	S_IFDIR  = 0x4000
	S_IFIFO  = 0x1000
	S_IFLNK  = 0xa000
	S_IFMT   = 0xf000
	S_IFREG  = 0x8000
	S_IFSOCK = 0xc000
)

Functions

func NewCmdMount

func NewCmdMount(streams genericclioptions.IOStreams) *cobra.Command

NewCmdMount provides a cobra command wrapping MountOptions

func Readlink

func Readlink(fsys fs.FS, name string) (string, error)

Types

type Executor

type Executor interface {
	Run(ctx context.Context, command []string) ([]byte, error)
	RunRead(ctx context.Context, command []string) (io.ReadCloser, error)
}

type LinuxStat_t

type LinuxStat_t struct {
	Dev     uint64
	Ino     uint64
	Nlink   uint64
	Mode    uint32
	Uid     uint32
	Gid     uint32
	Rdev    uint64
	Size    int64
	Blksize int64
	Blocks  int64
	Atim    syscall.Timespec
	Mtim    syscall.Timespec
	Ctim    syscall.Timespec
}

type MountOptions

type MountOptions struct {
	User          string
	PodName       string
	RemoteDir     string
	MountPoint    string
	Namespace     string
	ContainerName string
	Debug         bool

	genericclioptions.IOStreams
	// contains filtered or unexported fields
}

func NewMountOptions

func NewMountOptions(streams genericclioptions.IOStreams) *MountOptions

func (*MountOptions) Complete

func (o *MountOptions) Complete(c *cobra.Command, args []string) error

func (*MountOptions) RunMount

func (o *MountOptions) RunMount(ctx context.Context) error

Run mounts a pod or pods on the resources

type PodDirEntry

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

func (*PodDirEntry) Info

func (e *PodDirEntry) Info() (fs.FileInfo, error)

func (*PodDirEntry) IsDir

func (e *PodDirEntry) IsDir() bool

func (*PodDirEntry) Name

func (e *PodDirEntry) Name() string

func (*PodDirEntry) Type

func (e *PodDirEntry) Type() fs.FileMode

type PodExecutor

type PodExecutor struct {
	Namespace     string
	PodName       string
	ContainerName string

	Config     *restclient.Config
	RestClient *restclient.RESTClient
}

func (*PodExecutor) Run

func (e *PodExecutor) Run(ctx context.Context, command []string) ([]byte, error)

func (*PodExecutor) RunRead

func (e *PodExecutor) RunRead(ctx context.Context, command []string) (io.ReadCloser, error)

type PodFS

type PodFS struct {
	Executor Executor
	Pwd      string
}

func (*PodFS) Open

func (f *PodFS) Open(name string) (fs.File, error)

func (*PodFS) ReadDir

func (f *PodFS) ReadDir(name string) ([]fs.DirEntry, error)

func (*PodFS) Readlink

func (f *PodFS) Readlink(name string) (string, error)

func (*PodFS) Stat

func (f *PodFS) Stat(name string) (fs.FileInfo, error)

func (*PodFS) Sub

func (f *PodFS) Sub(dir string) (fs.FS, error)

type PodFile

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

func (*PodFile) Close

func (f *PodFile) Close() error

func (*PodFile) Read

func (f *PodFile) Read(b []byte) (int, error)

func (*PodFile) Stat

func (f *PodFile) Stat() (fs.FileInfo, error)

type PodFileInfo

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

func (*PodFileInfo) IsDir

func (i *PodFileInfo) IsDir() bool

func (*PodFileInfo) ModTime

func (i *PodFileInfo) ModTime() time.Time

func (*PodFileInfo) Mode

func (i *PodFileInfo) Mode() fs.FileMode

func (*PodFileInfo) Name

func (i *PodFileInfo) Name() string

func (*PodFileInfo) Size

func (i *PodFileInfo) Size() int64

func (*PodFileInfo) Sys

func (i *PodFileInfo) Sys() interface{}

type PodFuseNode

type PodFuseNode struct {
	fusefs.Inode
	// contains filtered or unexported fields
}

func (*PodFuseNode) Getattr

func (n *PodFuseNode) Getattr(ctx context.Context, f fusefs.FileHandle, out *fuse.AttrOut) syscall.Errno

func (*PodFuseNode) Link

func (f *PodFuseNode) Link(ctx context.Context, target fusefs.InodeEmbedder, name string, out *fuse.EntryOut) (node *fusefs.Inode, errno syscall.Errno)

func (*PodFuseNode) Lookup

func (n *PodFuseNode) Lookup(ctx context.Context, name string, out *fuse.EntryOut) (*fusefs.Inode, syscall.Errno)

func (*PodFuseNode) Mkdir

func (f *PodFuseNode) Mkdir(ctx context.Context, name string, mode uint32, out *fuse.EntryOut) (*fusefs.Inode, syscall.Errno)

func (*PodFuseNode) Mknod

func (f *PodFuseNode) Mknod(ctx context.Context, name string, mode uint32, dev uint32, out *fuse.EntryOut) (*fusefs.Inode, syscall.Errno)

func (*PodFuseNode) Open

func (f *PodFuseNode) Open(ctx context.Context, flags uint32) (fh fusefs.FileHandle, fuseFlags uint32, errno syscall.Errno)

func (*PodFuseNode) Read

func (f *PodFuseNode) Read(ctx context.Context, h fusefs.FileHandle, dest []byte, off int64) (fuse.ReadResult, syscall.Errno)

func (*PodFuseNode) Readdir

func (n *PodFuseNode) Readdir(ctx context.Context) (fusefs.DirStream, syscall.Errno)

func (*PodFuseNode) Readlink

func (f *PodFuseNode) Readlink(ctx context.Context) ([]byte, syscall.Errno)

func (*PodFuseNode) Release

func (f *PodFuseNode) Release(ctx context.Context, h fusefs.FileHandle) syscall.Errno

func (*PodFuseNode) Setattr

func (n *PodFuseNode) Setattr(ctx context.Context, f fusefs.FileHandle, in *fuse.SetAttrIn, out *fuse.AttrOut) syscall.Errno

func (*PodFuseNode) Symlink

func (f *PodFuseNode) Symlink(ctx context.Context, target, name string, out *fuse.EntryOut) (node *fusefs.Inode, errno syscall.Errno)

func (*PodFuseNode) Unlink

func (f *PodFuseNode) Unlink(ctx context.Context, name string) syscall.Errno

type ReadlinkFS

type ReadlinkFS interface {
	Readlink(name string) (string, error)
}

type RemoteCommandErr

type RemoteCommandErr struct {
	Stderr []byte
	Err    error
}

func (*RemoteCommandErr) Error

func (e *RemoteCommandErr) Error() string