(ctx context.Context)
| 108 | var _ database.DialerConnector = &connector{} |
| 109 | |
| 110 | func (c *connector) Connect(ctx context.Context) (driver.Conn, error) { |
| 111 | nURL, err := getAuthenticatedURL(c.cfg, c.url) |
| 112 | if err != nil { |
| 113 | return nil, xerrors.Errorf("assigning authentication token to url: %w", err) |
| 114 | } |
| 115 | |
| 116 | nc, err := pq.NewConnector(nURL) |
| 117 | if err != nil { |
| 118 | return nil, xerrors.Errorf("creating new connector: %w", err) |
| 119 | } |
| 120 | |
| 121 | if c.dialer != nil { |
| 122 | nc.Dialer(c.dialer) |
| 123 | } |
| 124 | |
| 125 | return nc.Connect(ctx) |
| 126 | } |
| 127 | |
| 128 | func (*connector) Driver() driver.Driver { |
| 129 | return &pq.Driver{} |
nothing calls this directly
no test coverage detected