Skip to content

Commit

Permalink
Add logging to matching / history client (#2340)
Browse files Browse the repository at this point in the history
* Add logging to matching client
* Add logging to history client
  • Loading branch information
wxing1292 committed Jan 21, 2022
1 parent 71c6979 commit fc9390e
Show file tree
Hide file tree
Showing 4 changed files with 301 additions and 453 deletions.
5 changes: 3 additions & 2 deletions client/clientfactory.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@ import (
"time"

"go.temporal.io/api/workflowservice/v1"

"go.temporal.io/server/api/adminservice/v1"
"go.temporal.io/server/api/historyservice/v1"
"go.temporal.io/server/api/matchingservice/v1"
Expand Down Expand Up @@ -147,7 +148,7 @@ func (cf *rpcClientFactory) NewHistoryClientWithTimeout(timeout time.Duration) (
clientCache := common.NewClientCache(keyResolver, clientProvider)
client := history.NewClient(cf.numberOfHistoryShards, timeout, clientCache, cf.logger)
if cf.metricsClient != nil {
client = history.NewMetricClient(client, cf.metricsClient)
client = history.NewMetricClient(client, cf.metricsClient, cf.logger)
}
return client, nil
}
Expand Down Expand Up @@ -175,7 +176,7 @@ func (cf *rpcClientFactory) NewMatchingClientWithTimeout(
)

if cf.metricsClient != nil {
client = matching.NewMetricClient(client, cf.metricsClient)
client = matching.NewMetricClient(client, cf.metricsClient, cf.logger)
}
return client, nil

Expand Down
Loading

0 comments on commit fc9390e

Please sign in to comment.