Documentation ¶
Overview ¶
chunkbuffer provides a buffer over an arbitrary object store.
To use a ChunkBuffer, you simply make and configure a Pile for the storage backend you want to use. Then you call `chunkbuffer.New` with your buffer's unique name and the Pile. This enables you to buffer anything using memory, the disk, the cloud, or anything other method.
Happy limitless buffering!
Index ¶
Constants ¶
View Source
const CHUNK_SIZE = 1024 * 1024 * 5
View Source
const PARALLEL_WORKERS = 2
Variables ¶
View Source
var ErrLastChunk = errors.New("last chunk")
Functions ¶
This section is empty.
Types ¶
type ChunkBuffer ¶
type ChunkBuffer struct { Name string // contains filtered or unexported fields }
ChunkBuffer is a buffer working on a storage backend
func (*ChunkBuffer) Close ¶
func (cb *ChunkBuffer) Close() error
Close finalizes any in-progress reads and writes
Click to show internal directories.
Click to hide internal directories.