Versions in this module Expand all Collapse all v0 v0.3.2 Jul 4, 2023 Changes in this version + type Decoder struct + Header chan<- []byte + func NewDecoder(options DecoderOptions) (*Decoder, error) + func (enc *Decoder) Close() error + func (enc *Decoder) DumpStatsToStdout() + func (enc *Decoder) GetStreamError() error + func (enc *Decoder) Process(ctx context.Context) error + type DecoderOptions struct + BlockSizeKB int + EnableStats bool + FileID string + FromFile io.ReadSeeker + PatchFile io.Reader + ToFile io.Writer + type Encoder struct + func NewEncoder(options EncoderOptions) (*Encoder, error) + func (enc *Encoder) Close() error + func (enc *Encoder) DumpStatsToStdout() + func (enc *Encoder) GetStreamError() error + func (enc *Encoder) Process(ctx context.Context) error + type EncoderOptions struct + BlockSizeKB int + EnableStats bool + FileID string + FromFile io.ReadSeeker + Header []byte + PatchFile io.Writer + ToFile io.Reader + type Stats struct + func (s *Stats) DumpToStdout()