process

Documentation

Index

• type Unzipper
  • func Unzip() *Unzipper
  • func (u *Unzipper) Name() string
  • func (u *Unzipper) OnAdd(prevRunner ingest.Runner)
  • func (u *Unzipper) Run(stage *ingest.Stage) error
  • func (u *Unzipper) SetSelection(selections ...string)
  • func (u *Unzipper) SkipAbortErr() bool

Types

type Unzipper

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

Unzipper is a Runner that will unzip a file

func Unzip

func Unzip() *Unzipper

Unzip receives an os.File and will Unzip it, emitting the files within

It is selectable, allowing you to use a Regex to filter said files

func (*Unzipper) Name

func (u *Unzipper) Name() string

Name implements ingest.Runner for Unzipper

func (*Unzipper) OnAdd

func (u *Unzipper) OnAdd(prevRunner ingest.Runner)

OnAdd implements ingest.OnAdd for Unzipper

It will configure the ingest.Opener to have a tmp Directory (needed since zips need random access) If it is not already configured to do so.

func (*Unzipper) Run

func (u *Unzipper) Run(stage *ingest.Stage) error

Run implements ingest.Runner for Unzipper

func (*Unzipper) SetSelection

func (u *Unzipper) SetSelection(selections ...string)

SetSelection implements ingest.Selectable for Unzipper

It will filter the contents of the extracted files for file names that match the regex provided by the selection

func (*Unzipper) SkipAbortErr

func (u *Unzipper) SkipAbortErr() bool

SkipAbortErr saves us having to send nil errors back on abort