netpollmux

Documentation

Index

• Variables
• func NewCliTransHandlerFactory() remote.ClientTransHandlerFactory
• func NewSvrTransHandlerFactory() remote.ServerTransHandlerFactory
• type BufferGetter
• type DealBufferGetters
• 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")

var SharedSize int32 = 32

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 BufferGetter

type BufferGetter func() (buf remote.ByteBuffer, isNil bool)

BufferGetter is used to get a remote.ByteBuffer.

type DealBufferGetters

type DealBufferGetters func(gts []BufferGetter)

DealBufferGetters is used to get deal of remote.ByteBuffer.

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.