netpoll

Documentation

Index

• func GetWrittenBytes(lb *netpoll.LinkBuffer) (buf []byte, err error)
• func NewCliTransHandlerFactory() remote.ClientTransHandlerFactory
• func NewDialer() remote.Dialer
• func NewHTTPCliTransHandlerFactory() remote.ClientTransHandlerFactory
• func NewNetpollConnExtension() trans.Extension
• func NewReaderByteBuffer(r netpoll.Reader) remote.ByteBuffer
• func NewReaderWriterByteBuffer(rw netpoll.ReadWriter) remote.ByteBuffer
• func NewSvrTransHandlerFactory() remote.ServerTransHandlerFactory
• func NewTransServerFactory() remote.TransServerFactory
• func NewWriterByteBuffer(w netpoll.Writer) remote.ByteBuffer

Functions

func GetWrittenBytes

func GetWrittenBytes(lb *netpoll.LinkBuffer) (buf []byte, err error)

GetWrittenBytes gets all written bytes from linkbuffer.

func NewCliTransHandlerFactory

func NewCliTransHandlerFactory() remote.ClientTransHandlerFactory

NewCliTransHandlerFactory returns a new remote.ClientTransHandlerFactory for netpoll.

func NewDialer

func NewDialer() remote.Dialer

NewDialer returns the default netpoll dialer.

func NewHTTPCliTransHandlerFactory

func NewHTTPCliTransHandlerFactory() remote.ClientTransHandlerFactory

NewHTTPCliTransHandlerFactory creates a netpoll http client transport handler factory.

func NewNetpollConnExtension

func NewNetpollConnExtension() trans.Extension

NewNetpollConnExtension to build new netpollConnExtension which implements trans.Extension

func NewReaderByteBuffer

func NewReaderByteBuffer(r netpoll.Reader) remote.ByteBuffer

NewReaderByteBuffer creates a new remote.ByteBuffer using the given netpoll.ZeroCopyReader.

func NewReaderWriterByteBuffer

func NewReaderWriterByteBuffer(rw netpoll.ReadWriter) remote.ByteBuffer

NewReaderWriterByteBuffer creates a new remote.ByteBuffer using the given netpoll.ZeroCopyReadWriter.

func NewSvrTransHandlerFactory

func NewSvrTransHandlerFactory() remote.ServerTransHandlerFactory

NewSvrTransHandlerFactory creates a default netpoll server transport handler factory.

func NewTransServerFactory

func NewTransServerFactory() remote.TransServerFactory

NewTransServerFactory creates a default netpoll transport server factory.

func NewWriterByteBuffer

func NewWriterByteBuffer(w netpoll.Writer) remote.ByteBuffer

NewWriterByteBuffer creates a new remote.ByteBuffer using the given netpoll.ZeroCopyWriter.