conn

Documentation

Index

• Constants
• type Connection
  • func WrapConnection(ctx context.Context, conn net.Conn, toRemoteCh 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 SkipFilter

Constants

const (
	MaxConnIdleIODuration = 5 * time.Minute
)

Types

type Connection

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

func WrapConnection

func WrapConnection(ctx context.Context, conn net.Conn, toRemoteCh chan []byte, fromRemoteCh chan *bytebufferpool.ByteBuffer, 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 SkipFilter

type SkipFilter func(proto.Header) bool

SkipFilter indicates that the network message should be skipped.