db

Documentation

Index

• type Config
• type Event
• type Node
• type OsFs
  • func (o *OsFs) Delete(name string) error
  • func (o *OsFs) Exists(name string) bool
  • func (o *OsFs) Open(name string, mode storage.OpenMode) (storage.FSFile, error)
• type Storage
  • func NewStorage(db *leveldb.DB, connector storage.NetConnector, ...) (*Storage, error)
  • func (s *Storage) DetectFileRefs(path string) (rootPath string, dirName string, _ []storage.FileRef, _ error)
  • func (s *Storage) GetActiveFiles(bagId []byte) ([]uint32, error)
  • func (s *Storage) GetAll() []*storage.Torrent
  • func (s *Storage) GetAllFilesRefsInDir(path string) ([]storage.FileRef, error)
  • func (s *Storage) GetFS() storage.FS
  • func (s *Storage) GetPiece(bagId []byte, id uint32) (*storage.PieceInfo, error)
  • func (s *Storage) GetSingleFileRef(path string) (storage.FileRef, error)
  • func (s *Storage) GetSpeedLimits() (download uint64, upload uint64, err error)
  • func (s *Storage) GetTorrent(hash []byte) *storage.Torrent
  • func (s *Storage) GetTorrentByOverlay(overlay []byte) *storage.Torrent
  • func (s *Storage) PiecesMask(bagId []byte, num uint32) []byte
  • func (s *Storage) RemovePiece(bagId []byte, id uint32) error
  • func (s *Storage) RemoveTorrent(t *storage.Torrent, withFiles bool) error
  • func (s *Storage) SetActiveFiles(bagId []byte, ids []uint32) error
  • func (s *Storage) SetPiece(bagId []byte, id uint32, p *storage.PieceInfo) error
  • func (s *Storage) SetSpeedLimits(download, upload uint64) error
  • func (s *Storage) SetTorrent(t *storage.Torrent) error
  • func (s *Storage) UpdateUploadStats(bagId []byte, val uint64) error
• type TorrentStored

Types

type Config

type Config struct {
	Key           ed25519.PrivateKey
	ListenAddr    string
	ExternalIP    string
	DownloadsPath string
}

type Event

type Event int

const (
	EventTorrentUpdated Event = iota
	EventUploadUpdated
)

type Node

type Node struct {
	Id       string
	Children []*Node
}

type OsFs

type OsFs struct{}

func (*OsFs) Delete

func (o *OsFs) Delete(name string) error

func (*OsFs) Exists

func (o *OsFs) Exists(name string) bool

func (*OsFs) Open

func (o *OsFs) Open(name string, mode storage.OpenMode) (storage.FSFile, error)

type Storage

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

func NewStorage

func NewStorage(db *leveldb.DB, connector storage.NetConnector, startWithoutActiveFilesToo bool, notifier chan Event) (*Storage, error)

func (*Storage) DetectFileRefs

func (s *Storage) DetectFileRefs(path string) (rootPath string, dirName string, _ []storage.FileRef, _ error)

func (*Storage) GetActiveFiles

func (s *Storage) GetActiveFiles(bagId []byte) ([]uint32, error)

func (*Storage) GetAll

func (s *Storage) GetAll() []*storage.Torrent

func (*Storage) GetAllFilesRefsInDir

func (s *Storage) GetAllFilesRefsInDir(path string) ([]storage.FileRef, error)

func (*Storage) GetFS

func (s *Storage) GetFS() storage.FS

func (*Storage) GetPiece

func (s *Storage) GetPiece(bagId []byte, id uint32) (*storage.PieceInfo, error)

func (*Storage) GetSingleFileRef

func (s *Storage) GetSingleFileRef(path string) (storage.FileRef, error)

func (*Storage) GetSpeedLimits

func (s *Storage) GetSpeedLimits() (download uint64, upload uint64, err error)

func (*Storage) GetTorrent

func (s *Storage) GetTorrent(hash []byte) *storage.Torrent

func (*Storage) GetTorrentByOverlay

func (s *Storage) GetTorrentByOverlay(overlay []byte) *storage.Torrent

func (*Storage) PiecesMask

func (s *Storage) PiecesMask(bagId []byte, num uint32) []byte

func (*Storage) RemovePiece

func (s *Storage) RemovePiece(bagId []byte, id uint32) error

func (*Storage) RemoveTorrent

func (s *Storage) RemoveTorrent(t *storage.Torrent, withFiles bool) error

func (*Storage) SetActiveFiles

func (s *Storage) SetActiveFiles(bagId []byte, ids []uint32) error

func (*Storage) SetPiece

func (s *Storage) SetPiece(bagId []byte, id uint32, p *storage.PieceInfo) error

func (*Storage) SetSpeedLimits

func (s *Storage) SetSpeedLimits(download, upload uint64) error

func (*Storage) SetTorrent

func (s *Storage) SetTorrent(t *storage.Torrent) error

func (*Storage) UpdateUploadStats

func (s *Storage) UpdateUploadStats(bagId []byte, val uint64) error

type TorrentStored

type TorrentStored struct {
	BagID     []byte
	Path      string
	Info      *storage.TorrentInfo
	Header    *storage.TorrentHeader
	CreatedAt time.Time

	ActiveUpload    bool
	ActiveDownload  bool
	DownloadAll     bool
	DownloadOrdered bool
}