Skip to content

Commit

Permalink
Fixed comment
Browse files Browse the repository at this point in the history
  • Loading branch information
jakobht committed Jan 16, 2025
1 parent 380904e commit 172ba0f
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions client/clientfactory.go
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ type (
NewMatchingClient(domainIDToName DomainIDToNameFunc, shardDistributorClient sharddistributor.Client) (matching.Client, error)

NewHistoryClientWithTimeout(timeout time.Duration) (history.Client, history.PeerResolver, error)
NewMatchingClientWithTimeout(domainIDToName DomainIDToNameFunc, timeout time.Duration, longPollTimeout time.Duration, shardDistributorClient sharddistributor.Client) (matching.Client, error)
NewMatchingClientWithTimeout(domainIDToName DomainIDToNameFunc, shardDistributorClient sharddistributor.Client, timeout time.Duration, longPollTimeout time.Duration) (matching.Client, error)

NewAdminClientWithTimeoutAndConfig(config transport.ClientConfig, timeout time.Duration, largeTimeout time.Duration) (admin.Client, error)
NewFrontendClientWithTimeoutAndConfig(config transport.ClientConfig, timeout time.Duration, longPollTimeout time.Duration) (frontend.Client, error)
Expand Down Expand Up @@ -109,7 +109,7 @@ func (cf *rpcClientFactory) NewHistoryClient() (history.Client, history.PeerReso
}

func (cf *rpcClientFactory) NewMatchingClient(domainIDToName DomainIDToNameFunc, shardDistributorClient sharddistributor.Client) (matching.Client, error) {
return cf.NewMatchingClientWithTimeout(domainIDToName, timeoutwrapper.MatchingDefaultTimeout, timeoutwrapper.MatchingDefaultLongPollTimeout, shardDistributorClient)
return cf.NewMatchingClientWithTimeout(domainIDToName, shardDistributorClient, timeoutwrapper.MatchingDefaultTimeout, timeoutwrapper.MatchingDefaultLongPollTimeout)
}

func (cf *rpcClientFactory) NewHistoryClientWithTimeout(timeout time.Duration) (history.Client, history.PeerResolver, error) {
Expand Down Expand Up @@ -145,9 +145,9 @@ func (cf *rpcClientFactory) NewHistoryClientWithTimeout(timeout time.Duration) (

func (cf *rpcClientFactory) NewMatchingClientWithTimeout(
domainIDToName DomainIDToNameFunc,
shardDistributorClient sharddistributor.Client,
timeout time.Duration,
longPollTimeout time.Duration,
shardDistributorClient sharddistributor.Client,
) (matching.Client, error) {
var rawClient matching.Client
var namedPort = membership.PortTchannel
Expand Down

0 comments on commit 172ba0f

Please sign in to comment.