archive_extractor

Documentation

Index

• Constants
• Variables
• func IsErrCompressLimitReached(err error) bool
• type ArchiveData
• type ArchiveHeader
  • func NewArchiveHeader(archiveReader io.Reader, name string, modTime int64, size int64) *ArchiveHeader
• type Archiver
• type DebArchiver
  • func (da DebArchiver) ExtractArchive(path string, processingFunc func(*ArchiveHeader, map[string]interface{}) error, ...) error
• type Decompressor
  • func (dc Decompressor) ExtractArchive(path string, processingFunc func(*ArchiveHeader, map[string]interface{}) error, ...) error
• type ErrCompressLimitReached
  • func (ErrCompressLimit *ErrCompressLimitReached) Error() string
• type GzMetadataArchiver
  • func (ga GzMetadataArchiver) ExtractArchive(path string, processingFunc func(*ArchiveHeader, map[string]interface{}) error, ...) error
• type LimitAggregatingReadCloser
• type LimitAggregatingReadCloserProvider
  • func (provider *LimitAggregatingReadCloserProvider) CreateLimitAggregatingReadCloser(rc io.Reader) LimitAggregatingReadCloser
• type RarArchiver
  • func (ra RarArchiver) ExtractArchive(path string, processingFunc func(*ArchiveHeader, map[string]interface{}) error, ...) error
• type RpmArchiver
  • func (ra RpmArchiver) ExtractArchive(path string, processingFunc func(*ArchiveHeader, map[string]interface{}) error, ...) error
• type RpmPkg
• type SevenZipArchiver
  • func (sa SevenZipArchiver) ExtractArchive(path string, processingFunc func(*ArchiveHeader, map[string]interface{}) error, ...) error
• type SevenZipReader
  • func (a *SevenZipReader) Close() error
  • func (a *SevenZipReader) Read(p []byte) (n int, err error)
• type TarArchiver
  • func (ta TarArchiver) ExtractArchive(path string, processingFunc func(*ArchiveHeader, map[string]interface{}) error, ...) error
• type ZipArchiver
  • func (za ZipArchiver) ExtractArchive(path string, processingFunc func(*ArchiveHeader, map[string]interface{}) error, ...) error
• type ZipReadCloser
• type ZoneInfoFileError
  • func (e *ZoneInfoFileError) Error() string

Constants

const DebArchiverSkipFoldersCheckParamsKey = "DebArchiverSkipFoldersCheckParamsKey"

const (
	NotCompressedOrNotSupportedError = "file %v is not compressed or the compression method is not supported"
)

const (
	RpmTagModularityLabel = 5096
)

Variables

var ErrTooManyEntries = errors.New("too many entries in archive")

Functions

func IsErrCompressLimitReached

func IsErrCompressLimitReached(err error) bool

Types

type ArchiveData

type ArchiveData struct {
	ArchiveReader io.Reader
	IsFolder      bool
	Name          string
	ModTime       int64
	Size          int64
}

type ArchiveHeader

type ArchiveHeader struct {
	ArchiveReader io.Reader
	IsFolder      bool
	Name          string
	ModTime       int64
	Size          int64
}

func NewArchiveHeader

func NewArchiveHeader(archiveReader io.Reader, name string, modTime int64, size int64) *ArchiveHeader

type Archiver

type Archiver interface {
	ExtractArchive(path string, processingFunc func(header *ArchiveHeader, params map[string]interface{}) error, params map[string]interface{}) error
}

type DebArchiver

type DebArchiver struct {
	MaxCompressRatio   int64
	MaxNumberOfEntries int
}

func (DebArchiver) ExtractArchive

func (da DebArchiver) ExtractArchive(path string,
	processingFunc func(*ArchiveHeader, map[string]interface{}) error, params map[string]interface{}) error

type Decompressor

type Decompressor struct {
	MaxCompressRatio int64
}

func (Decompressor) ExtractArchive

func (dc Decompressor) ExtractArchive(path string,
	processingFunc func(*ArchiveHeader, map[string]interface{}) error, params map[string]interface{}) error

type ErrCompressLimitReached

type ErrCompressLimitReached struct {
	SizeLimit int64
	CurrSize  int64
}

func (*ErrCompressLimitReached) Error

func (ErrCompressLimit *ErrCompressLimitReached) Error() string

type GzMetadataArchiver

type GzMetadataArchiver struct {
	MaxCompressRatio int64
}

func (GzMetadataArchiver) ExtractArchive

func (ga GzMetadataArchiver) ExtractArchive(path string,
	processingFunc func(*ArchiveHeader, map[string]interface{}) error, params map[string]interface{}) error

type LimitAggregatingReadCloser

type LimitAggregatingReadCloser interface {
	Read(p []byte) (int, error)
	Close() error
}

type LimitAggregatingReadCloserProvider

type LimitAggregatingReadCloserProvider struct {
	Total int64
	Limit int64
}

func (*LimitAggregatingReadCloserProvider) CreateLimitAggregatingReadCloser

func (provider *LimitAggregatingReadCloserProvider) CreateLimitAggregatingReadCloser(rc io.Reader) LimitAggregatingReadCloser

type RarArchiver

type RarArchiver struct {
	MaxCompressRatio   int64
	MaxNumberOfEntries int
}

func (RarArchiver) ExtractArchive

func (ra RarArchiver) ExtractArchive(path string,
	processingFunc func(*ArchiveHeader, map[string]interface{}) error, params map[string]interface{}) error

type RpmArchiver

type RpmArchiver struct {
	MaxCompressRatio   int64
	MaxNumberOfEntries int
}

func (RpmArchiver) ExtractArchive

func (ra RpmArchiver) ExtractArchive(path string,
	processingFunc func(*ArchiveHeader, map[string]interface{}) error, params map[string]interface{}) error

type RpmPkg

type RpmPkg struct {
	Name            string
	Version         string
	Release         string
	Epoch           int
	Licenses        []string
	Vendor          string
	ModularityLabel string
}

type SevenZipArchiver

type SevenZipArchiver struct {
	MaxCompressRatio   int64
	MaxNumberOfEntries int
}

func (SevenZipArchiver) ExtractArchive

func (sa SevenZipArchiver) ExtractArchive(path string,
	processingFunc func(*ArchiveHeader, map[string]interface{}) error, params map[string]interface{}) error

type SevenZipReader

type SevenZipReader struct {
	Archive *archive.Archive
	Size    int
}

func (*SevenZipReader) Close

func (a *SevenZipReader) Close() error

func (*SevenZipReader) Read

func (a *SevenZipReader) Read(p []byte) (n int, err error)

type TarArchiver

type TarArchiver struct {
	MaxCompressRatio   int64
	MaxNumberOfEntries int
}

func (TarArchiver) ExtractArchive

func (ta TarArchiver) ExtractArchive(path string,
	processingFunc func(*ArchiveHeader, map[string]interface{}) error, params map[string]interface{}) error

type ZipArchiver

type ZipArchiver struct {
	MaxCompressRatio   int64
	MaxNumberOfEntries int
}

func (ZipArchiver) ExtractArchive

func (za ZipArchiver) ExtractArchive(path string,
	processingFunc func(*ArchiveHeader, map[string]interface{}) error, params map[string]interface{}) error

type ZipReadCloser

type ZipReadCloser struct {
	*zip.Reader
	io.Closer
}

type ZoneInfoFileError

type ZoneInfoFileError struct{}

func (*ZoneInfoFileError) Error

func (e *ZoneInfoFileError) Error() string