conn

Documentation

Index

• type Connection
  • func WrapConnection(conn net.Conn, pool Pool, toRemoteCh chan []byte, fromRemoteCh chan []byte, ...) Connection
• type ConnectionImpl
  • func (a *ConnectionImpl) Close() error
  • func (a *ConnectionImpl) Conn() net.Conn
  • func (a *ConnectionImpl) ReceiveClosed() bool
  • func (a *ConnectionImpl) SendClosed() bool
• type Dialer
• type SkipFilter

Types

type Connection

type Connection interface {
	io.Closer
	Conn() net.Conn
	SendClosed() bool
	ReceiveClosed() bool
}

func WrapConnection

func WrapConnection(conn net.Conn, pool Pool, toRemoteCh chan []byte, fromRemoteCh chan []byte, errCh chan error, skip SkipFilter) Connection

type ConnectionImpl

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

func (*ConnectionImpl) Close

func (a *ConnectionImpl) Close() error

func (*ConnectionImpl) Conn

func (a *ConnectionImpl) Conn() net.Conn

func (*ConnectionImpl) ReceiveClosed

func (a *ConnectionImpl) ReceiveClosed() bool

func (*ConnectionImpl) SendClosed

func (a *ConnectionImpl) SendClosed() bool

type Dialer

type Dialer func(network string, addr string) (net.Conn, error)

type SkipFilter

type SkipFilter func(proto.Header) bool

if returned type is `true`, then network message will be skipped.