streampackage

package
v0.3.24 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 21, 2024 License: Apache-2.0 Imports: 12 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FileStream added in v0.2.9

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

func NewFileStream added in v0.2.9

func NewFileStream(localPath string, path string) *FileStream

func (*FileStream) Open added in v0.2.9

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

Jump to

Keyboard shortcuts

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