model

package
v0.8.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 26, 2014 License: MIT Imports: 22 Imported by: 0

Documentation

Overview

Package model implements repository abstraction and file pulling mechanisms

Index

Constants

View Source
const (
	RepoIdle repoState = iota
	RepoScanning
	RepoSyncing
	RepoCleaning
)
View Source
const (
	MaxChangeHistory = 4
)

Variables

View Source
var (
	ErrNoSuchFile = errors.New("no such file")
	ErrInvalid    = errors.New("file is invalid")
)

Functions

This section is empty.

Types

type ClusterConfigMismatch added in v0.8.6

type ClusterConfigMismatch error

type ConnectionInfo

type ConnectionInfo struct {
	protocol.Statistics
	Address       string
	ClientVersion string
	Completion    int
}

type Model

type Model struct {
	// contains filtered or unexported fields
}

func NewModel

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

NewModel creates and starts a new model. The model starts in read-only mode, where it sends index information to connected peers and responds to requests for file data without altering the local repository in any way.

func (*Model) AddConnection

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

AddConnection adds a new peer connection to the model. An initial index will be sent to the connected peer, thereafter index updates whenever the local repository changes.

func (*Model) AddRepo added in v0.8.6

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

func (*Model) CleanRepos added in v0.8.6

func (m *Model) CleanRepos()

func (*Model) Close

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

Close removes the peer from the model and closes the underlying connection if possible. Implements the protocol.Model interface.

func (*Model) ClusterConfig added in v0.8.6

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

func (*Model) ConnectedTo

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

ConnectedTo returns true if we are connected to the named node.

func (*Model) ConnectionStats

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

ConnectionStats returns a map with connection statistics for each connected node.

func (*Model) CurrentGlobalFile added in v0.8.6

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

func (*Model) CurrentRepoFile added in v0.8.6

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

func (*Model) GlobalSize

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

GlobalSize returns the number of files, deleted files and total bytes for all files in the global model.

func (*Model) Index

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

Index is called when a new node is connected and we receive their full index. Implements the protocol.Model interface.

func (*Model) IndexUpdate

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

IndexUpdate is called for incremental updates to connected nodes' indexes. Implements the protocol.Model interface.

func (*Model) LoadIndexes added in v0.8.6

func (m *Model) LoadIndexes(dir string)

func (*Model) LocalSize

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

LocalSize returns the number of files, deleted files and total bytes for all files in the local repository.

func (*Model) NeedFilesRepo added in v0.8.6

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

NeedFiles returns the list of currently needed files and the total size.

func (*Model) NeedSize added in v0.8.6

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

NeedSize returns the number and total size of currently needed files.

func (*Model) ReplaceLocal

func (m *Model) ReplaceLocal(repo string, fs []scanner.File)

ReplaceLocal replaces the local repository index with the given list of files.

func (*Model) Request

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

Request returns the specified data segment by reading it from local disk. Implements the protocol.Model interface.

func (*Model) SaveIndexes added in v0.8.6

func (m *Model) SaveIndexes(dir string)

func (*Model) ScanRepo added in v0.8.6

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

func (*Model) ScanRepos added in v0.8.6

func (m *Model) ScanRepos()

func (*Model) SeedLocal

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

func (*Model) StartRepoRO added in v0.8.6

func (m *Model) StartRepoRO(repo string)

StartRO starts read only processing on the current model. When in read only mode the model will announce files to the cluster but not pull in any external changes.

func (*Model) StartRepoRW added in v0.8.6

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

StartRW starts read/write processing on the current model. When in read/write mode the model will attempt to keep in sync with the cluster by pulling needed files from peer nodes.

func (*Model) State added in v0.8.6

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL