mock

Documentation

Index

• Variables
• func CreateChunkedBody(body []byte, trailer map[string]string, hasTrailer bool) []byte
• func CreateFixedBody(bodySize int) []byte
• func DialerFun(addr string) (network.Conn, error)
• func NewLimitReader(r *bytes.Buffer) io.LimitedReader
• func SlowReadDialer(addr string) (network.Conn, error)
• func SlowWriteDialer(addr string) (network.Conn, error)
• type BrokenConn
  • func NewBrokenConn(source string) *BrokenConn
  • func (o *BrokenConn) Flush() error
  • func (o *BrokenConn) Peek(i int) ([]byte, error)
  • func (o *BrokenConn) Read(b []byte) (n int, err error)
• type Conn
  • func NewConn(source string) *Conn
  • func (m *Conn) AddCloseCallback(callback netpoll.CloseCallback) error
  • func (m *Conn) Close() error
  • func (m *Conn) Flush() error
  • func (m *Conn) GetReadTimeout() time.Duration
  • func (m *Conn) IsActive() bool
  • func (m *Conn) Len() int
  • func (m *Conn) LocalAddr() net.Addr
  • func (m *Conn) Malloc(n int) (buf []byte, err error)
  • func (m *Conn) Peek(i int) ([]byte, error)
  • func (m *Conn) Read(b []byte) (n int, err error)
  • func (m *Conn) ReadBinary(n int) (p []byte, err error)
  • func (m *Conn) ReadByte() (byte, error)
  • func (m *Conn) Reader() network.Reader
  • func (m *Conn) Release() error
  • func (m *Conn) RemoteAddr() net.Addr
  • func (m *Conn) SetDeadline(t time.Time) error
  • func (m *Conn) SetIdleTimeout(timeout time.Duration) error
  • func (m *Conn) SetOnRequest(on netpoll.OnRequest) error
  • func (m *Conn) SetReadDeadline(t time.Time) error
  • func (m *Conn) SetReadTimeout(t time.Duration) error
  • func (m *Conn) SetWriteDeadline(t time.Time) error
  • func (m *Conn) SetWriteTimeout(t time.Duration) error
  • func (m *Conn) Skip(n int) error
  • func (m *Conn) Write(b []byte) (n int, err error)
  • func (m *Conn) WriteBinary(b []byte) (n int, err error)
  • func (m *Conn) Writer() network.Writer
  • func (m *Conn) WriterRecorder() Recorder
• type EOFReader
  • func (e *EOFReader) Len() int
  • func (e *EOFReader) Peek(n int) ([]byte, error)
  • func (e *EOFReader) Read(p []byte) (n int, err error)
  • func (e *EOFReader) ReadBinary(n int) (p []byte, err error)
  • func (e *EOFReader) ReadByte() (byte, error)
  • func (e *EOFReader) Release() error
  • func (e *EOFReader) Skip(n int) error
• type ErrorReadConn
  • func NewErrorReadConn(err error) *ErrorReadConn
  • func (er *ErrorReadConn) Peek(n int) ([]byte, error)
• type ExtWriter
  • func (m *ExtWriter) Finalize() error
  • func (m *ExtWriter) Flush() error
  • func (m *ExtWriter) SetBody(body []byte)
  • func (m *ExtWriter) Write(p []byte) (n int, err error)
• type OneTimeConn
  • func NewOneTimeConn(source string) *OneTimeConn
  • func (o *OneTimeConn) Flush() error
  • func (o *OneTimeConn) Peek(n int) ([]byte, error)
  • func (o *OneTimeConn) Skip(n int) error
• type Recorder
• type SlowReadConn
  • func NewSlowReadConn(source string) *SlowReadConn
  • func (m *SlowReadConn) Peek(i int) ([]byte, error)
  • func (m *SlowReadConn) SetReadTimeout(t time.Duration) error
  • func (m *SlowReadConn) SetWriteTimeout(t time.Duration) error
• type SlowWriteConn
  • func NewSlowWriteConn(source string) *SlowWriteConn
  • func (m *SlowWriteConn) Flush() error
  • func (m *SlowWriteConn) SetWriteTimeout(t time.Duration) error
• type StreamConn
  • func NewStreamConn() *StreamConn
  • func (m *StreamConn) Len() int
  • func (m *StreamConn) Peek(n int) ([]byte, error)
  • func (m *StreamConn) ReadBinary(n int) (p []byte, err error)
  • func (m *StreamConn) ReadByte() (byte, error)
  • func (m *StreamConn) Release() error
  • func (m *StreamConn) Skip(n int) error
