streampackage

Documentation

Index

• type FileStream
  • func NewFileStream(localPath string, path string) *FileStream
  • func (self *FileStream) Open(context contextpkg.Context) (io.ReadCloser, string, bool, error)
• type StaticStreamPackage
  • func NewDirStreamPackage(path string) (*StaticStreamPackage, error)
  • func NewStaticStreamPackage(streams ...Stream) *StaticStreamPackage
  • func (self *StaticStreamPackage) Close() error
  • func (self *StaticStreamPackage) Next() (Stream, error)
• type Stream
• type StreamPackage
  • func NewStreamPackage(context contextpkg.Context, url exturl.URL, archiveFormat string) (StreamPackage, error)
• type TarGZipStreamPackage
  • func NewTarGZipStreamPackage(context contextpkg.Context, url exturl.URL) (*TarGZipStreamPackage, error)
  • func (self *TarGZipStreamPackage) Close() error
  • func (self *TarGZipStreamPackage) Next() (Stream, error)
• type TarStream
  • func NewTarStream(header *tar.Header, tarReader *tar.Reader) *TarStream
  • func (self *TarStream) Open(context contextpkg.Context) (io.ReadCloser, string, bool, error)
• type TarStreamPackage
  • func NewTarStreamPackage(context contextpkg.Context, url exturl.URL) (*TarStreamPackage, error)
  • func (self *TarStreamPackage) Close() error
  • func (self *TarStreamPackage) Next() (Stream, error)
• type URLStream
  • func NewURLStream(url exturl.URL) *URLStream
  • func (self *URLStream) Open(context contextpkg.Context) (io.ReadCloser, string, bool, error)
• type ZipStream
  • func NewZipStream(file *zip.File) *ZipStream
  • func (self *ZipStream) Open(context contextpkg.Context) (io.ReadCloser, string, bool, error)
• type ZipStreamPackage
  • func NewZipStreamPackage(path string) (*ZipStreamPackage, error)
  • func (self *ZipStreamPackage) Close() error
  • func (self *ZipStreamPackage) Next() (Stream, error)

Types

type FileStream

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

func NewFileStream

func NewFileStream(localPath string, path string) *FileStream

func (*FileStream) Open

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

Stream interface

type StaticStreamPackage

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

func NewDirStreamPackage

func NewDirStreamPackage(path string) (*StaticStreamPackage, error)

func NewStaticStreamPackage

func NewStaticStreamPackage(streams ...Stream) *StaticStreamPackage

func (*StaticStreamPackage) Close

func (self *StaticStreamPackage) Close() error

StreamPackage interface

func (*StaticStreamPackage) Next

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

StreamPackage interface

type Stream

type Stream interface {
	Open(context contextpkg.Context) (io.ReadCloser, string, bool, error) // path, isExecutable
}

type StreamPackage

type StreamPackage interface {
	Next() (Stream, error)
	Close() error
}

func NewStreamPackage

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

`archiveFormat` can be "tar", "tgz", or "zip"

type TarGZipStreamPackage

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

func NewTarGZipStreamPackage

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

func (*TarGZipStreamPackage) Close

func (self *TarGZipStreamPackage) Close() error

StreamPackage interface

func (*TarGZipStreamPackage) Next

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

StreamPackage interface

type TarStream

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

func NewTarStream

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

func (*TarStream) Open

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

Stream interface

type TarStreamPackage

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

func NewTarStreamPackage

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

func (*TarStreamPackage) Close

func (self *TarStreamPackage) Close() error

StreamPackage interface

func (*TarStreamPackage) Next

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

StreamPackage interface

type URLStream

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

func NewURLStream

func NewURLStream(url exturl.URL) *URLStream

func (*URLStream) Open

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

Stream interface

type ZipStream

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

func NewZipStream

func NewZipStream(file *zip.File) *ZipStream

func (*ZipStream) Open

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

Stream interface

type ZipStreamPackage

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

func NewZipStreamPackage

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

func (*ZipStreamPackage) Close

func (self *ZipStreamPackage) Close() error

StreamPackage interface

func (*ZipStreamPackage) Next

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

StreamPackage interface