unistack-org/micro
4
0
Fork 3
Code Issues 19 Pull Requests 1 Actions Packages Projects Releases 258 Wiki Activity

use mucp server

Browse Source
This commit is contained in:
Asim Aslam 2020-01-18 20:48:08 +00:00
parent 0a37767127
commit 105596a0e5
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
network/default.go
View File

@ -13,6 +13,7 @@ import (
"github.com/golang/protobuf/proto" "github.com/golang/protobuf/proto"
"github.com/micro/go-micro/client" "github.com/micro/go-micro/client"
cmucp "github.com/micro/go-micro/client/mucp"
rtr "github.com/micro/go-micro/client/selector/router" rtr "github.com/micro/go-micro/client/selector/router"
"github.com/micro/go-micro/network/resolver/dns" "github.com/micro/go-micro/network/resolver/dns"
pbNet "github.com/micro/go-micro/network/service/proto" pbNet "github.com/micro/go-micro/network/service/proto"
@ -20,6 +21,7 @@ import (
"github.com/micro/go-micro/router" "github.com/micro/go-micro/router"
pbRtr "github.com/micro/go-micro/router/service/proto" pbRtr "github.com/micro/go-micro/router/service/proto"
"github.com/micro/go-micro/server" "github.com/micro/go-micro/server"
smucp "github.com/micro/go-micro/server/mucp"
"github.com/micro/go-micro/transport" "github.com/micro/go-micro/transport"
"github.com/micro/go-micro/tunnel" "github.com/micro/go-micro/tunnel"
bun "github.com/micro/go-micro/tunnel/broker" bun "github.com/micro/go-micro/tunnel/broker"
@ -138,7 +140,7 @@ func newNetwork(opts ...Option) Network {
) )
// server is network server // server is network server
server := server.NewServer( server := smucp.NewServer(
server.Id(options.Id), server.Id(options.Id),
server.Address(peerAddress), server.Address(peerAddress),
server.Advertise(advertise), server.Advertise(advertise),
@ -148,7 +150,7 @@ func newNetwork(opts ...Option) Network {
) )
// client is network client // client is network client
client := client.NewClient( client := cmucp.NewClient(
client.Broker(tunBroker), client.Broker(tunBroker),
client.Transport(tunTransport), client.Transport(tunTransport),
client.Selector( client.Selector(