2017-12-05 05:20:42 +00:00
|
|
|
package client
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
|
crc "git.loafle.net/commons_go/rpc/client"
|
|
|
|
|
"git.loafle.net/commons_go/rpc/protocol/json"
|
|
|
|
|
crr "git.loafle.net/commons_go/rpc/registry"
|
|
|
|
|
)
|
|
|
|
|
|
2017-12-15 07:47:39 +00:00
|
|
|
func newClientHandler(rpcInvoker crr.RPCInvoker) ClientHandler {
|
2017-12-05 05:20:42 +00:00
|
|
|
ch := &ClientHandlers{}
|
|
|
|
|
ch.RPCInvoker = rpcInvoker
|
|
|
|
|
ch.Codec = json.NewClientCodec()
|
|
|
|
|
|
|
|
|
|
return ch
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
type ClientHandlers struct {
|
|
|
|
|
crc.ClientHandlers
|
|
|
|
|
}
|
2017-12-17 08:58:52 +00:00
|
|
|
|
|
|
|
|
func (ch *ClientHandlers) Init(clientCTX crc.ClientContext) error {
|
|
|
|
|
|
|
|
|
|
return ch.ClientHandlers.Init(clientCTX)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (ch *ClientHandlers) Destroy(clientCTX crc.ClientContext) {
|
|
|
|
|
ch.ClientHandlers.Destroy(clientCTX)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (ch *ClientHandlers) Validate() {
|
|
|
|
|
ch.ClientHandlers.Validate()
|
|
|
|
|
}
|