• type ZeroCopyReader
  • func NewZeroCopyReader(r string) ZeroCopyReader
  • func (m ZeroCopyReader) Len() (length int)
  • func (m ZeroCopyReader) Peek(n int) ([]byte, error)
  • func (m ZeroCopyReader) ReadBinary(n int) (p []byte, err error)
  • func (m ZeroCopyReader) Release() (err error)
  • func (m ZeroCopyReader) Skip(n int) (err error)

Variables

var (
	ErrReadTimeout  = errs.New(errs.ErrTimeout, errs.ErrorTypePublic, "read timeout")
	ErrWriteTimeout = errs.New(errs.ErrTimeout, errs.ErrorTypePublic, "write timeout")
)

Functions

func CreateChunkedBody

func CreateChunkedBody(body []byte, trailer map[string]string, hasTrailer bool) []byte

func CreateFixedBody

func CreateFixedBody(bodySize int) []byte

func DialerFun

func DialerFun(addr string) (network.Conn, error)

func NewLimitReader

func NewLimitReader(r *bytes.Buffer) io.LimitedReader

func SlowReadDialer

func SlowReadDialer(addr string) (network.Conn, error)

func SlowWriteDialer

func SlowWriteDialer(addr string) (network.Conn, error)

Types

type BrokenConn

type BrokenConn struct {
	*Conn
}

func NewBrokenConn

func NewBrokenConn(source string) *BrokenConn

func (*BrokenConn) Flush

func (o *BrokenConn) Flush() error

func (*BrokenConn) Peek

func (o *BrokenConn) Peek(i int) ([]byte, error)

func (*BrokenConn) Read

func (o *BrokenConn) Read(b []byte) (n int, err error)

type Conn

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

func NewConn

func NewConn(source string) *Conn

func (*Conn) AddCloseCallback

func (m *Conn) AddCloseCallback(callback netpoll.CloseCallback) error

func (*Conn) Close

func (m *Conn) Close() error

func (*Conn) Flush

func (m *Conn) Flush() error

func (*Conn) GetReadTimeout

func (m *Conn) GetReadTimeout() time.Duration

func (*Conn) IsActive

func (m *Conn) IsActive() bool

func (*Conn) Len

func (m *Conn) Len() int

func (*Conn) LocalAddr

func (m *Conn) LocalAddr() net.Addr

func (*Conn) Malloc

func (m *Conn) Malloc(n int) (buf []byte, err error)

func (*Conn) Peek

func (m *Conn) Peek(i int) ([]byte, error)

func (*Conn) Read

func (m *Conn) Read(b []byte) (n int, err error)

func (*Conn) ReadBinary

func (m *Conn) ReadBinary(n int) (p []byte, err error)

func (*Conn) ReadByte

func (m *Conn) ReadByte() (byte, error)

func (*Conn) Reader

func (m *Conn) Reader() network.Reader

func (*Conn) Release

func (m *Conn) Release() error

func (*Conn) RemoteAddr

func (m *Conn) RemoteAddr() net.Addr

func (*Conn) SetDeadline

func (m *Conn) SetDeadline(t time.Time) error

func (*Conn) SetIdleTimeout

func (m *Conn) SetIdleTimeout(timeout time.Duration) error

func (*Conn) SetOnRequest

func (m *Conn) SetOnRequest(on netpoll.OnRequest) error

func (*Conn) SetReadDeadline

func (m *Conn) SetReadDeadline(t time.Time) error

func (*Conn) SetReadTimeout

func (m *Conn) SetReadTimeout(t time.Duration) error

func (*Conn) SetWriteDeadline

func (m *Conn) SetWriteDeadline(t time.Time) error

func (*Conn) SetWriteTimeout

func (m *Conn) SetWriteTimeout(t time.Duration) error

func (*Conn) Skip

func (m *Conn) Skip(n int) error

func (*Conn) Write

func (m *Conn) Write(b []byte) (n int, err error)

func (*Conn) WriteBinary

func (m *Conn) WriteBinary(b []byte) (n int, err error)

func (*Conn) Writer

func (m *Conn) Writer() network.Writer

func (*Conn) WriterRecorder

func (m *Conn) WriterRecorder() Recorder

type EOFReader

type EOFReader struct{}

func (*EOFReader) Len

func (e *EOFReader) Len() int

func (*EOFReader) Peek

