conn

Documentation

Index

• type Conn
  • func ConnectServer(host string, port int64) (c *Conn, err error)
  • func NewConn(conn net.Conn) (c *Conn)
  • func (c *Conn) CheckClosed() bool
  • func (c *Conn) Close()
  • func (c *Conn) GetLocalAddr() (addr string)
  • func (c *Conn) GetRemoteAddr() (addr string)
  • func (c *Conn) IsClosed() (closeFlag bool)
  • func (c *Conn) Read(p []byte) (n int, err error)
  • func (c *Conn) ReadLine() (buff string, err error)
  • func (c *Conn) SetDeadline(t time.Time) error
  • func (c *Conn) SetReadDeadline(t time.Time) error
  • func (c *Conn) SetTcpConn(tcpConn net.Conn)
  • func (c *Conn) Write(content string) (err error)
  • func (c *Conn) WriteBytes(content []byte) (n int, err error)
• type Listener
  • func Listen(bindAddr string, bindPort int64) (l *Listener, err error)
  • func (l *Listener) Accept() (*Conn, error)
  • func (l *Listener) Close() error

Types

type Conn

type Conn struct {
	TcpConn net.Conn
	Reader  *bufio.Reader
	// contains filtered or unexported fields
}

wrap for TCPConn

func ConnectServer

func ConnectServer(host string, port int64) (c *Conn, err error)

func NewConn

func NewConn(conn net.Conn) (c *Conn)

func (*Conn) CheckClosed

func (c *Conn) CheckClosed() bool

when you call this function, you should make sure that remote client won't send any bytes to this socket

func (*Conn) Close

func (c *Conn) Close()

func (*Conn) GetLocalAddr

func (c *Conn) GetLocalAddr() (addr string)

func (*Conn) GetRemoteAddr

func (c *Conn) GetRemoteAddr() (addr string)

func (*Conn) IsClosed

func (c *Conn) IsClosed() (closeFlag bool)

func (*Conn) Read

func (c *Conn) Read(p []byte) (n int, err error)

func (*Conn) ReadLine

func (c *Conn) ReadLine() (buff string, err error)

func (*Conn) SetDeadline

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

func (*Conn) SetReadDeadline

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

func (*Conn) SetTcpConn

func (c *Conn) SetTcpConn(tcpConn net.Conn)

if the tcpConn is different with c.TcpConn you should call c.Close() first

func (*Conn) Write

func (c *Conn) Write(content string) (err error)

func (*Conn) WriteBytes

func (c *Conn) WriteBytes(content []byte) (n int, err error)

type Listener

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

func Listen

func Listen(bindAddr string, bindPort int64) (l *Listener, err error)

func (*Listener) Accept

func (l *Listener) Accept() (*Conn, error)

wait util get one new connection or listener is closed if listener is closed, err returned

func (*Listener) Close

func (l *Listener) Close() error