set

Dec 17, 2024

Changes in this version

type Set

+ Metadata map[string]string

Nov 25, 2024

Changes in this version

type EntryStatus

+ const Replaced

+ const Skipped

type Set

+ Replaced uint64

+ SizeTotal uint64

+ SizeUploaded uint64

+ Skipped uint64

+ func (s *Set) UploadedSize() string

Oct 8, 2024

Changes in this version

type DBRO

+ func (d *DBRO) LogSetChangesToSlack(slacker Slacker)

type Set

+ func (s *Set) DiscoveryCompleted(numFiles uint64) error

+ func (s *Set) LogChangesToSlack(slacker Slacker)

+ func (s *Set) RecoveryError(err error) error

+ func (s *Set) SetError(errMsg string) error

+ func (s *Set) SetWarning(warnMsg string) error

+ func (s *Set) SuccessfullyStoredInDB() error

+ func (s *Set) UpdateBasedOnEntry(entry *Entry, getFileEntries func(string) ([]*Entry, error)) error

+ type Slacker interface

+ SendMessage func(level slack.Level, msg string) error

Nov 24, 2023

Changes in this version

type Set

+ func (s *Set) HasProblems() bool

+ func (s *Set) Incomplete() bool

+ func (s *Set) Queued() bool

Nov 16, 2023

Changes in this version

+ type DBRO struct

+ func NewRO(path string) (*DBRO, error)

+ func (d *DBRO) GetAll() ([]*Set, error)

+ func (d *DBRO) GetByID(id string) *Set

+ func (d *DBRO) GetByNameAndRequester(name, requester string) (*Set, error)

+ func (d *DBRO) GetByRequester(requester string) ([]*Set, error)

+ func (d *DBRO) GetDefinedFileEntry(setID string) (*Entry, error)

+ func (d *DBRO) GetDirEntries(setID string) ([]*Entry, error)

+ func (d *DBRO) GetFailedEntries(setID string) ([]*Entry, int, error)

+ func (d *DBRO) GetFileEntries(setID string) ([]*Entry, error)

+ func (d *DBRO) GetFileEntryForSet(setID, filePath string) (*Entry, error)

+ func (d *DBRO) GetPureFileEntries(setID string) ([]*Entry, error)

type Error

+ Msg string

type Set

+ func (s *Set) TransformPath(path string) (string, error)

+ type SizeAndNumber struct

+ For string

+ Number uint64

+ Size uint64

+ func (s *SizeAndNumber) SizeTiB() float64

+ type Usage struct

+ ByMonth []*SizeAndNumber

+ ByRequester []*SizeAndNumber

+ BySet []*SizeAndNumber

+ Total *SizeAndNumber

+ func UsageSummary(sets []*Set) *Usage

Jul 5, 2023

Changes in this version

type Entry

+ func (e *Entry) InodeStoragePath() string

Jun 30, 2023

Changes in this version

type EntryStatus

+ const AbnormalEntry

type EntryType

+ const Abnormal

type Set

+ Abnormal uint64

Jun 1, 2023

Changes in this version

+ const ErrNoAddDuringDiscovery

May 25, 2023

Changes in this version

type DB

+ func (d *DB) GetMountPointFromPath(path string) string

May 18, 2023

Changes in this version

+ const ErrInvalidTransformerPath

type DB

+ func (d *DB) Discover(setID string, cb DiscoverCallback) (*Set, error)

+ func (d *DB) HardlinkPaths(e *Entry) ([]string, error)

+ func (d *DB) HardlinkRemote(e *Entry) (string, error)

+ func (d *DB) SetWarning(setID, warnMsg string) error

+ type DiscoverCallback func([]*Entry) ([]*walk.Dirent, error)

type Entry

+ Dest string

+ Inode uint64

+ Type EntryType

+ type EntryType int

+ const Directory

+ const Hardlink

+ const Regular

+ const Symlink

+ const Unknown

type Set

+ Hardlinks uint64

+ Symlinks uint64

+ Warning string

Apr 20, 2023

Changes in this version

type DB

+ func (d *DB) Backup() error

+ func (d *DB) EnableRemoteBackups(remotePath string, handler put.Handler)

+ func (d *DB) GetByNameAndRequester(name, requester string) (*Set, error)

+ func (d *DB) GetDefinedFileEntry(setID string) (*Entry, error)

+ func (d *DB) SetBackupPath(path string)

+ func (d *DB) SetMinimumTimeBetweenBackups(dur time.Duration)

type Set

+ MonitorTime time.Duration

Mar 21, 2023

Changes in this version

type Entry

+ PathForJSON []byte

+ func (e *Entry) CorrectFromJSON()

+ func (e *Entry) MakeSafeForJSON()

Mar 6, 2023

Changes in this version

type DB

+ func (d *DB) GetFailedEntries(setID string) ([]*Entry, int, error)

Jan 23, 2023

Changes in this version

+ const AttemptsToBeConsideredFailing

+ const ErrInvalidEntry

+ const ErrInvalidRequest

+ const ErrInvalidSetID

+ const ErrInvalidTransformer

+ type DB struct

+ func New(path string) (*DB, error)

+ func (d *DB) AddOrUpdate(set *Set) error

+ func (d *DB) Close() error

+ func (d *DB) GetAll() ([]*Set, error)

+ func (d *DB) GetByID(id string) *Set

+ func (d *DB) GetByRequester(requester string) ([]*Set, error)

+ func (d *DB) GetDirEntries(setID string) ([]*Entry, error)

+ func (d *DB) GetFileEntries(setID string) ([]*Entry, error)

+ func (d *DB) GetPureFileEntries(setID string) ([]*Entry, error)

+ func (d *DB) SetDirEntries(setID string, paths []string) error

+ func (d *DB) SetDiscoveredEntries(setID string, paths []string) (*Set, error)

+ func (d *DB) SetDiscoveryStarted(setID string) error

+ func (d *DB) SetEntryStatus(r *put.Request) (*Entry, error)

+ func (d *DB) SetError(setID, errMsg string) error

+ func (d *DB) SetFileEntries(setID string, paths []string) error

+ type Entry struct

+ Attempts int

+ LastAttempt time.Time

+ LastError string

+ Path string

+ Size uint64

+ Status EntryStatus

+ func (e *Entry) ShouldUpload(reuploadAfter time.Time) bool

+ type EntryStatus int

+ const Failed

+ const Missing

+ const Pending

+ const Uploaded

+ const UploadingEntry

+ func (e EntryStatus) String() string

+ type Error struct

+ func (e Error) Error() string

+ type Set struct

+ DeleteLocal bool

+ Description string

+ Error string

+ Failed uint64

+ LastCompleted time.Time

+ LastCompletedCount uint64

+ LastCompletedSize uint64

+ LastDiscovery time.Time

+ Missing uint64

+ Monitor bool

+ Name string

+ NumFiles uint64

+ Requester string

+ SizeFiles uint64

+ StartedDiscovery time.Time

+ Status Status

+ Transformer string

+ Uploaded uint64

+ func (s *Set) Count() string

+ func (s *Set) Discovered() string

+ func (s *Set) ID() string

+ func (s *Set) MakeTransformer() (put.PathTransformer, error)

+ func (s *Set) Size() string

+ type Status int

+ const Complete

+ const Failing

+ const PendingDiscovery

+ const PendingUpload

+ const Uploading

+ func (s Status) String() string