dubboclient

package

v0.0.0-...-4d3f714 Latest Latest Go to latest Published: Jul 20, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/libbylg/mesher

Links

Open Source Insights

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
type DubboClientConnection
- func NewDubboClientConnetction(conn *net.TCPConn, client *DubboClient, routineMgr *util.RoutineManager) *DubboClientConnection
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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
chassis

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL