gofile

Oct 23, 2023

Changes in this version

type ManagedFileReadableTxn

+ func (t *ManagedFileReadableTxn) Read(b []byte) (nRead int64, err error)

Oct 14, 2023

Changes in this version

+ const APPROX_MAX_GOROUTINES_PER_THREAD

Oct 6, 2023

Changes in this version

type BufferedFile

+ BufferDataSize int64

Oct 5, 2023

Changes in this version

+ const DEFAULT_OPENED_FILES_LIMIT

+ const MAX_OPENED_FILES_LIMIT

+ func GetFilesLimit() (nLimit uint64, err error)

type BufferedFile

+ func (b *BufferedFile) Position() (pos int64)

+ func (b *BufferedFile) Read(data []byte) (nRead int64, err error)

+ type CommonMethods interface

+ Position func() (pos int64)

+ Seek func(offset int64, whence int) (ret int64, err error)

+ Size func() (length int64, err error)

+ type CommonTxn struct

+ func (t *CommonTxn) Position() (pos int64)

+ func (t *CommonTxn) Seek(offset int64, whence int) (ret int64, err error)

+ func (t *CommonTxn) Size() (length int64, err error)

type ManagedFile

+ func (f *ManagedFile) Position() (pos int64)

+ func (f *ManagedFile) Read(b []byte) (nRead int64, err error)

type ManagedFileRWTxn

+ func (t *ManagedFileRWTxn) Append(data []byte) (pos int64, err error)

+ func (t *ManagedFileRWTxn) Read(b []byte) (nRead int64, err error)

+ func (t *ManagedFileRWTxn) ReadAt(b []byte, offset int64) (nRead int64, err error)

+ func (t *ManagedFileRWTxn) Write(b []byte) (nWritten int64, err error)

+ func (t *ManagedFileRWTxn) WriteAt(b []byte, offset int64) (nWritten int64, err error)

type ManagedFileWritableTxn

+ func (t *ManagedFileWritableTxn) Read(b []byte) (nRead int64, err error)

+ func (t *ManagedFileWritableTxn) ReadAt(b []byte, offset int64) (nRead int64, err error)

+ type Pipeable interface

type Readable

+ Read func(b []byte) (nRead int64, err error)

+ type Transactional interface

+ PipeTo func(dest Pipeable, chunkSize int64) (err error)

+ TRead func(m func(txn Readable) (err error)) (err error)

+ TReadWrite func(m func(txn Editable) (err error)) (err error)

+ TWrite func(m func(txn Writable) (err error)) (err error)

Oct 5, 2023

Changes in this version

+ const MAX_OPEN_FILES

Oct 1, 2023

Changes in this version

+ const MAX_OPENED_FILES

+ const POS_REWIND

+ const WAKING_WORKERS_NUMBER

+ var ErrOutOfBound = errors.New("requested slice is out of the file's bounds")

+ var ErrStorageClosed = errors.New("operation is impossible, storage is closed")

+ func InitFileManager() (err error)

+ type BufferedFile struct

+ BufferSize int64

+ func NewBufferedFile(file File, bufferSize int64) (b *BufferedFile, err error)

+ func (b *BufferedFile) Append(data []byte) (pos int64, err error)

+ func (b *BufferedFile) Close()

+ func (b *BufferedFile) PipeTo(dest File, chunkSize int64) (err error)

+ func (b *BufferedFile) ReadAt(data []byte, offset int64) (nRead int64, err error)

+ func (b *BufferedFile) Seek(offset int64, whence int) (ret int64, err error)

+ func (b *BufferedFile) Size() (length int64, err error)

+ func (b *BufferedFile) TRead(m func(txn Readable) (err error)) (err error)

+ func (b *BufferedFile) TReadWrite(m func(txn Editable) (err error)) (err error)

+ func (b *BufferedFile) TWrite(m func(txn Writable) (err error)) (err error)

+ func (b *BufferedFile) Trunc() (err error)

+ func (b *BufferedFile) Write(data []byte) (nWritten int64, err error)

+ func (b *BufferedFile) WriteAt(data []byte, offset int64) (nWritten int64, err error)

+ type Editable interface

+ type File interface

+ Close func()

+ PipeTo func(dest File, chunkSize int64) (err error)

+ TRead func(m func(txn Readable) (err error)) (err error)

+ TReadWrite func(m func(txn Editable) (err error)) (err error)

+ TWrite func(m func(txn Writable) (err error)) (err error)

+ type Freeable interface

+ Trunc func() (err error)

+ type ManagedFile struct

+ Path string

+ func NewFile(filePath string, perm fs.FileMode) (file *ManagedFile, err error)

+ func (f *ManagedFile) Append(data []byte) (pos int64, err error)

+ func (f *ManagedFile) Close()

+ func (f *ManagedFile) PipeTo(dest File, chunkSize int64) (err error)

+ func (f *ManagedFile) ReadAt(b []byte, offset int64) (nRead int64, err error)

+ func (f *ManagedFile) Seek(offset int64, whence int) (ret int64, err error)

+ func (f *ManagedFile) Size() (length int64, err error)

+ func (f *ManagedFile) TRead(m func(txn Readable) (err error)) (err error)

+ func (f *ManagedFile) TReadWrite(m func(txn Editable) (err error)) (err error)

+ func (f *ManagedFile) TWrite(m func(txn Writable) (err error)) (err error)

+ func (f *ManagedFile) Trunc() (err error)

+ func (f *ManagedFile) Write(b []byte) (nWritten int64, err error)

+ func (f *ManagedFile) WriteAt(b []byte, offset int64) (nWritten int64, err error)

+ type ManagedFileRWTxn struct

+ type ManagedFileReadableTxn struct

+ func (t *ManagedFileReadableTxn) ReadAt(b []byte, offset int64) (nRead int64, err error)

+ func (t *ManagedFileReadableTxn) Size() (length int64, err error)

+ type ManagedFileWritableTxn struct

+ func (t *ManagedFileWritableTxn) Append(data []byte) (pos int64, err error)

+ func (t *ManagedFileWritableTxn) Seek(offset int64, whence int) (ret int64, err error)

+ func (t *ManagedFileWritableTxn) Write(b []byte) (nWritten int64, err error)

+ func (t *ManagedFileWritableTxn) WriteAt(b []byte, offset int64) (nWritten int64, err error)

+ type Readable interface

+ ReadAt func(b []byte, offset int64) (nRead int64, err error)

+ Size func() (length int64, err error)

+ type Writable interface

+ Append func(data []byte) (pos int64, err error)

+ Seek func(offset int64, whence int) (ret int64, err error)

+ Write func(b []byte) (nWritten int64, err error)

+ WriteAt func(b []byte, offset int64) (nWritten int64, err error)