tcp

Jun 17, 2022

Changes in this version

+ var ErrStopSend = errors.New("stop send message")

+ var ErrWriteNotAll = errors.New("write not all")

+ var ErrWriteTimeout = errors.New("write timeout")

+ func NewClient(handler zeronetwork.HandlerFunc, opts ...ClientOption) zeronetwork.Client

+ func NewServer() zeronetwork.Peer

+ type ClientOption func(*client)

+ func WithClientCompress(compress zerocompress.Compress) ClientOption

+ func WithClientCompressThreshold(compressThreshold int) ClientOption

+ func WithClientDatapack(datapack zeronetwork.Datapack) ClientOption

+ func WithClientLogger(logger zerologger.Logger) ClientOption

+ func WithClientLoggerLevel(loggerLevel int) ClientOption

+ func WithClientOnConnClose(onConnClose zeronetwork.ConnFunc) ClientOption

+ func WithClientOnConnected(onConnected zeronetwork.ConnFunc) ClientOption

+ func WithClientRecvDeadLine(recvDeadLine time.Duration) ClientOption

+ func WithClientRecvQueueSize(recvQueueSize int) ClientOption

+ func WithClientSendBufferSize(sendBufferSize int) ClientOption

+ func WithClientSendDeadLine(sendDeadLine time.Duration) ClientOption

+ func WithClientSendQueueSize(sendQueueSize int) ClientOption

+ func WithClientWhetherCompress(whetherCompress bool) ClientOption

+ func WithClientWhetherCrypto(whetherCrypto bool) ClientOption