piper

package

v0.0.7 Latest Latest Go to latest Published: Jun 16, 2023 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

View Source

var ErrAESDecode = errors.New("wrong secret or corrupted data")

func Close(stream interface{}) error

type AES struct {
	Key []byte
}

func (a *AES) Decoder(r io.Reader) (io.ReadCloser, error)

func (a *AES) Encoder(w io.Writer) (io.WriteCloser, error)

type Base64 struct {
	Encoding *base64.Encoding
}

func (e *Base64) Decoder(r io.Reader) (io.ReadCloser, error)

func (e *Base64) Encoder(w io.Writer) (io.WriteCloser, error)

type Buffer []byte

func (b *Buffer) Consume(dst []byte) int

Consume consumes the buffer to dst and returns the number of bytes consumed.

type EncodeDecoder interface {
	Encoder(io.Writer) (io.WriteCloser, error)
	Decoder(io.Reader) (io.ReadCloser, error)
}

func Join(list ...EncodeDecoder) EncodeDecoder

func NewAES(key []byte) EncodeDecoder

func NewBase64() EncodeDecoder

func NewGzip() EncodeDecoder

type EncodeDecoderFn struct {
	E func(io.Writer) (io.WriteCloser, error)
	D func(io.Reader) (io.ReadCloser, error)
}

func (ed *EncodeDecoderFn) Decoder(r io.Reader) (io.ReadCloser, error)

func (ed *EncodeDecoderFn) Encoder(w io.Writer) (io.WriteCloser, error)

type Gzip struct {
	Level int
}

func (g *Gzip) Decoder(r io.Reader) (io.ReadCloser, error)

func (g *Gzip) Encoder(w io.Writer) (io.WriteCloser, error)

type ReadClose struct {
	R func(p []byte) (n int, err error)
	C func() error
}

func (rc ReadClose) Close() error

func (rc ReadClose) Read(p []byte) (n int, err error)

type WriteClose struct {
	W func(p []byte) (n int, err error)
	C func() error
}

func (wc WriteClose) Close() error

func (wc WriteClose) Write(p []byte) (n int, err error)