netpollmux

Documentation

Index

• Variables
• func NewCliTransHandlerFactory() remote.ClientTransHandlerFactory
• func NewSvrTransHandlerFactory() remote.ServerTransHandlerFactory
• type ControlFrame
  • func NewControlFrame() *ControlFrame
  • func (p *ControlFrame) Read(iprot thrift.TProtocol) (err error)
  • func (p *ControlFrame) String() string
  • func (p *ControlFrame) Write(oprot thrift.TProtocol) (err error)
• 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) Read

func (p *ControlFrame) Read(iprot thrift.TProtocol) (err error)

func (*ControlFrame) String

func (p *ControlFrame) String() string

func (*ControlFrame) Write

func (p *ControlFrame) Write(oprot thrift.TProtocol) (err error)

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.