netpollmux

Documentation

Index

• Variables
• func NewCliTransHandlerFactory() remote.ClientTransHandlerFactory
• func NewSvrTransHandlerFactory() remote.ServerTransHandlerFactory
• type ControlFrame
  • func NewControlFrame() *ControlFrame
  • func (p *ControlFrame) BLength() int
  • func (p *ControlFrame) FastRead(b []byte) (off int, err error)
  • func (p *ControlFrame) FastWrite(b []byte) int
  • func (p *ControlFrame) FastWriteNocopy(b []byte, w thrift.NocopyWriter) int
• type EventHandler
• type MuxPool
  • func NewMuxConnPool(size int) *MuxPool
  • func (mp *MuxPool) Clean(network, address string)
  • func (mp *MuxPool) Close() error
  • func (mp *MuxPool) Discard(conn net.Conn) error
  • func (mp *MuxPool) Get(ctx context.Context, network, address string, opt remote.ConnOption) (net.Conn, error)
  • func (mp *MuxPool) Put(conn net.Conn) error

Variables

var ErrConnClosed = errors.New("conn closed")

ErrConnClosed .

Functions

func NewCliTransHandlerFactory

func NewCliTransHandlerFactory() remote.ClientTransHandlerFactory

NewCliTransHandlerFactory creates a new netpollmux client transport handler factory.

func NewSvrTransHandlerFactory

func NewSvrTransHandlerFactory() remote.ServerTransHandlerFactory

NewSvrTransHandlerFactory creates a default netpollmux remote.ServerTransHandlerFactory.

Types

type ControlFrame

type ControlFrame struct{}

func NewControlFrame

func NewControlFrame() *ControlFrame

func (*ControlFrame) BLength

func (p *ControlFrame) BLength() int

func (*ControlFrame) FastRead

func (p *ControlFrame) FastRead(b []byte) (off int, err error)

func (*ControlFrame) FastWrite

func (p *ControlFrame) FastWrite(b []byte) int

func (*ControlFrame) FastWriteNocopy

func (p *ControlFrame) FastWriteNocopy(b []byte, w thrift.NocopyWriter) int

type EventHandler

type EventHandler interface {
	Recv(bufReader remote.ByteBuffer, err error) error
}

EventHandler is used to handle events

type MuxPool

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

MuxPool manages a pool of long connections.

func NewMuxConnPool

func NewMuxConnPool(size int) *MuxPool

NewMuxConnPool size must be adjust to 2^N

func (*MuxPool) Clean

func (mp *MuxPool) Clean(network, address string)

Clean implements the LongConnPool interface.

func (*MuxPool) Close

func (mp *MuxPool) Close() error

Close is to release resource of ConnPool, it is executed when client is closed.

func (*MuxPool) Discard

func (mp *MuxPool) Discard(conn net.Conn) error

Discard implements the ConnPool interface.

func (*MuxPool) Get

func (mp *MuxPool) Get(ctx context.Context, network, address string, opt remote.ConnOption) (net.Conn, error)

Get pick or generate a net.Conn and return

func (*MuxPool) Put

func (mp *MuxPool) Put(conn net.Conn) error

Put implements the ConnPool interface.