overflow_cloud/probe
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ing

Browse Source
This commit is contained in:
crusader 2018-07-02 17:08:37 +09:00
parent 1455ae5cee
commit d5cb6e03c8
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
client/client.go
View File

@ -2,13 +2,14 @@ package client
import ( import (
crc "git.loafle.net/commons/rpc-go/client" crc "git.loafle.net/commons/rpc-go/client"
crcodec "git.loafle.net/commons/rpc-go/codec"
crpj "git.loafle.net/commons/rpc-go/protocol/json" crpj "git.loafle.net/commons/rpc-go/protocol/json"
crr "git.loafle.net/commons/rpc-go/registry" crr "git.loafle.net/commons/rpc-go/registry"
cssc "git.loafle.net/commons/server-go/socket/client" cssc "git.loafle.net/commons/server-go/socket/client"
) )
func New(name string, connector cssc.Connector, services []interface{}) *crc.Client { func New(name string, connector cssc.Connector, services []interface{}) *crc.Client {
codec := crpj.NewCustomClientCodec(crc.NewCompressionCodecSelector(connector.GetCompressionThreshold())) codec := crpj.NewCustomClientCodec(crcodec.NewCompressionCodecSelector(connector.GetCompressionThreshold()))
var rpcRegistry crr.RPCRegistry var rpcRegistry crr.RPCRegistry
if nil != services && 0 < len(services) { if nil != services && 0 < len(services) {