Versions in this module Expand all Collapse all v0 v0.0.1 Nov 28, 2024 Changes in this version + const InMemoryBufMaxSize + const InMemoryBufMaxSizeBytes + func GetRangeReadCloserFromLink(size int64, link *model.Link) (model.RangeReadCloserIF, error) + func RequestRangedHttp(ctx context.Context, link *model.Link, offset, length int64) (*http.Response, error) + type FileStream struct + Ctx context.Context + Exist model.Obj + ForceStreamUpload bool + Mimetype string + WebPutAsTask bool + func (f *FileStream) CacheFullInTempFile() (model.File, error) + func (f *FileStream) Close() error + func (f *FileStream) GetExist() model.Obj + func (f *FileStream) GetMimetype() string + func (f *FileStream) GetSize() int64 + func (f *FileStream) IsForceStreamUpload() bool + func (f *FileStream) NeedStore() bool + func (f *FileStream) RangeRead(httpRange http_range.Range) (io.Reader, error) + func (f *FileStream) SetExist(obj model.Obj) + func (f *FileStream) SetTmpFile(r *os.File) + type SeekableStream struct + Link *model.Link + func NewSeekableStream(fs FileStream, link *model.Link) (*SeekableStream, error) + func (ss *SeekableStream) CacheFullInTempFile() (model.File, error) + func (ss *SeekableStream) RangeRead(httpRange http_range.Range) (io.Reader, error) + func (ss *SeekableStream) Read(p []byte) (n int, err error)
Go to main page