part

Documentation

Index

• Variables
• func Copy(r io.Reader, w io.Writer, c CopyConfig) (e error)
• func RW2Chan(r io.ReadCloser, w io.WriteCloser) (rc, wc chan []byte)
• func ReadAll(r io.Reader, b []byte) ([]byte, error)
• func WithCtxCopy(ctx context.Context, callTree string, copybuf []byte, to time.Duration, ...) error
• func WithCtxTO(ctx context.Context, callTree string, to time.Duration, w io.Writer, ...) io.ReadWriteCloser
• func WriterWithConfig(w io.Writer, c CopyConfig) (wc io.Writer)
• type CacheWriter
  • func NewCacheWriter(ws io.Writer, ctx ...context.Context) *CacheWriter
  • func (t *CacheWriter) Write(b []byte) (int, error)
• type CopyConfig
• type IOpipe
  • func NewPipe() *IOpipe
  • func (t *IOpipe) Close() (err error)
  • func (t *IOpipe) CloseWithError(e error) (err error)
  • func (t *IOpipe) Read(p []byte) (n int, err error)
  • func (t *IOpipe) Write(p []byte) (n int, err error)
• type RWC
  • func (t RWC) Close() error
  • func (t RWC) Read(p []byte) (n int, err error)
  • func (t RWC) Write(p []byte) (n int, err error)

Variables

var (
	ErrWrite   = errors.New("ErrWrite")
	ErrRead    = errors.New("ErrRead")
	ErrLoopMax = errors.New("ErrLoopMax")
)

var ErrBusy = errors.New(`ErrBusy`)

Functions

func Copy

func Copy(r io.Reader, w io.Writer, c CopyConfig) (e error)

close by yourself

watch out uint64(c.MaxLoop*c.BytePerLoop) overflow

func RW2Chan

func RW2Chan(r io.ReadCloser, w io.WriteCloser) (rc, wc chan []byte)

no close rc any time you can close wc, r, w.

func ReadAll

func ReadAll(r io.Reader, b []byte) ([]byte, error)

func WithCtxCopy

func WithCtxCopy(ctx context.Context, callTree string, copybuf []byte, to time.Duration, w io.Writer, r io.Reader, panicf ...func(s string)) error

close reader by yourself

to avoid writer block after ctx done, you should close writer after ctx done

call Close() after writer fin

func WithCtxTO

func WithCtxTO(ctx context.Context, callTree string, to time.Duration, w io.Writer, r io.Reader, panicf ...func(s string)) io.ReadWriteCloser

close reader by yourself

to avoid writer block after ctx done, you should close writer after ctx done

call Close() after writer fin

func WriterWithConfig

func WriterWithConfig(w io.Writer, c CopyConfig) (wc io.Writer)

Types

type CacheWriter

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

func NewCacheWriter

func NewCacheWriter(ws io.Writer, ctx ...context.Context) *CacheWriter

func (*CacheWriter) Write

func (t *CacheWriter) Write(b []byte) (int, error)

type CopyConfig

type CopyConfig struct {
	BytePerLoop, MaxLoop, MaxByte, BytePerSec uint64
	SkipByte                                  int
}

type IOpipe

type IOpipe struct {
	R *io.PipeReader
	W *io.PipeWriter
	// contains filtered or unexported fields
}

func NewPipe

func NewPipe() *IOpipe

func (*IOpipe) Close

func (t *IOpipe) Close() (err error)

func (*IOpipe) CloseWithError

func (t *IOpipe) CloseWithError(e error) (err error)

func (*IOpipe) Read

func (t *IOpipe) Read(p []byte) (n int, err error)

func (*IOpipe) Write

func (t *IOpipe) Write(p []byte) (n int, err error)

type RWC

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

func (RWC) Close

func (t RWC) Close() error

func (RWC) Read

func (t RWC) Read(p []byte) (n int, err error)

func (RWC) Write

func (t RWC) Write(p []byte) (n int, err error)