pod

Documentation

Index

• type Dir
  • func (d *Dir) Attr(ctx context.Context, a *fuse.Attr) error
  • func (f *Dir) Create(ctx context.Context, req *fuse.CreateRequest, resp *fuse.CreateResponse) (fs.Node, fs.Handle, error)
  • func (d *Dir) GetDirent() fuse.Dirent
  • func (d *Dir) Lookup(ctx context.Context, name string) (fs.Node, error)
  • func (d *Dir) ReadDirAll(ctx context.Context) ([]fuse.Dirent, error)
  • func (f *Dir) Remove(ctx context.Context, req *fuse.RemoveRequest) error
• type File
  • func (f *File) Attr(ctx context.Context, a *fuse.Attr) error
  • func (f *File) Fsync(ctx context.Context, req *fuse.FsyncRequest) error
  • func (f *File) Open(ctx context.Context, req *fuse.OpenRequest, resp *fuse.OpenResponse) (fs.Handle, error)
  • func (f File) ReadAll(ctx context.Context) ([]byte, error)
  • func (f *File) Setattr(ctx context.Context, req *fuse.SetattrRequest, resp *fuse.SetattrResponse) error
  • func (f *File) Write(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse) error

Types

type Dir

type Dir struct {
	fuse.Dirent
	Cluster   cluster.Cluster
	Namespace v1.Namespace

	Client *kube.Clientset
	// contains filtered or unexported fields
}

NamespaceDir implements both Node and Handle for the root directory.

func (*Dir) Attr

func (d *Dir) Attr(ctx context.Context, a *fuse.Attr) error

func (*Dir) Create

func (f *Dir) Create(ctx context.Context, req *fuse.CreateRequest, resp *fuse.CreateResponse) (fs.Node, fs.Handle, error)

func (*Dir) GetDirent

func (d *Dir) GetDirent() fuse.Dirent

func (*Dir) Lookup

func (d *Dir) Lookup(ctx context.Context, name string) (fs.Node, error)

func (*Dir) ReadDirAll

func (d *Dir) ReadDirAll(ctx context.Context) ([]fuse.Dirent, error)

ReadDirAll lists all deployments in a given namespace

func (*Dir) Remove

func (f *Dir) Remove(ctx context.Context, req *fuse.RemoveRequest) error

Remove removes the file from the filesystem and the cluster

type File

type File struct {
	fs.Node
	fs.NodeSetattrer

	Namespace string

	Modified time.Time
	Client   *kube.Clientset
	// contains filtered or unexported fields
}

func (*File) Attr

func (f *File) Attr(ctx context.Context, a *fuse.Attr) error

func (*File) Fsync

func (f *File) Fsync(ctx context.Context, req *fuse.FsyncRequest) error

This is need for write to function

func (*File) Open

func (f *File) Open(ctx context.Context, req *fuse.OpenRequest, resp *fuse.OpenResponse) (fs.Handle, error)

func (File) ReadAll

func (f File) ReadAll(ctx context.Context) ([]byte, error)

func (*File) Setattr

func (f *File) Setattr(ctx context.Context, req *fuse.SetattrRequest, resp *fuse.SetattrResponse) error

func (*File) Write

func (f *File) Write(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse) error