README
¶
gascnet�ο�gnet��evioʵ�֣�ֻ��epoll��kqueue���˼ķ�װ���ṩ��tcp���ӿɶ���д�¼��ļ�����
gascnet��gnet��evio�IJ�ͬ�����ڻص��д�����eventloopʵ����id�ţ��Ա��������л����ܹ�������������
����˵����
����Dial��������ij����ַ��
����NewEngine���ڴ����¼�engine��
����WithLoops��������engine��eventloop������ÿһ��eventloop��һ��epoll��kqueue��ʵ����������ֵ����0����eventloop��������cpu����С��0��eventloop��������cpu����ȥ��ֵ������0����ʵ�ʵ�eventloop����һ����
����WithLoops��������engine��ÿһ��eventloop�Ƿ���ռһ���̡߳�
����WithProtoAddr��������service��ip�Ͷ˿�,service���Բ����ø�ֵ��
����WithListenbacklog��������service listeen��backlog���ȡ�
����WithReusePort��WithReuseAddr����service�ĵ�ַ�Ͷ˿��Ƿ���ռ��
����WithLoadBalance����service��accept���µ����Ӻ��ĸ��ؾ������ԡ�
engine�Ľӿ���
LoopNum���� ���ڻ�ȡ��ǰengine��evloop������
AddTask���ڴ���һ����ָ��loopid��ִ�к��������ص���������һ��ר�ŵ�Э���е��á�
AddService���ڴ���service���ص���������һ��ר�ŵ�Э���е��á�
StartService��������service��������serviceʹ��WithProtoAddr�����˵�ַ����ʱ���õ�ַ���ص���������һ��ר�ŵ�Э���е��á�
StopServiceֹͣservice��������service�����˵�ַ����close���ص���������һ��ר�ŵ�Э���е��á�
DelService�Ƴ���service���ص���������һ��ר�ŵ�Э���е��á�
AddToService�����������ӵ�ָ��loop�ϵ�ָ��service�ϣ���Ҫ���ڹ����������������ӡ�
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFuncQueue ¶
func NewFuncQueue(initlen, maxlen int) *funcqueue
Types ¶
type Conn ¶
type Conn interface {
SetCtx(ctx interface{})
GetCtx() (ctx interface{})
//当前连接运行的 loopid
GetLoopid() int
//从loop上移除
Detach() error
LocalAddr() string
RemoteAddr() string
//socket读写缓存大小
SetReadBuffer(bytes int) error
SetWriteBuffer(bytes int) error
//socket opt
SetLinger(sec int) error
SetKeepAlivePeriod(sec, probes int) error
SetNoDelay(nodelay bool) error
Close() error
Watch(canread, canwrite bool) error
Read(buf []byte) (int, error)
Write(buf []byte) (int, error)
}
type Engine ¶
type Engine interface {
LoopNum() int
AddTask(loopid int, call func(loopid int)) error
AddService(svrid int, call func(svrid int, err error), evhandle EvHandler, opts ...SvrOption) error
StartService(svrid int, call func(svrid int, err error)) error
StopService(svrid int, call func(svrid int, err error)) error
DelService(svrid int, call func(svrid int, err error)) error
//not thread safe
AddToService(loopid, svrid int, conn Conn) error
}
type LoadBalance ¶
type LoadBalance int
const ( LoadBalanceRR LoadBalance = iota //轮询 LoadBalanceLC //最少连接 LoadBalanceSAH //源地址哈希 )
type SvrOption ¶
type SvrOption func(*svroption)
func WithListenbacklog ¶
func WithLoadBalance ¶
func WithLoadBalance(value LoadBalance) SvrOption
Source Files
Directories