Documentation
¶
Index ¶
- Constants
- type ConnectionMgr
- type DubboConnection
- type DubboServer
- func (d *DubboServer) AcceptLoop(l *net.TCPListener)
- func (d *DubboServer) Init() error
- func (d *DubboServer) Register(schema interface{}, options ...server.RegisterOption) (string, error)
- func (d *DubboServer) Start() error
- func (d *DubboServer) Stop() error
- func (d *DubboServer) String() string
- func (d *DubboServer) Svc(arg interface{}) interface{}
- type ProcessTask
- type RecvTask
- type SndTask
Constants ¶
const (
NAME = "dubbo"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectionMgr ¶
type ConnectionMgr struct {
// contains filtered or unexported fields
}
ConnectionMgr -------连接管理
func NewConnectMgr ¶
func NewConnectMgr() *ConnectionMgr
NewConnectMgr is a function which new connection manager and returns it
func (*ConnectionMgr) DeactiveAllConn ¶
func (this *ConnectionMgr) DeactiveAllConn()
DeactiveAllConn is a function to close all connection
func (*ConnectionMgr) GetConnection ¶
func (this *ConnectionMgr) GetConnection(conn *net.TCPConn) *DubboConnection
GetConnection is a method to get connection
type DubboConnection ¶
type DubboConnection struct {
// contains filtered or unexported fields
}
DubboConnection is a struct which has attributes for dubbo connection
func NewDubboConnetction ¶
func NewDubboConnetction(conn *net.TCPConn, routineMgr *util.RoutineManager) *DubboConnection
NewDubboConnetction is a function to create new dubbo connection
func (*DubboConnection) Close ¶
func (this *DubboConnection) Close()
Close is a function to close a connection
func (*DubboConnection) HandleMsg ¶
func (this *DubboConnection) HandleMsg(req *dubbo.Request)
HandleMsg is a method
func (*DubboConnection) MsgRecvLoop ¶
func (this *DubboConnection) MsgRecvLoop()
MsgRecvLoop is a method receive data
func (*DubboConnection) MsgSndLoop ¶
func (this *DubboConnection) MsgSndLoop()
MsgSndLoop is a method to send data
func (*DubboConnection) Open ¶
func (this *DubboConnection) Open()
Open is a function to open a connection
func (*DubboConnection) ProcessBody ¶
func (this *DubboConnection) ProcessBody(req *dubbo.Request, bufBody []byte)
ProcessBody is a method to process the body of response
type DubboServer ¶
type DubboServer struct {
// contains filtered or unexported fields
}
DubboServer is a struct
func (*DubboServer) AcceptLoop ¶
func (d *DubboServer) AcceptLoop(l *net.TCPListener)
AcceptLoop is a method
func (*DubboServer) Init ¶
func (d *DubboServer) Init() error
Init is a method to initialize the server
func (*DubboServer) Register ¶
func (d *DubboServer) Register(schema interface{}, options ...server.RegisterOption) (string, error)
Register is a method to register the schema to the server
func (*DubboServer) Stop ¶
func (d *DubboServer) Stop() error
Stop is a method to disconnect all connection
func (*DubboServer) String ¶
func (d *DubboServer) String() string
type ProcessTask ¶
type ProcessTask struct {
// contains filtered or unexported fields
}
ProcessTask is a struct
Source Files