(ctx context.Context, filter *models.RouteFilter)
| 452 | } |
| 453 | |
| 454 | func (ds *PostgresDatastore) GetRoutes(ctx context.Context, filter *models.RouteFilter) ([]*models.Route, error) { |
| 455 | res := []*models.Route{} |
| 456 | filterQuery, args := buildFilterRouteQuery(filter) |
| 457 | rows, err := ds.db.Query(fmt.Sprintf("%s %s", routeSelector, filterQuery), args...) |
| 458 | // todo: check for no rows so we don't respond with a sql 500 err |
| 459 | if err != nil { |
| 460 | return nil, err |
| 461 | } |
| 462 | defer rows.Close() |
| 463 | |
| 464 | for rows.Next() { |
| 465 | var route models.Route |
| 466 | err := scanRoute(rows, &route) |
| 467 | if err != nil { |
| 468 | continue |
| 469 | } |
| 470 | res = append(res, &route) |
| 471 | |
| 472 | } |
| 473 | if err := rows.Err(); err != nil { |
| 474 | return nil, err |
| 475 | } |
| 476 | return res, nil |
| 477 | } |
| 478 | |
| 479 | func (ds *PostgresDatastore) GetRoutesByApp(ctx context.Context, appName string, filter *models.RouteFilter) ([]*models.Route, error) { |
| 480 | res := []*models.Route{} |
nothing calls this directly
no test coverage detected