kfs

Documentation

Index

• type Dir
  • func (d *Dir) Attr(ctx context.Context, o *fuse.Attr) error
  • func (d *Dir) Create(ctx context.Context, req *fuse.CreateRequest, resp *fuse.CreateResponse) (fs.Node, fs.Handle, error)
  • func (d *Dir) Lookup(ctx context.Context, name string) (fs.Node, error)
  • func (d *Dir) Mkdir(ctx context.Context, req *fuse.MkdirRequest) (fs.Node, error)
  • func (d *Dir) ReadDirAll(ctx context.Context) ([]fuse.Dirent, error)
  • func (d *Dir) Remove(ctx context.Context, req *fuse.RemoveRequest) error
  • func (d *Dir) Rename(ctx context.Context, req *fuse.RenameRequest, newDir fs.Node) error
• type File
  • func (f *File) Attr(ctx context.Context, o *fuse.Attr) error
  • func (f *File) Open(ctx context.Context, req *fuse.OpenRequest, resp *fuse.OpenResponse) (fs.Handle, error)
  • func (f *File) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadResponse) error
  • func (f *File) ReadAll(ctx context.Context) ([]byte, error)
  • func (f *File) Release(ctx context.Context, req *fuse.ReleaseRequest) error
  • func (f *File) Write(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse) error
• type KafkaFS
  • func New(zone, cluster string) *KafkaFS
  • func (this *KafkaFS) Root() (fs.Node, error)
  • func (this *KafkaFS) Statfs(ctx context.Context, req *fuse.StatfsRequest, res *fuse.StatfsResponse) error

Types

type Dir

type Dir struct {
	sarama.Client

	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Dir) Attr

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

func (*Dir) Create

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

func (*Dir) Lookup

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

func (*Dir) Mkdir

func (d *Dir) Mkdir(ctx context.Context, req *fuse.MkdirRequest) (fs.Node, error)

func (*Dir) ReadDirAll

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

func (*Dir) Remove

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

func (*Dir) Rename

func (d *Dir) Rename(ctx context.Context, req *fuse.RenameRequest, newDir fs.Node) error

type File

type File struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*File) Attr

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

func (*File) Open

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

func (*File) Read

func (f *File) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadResponse) error

func (*File) ReadAll

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

func (*File) Release

func (f *File) Release(ctx context.Context, req *fuse.ReleaseRequest) error

func (*File) Write

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

type KafkaFS

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

func New

func New(zone, cluster string) *KafkaFS

func (*KafkaFS) Root

func (this *KafkaFS) Root() (fs.Node, error)

func (*KafkaFS) Statfs

func (this *KafkaFS) Statfs(ctx context.Context, req *fuse.StatfsRequest,
	res *fuse.StatfsResponse) error