atomicfilefuse

Documentation

Index

• 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) Setattr(ctx context.Context, req *fuse.SetattrRequest, resp *fuse.SetattrResponse) error
• type FileState
  • func (r *FileState) AddRef(h *Handle)
  • func (s *FileState) ClearLazilyTruncated()
  • func (s *FileState) IsLazilyTruncated() bool
  • func (r *FileState) RemoveRef(ctx context.Context, h *Handle)
  • func (s *FileState) SetLazilyTruncated(ctx context.Context, file *File) error
• type Handle
  • func (h *Handle) Flush(ctx context.Context, req *fuse.FlushRequest) error
  • func (h *Handle) Fsync(ctx context.Context, req *fuse.FsyncRequest) error
  • func (h *Handle) ReadAll(ctx context.Context) ([]byte, error)
  • func (h *Handle) Release(ctx context.Context, req *fuse.ReleaseRequest) error
  • func (h *Handle) Write(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse) error
• type WriteMetadata

Types

type File

type File struct {
	Fields      map[string]interface{}
	SizeLimit   int64
	GetAttr     func(ctx context.Context, a *fuse.Attr) (bool, error)
	AtomicRead  func(ctx context.Context) ([]byte, string, bool, error)
	AtomicWrite func(ctx context.Context, data []byte, revision string) (string, error)
	// 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

func (*File) Open

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

func (*File) Setattr

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

type FileState

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

func (*FileState) AddRef

func (r *FileState) AddRef(h *Handle)

func (*FileState) ClearLazilyTruncated

func (s *FileState) ClearLazilyTruncated()

func (*FileState) IsLazilyTruncated

func (s *FileState) IsLazilyTruncated() bool

func (*FileState) RemoveRef

func (r *FileState) RemoveRef(ctx context.Context, h *Handle)

func (*FileState) SetLazilyTruncated

func (s *FileState) SetLazilyTruncated(ctx context.Context, file *File) error

type Handle

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

func (*Handle) Flush

func (h *Handle) Flush(ctx context.Context, req *fuse.FlushRequest) error

func (*Handle) Fsync

func (h *Handle) Fsync(ctx context.Context, req *fuse.FsyncRequest) error

func (*Handle) ReadAll

func (h *Handle) ReadAll(ctx context.Context) ([]byte, error)

func (*Handle) Release

func (h *Handle) Release(ctx context.Context, req *fuse.ReleaseRequest) error

func (*Handle) Write

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

type WriteMetadata

type WriteMetadata struct {
	LastRevision string
}