server

Documentation

Index

• Constants
• type ConnectionMgr
  • func NewConnectMgr() *ConnectionMgr
  • func (this *ConnectionMgr) DeactiveAllConn()
  • func (this *ConnectionMgr) GetConnection(conn *net.TCPConn) *DubboConnection
• type DubboConnection
  • func NewDubboConnetction(conn *net.TCPConn, routineMgr *util.RoutineManager) *DubboConnection
  • func (this *DubboConnection) Close()
  • func (this *DubboConnection) HandleMsg(req *dubbo.Request)
  • func (this *DubboConnection) MsgRecvLoop()
  • func (this *DubboConnection) MsgSndLoop()
  • func (this *DubboConnection) Open()
  • func (this *DubboConnection) ProcessBody(req *dubbo.Request, bufBody []byte)
• 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
  • func (this ProcessTask) Svc(arg interface{}) interface{}
• type RecvTask
  • func (this RecvTask) Svc(arg interface{}) interface{}
• type SndTask
  • func (this SndTask) Svc(arg interface{}) interface{}

Constants

const (
	NAME = "dubbo"
)

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) Start

func (d *DubboServer) Start() error

Start is a method to start 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

func (*DubboServer) Svc

func (d *DubboServer) Svc(arg interface{}) interface{}

Svc is a method

type ProcessTask

type ProcessTask struct {
	// contains filtered or unexported fields
}

ProcessTask is a struct

func (ProcessTask) Svc

func (this ProcessTask) Svc(arg interface{}) interface{}

Svc is a method

type RecvTask

type RecvTask struct {
}

RecvTask is a struct

func (RecvTask) Svc

func (this RecvTask) Svc(arg interface{}) interface{}

Svc is a method

type SndTask

type SndTask struct{}

SndTask is a struct

func (SndTask) Svc

func (this SndTask) Svc(arg interface{}) interface{}

Svc is a method