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

ing

Browse Source
This commit is contained in:
crusader 2018-07-03 00:18:05 +09:00
parent 9f7e224026
commit 1236a2644c
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
client/client.go
View File

@ -16,13 +16,13 @@ import (
) )
func New(portNumber int) *crc.Client { func New(portNumber int) *crc.Client {
rpcClientCodec := crpj.NewCustomClientCodec(crcodec.NewCompressionCodecSelector(connector.GetCompressionThreshold()))
connector, err := occ.NewConnector(occp.ContainerNetwork, portNumber) connector, err := occ.NewConnector(occp.ContainerNetwork, portNumber)
if nil != err { if nil != err {
logging.Logger().Panic(err) logging.Logger().Panic(err)
} }
rpcClientCodec := crpj.NewCustomClientCodec(crcodec.NewCompressionCodecSelector(connector.GetCompressionThreshold()))
ch := &ClientHandlers{} ch := &ClientHandlers{}
ch.Name = occp.ContainerNetwork.String() ch.Name = occp.ContainerNetwork.String()
ch.Connector = connector ch.Connector = connector