storage

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

type ClientImpl interface {
	OpenTorrent(info *metainfo.Info, infoHash metainfo.Hash) (TorrentImpl, error)
}

type ClientImplCloser interface {
	ClientImpl
	Close() error
}

type Completion struct {
	Complete bool
	Ok       bool
	Err      error
}

type ConsecutiveChunkReader interface {
	ReadConsecutiveChunks(prefix string) (io.ReadCloser, error)
}

type FileMapping = mmap_span.Mmap

type FilePathMaker func(opts FilePathMakerOpts) string

type FilePathMakerOpts struct {
	Info *metainfo.Info
	File *metainfo.FileInfo
}

type NewFileClientOpts struct {
	// The base directory for all downloads.
	ClientBaseDir   string
	FilePathMaker   FilePathMaker
	TorrentDirMaker TorrentDirFilePathMaker
	PieceCompletion PieceCompletion
}

type Piece struct {
	PieceImpl
	// contains filtered or unexported fields
}

type PieceCompletion interface {
	PieceCompletionGetSetter
	Close() error
}

type PieceCompletionGetSetter interface {
	Get(metainfo.PieceKey) (Completion, error)
	Set(_ metainfo.PieceKey, complete bool) error
}

type PieceImpl interface {
	// These interfaces are not as strict as normally required. They can
	// assume that the parameters are appropriate for the dimensions of the
	// piece.
	io.ReaderAt
	io.WriterAt
	// Called when the client believes the piece data will pass a hash check.
	// The storage can move or mark the piece data as read-only as it sees
	// fit.
	MarkComplete() error
	MarkNotComplete() error
	// Returns true if the piece is complete.
	Completion() Completion
}

type PieceProvider interface {
	resource.Provider
}

type ResourcePiecesOpts struct {
	// After marking a piece complete, don't bother deleting its incomplete blobs.
	LeaveIncompleteChunks bool
	// Sized puts require being able to stream from a statement executed on another connection.
	// Without them, we buffer the entire read and then put that.
	NoSizedPuts bool
	Capacity    *int64
}

type SelfHashing interface {
	SelfHash() (metainfo.Hash, error)
}

type SizedPutter interface {
	PutSized(io.Reader, int64) error
}

type Torrent struct {
	TorrentImpl
}

type TorrentCapacity *func() (cap int64, capped bool)

type TorrentDirFilePathMaker func(baseDir string, info *metainfo.Info, infoHash metainfo.Hash) string

type TorrentImpl struct {
	Piece func(p metainfo.Piece) PieceImpl
	Close func() error
	Flush func() error
	// Storages that share the same space, will provide equal pointers. The function is called once
	// to determine the storage for torrents sharing the same function pointer, and mutated in
	// place.
	Capacity TorrentCapacity
}