Versions in this module Expand all Collapse all v0 v0.6.1 Jul 31, 2023 v0.0.4 Jul 31, 2023 Changes in this version + type MockConn struct + func NewMockConn(ctrl *gomock.Controller) *MockConn + func (m *MockConn) Close() error + func (m *MockConn) EXPECT() *MockConnMockRecorder + func (m *MockConn) Fd() int + func (m *MockConn) LocalAddr() net.Addr + func (m *MockConn) Read(b []byte) (int, error) + func (m *MockConn) RemoteAddr() net.Addr + func (m *MockConn) SetDeadline(t time.Time) error + func (m *MockConn) SetReadDeadline(t time.Time) error + func (m *MockConn) SetWriteDeadline(t time.Time) error + func (m *MockConn) Write(b []byte) (int, error) + type MockConnMockRecorder struct + func (mr *MockConnMockRecorder) Close() *gomock.Call + func (mr *MockConnMockRecorder) Fd() *gomock.Call + func (mr *MockConnMockRecorder) LocalAddr() *gomock.Call + func (mr *MockConnMockRecorder) Read(b interface{}) *gomock.Call + func (mr *MockConnMockRecorder) RemoteAddr() *gomock.Call + func (mr *MockConnMockRecorder) SetDeadline(t interface{}) *gomock.Call + func (mr *MockConnMockRecorder) SetReadDeadline(t interface{}) *gomock.Call + func (mr *MockConnMockRecorder) SetWriteDeadline(t interface{}) *gomock.Call + func (mr *MockConnMockRecorder) Write(b interface{}) *gomock.Call + type MockConnection struct + func NewMockConnection(ctrl *gomock.Controller) *MockConnection + func (m *MockConnection) AddCloseCallback(callback netpoll.CloseCallback) error + func (m *MockConnection) Close() error + func (m *MockConnection) EXPECT() *MockConnectionMockRecorder + func (m *MockConnection) IsActive() bool + func (m *MockConnection) LocalAddr() net.Addr + func (m *MockConnection) Read(b []byte) (int, error) + func (m *MockConnection) Reader() netpoll.Reader + func (m *MockConnection) RemoteAddr() net.Addr + func (m *MockConnection) SetDeadline(t time.Time) error + func (m *MockConnection) SetIdleTimeout(timeout time.Duration) error + func (m *MockConnection) SetOnRequest(on netpoll.OnRequest) error + func (m *MockConnection) SetReadDeadline(t time.Time) error + func (m *MockConnection) SetReadTimeout(timeout time.Duration) error + func (m *MockConnection) SetWriteDeadline(t time.Time) error + func (m *MockConnection) SetWriteTimeout(timeout time.Duration) error + func (m *MockConnection) Write(b []byte) (int, error) + func (m *MockConnection) Writer() netpoll.Writer + type MockConnectionMockRecorder struct + func (mr *MockConnectionMockRecorder) AddCloseCallback(callback interface{}) *gomock.Call + func (mr *MockConnectionMockRecorder) Close() *gomock.Call + func (mr *MockConnectionMockRecorder) IsActive() *gomock.Call + func (mr *MockConnectionMockRecorder) LocalAddr() *gomock.Call + func (mr *MockConnectionMockRecorder) Read(b interface{}) *gomock.Call + func (mr *MockConnectionMockRecorder) Reader() *gomock.Call + func (mr *MockConnectionMockRecorder) RemoteAddr() *gomock.Call + func (mr *MockConnectionMockRecorder) SetDeadline(t interface{}) *gomock.Call + func (mr *MockConnectionMockRecorder) SetIdleTimeout(timeout interface{}) *gomock.Call + func (mr *MockConnectionMockRecorder) SetOnRequest(on interface{}) *gomock.Call + func (mr *MockConnectionMockRecorder) SetReadDeadline(t interface{}) *gomock.Call + func (mr *MockConnectionMockRecorder) SetReadTimeout(timeout interface{}) *gomock.Call + func (mr *MockConnectionMockRecorder) SetWriteDeadline(t interface{}) *gomock.Call + func (mr *MockConnectionMockRecorder) SetWriteTimeout(timeout interface{}) *gomock.Call + func (mr *MockConnectionMockRecorder) Write(b interface{}) *gomock.Call + func (mr *MockConnectionMockRecorder) Writer() *gomock.Call + type MockDialer struct + func NewMockDialer(ctrl *gomock.Controller) *MockDialer + func (m *MockDialer) DialConnection(network, address string, timeout time.Duration) (netpoll.Connection, error) + func (m *MockDialer) DialTimeout(network, address string, timeout time.Duration) (net.Conn, error) + func (m *MockDialer) EXPECT() *MockDialerMockRecorder + type MockDialerMockRecorder struct + func (mr *MockDialerMockRecorder) DialConnection(network, address, timeout interface{}) *gomock.Call + func (mr *MockDialerMockRecorder) DialTimeout(network, address, timeout interface{}) *gomock.Call + type MockListener struct + func NewMockListener(ctrl *gomock.Controller) *MockListener + func (m *MockListener) Accept() (net.Conn, error) + func (m *MockListener) Addr() net.Addr + func (m *MockListener) Close() error + func (m *MockListener) EXPECT() *MockListenerMockRecorder + func (m *MockListener) Fd() int + type MockListenerMockRecorder struct + func (mr *MockListenerMockRecorder) Accept() *gomock.Call + func (mr *MockListenerMockRecorder) Addr() *gomock.Call + func (mr *MockListenerMockRecorder) Close() *gomock.Call + func (mr *MockListenerMockRecorder) Fd() *gomock.Call + type MockReadWriter struct + func NewMockReadWriter(ctrl *gomock.Controller) *MockReadWriter + func (m *MockReadWriter) Append(w netpoll.Writer) error + func (m *MockReadWriter) EXPECT() *MockReadWriterMockRecorder + func (m *MockReadWriter) Flush() error + func (m *MockReadWriter) Len() int + func (m *MockReadWriter) Malloc(n int) ([]byte, error) + func (m *MockReadWriter) MallocAck(n int) error + func (m *MockReadWriter) MallocLen() int + func (m *MockReadWriter) Next(n int) ([]byte, error) + func (m *MockReadWriter) Peek(n int) ([]byte, error) + func (m *MockReadWriter) ReadBinary(n int) ([]byte, error) + func (m *MockReadWriter) ReadByte() (byte, error) + func (m *MockReadWriter) ReadString(n int) (string, error) + func (m *MockReadWriter) Release() error + func (m *MockReadWriter) Skip(n int) error + func (m *MockReadWriter) Slice(n int) (netpoll.Reader, error) + func (m *MockReadWriter) Until(delim byte) ([]byte, error) + func (m *MockReadWriter) WriteBinary(b []byte) (int, error) + func (m *MockReadWriter) WriteByte(b byte) error + func (m *MockReadWriter) WriteDirect(p []byte, remainCap int) error + func (m *MockReadWriter) WriteString(s string) (int, error) + type MockReadWriterMockRecorder struct + func (mr *MockReadWriterMockRecorder) Append(w interface{}) *gomock.Call + func (mr *MockReadWriterMockRecorder) Flush() *gomock.Call + func (mr *MockReadWriterMockRecorder) Len() *gomock.Call + func (mr *MockReadWriterMockRecorder) Malloc(n interface{}) *gomock.Call + func (mr *MockReadWriterMockRecorder) MallocAck(n interface{}) *gomock.Call + func (mr *MockReadWriterMockRecorder) MallocLen() *gomock.Call + func (mr *MockReadWriterMockRecorder) Next(n interface{}) *gomock.Call + func (mr *MockReadWriterMockRecorder) Peek(n interface{}) *gomock.Call + func (mr *MockReadWriterMockRecorder) ReadBinary(n interface{}) *gomock.Call + func (mr *MockReadWriterMockRecorder) ReadByte() *gomock.Call + func (mr *MockReadWriterMockRecorder) ReadString(n interface{}) *gomock.Call + func (mr *MockReadWriterMockRecorder) Release() *gomock.Call + func (mr *MockReadWriterMockRecorder) Skip(n interface{}) *gomock.Call + func (mr *MockReadWriterMockRecorder) Slice(n interface{}) *gomock.Call + func (mr *MockReadWriterMockRecorder) Until(delim interface{}) *gomock.Call + func (mr *MockReadWriterMockRecorder) WriteBinary(b interface{}) *gomock.Call + func (mr *MockReadWriterMockRecorder) WriteByte(b interface{}) *gomock.Call + func (mr *MockReadWriterMockRecorder) WriteDirect(p, remainCap interface{}) *gomock.Call + func (mr *MockReadWriterMockRecorder) WriteString(s interface{}) *gomock.Call + type MockReader struct + func NewMockReader(ctrl *gomock.Controller) *MockReader + func (m *MockReader) EXPECT() *MockReaderMockRecorder + func (m *MockReader) Len() int + func (m *MockReader) Next(n int) ([]byte, error) + func (m *MockReader) Peek(n int) ([]byte, error) + func (m *MockReader) ReadBinary(n int) ([]byte, error) + func (m *MockReader) ReadByte() (byte, error) + func (m *MockReader) ReadString(n int) (string, error) + func (m *MockReader) Release() error + func (m *MockReader) Skip(n int) error + func (m *MockReader) Slice(n int) (netpoll.Reader, error) + func (m *MockReader) Until(delim byte) ([]byte, error) + type MockReaderMockRecorder struct + func (mr *MockReaderMockRecorder) Len() *gomock.Call + func (mr *MockReaderMockRecorder) Next(n interface{}) *gomock.Call + func (mr *MockReaderMockRecorder) Peek(n interface{}) *gomock.Call + func (mr *MockReaderMockRecorder) ReadBinary(n interface{}) *gomock.Call + func (mr *MockReaderMockRecorder) ReadByte() *gomock.Call + func (mr *MockReaderMockRecorder) ReadString(n interface{}) *gomock.Call + func (mr *MockReaderMockRecorder) Release() *gomock.Call + func (mr *MockReaderMockRecorder) Skip(n interface{}) *gomock.Call + func (mr *MockReaderMockRecorder) Slice(n interface{}) *gomock.Call + func (mr *MockReaderMockRecorder) Until(delim interface{}) *gomock.Call + type MockWriter struct + func NewMockWriter(ctrl *gomock.Controller) *MockWriter + func (m *MockWriter) Append(w netpoll.Writer) error + func (m *MockWriter) EXPECT() *MockWriterMockRecorder + func (m *MockWriter) Flush() error + func (m *MockWriter) Malloc(n int) ([]byte, error) + func (m *MockWriter) MallocAck(n int) error + func (m *MockWriter) MallocLen() int + func (m *MockWriter) WriteBinary(b []byte) (int, error) + func (m *MockWriter) WriteByte(b byte) error + func (m *MockWriter) WriteDirect(p []byte, remainCap int) error + func (m *MockWriter) WriteString(s string) (int, error) + type MockWriterMockRecorder struct + func (mr *MockWriterMockRecorder) Append(w interface{}) *gomock.Call + func (mr *MockWriterMockRecorder) Flush() *gomock.Call + func (mr *MockWriterMockRecorder) Malloc(n interface{}) *gomock.Call + func (mr *MockWriterMockRecorder) MallocAck(n interface{}) *gomock.Call + func (mr *MockWriterMockRecorder) MallocLen() *gomock.Call + func (mr *MockWriterMockRecorder) WriteBinary(b interface{}) *gomock.Call + func (mr *MockWriterMockRecorder) WriteByte(b interface{}) *gomock.Call + func (mr *MockWriterMockRecorder) WriteDirect(p, remainCap interface{}) *gomock.Call + func (mr *MockWriterMockRecorder) WriteString(s interface{}) *gomock.Call