File tree Expand file tree Collapse file tree 2 files changed +2
-14
lines changed
Expand file tree Collapse file tree 2 files changed +2
-14
lines changed Original file line number Diff line number Diff line change @@ -15,6 +15,3 @@ vendor/
1515# Executables produced by cadence-samples repo
1616bin /
1717docker-compose.yml
18- # Credentials
19- new_samples /client_samples /helloworld_tls /credentials /
20- credentials /
Original file line number Diff line number Diff line change @@ -11,8 +11,6 @@ import (
1111 "go.uber.org/cadence/worker"
1212 "go.uber.org/cadence/workflow"
1313 "go.uber.org/yarpc"
14- "go.uber.org/yarpc/peer"
15- yarpchostport "go.uber.org/yarpc/peer/hostport"
1614 "go.uber.org/yarpc/transport/grpc"
1715 "go.uber.org/zap"
1816 "go.uber.org/zap/zapcore"
@@ -71,18 +69,11 @@ func StartWorker() {
7169
7270}
7371
74- func BuildCadenceClient (dialOptions ... grpc.DialOption ) workflowserviceclient.Interface {
75- grpcTransport := grpc .NewTransport ()
76- myChooser := peer .NewSingle (
77- yarpchostport .Identify (HostPort ),
78- grpcTransport .NewDialer (dialOptions ... ),
79- )
80- outbound := grpcTransport .NewOutbound (myChooser )
81-
72+ func BuildCadenceClient () workflowserviceclient.Interface {
8273 dispatcher := yarpc .NewDispatcher (yarpc.Config {
8374 Name : ClientName ,
8475 Outbounds : yarpc.Outbounds {
85- CadenceService : {Unary : outbound },
76+ CadenceService : {Unary : grpc . NewTransport (). NewSingleOutbound ( HostPort ) },
8677 },
8778 })
8879 if err := dispatcher .Start (); err != nil {
You can’t perform that action at this time.
0 commit comments