mock

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 26, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func CreateChunkedBody added in v0.6.7 

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 added in v0.6.8 

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

func SlowReadDialer 

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

func SlowWriteDialer added in v0.4.1 

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

Types

type BrokenConn added in v0.6.7 

type BrokenConn struct {
	*Conn
}

func NewBrokenConn added in v0.6.7 

func NewBrokenConn(source string) *BrokenConn

func (*BrokenConn) Flush added in v0.6.7 

func (o *BrokenConn) Flush() error

func (*BrokenConn) Peek added in v0.6.7 

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

func (*BrokenConn) Read added in v0.6.7 

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 added in v0.6.7 

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 added in v0.4.1 

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 added in v0.6.5 

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

func NewErrorReadConn added in v0.6.5 

func NewErrorReadConn(err error) *ErrorReadConn

func (*ErrorReadConn) Peek added in v0.6.5 

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

type ExtWriter added in v0.6.0 

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

func (*ExtWriter) Finalize added in v0.6.0 

func (m *ExtWriter) Finalize() error

func (*ExtWriter) Flush added in v0.6.0 

func (m *ExtWriter) Flush() error

func (*ExtWriter) SetBody added in v0.6.0 

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

func (*ExtWriter) Write added in v0.6.0 

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

type OneTimeConn added in v0.6.7 

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

func NewOneTimeConn added in v0.6.7 

func NewOneTimeConn(source string) *OneTimeConn

func (*OneTimeConn) Flush added in v0.6.7 

func (o *OneTimeConn) Flush() error

func (*OneTimeConn) Peek added in v0.6.7 

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

func (*OneTimeConn) Skip added in v0.6.7 

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

type Recorder added in v0.6.0 

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 added in v0.6.1 

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

func (*SlowReadConn) SetWriteTimeout added in v0.4.1 

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

type SlowWriteConn added in v0.4.1 

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

func NewSlowWriteConn added in v0.4.1 

func NewSlowWriteConn(source string) *SlowWriteConn

func (*SlowWriteConn) Flush added in v0.4.1 

func (m *SlowWriteConn) Flush() error

func (*SlowWriteConn) SetWriteTimeout added in v0.4.1 

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.