func (e *EOFReader) Peek(n int) ([]byte, error)

func (*EOFReader) Read

func (e *EOFReader) Read(p []byte) (n int, err error)

func (*EOFReader) ReadBinary

func (e *EOFReader) ReadBinary(n int) (p []byte, err error)

func (*EOFReader) ReadByte

func (e *EOFReader) ReadByte() (byte, error)

func (*EOFReader) Release

func (e *EOFReader) Release() error

func (*EOFReader) Skip

func (e *EOFReader) Skip(n int) error

type ErrorReadConn

type ErrorReadConn struct {
	*Conn
	// contains filtered or unexported fields
}

func NewErrorReadConn

func NewErrorReadConn(err error) *ErrorReadConn

func (*ErrorReadConn) Peek

func (er *ErrorReadConn) Peek(n int) ([]byte, error)

type ExtWriter

type ExtWriter struct {
	Buf     *bytes.Buffer
	IsFinal *bool
	// contains filtered or unexported fields
}

func (*ExtWriter) Finalize

func (m *ExtWriter) Finalize() error

func (*ExtWriter) Flush

func (m *ExtWriter) Flush() error

func (*ExtWriter) SetBody

func (m *ExtWriter) SetBody(body []byte)

func (*ExtWriter) Write

func (m *ExtWriter) Write(p []byte) (n int, err error)

type OneTimeConn

type OneTimeConn struct {
	*Conn
	// contains filtered or unexported fields
}

func NewOneTimeConn

func NewOneTimeConn(source string) *OneTimeConn

func (*OneTimeConn) Flush

func (o *OneTimeConn) Flush() error

func (*OneTimeConn) Peek

func (o *OneTimeConn) Peek(n int) ([]byte, error)

func (*OneTimeConn) Skip

func (o *OneTimeConn) Skip(n int) error

type Recorder

type Recorder interface {
	network.Reader
	WroteLen() int
}

type SlowReadConn

type SlowReadConn struct {
	*Conn
}

func NewSlowReadConn

func NewSlowReadConn(source string) *SlowReadConn

func (*SlowReadConn) Peek

func (m *SlowReadConn) Peek(i int) ([]byte, error)

func (*SlowReadConn) SetReadTimeout

func (m *SlowReadConn) SetReadTimeout(t time.Duration) error

func (*SlowReadConn) SetWriteTimeout

func (m *SlowReadConn) SetWriteTimeout(t time.Duration) error

type SlowWriteConn

type SlowWriteConn struct {
	*Conn
	// contains filtered or unexported fields
}

func NewSlowWriteConn

func NewSlowWriteConn(source string) *SlowWriteConn

func (*SlowWriteConn) Flush

func (m *SlowWriteConn) Flush() error

func (*SlowWriteConn) SetWriteTimeout

func (m *SlowWriteConn) SetWriteTimeout(t time.Duration) error

type StreamConn

type StreamConn struct {
	Data []byte
}

func NewStreamConn

func NewStreamConn() *StreamConn

func (*StreamConn) Len

func (m *StreamConn) Len() int

func (*StreamConn) Peek

func (m *StreamConn) Peek(n int) ([]byte, error)

func (*StreamConn) ReadBinary

func (m *StreamConn) ReadBinary(n int) (p []byte, err error)

func (*StreamConn) ReadByte

func (m *StreamConn) ReadByte() (byte, error)

func (*StreamConn) Release

func (m *StreamConn) Release() error

func (*StreamConn) Skip

func (m *StreamConn) Skip(n int) error

type ZeroCopyReader

type ZeroCopyReader struct {
	*bufio.Reader
}

ZeroCopyReader is used to create ZeroCopyReader for testing.

NOTE: In principle, ut should use the zcReader created by netpoll.NewReader() for mock testing, but because zcReader does not implement the io.Reader interface, the test requirements of io.Reader involved are replaced with MockZeroCopyReader

func NewZeroCopyReader

func NewZeroCopyReader(r string) ZeroCopyReader

func (ZeroCopyReader) Len

func (m ZeroCopyReader) Len() (length int)

func (ZeroCopyReader) Peek

func (m ZeroCopyReader) Peek(n int) ([]byte, error)

func (ZeroCopyReader) ReadBinary

func (m ZeroCopyReader) ReadBinary(n int) (p []byte, err error)

func (ZeroCopyReader) Release

func (m ZeroCopyReader) Release() (err error)

func (ZeroCopyReader) Skip

func (m ZeroCopyReader) Skip(n int) (err error)