( client workflowservice.WorkflowServiceClient, timeout time.Duration, longPollTimeout time.Duration, )
| 203 | } |
| 204 | |
| 205 | func (cf *rpcClientFactory) newFrontendClient( |
| 206 | client workflowservice.WorkflowServiceClient, |
| 207 | timeout time.Duration, |
| 208 | longPollTimeout time.Duration, |
| 209 | ) workflowservice.WorkflowServiceClient { |
| 210 | client = frontend.NewClient(timeout, longPollTimeout, client) |
| 211 | if cf.metricsHandler != nil { |
| 212 | client = frontend.NewMetricClient(client, cf.metricsHandler, cf.throttledLogger) |
| 213 | } |
| 214 | return client |
| 215 | } |
| 216 | |
| 217 | func newServiceKeyResolver(resolver membership.ServiceResolver) *serviceKeyResolverImpl { |
| 218 | return &serviceKeyResolverImpl{ |
no test coverage detected