fs

Documentation

Index

• type Disk
  • func NewDisk() *Disk
  • func (fs *Disk) Open(path string) (cask.File, error)
  • func (fs *Disk) ReadFileAt(path string, file string, b []byte, o int64) (int, error)
  • func (fs *Disk) Rotate(path string) (cask.File, error)
  • func (fs *Disk) Walk(path string, wf func(cask.File) error) error
• type DiskFile
  • func (f *DiskFile) Name() string
  • func (f *DiskFile) Size() int64
  • func (f *DiskFile) Write(p []byte) (int, error)
• type InMemory
  • func NewInMemory() *InMemory
  • func (i *InMemory) Open(_ string) (cask.File, error)
  • func (i *InMemory) ReadFileAt(_ string, _ string, b []byte, offset int64) (int, error)
  • func (i *InMemory) Rotate(_ string) (cask.File, error)
  • func (i *InMemory) Walk(_ string, f func(cask.File) error) error
• type InMemoryFile
  • func (i *InMemoryFile) Close() error
  • func (i *InMemoryFile) Name() string
  • func (i *InMemoryFile) Read(p []byte) (n int, err error)
  • func (i *InMemoryFile) Size() int64
  • func (i *InMemoryFile) Write(p []byte) (int, error)

Types

type Disk

type Disk struct{}

Disk represents disk based file system

func NewDisk

func NewDisk() *Disk

NewDisk instantiates new disk based file system

func (*Disk) Open

func (fs *Disk) Open(path string) (cask.File, error)

Open opens a default data file for reading and creates it if it does not exist

func (*Disk) ReadFileAt

func (fs *Disk) ReadFileAt(path string, file string, b []byte, o int64) (int, error)

func (*Disk) Rotate

func (fs *Disk) Rotate(path string) (cask.File, error)

Rotate creates a new active data file and opens it

func (*Disk) Walk

func (fs *Disk) Walk(path string, wf func(cask.File) error) error

type DiskFile

type DiskFile struct {
	*os.File
	// contains filtered or unexported fields
}

DiskFile represents file on disk

func (*DiskFile) Name

func (f *DiskFile) Name() string

Name returns the base name of the file (without path and/or extension)

func (*DiskFile) Size

func (f *DiskFile) Size() int64

Size returns current data file size in kb

func (*DiskFile) Write

func (f *DiskFile) Write(p []byte) (int, error)

Write delegates writing to the underlying file and increments file size

type InMemory

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

func NewInMemory

func NewInMemory() *InMemory

func (*InMemory) Open

func (i *InMemory) Open(_ string) (cask.File, error)

func (*InMemory) ReadFileAt

func (i *InMemory) ReadFileAt(_ string, _ string, b []byte, offset int64) (int, error)

func (*InMemory) Rotate

func (i *InMemory) Rotate(_ string) (cask.File, error)

func (*InMemory) Walk

func (i *InMemory) Walk(_ string, f func(cask.File) error) error

type InMemoryFile

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

func (*InMemoryFile) Close

func (i *InMemoryFile) Close() error

func (*InMemoryFile) Name

func (i *InMemoryFile) Name() string

func (*InMemoryFile) Read

func (i *InMemoryFile) Read(p []byte) (n int, err error)

func (*InMemoryFile) Size

func (i *InMemoryFile) Size() int64

func (*InMemoryFile) Write

func (i *InMemoryFile) Write(p []byte) (int, error)