Documentation ¶
Index ¶
- func DecodeInterfaceByJson(data interface{}, result_pointer interface{}) error
- func DispatchRequests(peer *cascade.Peer, message []byte, callbacks map[string]ReqCallback)
- func DispatchResponse(msg *cascade.HubByteMessage, callbacks map[string]RspCallback)
- func HttpRequest(client *http.Client, reqType string, data string, url string, ...) ([]byte, error)
- func HttpResponse(w http.ResponseWriter, msg string, errId int64, errMsg string, ...)
- func ReadPostBody(r *http.Request, obj interface{}) error
- func ResponseClient(peer *cascade.Peer, rsp *common.MessageRspCommon)
- func ResponseError(peer *cascade.Peer, errId int64, errMsg string, data interface{})
- type OrderCacheManager
- func (this *OrderCacheManager) AddCache(order *common.MessageOrder) error
- func (this *OrderCacheManager) CleanExpire(expireSecond int64)
- func (this *OrderCacheManager) GetOrder(outsideOid string) (*common.MessageOrder, error)
- func (this *OrderCacheManager) UpdateOrderStatus(outsideOrderId string, status int) error
- type PeerMsgLinker
- func (this *PeerMsgLinker) AddPeer(peer *cascade.Peer) error
- func (this *PeerMsgLinker) CacheMsg(peer *cascade.Peer, msg string) error
- func (this *PeerMsgLinker) CleanExpire(expireSecond int64)
- func (this *PeerMsgLinker) DelPeer(peer *cascade.Peer) error
- func (this *PeerMsgLinker) GetMsgPeer(msg string) (*cascade.Peer, error)
- func (this *PeerMsgLinker) OutputMsgPeer()
- type ReqCallback
- type RspCallback
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DecodeInterfaceByJson ¶
func DecodeInterfaceByJson(data interface{}, result_pointer interface{}) error
/////////////// utils functions /////////////////
func DispatchRequests ¶
func DispatchRequests(peer *cascade.Peer, message []byte, callbacks map[string]ReqCallback)
func DispatchResponse ¶
func DispatchResponse(msg *cascade.HubByteMessage, callbacks map[string]RspCallback)
func HttpRequest ¶
func HttpResponse ¶
func HttpResponse(w http.ResponseWriter, msg string, errId int64, errMsg string, data interface{})
func ReadPostBody ¶
func ResponseClient ¶
func ResponseClient(peer *cascade.Peer, rsp *common.MessageRspCommon)
Types ¶
type OrderCacheManager ¶
type OrderCacheManager struct {
OutsideOidMap map[string]*orderCache
}
func NewOrderCacheManager ¶
func NewOrderCacheManager() *OrderCacheManager
func (*OrderCacheManager) AddCache ¶
func (this *OrderCacheManager) AddCache(order *common.MessageOrder) error
func (*OrderCacheManager) CleanExpire ¶
func (this *OrderCacheManager) CleanExpire(expireSecond int64)
func (*OrderCacheManager) GetOrder ¶
func (this *OrderCacheManager) GetOrder(outsideOid string) (*common.MessageOrder, error)
func (*OrderCacheManager) UpdateOrderStatus ¶
func (this *OrderCacheManager) UpdateOrderStatus(outsideOrderId string, status int) error
type PeerMsgLinker ¶
type PeerMsgLinker struct {
// contains filtered or unexported fields
}
func NewPeerMsgLinker ¶
func NewPeerMsgLinker() *PeerMsgLinker
func (*PeerMsgLinker) CacheMsg ¶
func (this *PeerMsgLinker) CacheMsg(peer *cascade.Peer, msg string) error
func (*PeerMsgLinker) CleanExpire ¶
func (this *PeerMsgLinker) CleanExpire(expireSecond int64)
func (*PeerMsgLinker) GetMsgPeer ¶
func (this *PeerMsgLinker) GetMsgPeer(msg string) (*cascade.Peer, error)
func (*PeerMsgLinker) OutputMsgPeer ¶
func (this *PeerMsgLinker) OutputMsgPeer()
type ReqCallback ¶
type ReqCallback func(*cascade.Peer, *common.MessageReqCommon) (*common.MessageRspCommon, error)
/////////////// handle requests /////////////////
type RspCallback ¶
type RspCallback func(*common.MessageRspCommon, *cascade.HubByteMessage)
Click to show internal directories.
Click to hide internal directories.