streampackage

Aug 14, 2023

Changes in this version

+ type FileStream struct

+ func NewFileStream(localPath string, path string) *FileStream

+ func (self *FileStream) Open(context contextpkg.Context) (io.ReadCloser, string, bool, error)

Jun 1, 2023

Changes in this version

+ type DirStream struct

+ func NewDirStream(localPath string, providedPath string) *DirStream

+ func (self *DirStream) Close() error

+ func (self *DirStream) Open(context contextpkg.Context) (string, bool, io.Reader, error)

+ type StaticStreamPackage struct

+ func NewStaticStreamPackage(streams ...Stream) *StaticStreamPackage

+ func (self *StaticStreamPackage) Close() error

+ func (self *StaticStreamPackage) Next() (Stream, error)

+ type Stream interface

+ Close func() error

+ Open func(context contextpkg.Context) (string, bool, io.Reader, error)

+ type StreamPackage interface

+ Close func() error

+ Next func() (Stream, error)

+ func NewDirStreamPackage(path string) (StreamPackage, error)

+ func NewStreamPackage(context contextpkg.Context, url exturl.URL, unpack string) (StreamPackage, error)

+ type TarGZipStreamPackage struct

+ func NewTarGZipStreamPackage(context contextpkg.Context, url exturl.URL) (*TarGZipStreamPackage, error)

+ func (self *TarGZipStreamPackage) Close() error

+ func (self *TarGZipStreamPackage) Next() (Stream, error)

+ type TarStream struct

+ func NewTarStream(header *tar.Header, tarReader *tar.Reader) *TarStream

+ func (self *TarStream) Close() error

+ func (self *TarStream) Open(context contextpkg.Context) (string, bool, io.Reader, error)

+ type TarStreamPackage struct

+ func NewTarStreamPackage(context contextpkg.Context, url exturl.URL) (*TarStreamPackage, error)

+ func (self *TarStreamPackage) Close() error

+ func (self *TarStreamPackage) Next() (Stream, error)

+ type URLStream struct

+ func NewURLStream(url exturl.URL) *URLStream

+ func (self *URLStream) Close() error

+ func (self *URLStream) Open(context contextpkg.Context) (string, bool, io.Reader, error)

+ type ZipStream struct

+ func NewZipStream(file *zip.File) *ZipStream

+ func (self *ZipStream) Close() error

+ func (self *ZipStream) Open(context contextpkg.Context) (string, bool, io.Reader, error)

+ type ZipStreamPackage struct

+ func NewZipStreamPackage(path string) (*ZipStreamPackage, error)

+ func (self *ZipStreamPackage) Close() error

+ func (self *ZipStreamPackage) Next() (Stream, error)