Documentation
¶
Index ¶
- type BytesStore
- type FileBasic
- 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
- type FileTreeStruct
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BytesStore ¶
func NewBytesStore ¶
func NewBytesStore() (bs *BytesStore)
func (*BytesStore) Hash ¶
func (bs *BytesStore) Hash() (hash string, err error)
type FileBasic ¶
type FileBasic struct {
Name string `json:"name"`
Path string `json:"path"`
Err ftp_context.LogErr `json:"error"`
Type FileType `json:"type"`
Size int64 `json:"size"`
// contains filtered or unexported fields
}
func NewFileBasic ¶
func (*FileBasic) ResetError ¶
func (fo *FileBasic) ResetError()
type FileTreeStruct ¶
type FileTreeStruct struct {
FileBasic
Directory string `json:"directory"`
FilesList []*FileHash `json:"files_list"`
LatesttUploadTime time.Time `json:"latest_upload_time"`
LatestHash time.Time `json:"latest_hash"`
HashQueue base.MutexedQueue[*FileHash] `json:"hash_queue"`
UploadQueue base.MutexedQueue[*FileHash] `json:"upload_queue"`
}
func (*FileTreeStruct) DequeueHashing ¶
func (fts *FileTreeStruct) DequeueHashing() <-chan int64
func (*FileTreeStruct) DequeueUpload ¶
func (fts *FileTreeStruct) DequeueUpload() <-chan int64
func (*FileTreeStruct) EnqueueHashing ¶
func (fts *FileTreeStruct) EnqueueHashing(fh *FileHash)
func (*FileTreeStruct) EnqueueUpload ¶
func (fts *FileTreeStruct) EnqueueUpload(fh *FileHash)
func (*FileTreeStruct) MarkDoneHashing ¶
func (fts *FileTreeStruct) MarkDoneHashing(n int64)
func (*FileTreeStruct) MarkDoneUpload ¶
func (fts *FileTreeStruct) MarkDoneUpload(n int64)
Click to show internal directories.
Click to hide internal directories.