(address string)
| 279 | } |
| 280 | |
| 281 | func (w *querierWorker) connect(address string) (*grpc.ClientConn, error) { |
| 282 | // Because we only use single long-running method, it doesn't make sense to inject user ID, send over tracing or add metrics. |
| 283 | opts, err := w.cfg.GRPCClientConfig.DialOption(nil, nil) |
| 284 | if err != nil { |
| 285 | return nil, err |
| 286 | } |
| 287 | |
| 288 | conn, err := grpc.NewClient(address, opts...) |
| 289 | if err != nil { |
| 290 | return nil, err |
| 291 | } |
| 292 | return conn, nil |
| 293 | } |
no test coverage detected