utils

Documentation

Index

• Variables
• func NewFakeConnPair(localAddr, remoteAddr net.Addr) (*FakeConn, *FakeConn)
• func StrEQ(s1, s2 string) bool
• func Transport(rw1, rw2 io.ReadWriter) error
• type FakeConn
  • func NewFakeConn(localAddr, remoteAddr net.Addr) *FakeConn
  • func (f *FakeConn) Close() error
  • func (f *FakeConn) LocalAddr() net.Addr
  • func (f *FakeConn) Read(b []byte) (int, error)
  • func (f *FakeConn) RemoteAddr() net.Addr
  • func (f *FakeConn) SetDeadline(t time.Time) error
  • func (f *FakeConn) SetReadDeadline(t time.Time) error
  • func (f *FakeConn) SetWriteDeadline(t time.Time) error
  • func (f *FakeConn) Write(b []byte) (int, error)

Variables

var (
	SPool = sync.Pool{
		New: func() interface{} {
			return make([]byte, 576)
		},
	} // small buff pool
	LPool = sync.Pool{
		New: func() interface{} {
			return make([]byte, 64*1024+262)
		},
	} // large buff pool for udp
)

buffer pools

Functions

func NewFakeConnPair

func NewFakeConnPair(localAddr, remoteAddr net.Addr) (*FakeConn, *FakeConn)

NewFakeConnPair returns a FakeConn pair

func StrEQ

func StrEQ(s1, s2 string) bool

StrEQ returns whether s1 and s2 are equal

func Transport

func Transport(rw1, rw2 io.ReadWriter) error

Transport rw1 and rw2

Types

type FakeConn

type FakeConn struct {
	In  *bytes.Buffer
	Out *bytes.Buffer
	// contains filtered or unexported fields
}

FakeConn implements interface Conn

func NewFakeConn

func NewFakeConn(localAddr, remoteAddr net.Addr) *FakeConn

NewFakeConn returns a FakeConn instance

func (*FakeConn) Close

func (f *FakeConn) Close() error

func (*FakeConn) LocalAddr

func (f *FakeConn) LocalAddr() net.Addr

func (*FakeConn) Read

func (f *FakeConn) Read(b []byte) (int, error)

func (*FakeConn) RemoteAddr

func (f *FakeConn) RemoteAddr() net.Addr

func (*FakeConn) SetDeadline

func (f *FakeConn) SetDeadline(t time.Time) error

func (*FakeConn) SetReadDeadline

func (f *FakeConn) SetReadDeadline(t time.Time) error

func (*FakeConn) SetWriteDeadline

func (f *FakeConn) SetWriteDeadline(t time.Time) error

func (*FakeConn) Write

func (f *FakeConn) Write(b []byte) (int, error)