proxy

Documentation

Index

• type CallMap
• type ProxyCall
  • func (pc *ProxyCall) DecRetryTime()
  • func (pc *ProxyCall) DoRet(body []byte)
  • func (pc ProxyCall) GetErrorCode() uint32
  • func (pc *ProxyCall) GetRetryTime() int32
  • func (pc *ProxyCall) GetTimeOut() uint32
  • func (pc *ProxyCall) GlobalIndex() protocol.GlobalIndexType
  • func (pc *ProxyCall) SetErrorCode(errCode uint32)
  • func (pc *ProxyCall) SetGlobalIndex(index protocol.GlobalIndexType)
• type ProxyCallManager
  • func NewCallManager() *ProxyCallManager
  • func (pcm *ProxyCallManager) Add(pc *ProxyCall) error
  • func (pcm *ProxyCallManager) CreateProxyCall(proxyId ProxyUuid, timeOut uint32, retryTime int32, ...) *ProxyCall
  • func (pcm *ProxyCallManager) Destroy(callId uint32)
  • func (pcm *ProxyCallManager) GenCallID() uint32
  • func (pcm *ProxyCallManager) Get(callId uint32) *ProxyCall
• type ProxyUuid

Types

type CallMap

type CallMap map[uint32]*ProxyCall

type ProxyCall

type ProxyCall struct {
	CallID  uint32      //proxy call uuid, do not modify
	ProxyId ProxyUuid   //proxy instance id
	ReqData []byte      //serizaled data of rpc request
	Ch      chan []byte //response notify channel

	MethodId uint32 // method id 提供给日志使用
	// contains filtered or unexported fields
}

ProxyCall rpc-proxy call information of remote call description

func (*ProxyCall) DecRetryTime

func (pc *ProxyCall) DecRetryTime()

DecRetryTime decrease retry time, read & write in worker goroutine

func (*ProxyCall) DoRet

func (pc *ProxyCall) DoRet(body []byte)

func (ProxyCall) GetErrorCode

func (pc ProxyCall) GetErrorCode() uint32

func (*ProxyCall) GetRetryTime

func (pc *ProxyCall) GetRetryTime() int32

GetRetryTime get left retry time

func (*ProxyCall) GetTimeOut

func (pc *ProxyCall) GetTimeOut() uint32

GetTimeOut timeout millisecond

func (*ProxyCall) GlobalIndex

func (pc *ProxyCall) GlobalIndex() protocol.GlobalIndexType

func (*ProxyCall) SetErrorCode

func (pc *ProxyCall) SetErrorCode(errCode uint32)

func (*ProxyCall) SetGlobalIndex

func (pc *ProxyCall) SetGlobalIndex(index protocol.GlobalIndexType)

type ProxyCallManager

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

ProxyCallManager manager proxy call for multi goroutine

func NewCallManager

func NewCallManager() *ProxyCallManager

func (*ProxyCallManager) Add

func (pcm *ProxyCallManager) Add(pc *ProxyCall) error

func (*ProxyCallManager) CreateProxyCall

func (pcm *ProxyCallManager) CreateProxyCall(proxyId ProxyUuid, timeOut uint32, retryTime int32, globalIndex protocol.GlobalIndexType) *ProxyCall

func (*ProxyCallManager) Destroy

func (pcm *ProxyCallManager) Destroy(callId uint32)

func (*ProxyCallManager) GenCallID

func (pcm *ProxyCallManager) GenCallID() uint32

func (*ProxyCallManager) Get

func (pcm *ProxyCallManager) Get(callId uint32) *ProxyCall

type ProxyUuid

type ProxyUuid uint32