archive

Documentation

Index

• type Zipper
  • func NewZipper() *Zipper
  • func (z *Zipper) Proc(inputStream *stream.IOStream, inputErr *stream.ErrorPasser) (outputStream *stream.IOStream, outputErr *stream.ErrorPasser)
  • func (z *Zipper) SetCtxKeyOfFileName(key string)
  • func (z *Zipper) SetDownstreamCtx(ctx context.Context)

Types

type Zipper

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

func NewZipper

func NewZipper() *Zipper

func (*Zipper) Proc

func (z *Zipper) Proc(inputStream *stream.IOStream, inputErr *stream.ErrorPasser) (
	outputStream *stream.IOStream, outputErr *stream.ErrorPasser)

Proc note that outputStream only contains one datapack.

func (*Zipper) SetCtxKeyOfFileName

func (z *Zipper) SetCtxKeyOfFileName(key string)

func (*Zipper) SetDownstreamCtx

func (z *Zipper) SetDownstreamCtx(ctx context.Context)