Method createFrontendClient

pkg/ruler/frontend_client_pool.go:53–68

(addr string)

}

func (f *frontendPool) createFrontendClient(addr string) (client.PoolClient, error) {
	opts, err := f.grpcConfig.DialOption(grpcclient.Instrument(f.frontendClientRequestDuration))
	if err != nil {
		return nil, err
	}

	conn, err := grpc.NewClient(addr, opts...)
	if err != nil {
		return nil, err
	}

	return &frontendClient{
		FrontendClient: NewFrontendClient(httpgrpc.NewHTTPClient(conn), f.timeout, f.prometheusHTTPPrefix, f.queryResponseFormat),
		HealthClient:   grpc_health_v1.NewHealthClient(conn),
	}, nil
}

type frontendClient struct {
	*FrontendClient