|
60 | 60 | NewMatchingClient(domainIDToName DomainIDToNameFunc, shardDistributorClient sharddistributor.Client) (matching.Client, error)
|
61 | 61 |
|
62 | 62 | NewHistoryClientWithTimeout(timeout time.Duration) (history.Client, history.PeerResolver, error)
|
63 |
| - NewMatchingClientWithTimeout(domainIDToName DomainIDToNameFunc, timeout time.Duration, longPollTimeout time.Duration, shardDistributorClient sharddistributor.Client) (matching.Client, error) |
| 63 | + NewMatchingClientWithTimeout(domainIDToName DomainIDToNameFunc, shardDistributorClient sharddistributor.Client, timeout time.Duration, longPollTimeout time.Duration) (matching.Client, error) |
64 | 64 |
|
65 | 65 | NewAdminClientWithTimeoutAndConfig(config transport.ClientConfig, timeout time.Duration, largeTimeout time.Duration) (admin.Client, error)
|
66 | 66 | NewFrontendClientWithTimeoutAndConfig(config transport.ClientConfig, timeout time.Duration, longPollTimeout time.Duration) (frontend.Client, error)
|
@@ -109,7 +109,7 @@ func (cf *rpcClientFactory) NewHistoryClient() (history.Client, history.PeerReso
|
109 | 109 | }
|
110 | 110 |
|
111 | 111 | func (cf *rpcClientFactory) NewMatchingClient(domainIDToName DomainIDToNameFunc, shardDistributorClient sharddistributor.Client) (matching.Client, error) {
|
112 |
| - return cf.NewMatchingClientWithTimeout(domainIDToName, timeoutwrapper.MatchingDefaultTimeout, timeoutwrapper.MatchingDefaultLongPollTimeout, shardDistributorClient) |
| 112 | + return cf.NewMatchingClientWithTimeout(domainIDToName, shardDistributorClient, timeoutwrapper.MatchingDefaultTimeout, timeoutwrapper.MatchingDefaultLongPollTimeout) |
113 | 113 | }
|
114 | 114 |
|
115 | 115 | func (cf *rpcClientFactory) NewHistoryClientWithTimeout(timeout time.Duration) (history.Client, history.PeerResolver, error) {
|
@@ -145,9 +145,9 @@ func (cf *rpcClientFactory) NewHistoryClientWithTimeout(timeout time.Duration) (
|
145 | 145 |
|
146 | 146 | func (cf *rpcClientFactory) NewMatchingClientWithTimeout(
|
147 | 147 | domainIDToName DomainIDToNameFunc,
|
| 148 | + shardDistributorClient sharddistributor.Client, |
148 | 149 | timeout time.Duration,
|
149 | 150 | longPollTimeout time.Duration,
|
150 |
| - shardDistributorClient sharddistributor.Client, |
151 | 151 | ) (matching.Client, error) {
|
152 | 152 | var rawClient matching.Client
|
153 | 153 | var namedPort = membership.PortTchannel
|
|
0 commit comments