handlers

Documentation

Index

• func HandleFile(ctx context.Context, file io.Reader, chunkSkel *sources.Chunk, ...) bool
• func SetArchiveMaxDepth(depth int)
• func SetArchiveMaxSize(size int)
• func SetArchiveMaxTimeout(timeout time.Duration)
• type Archive
  • func (d *Archive) FromFile(originalCtx context.Context, data io.Reader) chan ([]byte)
  • func (d *Archive) IsFiletype(ctx context.Context, reader io.Reader) (io.Reader, bool)
  • func (d *Archive) New()
  • func (d *Archive) ReadToMax(ctx context.Context, reader io.Reader) (data []byte, err error)
• type Handler
  • func DefaultHandlers() []Handler

Functions

func HandleFile

func HandleFile(ctx context.Context, file io.Reader, chunkSkel *sources.Chunk, chunksChan chan (*sources.Chunk)) bool

func SetArchiveMaxDepth

func SetArchiveMaxDepth(depth int)

SetArchiveMaxDepth sets the maximum depth of the archive.

func SetArchiveMaxSize

func SetArchiveMaxSize(size int)

SetArchiveMaxSize sets the maximum size of the archive.

func SetArchiveMaxTimeout

func SetArchiveMaxTimeout(timeout time.Duration)

SetArchiveMaxTimeout sets the maximum timeout for the archive handler.

Types

type Archive

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

Archive is a handler for extracting and decompressing archives.

func (*Archive) FromFile

func (d *Archive) FromFile(originalCtx context.Context, data io.Reader) chan ([]byte)

FromFile extracts the files from an archive.

func (*Archive) IsFiletype

func (d *Archive) IsFiletype(ctx context.Context, reader io.Reader) (io.Reader, bool)

IsFiletype returns true if the provided reader is an archive.

func (*Archive) New

func (d *Archive) New()

New sets a default maximum size and current size counter.

func (*Archive) ReadToMax

func (d *Archive) ReadToMax(ctx context.Context, reader io.Reader) (data []byte, err error)

ReadToMax reads up to the max size.

type Handler

type Handler interface {
	FromFile(context.Context, io.Reader) chan ([]byte)
	IsFiletype(context.Context, io.Reader) (io.Reader, bool)
	New()
}

func DefaultHandlers

func DefaultHandlers() []Handler