model

Jan 3, 2015

Changes in this version

type Model

+ func (m *Model) BringToFront(folder, file string)

+ func (m *Model) NeedFolderFiles(folder string, max int) ([]protocol.FileInfoTruncated, []protocol.FileInfoTruncated, ...)

type Puller

+ func (p *Puller) BringToFront(filename string)

+ func (p *Puller) Jobs() ([]string, []string)

type Scanner

+ func (s *Scanner) BringToFront(string)

+ func (s *Scanner) Jobs() ([]string, []string)

Dec 16, 2014

Changes in this version

type Model

+ func (m *Model) FolderStatistics() map[string]stats.FolderStatistics

Nov 30, 2014

Changes in this version

+ type ProgressEmitter struct

+ func NewProgressEmitter(cfg *config.ConfigWrapper) *ProgressEmitter

+ func (t *ProgressEmitter) BytesCompleted(folder string) (bytes int64)

+ func (t *ProgressEmitter) Changed(cfg config.Configuration) error

+ func (t *ProgressEmitter) Deregister(s *sharedPullerState)

+ func (t *ProgressEmitter) Register(s *sharedPullerState)

+ func (t *ProgressEmitter) Serve()

+ func (t *ProgressEmitter) Stop()

Nov 24, 2014

Changes in this version

+ var SymlinkWarning = sync.Once

Oct 8, 2014

Changes in this version

+ const FolderCleaning

+ const FolderIdle

+ const FolderScanning

+ const FolderSyncing

type Model

+ func (m *Model) AddFolder(cfg config.FolderConfiguration)

+ func (m *Model) CurrentFolderFile(folder string, file string) protocol.FileInfo

+ func (m *Model) CurrentLocalVersion(folder string) uint64

+ func (m *Model) DeviceStatistics() map[string]stats.DeviceStatistics

+ func (m *Model) NeedFolderFilesLimited(folder string, maxFiles, maxBlocks int) []protocol.FileInfo

+ func (m *Model) RemoteLocalVersion(folder string) uint64

+ func (m *Model) ScanFolder(folder string) error

+ func (m *Model) ScanFolderSub(folder, sub string) error

+ func (m *Model) ScanFolders()

+ func (m *Model) StartFolderRO(folder string)

+ func (m *Model) StartFolderRW(folder string)

+ func (m *Model) String() string

+ type Puller struct

+ func (p *Puller) Serve()

+ func (p *Puller) Stop()

+ func (p *Puller) String() string

+ type Scanner struct

+ func (s *Scanner) Serve()

+ func (s *Scanner) Stop()

+ func (s *Scanner) String() string

Sep 28, 2014

Changes in this version

+ const IndexPerBlockSize

+ const RepoCleaning

+ const RepoIdle

+ const RepoScanning

+ const RepoSyncing

+ var ErrInvalid = errors.New("file is invalid")

+ var ErrNoSuchFile = errors.New("no such file")

+ type ConnectionInfo struct

+ Address string

+ ClientVersion string

+ type Model struct

+ func NewModel(indexDir string, cfg *config.Configuration, ...) *Model

+ func (m *Model) AddConnection(rawConn io.Closer, protoConn protocol.Connection)

+ func (m *Model) AddRepo(cfg config.RepositoryConfiguration)

+ func (m *Model) CleanRepos()

+ func (m *Model) Close(node protocol.NodeID, err error)

+ func (m *Model) ClusterConfig(nodeID protocol.NodeID, cm protocol.ClusterConfigMessage)

+ func (m *Model) Completion(node protocol.NodeID, repo string) float64

+ func (m *Model) ConnectedTo(nodeID protocol.NodeID) bool

+ func (m *Model) ConnectionStats() map[string]ConnectionInfo

+ func (m *Model) CurrentGlobalFile(repo string, file string) protocol.FileInfo

+ func (m *Model) CurrentRepoFile(repo string, file string) protocol.FileInfo

+ func (m *Model) GetIgnores(repo string) ([]string, error)

+ func (m *Model) GlobalSize(repo string) (files, deleted int, bytes int64)

+ func (m *Model) Index(nodeID protocol.NodeID, repo string, fs []protocol.FileInfo)

+ func (m *Model) IndexUpdate(nodeID protocol.NodeID, repo string, fs []protocol.FileInfo)

+ func (m *Model) LocalSize(repo string) (files, deleted int, bytes int64)

+ func (m *Model) LocalVersion(repo string) uint64

+ func (m *Model) NeedFilesRepoLimited(repo string, maxFiles, maxBlocks int) []protocol.FileInfo

+ func (m *Model) NeedSize(repo string) (files int, bytes int64)

+ func (m *Model) NodeStatistics() map[string]stats.NodeStatistics

+ func (m *Model) Override(repo string)

+ func (m *Model) ReplaceLocal(repo string, fs []protocol.FileInfo)

+ func (m *Model) Request(nodeID protocol.NodeID, repo, name string, offset int64, size int) ([]byte, error)

+ func (m *Model) ScanRepo(repo string) error

+ func (m *Model) ScanRepoSub(repo, sub string) error

+ func (m *Model) ScanRepos()

+ func (m *Model) SetIgnores(repo string, content []string) error

+ func (m *Model) StartRepoRO(repo string)

+ func (m *Model) StartRepoRW(repo string, threads int)

+ func (m *Model) State(repo string) (string, time.Time)