file_handler/

Jun 1, 2024

Changes in this version

+ type BytesStore struct

+ func NewBytesStore() (bs *BytesStore)

+ func (bs *BytesStore) CopyFrom(fo io.Reader) (n int64, err error)

+ func (bs *BytesStore) CopyTo(fo io.Writer) (n int64, err error)

+ func (bs *BytesStore) Hash() (hash string, err error)

+ type FileBasic struct

+ Err ftp_context.LogErr

+ Name string

+ Path string

+ Size int64

+ Type FileType

+ func NewFileBasic(path string) (fo *FileBasic)

+ func ReadDir(ctx ftp_context.Context, dir_path string, exclude []string) (files []FileBasic, err error)

+ func (fo *FileBasic) Close() error

+ func (fo *FileBasic) Create() *FileBasic

+ func (fo *FileBasic) Ext() string

+ func (fo *FileBasic) IsOpen() bool

+ func (fo *FileBasic) ModTime() string

+ func (fo *FileBasic) Open() *FileBasic

+ func (fo *FileBasic) Read(buf []byte) (n int, err error)

+ func (fo *FileBasic) ReadAll() (data []byte, err error)

+ func (fo *FileBasic) ResetError()

+ func (fo *FileBasic) Write(buf []byte) (n int, err error)

+ func (fo *FileBasic) WriteJson(v any) ftp_context.LogErr

+ type FileHash struct

+ Hash string

+ LastModTime time.Time

+ PrevModTime time.Time

+ type FileTreeStruct struct

+ Directory string

+ FilesList []*FileHash

+ HashQueue base.MutexedQueue[*FileHash]

+ LatestHash time.Time

+ LatesttUploadTime time.Time

+ UploadQueue base.MutexedQueue[*FileHash]

+ func (fts *FileTreeStruct) DequeueHashing() <-chan int64

+ func (fts *FileTreeStruct) DequeueUpload() <-chan int64

+ func (fts *FileTreeStruct) EnqueueHashing(fh *FileHash)

+ func (fts *FileTreeStruct) EnqueueUpload(fh *FileHash)

+ func (fts *FileTreeStruct) MarkDoneHashing(n int64)

+ func (fts *FileTreeStruct) MarkDoneUpload(n int64)

+ type FileType = string