dubboclient

Documentation

Index

• type ClientMgr
  • func NewClientMgr() *ClientMgr
  • func (this *ClientMgr) GetClient(addr string) (*DubboClient, error)
• type DubboClient
  • func NewDubboClient(addr string, routeMgr *util.RoutineManager) *DubboClient
  • func (this *DubboClient) AddWaitMsg(msgID int64, result *RespondResult)
  • func (this *DubboClient) Close()
  • func (this *DubboClient) Closed() bool
  • func (this *DubboClient) GetAddr() string
  • func (this *DubboClient) Open() error
  • func (this *DubboClient) ReOpen() error
  • func (this *DubboClient) RemoveWaitMsg(msgID int64)
  • func (this *DubboClient) RspCallBack(rsp *dubbo.DubboRsp)
  • func (this *DubboClient) Send(dubboReq *dubbo.Request) (*dubbo.DubboRsp, error)
  • func (this *DubboClient) Svc(agr interface{}) interface{}
• type DubboClientConnection
  • func NewDubboClientConnetction(conn *net.TCPConn, client *DubboClient, routineMgr *util.RoutineManager) *DubboClientConnection
  • func (this *DubboClientConnection) Close()
  • func (this *DubboClientConnection) Closed() bool
  • func (this *DubboClientConnection) HandleMsg(rsp *dubbo.DubboRsp)
  • func (this *DubboClientConnection) MsgRecvLoop()
  • func (this *DubboClientConnection) MsgSndLoop()
  • func (this *DubboClientConnection) Open()
  • func (this *DubboClientConnection) ProcessBody(rsp *dubbo.DubboRsp, bufBody []byte)
  • func (this *DubboClientConnection) SendMsg(req *dubbo.Request)
• type ProcessTask
  • func (this ProcessTask) Svc(arg interface{}) interface{}
• type RecvTask
  • func (this RecvTask) Svc(arg interface{}) interface{}
• type RespondResult
• type SndTask
  • func (this SndTask) Svc(arg interface{}) interface{}
• type WrapResponse

Types

type ClientMgr

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

ClientMgr is a struct which has attributes for managing client

var CachedClients *ClientMgr

CachedClients is a variable which stores

func NewClientMgr

func NewClientMgr() *ClientMgr

NewClientMgr is a function which creates new clientmanager and returns it

func (*ClientMgr) GetClient

func (this *ClientMgr) GetClient(addr string) (*DubboClient, error)

GetClient is a function which returns the particular client for that address

type DubboClient

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

DubboClient is a struct which has attributes for dubboClient

func NewDubboClient

func NewDubboClient(addr string, routeMgr *util.RoutineManager) *DubboClient

NewDubboClient is a function which creates new dubbo client for given value

func (*DubboClient) AddWaitMsg

func (this *DubboClient) AddWaitMsg(msgID int64, result *RespondResult)

AddWaitMsg is a method which adds wait message in the response

func (*DubboClient) Close

func (this *DubboClient) Close()

Close is a method which closes a connection

func (*DubboClient) Closed

func (this *DubboClient) Closed() bool

Closed is a method which checks whether connection has been closed or not

func (*DubboClient) GetAddr

func (this *DubboClient) GetAddr() string

GetAddr is a method which returns address of particular client

func (*DubboClient) Open

func (this *DubboClient) Open() error

Open is a method which opens a connection

func (*DubboClient) ReOpen

func (this *DubboClient) ReOpen() error

ReOpen is a method which reopens connection

func (*DubboClient) RemoveWaitMsg

func (this *DubboClient) RemoveWaitMsg(msgID int64)

RemoveWaitMsg is a method which delete waiting message

func (*DubboClient) RspCallBack

func (this *DubboClient) RspCallBack(rsp *dubbo.DubboRsp)

RspCallBack is a method

func (*DubboClient) Send

func (this *DubboClient) Send(dubboReq *dubbo.Request) (*dubbo.DubboRsp, error)

Send is a method which send request from dubbo client

func (*DubboClient) Svc

func (this *DubboClient) Svc(agr interface{}) interface{}

Svc is a method

type DubboClientConnection

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

DubboClientConnection is a struct which has attributes for dubbo protocol connection

func NewDubboClientConnetction

func NewDubboClientConnetction(conn *net.TCPConn, client *DubboClient, routineMgr *util.RoutineManager) *DubboClientConnection

NewDubboClientConnetction is a function which create new dubbo client connection

func (*DubboClientConnection) Close

func (this *DubboClientConnection) Close()

Close is a method which closes connection

func (*DubboClientConnection) Closed

func (this *DubboClientConnection) Closed() bool

Closed is a method which checks connnection is closed or not

func (*DubboClientConnection) HandleMsg

func (this *DubboClientConnection) HandleMsg(rsp *dubbo.DubboRsp)

HandleMsg is a method which returns message from dubbo response

func (*DubboClientConnection) MsgRecvLoop

func (this *DubboClientConnection) MsgRecvLoop()

MsgRecvLoop is a method which receives message

func (*DubboClientConnection) MsgSndLoop

func (this *DubboClientConnection) MsgSndLoop()

MsgSndLoop is a method which send data

func (*DubboClientConnection) Open

func (this *DubboClientConnection) Open()

Open is a method which open connection

func (*DubboClientConnection) ProcessBody

func (this *DubboClientConnection) ProcessBody(rsp *dubbo.DubboRsp, bufBody []byte)

ProcessBody is a method which process body data

func (*DubboClientConnection) SendMsg

func (this *DubboClientConnection) SendMsg(req *dubbo.Request)

SendMsg is a method which send a request

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 RespondResult

type RespondResult struct {
	Rsp  *dubbo.DubboRsp
	Wait *chan int
}

RespondResult is a struct which has attribute for dubbo response

type SndTask

type SndTask struct{}

SndTask is a struct

func (SndTask) Svc

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

Svc is a method

type WrapResponse

type WrapResponse struct {
	Resp *dubbo.DubboRsp
}

WrapResponse is a struct