possumTorrentStorage

Documentation

Index

• type Provider
  • func (pp Provider) MovePrefix(from, to string) (err error)
  • func (p Provider) ReadConsecutiveChunks(prefix string) (rc io.ReadCloser, err error)

Types

type Provider

type Provider struct {
	possumResource.Provider
	Logger log.Logger
}

Extends possum resource.Provider with an efficient implementation of torrent storage.ConsecutiveChunkReader. TODO: This doesn't expose Capacity. TODO: Add a MarkComplete method that renames incomplete chunks rather than writing them to a single giant key and deleting them.

func (Provider) MovePrefix

func (pp Provider) MovePrefix(from, to string) (err error)

func (Provider) ReadConsecutiveChunks

func (p Provider) ReadConsecutiveChunks(prefix string) (rc io.ReadCloser, err error)

TODO: Should the parent ReadConsecutiveChunks method take the expected number of bytes to avoid trying to read discontinuous or incomplete sequences of chunks?