mock

Documentation

Index

• func CreateFixedBody(bodySize int) []byte
• func DialerFun(addr string) (network.Conn, error)
• func SlowReadDialer(addr string) (network.Conn, error)
• func SlowWriteDialer(addr string) (network.Conn, 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) 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 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 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)

Functions

func CreateFixedBody

func CreateFixedBody(bodySize int) []byte

func DialerFun

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

func SlowReadDialer

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

func SlowWriteDialer

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

Types

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) 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 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 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)