Method Open

internal/pgx/poolcache/poolcache.go:23–46

(ctx context.Context, uri string)

}

func (c *Cache) Open(ctx context.Context, uri string) (*pgxpool.Pool, error) {
	if c.closed {
		return nil, fmt.Errorf("poolcache is closed")
	}

	c.lock.RLock()
	existing, found := c.pools[uri]
	c.lock.RUnlock()

	if found {
		return existing, nil
	}

	pool, err := pgxpool.New(ctx, uri)
	if err != nil {
		return nil, err
	}

	c.lock.Lock()
	c.pools[uri] = pool
	c.lock.Unlock()

	return pool, nil
}

func (c *Cache) Close() error {
	c.lock.Lock()