server

Documentation

Index

• func ConnStateListener(c net.Conn, cs http.ConnState)
• type HttpListener
  • func (l *HttpListener) Accept() (net.Conn, error)
  • func (l *HttpListener) Addr() net.Addr
  • func (l *HttpListener) Close() error
• type MultiProtoHttpCodec
  • func NewMultiProtoHttpCodec(conn *TcpConnWrapper) *MultiProtoHttpCodec
  • func (m *MultiProtoHttpCodec) Close() error
  • func (m *MultiProtoHttpCodec) Receive() (interface{}, error)
  • func (m *MultiProtoHttpCodec) Send(msg interface{}) error
• type MultiProtoInsance
  • func (this *MultiProtoInsance) Destroy()
  • func (this *MultiProtoInsance) Initialize() error
  • func (this *MultiProtoInsance) RunLoop()
• type MultiProtoProxy
  • func NewMultiProtoProxy() *MultiProtoProxy
  • func (m *MultiProtoProxy) NewCodec(rw io.ReadWriter) (net2.Codec, error)
• type MultiProtoProxyCodec
  • func (c *MultiProtoProxyCodec) Close() error
  • func (c *MultiProtoProxyCodec) Receive() (interface{}, error)
  • func (c *MultiProtoProxyCodec) Send(msg interface{}) error
• type MultiProtoServer
  • func NewMultiProtoServer(listener net.Listener, protoName string) *MultiProtoServer
  • func (s *MultiProtoServer) OnConnectionClosed(conn *net2.TcpConnection)
  • func (s *MultiProtoServer) OnConnectionDataArrived(conn *net2.TcpConnection, msg interface{}) error
  • func (s *MultiProtoServer) OnNewConnection(conn *net2.TcpConnection)
  • func (s *MultiProtoServer) Serve()
• type TcpConnWrapper
  • func NewTcpConnWrapper(base net.Conn) (conn *TcpConnWrapper)
  • func (c *TcpConnWrapper) Close() error
  • func (c *TcpConnWrapper) LocalAddr() net.Addr
  • func (c *TcpConnWrapper) Peek(n int) ([]byte, error)
  • func (c *TcpConnWrapper) Read(b []byte) (n int, err error)
  • func (c *TcpConnWrapper) RemoteAddr() net.Addr
  • func (c *TcpConnWrapper) SetDeadline(t time.Time) error
  • func (c *TcpConnWrapper) SetReadDeadline(t time.Time) error
  • func (c *TcpConnWrapper) SetWriteDeadline(t time.Time) error
  • func (c *TcpConnWrapper) WrapBaseForTest(wrap func(net.Conn) net.Conn)
  • func (c *TcpConnWrapper) Write(b []byte) (n int, err error)

Functions

func ConnStateListener

func ConnStateListener(c net.Conn, cs http.ConnState)

ConnStateListener bound to server and maintains a list of connections by pointer

Types

type HttpListener

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

func (*HttpListener) Accept

func (l *HttpListener) Accept() (net.Conn, error)

func (*HttpListener) Addr

func (l *HttpListener) Addr() net.Addr

func (*HttpListener) Close

func (l *HttpListener) Close() error

type MultiProtoHttpCodec

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

func NewMultiProtoHttpCodec

func NewMultiProtoHttpCodec(conn *TcpConnWrapper) *MultiProtoHttpCodec

func (*MultiProtoHttpCodec) Close

func (m *MultiProtoHttpCodec) Close() error

func (*MultiProtoHttpCodec) Receive

func (m *MultiProtoHttpCodec) Receive() (interface{}, error)

func (*MultiProtoHttpCodec) Send

func (m *MultiProtoHttpCodec) Send(msg interface{}) error

type MultiProtoInsance

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

func (*MultiProtoInsance) Destroy

func (this *MultiProtoInsance) Destroy()

func (*MultiProtoInsance) Initialize

func (this *MultiProtoInsance) Initialize() error

func (*MultiProtoInsance) RunLoop

func (this *MultiProtoInsance) RunLoop()

type MultiProtoProxy

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

func NewMultiProtoProxy

func NewMultiProtoProxy() *MultiProtoProxy

func (*MultiProtoProxy) NewCodec

func (m *MultiProtoProxy) NewCodec(rw io.ReadWriter) (net2.Codec, error)

type MultiProtoProxyCodec

type MultiProtoProxyCodec struct {
	State int
	// contains filtered or unexported fields
}

func (*MultiProtoProxyCodec) Close

func (c *MultiProtoProxyCodec) Close() error

func (*MultiProtoProxyCodec) Receive

func (c *MultiProtoProxyCodec) Receive() (interface{}, error)

func (*MultiProtoProxyCodec) Send

func (c *MultiProtoProxyCodec) Send(msg interface{}) error

type MultiProtoServer

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

func NewMultiProtoServer

func NewMultiProtoServer(listener net.Listener, protoName string) *MultiProtoServer

func (*MultiProtoServer) OnConnectionClosed

func (s *MultiProtoServer) OnConnectionClosed(conn *net2.TcpConnection)

func (*MultiProtoServer) OnConnectionDataArrived

func (s *MultiProtoServer) OnConnectionDataArrived(conn *net2.TcpConnection, msg interface{}) error

func (*MultiProtoServer) OnNewConnection

func (s *MultiProtoServer) OnNewConnection(conn *net2.TcpConnection)

func (*MultiProtoServer) Serve

func (s *MultiProtoServer) Serve()

type TcpConnWrapper

type TcpConnWrapper struct {
	RecvChan chan interface{}
	SendChan chan interface{}
	// contains filtered or unexported fields
}

func NewTcpConnWrapper

func NewTcpConnWrapper(base net.Conn) (conn *TcpConnWrapper)

func (*TcpConnWrapper) Close

func (c *TcpConnWrapper) Close() error

func (*TcpConnWrapper) LocalAddr

func (c *TcpConnWrapper) LocalAddr() net.Addr

func (*TcpConnWrapper) Peek

func (c *TcpConnWrapper) Peek(n int) ([]byte, error)

func (*TcpConnWrapper) Read

func (c *TcpConnWrapper) Read(b []byte) (n int, err error)

func (*TcpConnWrapper) RemoteAddr

func (c *TcpConnWrapper) RemoteAddr() net.Addr

func (*TcpConnWrapper) SetDeadline

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

func (*TcpConnWrapper) SetReadDeadline

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

func (*TcpConnWrapper) SetWriteDeadline

func (c *TcpConnWrapper) SetWriteDeadline(t time.Time) error

func (*TcpConnWrapper) WrapBaseForTest

func (c *TcpConnWrapper) WrapBaseForTest(wrap func(net.Conn) net.Conn)

func (*TcpConnWrapper) Write

func (c *TcpConnWrapper) Write(b []byte) (n int, err error)