model

May 16, 2014

Changes in this version

+ const MaxChangeHistory

+ const RepoCleaning

+ const RepoIdle

+ const RepoScanning

+ const RepoSyncing

+ func Rename(from, to string) error

+ type ClusterConfigMismatch error

type ConnectionInfo

+ Completion int

type Model

+ func (m *Model) AddRepo(id, dir string, nodes []config.NodeConfiguration)

+ func (m *Model) CleanRepos()

+ func (m *Model) ClusterConfig(nodeID string, config protocol.ClusterConfigMessage)

+ func (m *Model) CurrentGlobalFile(repo string, file string) scanner.File

+ func (m *Model) CurrentRepoFile(repo string, file string) scanner.File

+ func (m *Model) LoadIndexes(dir string)

+ func (m *Model) NeedFilesRepo(repo string) []scanner.File

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

+ func (m *Model) SaveIndexes(dir string)

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

+ func (m *Model) ScanRepos()

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

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

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

Jan 26, 2014

Changes in this version

+ const MAX_CHANGE_HISTORY

type Connection

+ Option func(key string) string

type ConnectionInfo

+ ClientID string

+ ClientVersion string

Jan 20, 2014

Changes in this version

type FileQueue

+ func NewFileQueue() *FileQueue

type Model

+ func (m *Model) LocalAge() float64

Jan 13, 2014

Changes in this version

type Block

+ Size uint32

type File

+ func (f File) String() string

+ type FileQueue struct

+ func (q *FileQueue) Add(name string, blocks []Block, monitor Monitor)

+ func (q *FileQueue) AddAvailable(file, node string)

+ func (q *FileQueue) Done(file string, offset int64, data []byte)

+ func (q *FileQueue) Get(nodeID string) (queuedBlock, bool)

+ func (q *FileQueue) Len() int

+ func (q *FileQueue) Queued(file string) bool

+ func (q *FileQueue) QueuedFiles() (files []string)

+ func (q *FileQueue) RemoveAvailable(toRemove string)

+ func (q *FileQueue) SetAvailable(file, node string)

type Model

+ func (m *Model) LimitRate(kbps int)

+ func (m *Model) WhoHas(name string) []string

+ type Monitor interface

+ FileBegins func(<-chan content) error

+ FileDone func() error

Jan 9, 2014

Changes in this version

+ type Connection interface

+ ID func() string

+ Index func([]protocol.FileInfo)

+ Request func(name string, offset uint64, size uint32, hash []byte) ([]byte, error)

+ Statistics func() protocol.Statistics

Jan 9, 2014

Changes in this version

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

type File

+ Version uint32

+ func (f File) Equals(o File) bool

+ func (f File) NewerThan(o File) bool

Jan 7, 2014

Changes in this version

+ const BlockSize

+ const FlagDeleted

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

+ type Block struct

+ Hash []byte

+ Length uint32

+ Offset uint64

+ func BlockDiff(src, tgt []Block) (have, need []Block)

+ func Blocks(r io.Reader, blocksize int) ([]Block, error)

+ type ConnectionInfo struct

+ Address string

+ type File struct

+ Blocks []Block

+ Flags uint32

+ Modified int64

+ Name string

+ func (f File) Size() (bytes int)

+ type Model struct

+ func NewModel(dir string) *Model

+ func (m *Model) AddConnection(conn io.ReadWriteCloser, nodeID string)

+ func (m *Model) Close(node string, err error)

+ func (m *Model) ConnectedTo(nodeID string) bool

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

+ func (m *Model) FilteredWalk(followSymlinks bool) []File

+ func (m *Model) Generation() int64

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

+ func (m *Model) InSyncSize() (files, bytes int)

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

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

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

+ func (m *Model) NeedFiles() (files []File, bytes int)

+ func (m *Model) ProtocolIndex() []protocol.FileInfo

+ func (m *Model) ReplaceLocal(fs []File)

+ func (m *Model) RepoID() string

+ func (m *Model) Request(nodeID, name string, offset uint64, size uint32, hash []byte) ([]byte, error)

+ func (m *Model) SeedLocal(fs []protocol.FileInfo)

+ func (m *Model) StartRW(del bool, pfiles, preqs int)

+ func (m *Model) Trace(t string)

+ func (m *Model) Walk(followSymlinks bool) (files []File, ignore map[string][]string)