chunk

package

v0.0.0-...-4ac647c Latest Latest Go to latest Published: Dec 24, 2019 License: MIT Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/echterago/plexdrive

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type DownloadCallback
type Downloader
- func NewDownloader(threads int, client *drive.Client) (*Downloader, error)
- func (d *Downloader) Download(req *Request, callback DownloadCallback)
type Item
type Manager
- func NewManager(chunkSize int64, loadAhead, checkThreads int, loadThreads int, ...) (*Manager, error)
- func (m *Manager) GetChunk(object *drive.APIObject, offset, size int64, response chan Response)
type QueueEntry
type Request
type Response
type Stack
- func NewStack(maxChunks int) *Stack
type Storage
- func NewStorage(chunkSize int64, maxChunks int) *Storage

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrTimeout = errors.New("timeout")

ErrTimeout is a timeout error

Functions ¶

This section is empty.

Types ¶

type DownloadCallback ¶

type DownloadCallback func(error, []byte)

type Downloader ¶

type Downloader struct {
	Client *drive.Client
	// contains filtered or unexported fields
}

Downloader handles concurrent chunk downloads

func NewDownloader ¶

func NewDownloader(threads int, client *drive.Client) (*Downloader, error)

NewDownloader creates a new download manager

func (*Downloader) Download ¶

func (d *Downloader) Download(req *Request, callback DownloadCallback)

Download starts a new download request

type Item ¶

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

Item represents a chunk in RAM

type Manager ¶

type Manager struct {
	ChunkSize int64
	LoadAhead int
	// contains filtered or unexported fields
}

Manager manages chunks on disk

func NewManager ¶

func NewManager(
	chunkSize int64,
	loadAhead,
	checkThreads int,
	loadThreads int,
	client *drive.Client,
	maxChunks int) (*Manager, error)

NewManager creates a new chunk manager

func (*Manager) GetChunk ¶

func (m *Manager) GetChunk(object *drive.APIObject, offset, size int64, response chan Response)

GetChunk loads one chunk and starts the preload for the next chunks

type QueueEntry ¶

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

type Request ¶

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

Request represents a chunk request

type Response ¶

type Response struct {
	Error error
	Bytes []byte
}

Response represetns a chunk response

type Stack ¶

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

Stack is a thread safe list/stack implementation

func NewStack ¶

func NewStack(maxChunks int) *Stack

NewStack creates a new stack

func (*Stack) Pop ¶

func (s *Stack) Pop() string

Pop pops the first item from the stack

func (*Stack) Push ¶

func (s *Stack) Push(id string)

Push adds a new item to the last position of the stack

func (*Stack) Touch ¶

func (s *Stack) Touch(id string)

Touch moves the specified item to the last position of the stack

type Storage ¶

type Storage struct {
	ChunkSize int64
	MaxChunks int
	// contains filtered or unexported fields
}

Storage is a chunk storage

func NewStorage ¶

func NewStorage(chunkSize int64, maxChunks int) *Storage

NewStorage creates a new storage

func (*Storage) Clear ¶

func (s *Storage) Clear() error

Clear removes all old chunks on disk (will be called on each program start)

func (*Storage) Load ¶

func (s *Storage) Load(id string) []byte

Load a chunk from ram or creates it

func (*Storage) Store ¶

func (s *Storage) Store(id string, bytes []byte) error

Store stores a chunk in the RAM and adds it to the disk storage queue

Source Files ¶

View all Source files

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