redisfs

Documentation

Index

• func Exit() error
• func Mount(mountPoint string, ioMap *qos.IOMap) error
• type RDir
  • func (rd *RDir) Attr(ctx context.Context, a *fuse.Attr) error
  • func (rd *RDir) IsRoot() bool
  • func (rd *RDir) Lookup(ctx context.Context, req *fuse.LookupRequest, resp *fuse.LookupResponse) (fs.Node, error)
• type RFS
  • func NewRFS(path string, opts *redis.Options) *RFS
  • func (rfs *RFS) Root() (fs.Node, error)
• type RedisPipe
  • func (rp *RedisPipe) Attr(ctx context.Context, a *fuse.Attr) error
  • func (rp *RedisPipe) Open(ctx context.Context, req *fuse.OpenRequest, resp *fuse.OpenResponse) (fs.Handle, error)
  • func (rp *RedisPipe) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadResponse) error
  • func (rp *RedisPipe) Write(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse) error

Functions

func Exit

func Exit() error

Exit ... Exit hook

func Mount

func Mount(mountPoint string, ioMap *qos.IOMap) error

Mount ... Place to mount etcd

Types

type RDir

type RDir struct {
	RFS  *RFS
	Path string
}

RDir ... directory structure

func (*RDir) Attr

func (rd *RDir) Attr(ctx context.Context, a *fuse.Attr) error

Attr ... set attributes

func (*RDir) IsRoot

func (rd *RDir) IsRoot() bool

IsRoot ... check to see if path is root

func (*RDir) Lookup

func (rd *RDir) Lookup(ctx context.Context, req *fuse.LookupRequest, resp *fuse.LookupResponse) (fs.Node, error)

Lookup ... lookup a node

type RFS

type RFS struct {
	Path string
	Host string
	Opts *redis.Options
}

RFS ... redis file system

func NewRFS

func NewRFS(path string, opts *redis.Options) *RFS

NewRFS ... create a RFS

func (*RFS) Root

func (rfs *RFS) Root() (fs.Node, error)

Root ... root for filesystem

type RedisPipe

type RedisPipe struct {
	FileName string
	DB       string
	Topic    string
	Opts     *redis.Options
	Client   *redis.Client
	PubSub   *redis.PubSub
}

RedisPipe ... redis pipe like file

func (*RedisPipe) Attr

func (rp *RedisPipe) Attr(ctx context.Context, a *fuse.Attr) error

Attr ... hmmm

func (*RedisPipe) Open

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

Open ... manage cache ect

func (*RedisPipe) Read

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

Read ... read stream This provides 3 reading reading strategies for the cluster. reader - This is just writing raw messages out messages - provides binary provides a single bit errors - stream of error messages

func (*RedisPipe) Write

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

Write ... Write a message to the PubSub