socket

Documentation

Index

• type Client
• type Server
• type Socket
  • func NewSocket(conn net.Conn, server Server, client Client) *Socket
  • func (p *Socket) Client() Client
  • func (p *Socket) Close() error
  • func (p *Socket) LocalAddr() net.Addr
  • func (p *Socket) Read() (io.Reader, error)
  • func (p *Socket) RemoteAddr() net.Addr
  • func (p *Socket) Server() Server
• type TcpClient
  • func NewTcpClient(addr string) (*TcpClient, error)
  • func (t *TcpClient) Close() error
  • func (t *TcpClient) Connect() (*Socket, error)
• type TcpServer
  • func NewTcpServer(addr string) (*TcpServer, error)
  • func (p *TcpServer) Accept() (*Socket, error)
  • func (p *TcpServer) Close() error

Types

type Client

type Client interface {
	Connect() (*Socket, error)
	Close() error
}

type Server

type Server interface {
	Accept() (*Socket, error)
	Close() error
}

type Socket

type Socket struct {
	*bufio.Reader
	*bufio.Writer
	// contains filtered or unexported fields
}

func NewSocket

func NewSocket(conn net.Conn, server Server, client Client) *Socket

func (*Socket) Client

func (p *Socket) Client() Client

func (*Socket) Close

func (p *Socket) Close() error

func (*Socket) LocalAddr

func (p *Socket) LocalAddr() net.Addr

func (*Socket) Read

func (p *Socket) Read() (io.Reader, error)

func (*Socket) RemoteAddr

func (p *Socket) RemoteAddr() net.Addr

func (*Socket) Server

func (p *Socket) Server() Server

type TcpClient

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

func NewTcpClient

func NewTcpClient(addr string) (*TcpClient, error)

func (*TcpClient) Close

func (t *TcpClient) Close() error

func (*TcpClient) Connect

func (t *TcpClient) Connect() (*Socket, error)

type TcpServer

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

func NewTcpServer

func NewTcpServer(addr string) (*TcpServer, error)

func (*TcpServer) Accept

func (p *TcpServer) Accept() (*Socket, error)

func (*TcpServer) Close

func (p *TcpServer) Close() error