Documentation ¶
Index ¶
- type Agency
- type Alert
- type AlertActivePeriod
- type AlertAgency
- type AlertRoute
- type AlertRouteType
- type AlertStop
- type AlertTrip
- type DBTX
- type DeleteScheduledServicesParams
- type DeleteServiceMapParams
- type DeleteShapesParams
- type DeleteStaleAgenciesParams
- type DeleteStaleAlertsParams
- type DeleteStaleRoutesParams
- type DeleteStaleStopsParams
- type DeleteStaleTripsParams
- type DeleteVehiclesParams
- type EstimateHeadwaysForRoutesParams
- type EstimateHeadwaysForRoutesRow
- type Feed
- type GetAgencyParams
- type GetAlertInSystemParams
- type GetDestinationsForTripsRow
- type GetFeedParams
- type GetRouteParams
- type GetScheduledServiceParams
- type GetScheduledTripParams
- type GetShapeParams
- type GetStopParams
- type GetTripParams
- type GetTripRow
- type GetVehicleParams
- type GetVehicleRow
- type InsertAgencyParams
- type InsertAlertActivePeriodParams
- type InsertAlertAgencyParams
- type InsertAlertParams
- type InsertAlertRouteParams
- type InsertAlertRouteTypeParams
- type InsertAlertStopParams
- type InsertAlertTripParams
- type InsertFeedParams
- type InsertRouteParams
- type InsertScheduledServiceAdditionParams
- type InsertScheduledServiceParams
- type InsertScheduledServiceRemovalParams
- type InsertScheduledTripFrequencyParams
- type InsertScheduledTripParams
- type InsertScheduledTripStopTimeParams
- type InsertServiceMapConfigParams
- type InsertServiceMapParams
- type InsertServiceMapStopParams
- type InsertShapeParams
- type InsertStopHeadSignRuleParams
- type InsertStopParams
- type InsertSystemParams
- type InsertTransferParams
- type InsertTripParams
- type InsertTripStopTimeParams
- type InsertVehicleParams
- type ListActiveAlertsForAgenciesParams
- type ListActiveAlertsForAgenciesRow
- type ListActiveAlertsForRoutesParams
- type ListActiveAlertsForRoutesRow
- type ListActiveAlertsForStopsParams
- type ListActiveAlertsForStopsRow
- type ListActivePeriodsForAlertsRow
- type ListAlertPksAndHashesParams
- type ListAlertPksAndHashesRow
- type ListAlertsInSystemAndByIDsParams
- type ListAlertsWithActivePeriodsAndAllInformedEntitiesRow
- type ListRoutesByPkRow
- type ListRoutesInAgencyRow
- type ListScheduledServicesRow
- type ListScheduledTripFrequenciesRow
- type ListScheduledTripStopTimesRow
- type ListScheduledTripsRow
- type ListServiceMapsConfigIDsForStopsRow
- type ListServiceMapsForRoutesRow
- type ListServiceMapsForStopsRow
- type ListShapesAndTripsRow
- type ListShapesParams
- type ListStopPksForRealtimeMapRow
- type ListStopsByPkRow
- type ListStopsParams
- type ListStopsTimesForTripRow
- type ListStops_GeographicParams
- type ListTransfersInSystemRow
- type ListTripPksInSystemParams
- type ListTripPksInSystemRow
- type ListTripStopTimesByStopsRow
- type ListTripStopTimesForUpdateRow
- type ListTripsParams
- type ListTripsRow
- type ListVehiclesParams
- type ListVehiclesRow
- type ListVehicles_GeographicParams
- type ListVehicles_GeographicRow
- type MapAgencyPkToIdRow
- type MapRouteIDToPkInSystemParams
- type MapRouteIDToPkInSystemRow
- type MapScheduledTripIDToPkInSystemParams
- type MapScheduledTripIDToPkInSystemRow
- type MapScheduledTripIDToRoutePkInSystemParams
- type MapScheduledTripIDToRoutePkInSystemRow
- type MapStopIDAndPkToStationPkParams
- type MapStopIDAndPkToStationPkRow
- type MapStopIDToPkParams
- type MapStopIDToPkRow
- type MapStopPkToChildPksRow
- type MapStopPkToDescendentPksRow
- type MapTripIDToPkInSystemParams
- type MapTripIDToPkInSystemRow
- type MapTripPkToVehicleIDParams
- type MapTripPkToVehicleIDRow
- type MarkFailedUpdateParams
- type MarkSkippedUpdateParams
- type MarkSuccessfulUpdateParams
- type MarkTripStopTimesPastBatchResults
- type MarkTripStopTimesPastParams
- type Querier
- type Queries
- func (q *Queries) CountAgenciesInSystem(ctx context.Context, systemPk int64) (int64, error)
- func (q *Queries) CountFeedsInSystem(ctx context.Context, systemPk int64) (int64, error)
- func (q *Queries) CountRoutesInSystem(ctx context.Context, systemPk int64) (int64, error)
- func (q *Queries) CountStopsInSystem(ctx context.Context, systemPk int64) (int64, error)
- func (q *Queries) CountTransfersInSystem(ctx context.Context, systemPk pgtype.Int8) (int64, error)
- func (q *Queries) DeleteAlerts(ctx context.Context, alertPks []int64) error
- func (q *Queries) DeleteFeed(ctx context.Context, pk int64) error
- func (q *Queries) DeleteScheduledServices(ctx context.Context, arg DeleteScheduledServicesParams) error
- func (q *Queries) DeleteServiceMap(ctx context.Context, arg DeleteServiceMapParams) error
- func (q *Queries) DeleteServiceMapConfig(ctx context.Context, pk int64) error
- func (q *Queries) DeleteShapes(ctx context.Context, arg DeleteShapesParams) error
- func (q *Queries) DeleteStaleAgencies(ctx context.Context, arg DeleteStaleAgenciesParams) error
- func (q *Queries) DeleteStaleAlerts(ctx context.Context, arg DeleteStaleAlertsParams) error
- func (q *Queries) DeleteStaleRoutes(ctx context.Context, arg DeleteStaleRoutesParams) error
- func (q *Queries) DeleteStaleStops(ctx context.Context, arg DeleteStaleStopsParams) error
- func (q *Queries) DeleteStaleTrips(ctx context.Context, arg DeleteStaleTripsParams) ([]int64, error)
- func (q *Queries) DeleteStopHeadsignRules(ctx context.Context, feedPk int64) error
- func (q *Queries) DeleteSystem(ctx context.Context, pk int64) error
- func (q *Queries) DeleteTransfers(ctx context.Context, feedPk int64) error
- func (q *Queries) DeleteTripStopTimes(ctx context.Context, pks []int64) error
- func (q *Queries) DeleteVehicles(ctx context.Context, arg DeleteVehiclesParams) error
- func (q *Queries) EstimateHeadwaysForRoutes(ctx context.Context, arg EstimateHeadwaysForRoutesParams) ([]EstimateHeadwaysForRoutesRow, error)
- func (q *Queries) GetAgency(ctx context.Context, arg GetAgencyParams) (Agency, error)
- func (q *Queries) GetAlertInSystem(ctx context.Context, arg GetAlertInSystemParams) (Alert, error)
- func (q *Queries) GetDestinationsForTrips(ctx context.Context, tripPks []int64) ([]GetDestinationsForTripsRow, error)
- func (q *Queries) GetFeed(ctx context.Context, arg GetFeedParams) (Feed, error)
- func (q *Queries) GetRoute(ctx context.Context, arg GetRouteParams) (Route, error)
- func (q *Queries) GetScheduledService(ctx context.Context, arg GetScheduledServiceParams) (ScheduledService, error)
- func (q *Queries) GetScheduledTrip(ctx context.Context, arg GetScheduledTripParams) (ScheduledTrip, error)
- func (q *Queries) GetShape(ctx context.Context, arg GetShapeParams) (Shape, error)
- func (q *Queries) GetStop(ctx context.Context, arg GetStopParams) (Stop, error)
- func (q *Queries) GetSystem(ctx context.Context, id string) (System, error)
- func (q *Queries) GetTrip(ctx context.Context, arg GetTripParams) (GetTripRow, error)
- func (q *Queries) GetVehicle(ctx context.Context, arg GetVehicleParams) (GetVehicleRow, error)
- func (q *Queries) InsertAgency(ctx context.Context, arg InsertAgencyParams) (int64, error)
- func (q *Queries) InsertAlert(ctx context.Context, arg InsertAlertParams) (int64, error)
- func (q *Queries) InsertAlertActivePeriod(ctx context.Context, arg InsertAlertActivePeriodParams) error
- func (q *Queries) InsertAlertAgency(ctx context.Context, arg InsertAlertAgencyParams) error
- func (q *Queries) InsertAlertRoute(ctx context.Context, arg InsertAlertRouteParams) error
- func (q *Queries) InsertAlertRouteType(ctx context.Context, arg InsertAlertRouteTypeParams) error
- func (q *Queries) InsertAlertStop(ctx context.Context, arg InsertAlertStopParams) error
- func (q *Queries) InsertAlertTrip(ctx context.Context, arg InsertAlertTripParams) error
- func (q *Queries) InsertFeed(ctx context.Context, arg InsertFeedParams) error
- func (q *Queries) InsertRoute(ctx context.Context, arg InsertRouteParams) (int64, error)
- func (q *Queries) InsertScheduledService(ctx context.Context, arg InsertScheduledServiceParams) (int64, error)
- func (q *Queries) InsertScheduledServiceAddition(ctx context.Context, arg InsertScheduledServiceAdditionParams) error
- func (q *Queries) InsertScheduledServiceRemoval(ctx context.Context, arg InsertScheduledServiceRemovalParams) error
- func (q *Queries) InsertScheduledTrip(ctx context.Context, arg []InsertScheduledTripParams) (int64, error)
- func (q *Queries) InsertScheduledTripFrequency(ctx context.Context, arg InsertScheduledTripFrequencyParams) error
- func (q *Queries) InsertScheduledTripStopTime(ctx context.Context, arg []InsertScheduledTripStopTimeParams) (int64, error)
- func (q *Queries) InsertServiceMap(ctx context.Context, arg InsertServiceMapParams) (int64, error)
- func (q *Queries) InsertServiceMapConfig(ctx context.Context, arg InsertServiceMapConfigParams) error
- func (q *Queries) InsertServiceMapStop(ctx context.Context, arg []InsertServiceMapStopParams) (int64, error)
- func (q *Queries) InsertShape(ctx context.Context, arg InsertShapeParams) (int64, error)
- func (q *Queries) InsertStop(ctx context.Context, arg InsertStopParams) (int64, error)
- func (q *Queries) InsertStopHeadSignRule(ctx context.Context, arg InsertStopHeadSignRuleParams) error
- func (q *Queries) InsertSystem(ctx context.Context, arg InsertSystemParams) (int64, error)
- func (q *Queries) InsertTransfer(ctx context.Context, arg InsertTransferParams) error
- func (q *Queries) InsertTrip(ctx context.Context, arg InsertTripParams) (int64, error)
- func (q *Queries) InsertTripStopTime(ctx context.Context, arg []InsertTripStopTimeParams) (int64, error)
- func (q *Queries) InsertVehicle(ctx context.Context, arg InsertVehicleParams) error
- func (q *Queries) ListActiveAlertsForAgencies(ctx context.Context, arg ListActiveAlertsForAgenciesParams) ([]ListActiveAlertsForAgenciesRow, error)
- func (q *Queries) ListActiveAlertsForRoutes(ctx context.Context, arg ListActiveAlertsForRoutesParams) ([]ListActiveAlertsForRoutesRow, error)
- func (q *Queries) ListActiveAlertsForStops(ctx context.Context, arg ListActiveAlertsForStopsParams) ([]ListActiveAlertsForStopsRow, error)
- func (q *Queries) ListActivePeriodsForAlerts(ctx context.Context, pks []int64) ([]ListActivePeriodsForAlertsRow, error)
- func (q *Queries) ListAgencies(ctx context.Context, systemPk int64) ([]Agency, error)
- func (q *Queries) ListAgenciesByPk(ctx context.Context, pk []int64) ([]Agency, error)
- func (q *Queries) ListAlertPksAndHashes(ctx context.Context, arg ListAlertPksAndHashesParams) ([]ListAlertPksAndHashesRow, error)
- func (q *Queries) ListAlertsInSystem(ctx context.Context, systemPk int64) ([]Alert, error)
- func (q *Queries) ListAlertsInSystemAndByIDs(ctx context.Context, arg ListAlertsInSystemAndByIDsParams) ([]Alert, error)
- func (q *Queries) ListAlertsWithActivePeriodsAndAllInformedEntities(ctx context.Context, systemPk int64) ([]ListAlertsWithActivePeriodsAndAllInformedEntitiesRow, error)
- func (q *Queries) ListFeeds(ctx context.Context, systemPk int64) ([]Feed, error)
- func (q *Queries) ListRoutes(ctx context.Context, systemPk int64) ([]Route, error)
- func (q *Queries) ListRoutesByPk(ctx context.Context, routePks []int64) ([]ListRoutesByPkRow, error)
- func (q *Queries) ListRoutesInAgency(ctx context.Context, agencyPk int64) ([]ListRoutesInAgencyRow, error)
- func (q *Queries) ListScheduledServices(ctx context.Context, systemPk int64) ([]ListScheduledServicesRow, error)
- func (q *Queries) ListScheduledTripFrequencies(ctx context.Context, systemPk int64) ([]ListScheduledTripFrequenciesRow, error)
- func (q *Queries) ListScheduledTripStopTimes(ctx context.Context, systemPk int64) ([]ListScheduledTripStopTimesRow, error)
- func (q *Queries) ListScheduledTrips(ctx context.Context, systemPk int64) ([]ListScheduledTripsRow, error)
- func (q *Queries) ListServiceMapConfigsInSystem(ctx context.Context, systemPk int64) ([]ServiceMapConfig, error)
- func (q *Queries) ListServiceMapsConfigIDsForStops(ctx context.Context, stopPks []int64) ([]ListServiceMapsConfigIDsForStopsRow, error)
- func (q *Queries) ListServiceMapsForRoutes(ctx context.Context, routePks []int64) ([]ListServiceMapsForRoutesRow, error)
- func (q *Queries) ListServiceMapsForStops(ctx context.Context, stopPks []int64) ([]ListServiceMapsForStopsRow, error)
- func (q *Queries) ListShapes(ctx context.Context, arg ListShapesParams) ([]Shape, error)
- func (q *Queries) ListShapesAndTrips(ctx context.Context, systemPk int64) ([]ListShapesAndTripsRow, error)
- func (q *Queries) ListStopHeadsignRulesForStops(ctx context.Context, stopPks []int64) ([]StopHeadsignRule, error)
- func (q *Queries) ListStopPksForRealtimeMap(ctx context.Context, routePk int64) ([]ListStopPksForRealtimeMapRow, error)
- func (q *Queries) ListStops(ctx context.Context, arg ListStopsParams) ([]Stop, error)
- func (q *Queries) ListStopsByPk(ctx context.Context, stopPks []int64) ([]ListStopsByPkRow, error)
- func (q *Queries) ListStopsTimesForTrip(ctx context.Context, tripPk int64) ([]ListStopsTimesForTripRow, error)
- func (q *Queries) ListStops_Geographic(ctx context.Context, arg ListStops_GeographicParams) ([]Stop, error)
- func (q *Queries) ListSystems(ctx context.Context) ([]System, error)
- func (q *Queries) ListTransfersFromStops(ctx context.Context, fromStopPks []int64) ([]Transfer, error)
- func (q *Queries) ListTransfersInSystem(ctx context.Context, systemPk pgtype.Int8) ([]ListTransfersInSystemRow, error)
- func (q *Queries) ListTripPksInSystem(ctx context.Context, arg ListTripPksInSystemParams) ([]ListTripPksInSystemRow, error)
- func (q *Queries) ListTripStopTimesByStops(ctx context.Context, stopPks []int64) ([]ListTripStopTimesByStopsRow, error)
- func (q *Queries) ListTripStopTimesForUpdate(ctx context.Context, tripPks []int64) ([]ListTripStopTimesForUpdateRow, error)
- func (q *Queries) ListTrips(ctx context.Context, arg ListTripsParams) ([]ListTripsRow, error)
- func (q *Queries) ListVehicles(ctx context.Context, arg ListVehiclesParams) ([]ListVehiclesRow, error)
- func (q *Queries) ListVehicles_Geographic(ctx context.Context, arg ListVehicles_GeographicParams) ([]ListVehicles_GeographicRow, error)
- func (q *Queries) MapAgencyPkToId(ctx context.Context, systemPk int64) ([]MapAgencyPkToIdRow, error)
- func (q *Queries) MapRouteIDToPkInSystem(ctx context.Context, arg MapRouteIDToPkInSystemParams) ([]MapRouteIDToPkInSystemRow, error)
- func (q *Queries) MapScheduledTripIDToPkInSystem(ctx context.Context, arg MapScheduledTripIDToPkInSystemParams) ([]MapScheduledTripIDToPkInSystemRow, error)
- func (q *Queries) MapScheduledTripIDToRoutePkInSystem(ctx context.Context, arg MapScheduledTripIDToRoutePkInSystemParams) ([]MapScheduledTripIDToRoutePkInSystemRow, error)
- func (q *Queries) MapStopIDAndPkToStationPk(ctx context.Context, arg MapStopIDAndPkToStationPkParams) ([]MapStopIDAndPkToStationPkRow, error)
- func (q *Queries) MapStopIDToPk(ctx context.Context, arg MapStopIDToPkParams) ([]MapStopIDToPkRow, error)
- func (q *Queries) MapStopPkToChildPks(ctx context.Context, stopPks []int64) ([]MapStopPkToChildPksRow, error)
- func (q *Queries) MapStopPkToDescendentPks(ctx context.Context, stopPks []int64) ([]MapStopPkToDescendentPksRow, error)
- func (q *Queries) MapTripIDToPkInSystem(ctx context.Context, arg MapTripIDToPkInSystemParams) ([]MapTripIDToPkInSystemRow, error)
- func (q *Queries) MapTripPkToVehicleID(ctx context.Context, arg MapTripPkToVehicleIDParams) ([]MapTripPkToVehicleIDRow, error)
- func (q *Queries) MarkFailedUpdate(ctx context.Context, arg MarkFailedUpdateParams) error
- func (q *Queries) MarkSkippedUpdate(ctx context.Context, arg MarkSkippedUpdateParams) error
- func (q *Queries) MarkSuccessfulUpdate(ctx context.Context, arg MarkSuccessfulUpdateParams) error
- func (q *Queries) MarkTripStopTimesPast(ctx context.Context, arg []MarkTripStopTimesPastParams) *MarkTripStopTimesPastBatchResults
- func (q *Queries) UpdateAgency(ctx context.Context, arg UpdateAgencyParams) error
- func (q *Queries) UpdateFeed(ctx context.Context, arg UpdateFeedParams) error
- func (q *Queries) UpdateRoute(ctx context.Context, arg UpdateRouteParams) error
- func (q *Queries) UpdateServiceMapConfig(ctx context.Context, arg UpdateServiceMapConfigParams) error
- func (q *Queries) UpdateStop(ctx context.Context, arg UpdateStopParams) error
- func (q *Queries) UpdateStop_Parent(ctx context.Context, arg UpdateStop_ParentParams) error
- func (q *Queries) UpdateSystem(ctx context.Context, arg UpdateSystemParams) error
- func (q *Queries) UpdateSystemStatus(ctx context.Context, arg UpdateSystemStatusParams) error
- func (q *Queries) UpdateTrip(ctx context.Context, arg []UpdateTripParams) *UpdateTripBatchResults
- func (q *Queries) UpdateTripStopTime(ctx context.Context, arg UpdateTripStopTimeParams) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type Route
- type ScheduledService
- type ScheduledServiceAddition
- type ScheduledServiceRemoval
- type ScheduledTrip
- type ScheduledTripFrequency
- type ScheduledTripStopTime
- type ServiceMap
- type ServiceMapConfig
- type ServiceMapVertex
- type Shape
- type Stop
- type StopHeadsignRule
- type System
- type Transfer
- type Trip
- type TripStopTime
- type UpdateAgencyParams
- type UpdateFeedParams
- type UpdateRouteParams
- type UpdateServiceMapConfigParams
- type UpdateStopParams
- type UpdateStop_ParentParams
- type UpdateSystemParams
- type UpdateSystemStatusParams
- type UpdateTripBatchResults
- type UpdateTripParams
- type UpdateTripStopTimeParams
- type Vehicle
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AlertActivePeriod ¶
type AlertActivePeriod struct { Pk int64 AlertPk int64 StartsAt pgtype.Timestamptz EndsAt pgtype.Timestamptz }
type AlertAgency ¶
type AlertRoute ¶
type AlertRouteType ¶ added in v0.6.1
type DBTX ¶
type DBTX interface { Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error) Query(context.Context, string, ...interface{}) (pgx.Rows, error) QueryRow(context.Context, string, ...interface{}) pgx.Row CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error) SendBatch(context.Context, *pgx.Batch) pgx.BatchResults }
type DeleteScheduledServicesParams ¶ added in v0.6.1
type DeleteServiceMapParams ¶
type DeleteShapesParams ¶ added in v0.6.1
type DeleteStaleAlertsParams ¶
type DeleteStaleRoutesParams ¶
type DeleteStaleStopsParams ¶
type DeleteStaleTripsParams ¶
type DeleteVehiclesParams ¶ added in v0.6.1
type EstimateHeadwaysForRoutesParams ¶
type EstimateHeadwaysForRoutesParams struct { RoutePks []int64 PresentTime pgtype.Timestamptz }
type Feed ¶
type Feed struct { Pk int64 ID string SystemPk int64 Config string LastContentHash pgtype.Text LastUpdate pgtype.Timestamptz LastSuccessfulUpdate pgtype.Timestamptz LastSkippedUpdate pgtype.Timestamptz LastFailedUpdate pgtype.Timestamptz }
type GetAgencyParams ¶
type GetAlertInSystemParams ¶
type GetFeedParams ¶
type GetRouteParams ¶
type GetScheduledServiceParams ¶ added in v0.6.1
type GetScheduledTripParams ¶ added in v0.6.1
type GetShapeParams ¶ added in v0.6.1
type GetStopParams ¶
type GetTripParams ¶
type GetTripRow ¶
type GetVehicleParams ¶
type GetVehicleRow ¶
type GetVehicleRow struct { Pk int64 ID pgtype.Text SystemPk int64 TripPk pgtype.Int8 Label pgtype.Text LicensePlate pgtype.Text CurrentStatus pgtype.Text Bearing pgtype.Float4 Odometer pgtype.Float8 Speed pgtype.Float4 CongestionLevel string UpdatedAt pgtype.Timestamptz CurrentStopPk pgtype.Int8 CurrentStopSequence pgtype.Int4 OccupancyStatus pgtype.Text FeedPk int64 OccupancyPercentage pgtype.Int4 Location types.Geography StopID pgtype.Text StopName pgtype.Text TripID pgtype.Text TripDirectionID pgtype.Bool RouteID pgtype.Text RouteColor pgtype.Text }
type InsertAgencyParams ¶
type InsertAlertActivePeriodParams ¶
type InsertAlertActivePeriodParams struct { AlertPk int64 StartsAt pgtype.Timestamptz EndsAt pgtype.Timestamptz }
type InsertAlertAgencyParams ¶
type InsertAlertParams ¶
type InsertAlertRouteParams ¶
type InsertAlertRouteTypeParams ¶ added in v0.6.1
type InsertAlertStopParams ¶
type InsertAlertTripParams ¶ added in v0.6.1
type InsertFeedParams ¶
type InsertRouteParams ¶
type InsertScheduledServiceAdditionParams ¶ added in v0.6.1
type InsertScheduledServiceParams ¶ added in v0.6.1
type InsertScheduledServiceRemovalParams ¶ added in v0.6.1
type InsertScheduledTripFrequencyParams ¶ added in v0.6.1
type InsertScheduledTripParams ¶ added in v0.6.1
type InsertScheduledTripStopTimeParams ¶ added in v0.6.1
type InsertScheduledTripStopTimeParams struct { TripPk int64 StopPk int64 ArrivalTime pgtype.Int4 DepartureTime pgtype.Int4 StopSequence int32 ContinuousDropOff string ContinuousPickup string DropOffType string ExactTimes bool Headsign pgtype.Text PickupType string ShapeDistanceTraveled pgtype.Float8 }
type InsertServiceMapParams ¶
type InsertShapeParams ¶ added in v0.6.1
type InsertStopParams ¶
type InsertSystemParams ¶
type InsertTransferParams ¶
type InsertTripParams ¶
type InsertTripStopTimeParams ¶
type InsertTripStopTimeParams struct { StopPk int64 TripPk int64 ArrivalTime pgtype.Timestamptz ArrivalDelay pgtype.Int4 ArrivalUncertainty pgtype.Int4 DepartureTime pgtype.Timestamptz DepartureDelay pgtype.Int4 DepartureUncertainty pgtype.Int4 StopSequence int32 Track pgtype.Text Headsign pgtype.Text Past bool }
type InsertVehicleParams ¶
type InsertVehicleParams struct { ID pgtype.Text SystemPk int64 TripPk pgtype.Int8 Label pgtype.Text LicensePlate pgtype.Text CurrentStatus pgtype.Text Location types.Geography Bearing pgtype.Float4 Odometer pgtype.Float8 Speed pgtype.Float4 CongestionLevel string UpdatedAt pgtype.Timestamptz CurrentStopPk pgtype.Int8 CurrentStopSequence pgtype.Int4 OccupancyStatus pgtype.Text FeedPk int64 OccupancyPercentage pgtype.Int4 }
type ListActiveAlertsForAgenciesParams ¶
type ListActiveAlertsForAgenciesParams struct { AgencyPks []int64 PresentTime pgtype.Timestamptz }
type ListActiveAlertsForRoutesParams ¶
type ListActiveAlertsForRoutesParams struct { RoutePks []int64 PresentTime pgtype.Timestamptz }
type ListActiveAlertsForStopsParams ¶
type ListActiveAlertsForStopsParams struct { StopPks []int64 PresentTime pgtype.Timestamptz }
type ListActiveAlertsForStopsRow ¶
type ListActiveAlertsForStopsRow struct { StopPk int64 Pk int64 ID string Cause string Effect string StartsAt pgtype.Timestamptz EndsAt pgtype.Timestamptz }
type ListActivePeriodsForAlertsRow ¶
type ListActivePeriodsForAlertsRow struct { Pk int64 StartsAt pgtype.Timestamptz EndsAt pgtype.Timestamptz }
type ListAlertsWithActivePeriodsAndAllInformedEntitiesRow ¶ added in v0.6.1
type ListAlertsWithActivePeriodsAndAllInformedEntitiesRow struct { ID string Cause string Effect string Header string Description string Url string ActivePeriods []pgtype.Range[pgtype.Timestamptz] Agencies []string Routes []string Stops []string Trips []string ScheduledTrips []string RouteTypes []string }
type ListRoutesByPkRow ¶
type ListRoutesInAgencyRow ¶
type ListScheduledServicesRow ¶ added in v0.6.1
type ListScheduledServicesRow struct { Pk int64 ID string SystemPk int64 Monday pgtype.Bool Tuesday pgtype.Bool Wednesday pgtype.Bool Thursday pgtype.Bool Friday pgtype.Bool Saturday pgtype.Bool Sunday pgtype.Bool EndDate pgtype.Date StartDate pgtype.Date FeedPk int64 Additions []pgtype.Date Removals []pgtype.Date }
type ListScheduledTripFrequenciesRow ¶ added in v0.6.1
type ListScheduledTripStopTimesRow ¶ added in v0.6.1
type ListScheduledTripStopTimesRow struct { Pk int64 TripPk int64 StopPk int64 StopSequence int32 ContinuousDropOff string ContinuousPickup string DropOffType string ExactTimes bool Headsign pgtype.Text PickupType string ShapeDistanceTraveled pgtype.Float8 ArrivalTime pgtype.Int4 DepartureTime pgtype.Int4 TripID string StopID string }
type ListScheduledTripsRow ¶ added in v0.6.1
type ListShapesAndTripsRow ¶ added in v0.6.1
type ListShapesParams ¶ added in v0.6.1
type ListStopsByPkRow ¶
type ListStopsParams ¶
type ListStopsTimesForTripRow ¶
type ListStopsTimesForTripRow struct { Pk int64 StopPk int64 TripPk int64 ArrivalTime pgtype.Timestamptz ArrivalDelay pgtype.Int4 ArrivalUncertainty pgtype.Int4 DepartureTime pgtype.Timestamptz DepartureDelay pgtype.Int4 DepartureUncertainty pgtype.Int4 StopSequence int32 Track pgtype.Text Headsign pgtype.Text Past bool StopID string StopName pgtype.Text }
type ListTripPksInSystemRow ¶
type ListTripStopTimesByStopsRow ¶
type ListTripStopTimesByStopsRow struct { Pk int64 StopPk int64 TripPk int64 ArrivalTime pgtype.Timestamptz ArrivalDelay pgtype.Int4 ArrivalUncertainty pgtype.Int4 DepartureTime pgtype.Timestamptz DepartureDelay pgtype.Int4 DepartureUncertainty pgtype.Int4 StopSequence int32 Track pgtype.Text Headsign pgtype.Text Past bool Pk_2 int64 ID string RoutePk int64 DirectionID pgtype.Bool StartedAt pgtype.Timestamptz GtfsHash string FeedPk int64 VehicleID pgtype.Text VehicleLocation types.Geography VehicleBearing pgtype.Float4 VehicleUpdatedAt pgtype.Timestamptz }
type ListTripsParams ¶ added in v0.6.1
type ListTripsRow ¶
type ListVehiclesParams ¶
type ListVehiclesRow ¶
type ListVehiclesRow struct { Pk int64 ID pgtype.Text SystemPk int64 TripPk pgtype.Int8 Label pgtype.Text LicensePlate pgtype.Text CurrentStatus pgtype.Text Bearing pgtype.Float4 Odometer pgtype.Float8 Speed pgtype.Float4 CongestionLevel string UpdatedAt pgtype.Timestamptz CurrentStopPk pgtype.Int8 CurrentStopSequence pgtype.Int4 OccupancyStatus pgtype.Text FeedPk int64 OccupancyPercentage pgtype.Int4 Location types.Geography StopID pgtype.Text StopName pgtype.Text TripID pgtype.Text TripDirectionID pgtype.Bool RouteID pgtype.Text RouteColor pgtype.Text }
type ListVehicles_GeographicRow ¶
type ListVehicles_GeographicRow struct { Pk int64 ID pgtype.Text SystemPk int64 TripPk pgtype.Int8 Label pgtype.Text LicensePlate pgtype.Text CurrentStatus pgtype.Text Bearing pgtype.Float4 Odometer pgtype.Float8 Speed pgtype.Float4 CongestionLevel string UpdatedAt pgtype.Timestamptz CurrentStopPk pgtype.Int8 CurrentStopSequence pgtype.Int4 OccupancyStatus pgtype.Text FeedPk int64 OccupancyPercentage pgtype.Int4 Location types.Geography StopID pgtype.Text StopName pgtype.Text TripID pgtype.Text TripDirectionID pgtype.Bool RouteID pgtype.Text RouteColor pgtype.Text }
type MapAgencyPkToIdRow ¶
type MapScheduledTripIDToPkInSystemParams ¶ added in v0.6.1
type MapScheduledTripIDToPkInSystemRow ¶ added in v0.6.1
type MapScheduledTripIDToRoutePkInSystemParams ¶ added in v0.6.1
type MapScheduledTripIDToRoutePkInSystemRow ¶ added in v0.6.1
type MapStopIDToPkParams ¶
type MapStopIDToPkRow ¶
type MapStopPkToChildPksRow ¶
type MapTripPkToVehicleIDParams ¶ added in v0.6.1
type MapTripPkToVehicleIDRow ¶ added in v0.6.1
type MarkFailedUpdateParams ¶
type MarkFailedUpdateParams struct { UpdateTime pgtype.Timestamptz FeedPk int64 }
type MarkSkippedUpdateParams ¶
type MarkSkippedUpdateParams struct { UpdateTime pgtype.Timestamptz FeedPk int64 }
type MarkSuccessfulUpdateParams ¶
type MarkSuccessfulUpdateParams struct { ContentHash pgtype.Text UpdateTime pgtype.Timestamptz FeedPk int64 }
type MarkTripStopTimesPastBatchResults ¶
type MarkTripStopTimesPastBatchResults struct {
// contains filtered or unexported fields
}
func (*MarkTripStopTimesPastBatchResults) Close ¶
func (b *MarkTripStopTimesPastBatchResults) Close() error
func (*MarkTripStopTimesPastBatchResults) Exec ¶
func (b *MarkTripStopTimesPastBatchResults) Exec(f func(int, error))
type Querier ¶
type Querier interface { CountAgenciesInSystem(ctx context.Context, systemPk int64) (int64, error) CountFeedsInSystem(ctx context.Context, systemPk int64) (int64, error) CountRoutesInSystem(ctx context.Context, systemPk int64) (int64, error) CountStopsInSystem(ctx context.Context, systemPk int64) (int64, error) CountTransfersInSystem(ctx context.Context, systemPk pgtype.Int8) (int64, error) DeleteAlerts(ctx context.Context, alertPks []int64) error DeleteFeed(ctx context.Context, pk int64) error DeleteScheduledServices(ctx context.Context, arg DeleteScheduledServicesParams) error DeleteServiceMap(ctx context.Context, arg DeleteServiceMapParams) error DeleteServiceMapConfig(ctx context.Context, pk int64) error DeleteShapes(ctx context.Context, arg DeleteShapesParams) error DeleteStaleAgencies(ctx context.Context, arg DeleteStaleAgenciesParams) error DeleteStaleAlerts(ctx context.Context, arg DeleteStaleAlertsParams) error DeleteStaleRoutes(ctx context.Context, arg DeleteStaleRoutesParams) error DeleteStaleStops(ctx context.Context, arg DeleteStaleStopsParams) error DeleteStaleTrips(ctx context.Context, arg DeleteStaleTripsParams) ([]int64, error) DeleteStopHeadsignRules(ctx context.Context, feedPk int64) error DeleteSystem(ctx context.Context, pk int64) error DeleteTransfers(ctx context.Context, feedPk int64) error DeleteTripStopTimes(ctx context.Context, pks []int64) error DeleteVehicles(ctx context.Context, arg DeleteVehiclesParams) error EstimateHeadwaysForRoutes(ctx context.Context, arg EstimateHeadwaysForRoutesParams) ([]EstimateHeadwaysForRoutesRow, error) GetAgency(ctx context.Context, arg GetAgencyParams) (Agency, error) GetAlertInSystem(ctx context.Context, arg GetAlertInSystemParams) (Alert, error) GetDestinationsForTrips(ctx context.Context, tripPks []int64) ([]GetDestinationsForTripsRow, error) GetFeed(ctx context.Context, arg GetFeedParams) (Feed, error) GetRoute(ctx context.Context, arg GetRouteParams) (Route, error) GetScheduledService(ctx context.Context, arg GetScheduledServiceParams) (ScheduledService, error) GetScheduledTrip(ctx context.Context, arg GetScheduledTripParams) (ScheduledTrip, error) GetShape(ctx context.Context, arg GetShapeParams) (Shape, error) GetStop(ctx context.Context, arg GetStopParams) (Stop, error) GetSystem(ctx context.Context, id string) (System, error) GetTrip(ctx context.Context, arg GetTripParams) (GetTripRow, error) GetVehicle(ctx context.Context, arg GetVehicleParams) (GetVehicleRow, error) InsertAgency(ctx context.Context, arg InsertAgencyParams) (int64, error) InsertAlert(ctx context.Context, arg InsertAlertParams) (int64, error) InsertAlertActivePeriod(ctx context.Context, arg InsertAlertActivePeriodParams) error InsertAlertAgency(ctx context.Context, arg InsertAlertAgencyParams) error InsertAlertRoute(ctx context.Context, arg InsertAlertRouteParams) error InsertAlertRouteType(ctx context.Context, arg InsertAlertRouteTypeParams) error InsertAlertStop(ctx context.Context, arg InsertAlertStopParams) error InsertAlertTrip(ctx context.Context, arg InsertAlertTripParams) error InsertFeed(ctx context.Context, arg InsertFeedParams) error InsertRoute(ctx context.Context, arg InsertRouteParams) (int64, error) InsertScheduledService(ctx context.Context, arg InsertScheduledServiceParams) (int64, error) InsertScheduledServiceAddition(ctx context.Context, arg InsertScheduledServiceAdditionParams) error InsertScheduledServiceRemoval(ctx context.Context, arg InsertScheduledServiceRemovalParams) error InsertScheduledTrip(ctx context.Context, arg []InsertScheduledTripParams) (int64, error) InsertScheduledTripFrequency(ctx context.Context, arg InsertScheduledTripFrequencyParams) error InsertScheduledTripStopTime(ctx context.Context, arg []InsertScheduledTripStopTimeParams) (int64, error) InsertServiceMap(ctx context.Context, arg InsertServiceMapParams) (int64, error) InsertServiceMapConfig(ctx context.Context, arg InsertServiceMapConfigParams) error InsertServiceMapStop(ctx context.Context, arg []InsertServiceMapStopParams) (int64, error) InsertShape(ctx context.Context, arg InsertShapeParams) (int64, error) InsertStop(ctx context.Context, arg InsertStopParams) (int64, error) InsertStopHeadSignRule(ctx context.Context, arg InsertStopHeadSignRuleParams) error InsertSystem(ctx context.Context, arg InsertSystemParams) (int64, error) InsertTransfer(ctx context.Context, arg InsertTransferParams) error InsertTrip(ctx context.Context, arg InsertTripParams) (int64, error) InsertTripStopTime(ctx context.Context, arg []InsertTripStopTimeParams) (int64, error) InsertVehicle(ctx context.Context, arg InsertVehicleParams) error ListActiveAlertsForAgencies(ctx context.Context, arg ListActiveAlertsForAgenciesParams) ([]ListActiveAlertsForAgenciesRow, error) // ListActiveAlertsForRoutes returns preview information about active alerts for the provided routes. ListActiveAlertsForRoutes(ctx context.Context, arg ListActiveAlertsForRoutesParams) ([]ListActiveAlertsForRoutesRow, error) ListActiveAlertsForStops(ctx context.Context, arg ListActiveAlertsForStopsParams) ([]ListActiveAlertsForStopsRow, error) ListActivePeriodsForAlerts(ctx context.Context, pks []int64) ([]ListActivePeriodsForAlertsRow, error) ListAgencies(ctx context.Context, systemPk int64) ([]Agency, error) ListAgenciesByPk(ctx context.Context, pk []int64) ([]Agency, error) ListAlertPksAndHashes(ctx context.Context, arg ListAlertPksAndHashesParams) ([]ListAlertPksAndHashesRow, error) ListAlertsInSystem(ctx context.Context, systemPk int64) ([]Alert, error) ListAlertsInSystemAndByIDs(ctx context.Context, arg ListAlertsInSystemAndByIDsParams) ([]Alert, error) ListAlertsWithActivePeriodsAndAllInformedEntities(ctx context.Context, systemPk int64) ([]ListAlertsWithActivePeriodsAndAllInformedEntitiesRow, error) ListFeeds(ctx context.Context, systemPk int64) ([]Feed, error) ListRoutes(ctx context.Context, systemPk int64) ([]Route, error) ListRoutesByPk(ctx context.Context, routePks []int64) ([]ListRoutesByPkRow, error) ListRoutesInAgency(ctx context.Context, agencyPk int64) ([]ListRoutesInAgencyRow, error) ListScheduledServices(ctx context.Context, systemPk int64) ([]ListScheduledServicesRow, error) ListScheduledTripFrequencies(ctx context.Context, systemPk int64) ([]ListScheduledTripFrequenciesRow, error) ListScheduledTripStopTimes(ctx context.Context, systemPk int64) ([]ListScheduledTripStopTimesRow, error) ListScheduledTrips(ctx context.Context, systemPk int64) ([]ListScheduledTripsRow, error) ListServiceMapConfigsInSystem(ctx context.Context, systemPk int64) ([]ServiceMapConfig, error) ListServiceMapsConfigIDsForStops(ctx context.Context, stopPks []int64) ([]ListServiceMapsConfigIDsForStopsRow, error) // TODO: make this better? ListServiceMapsForRoutes(ctx context.Context, routePks []int64) ([]ListServiceMapsForRoutesRow, error) ListServiceMapsForStops(ctx context.Context, stopPks []int64) ([]ListServiceMapsForStopsRow, error) ListShapes(ctx context.Context, arg ListShapesParams) ([]Shape, error) ListShapesAndTrips(ctx context.Context, systemPk int64) ([]ListShapesAndTripsRow, error) ListStopHeadsignRulesForStops(ctx context.Context, stopPks []int64) ([]StopHeadsignRule, error) ListStopPksForRealtimeMap(ctx context.Context, routePk int64) ([]ListStopPksForRealtimeMapRow, error) ListStops(ctx context.Context, arg ListStopsParams) ([]Stop, error) ListStopsByPk(ctx context.Context, stopPks []int64) ([]ListStopsByPkRow, error) ListStopsTimesForTrip(ctx context.Context, tripPk int64) ([]ListStopsTimesForTripRow, error) ListStops_Geographic(ctx context.Context, arg ListStops_GeographicParams) ([]Stop, error) ListSystems(ctx context.Context) ([]System, error) ListTransfersFromStops(ctx context.Context, fromStopPks []int64) ([]Transfer, error) ListTransfersInSystem(ctx context.Context, systemPk pgtype.Int8) ([]ListTransfersInSystemRow, error) ListTripPksInSystem(ctx context.Context, arg ListTripPksInSystemParams) ([]ListTripPksInSystemRow, error) ListTripStopTimesByStops(ctx context.Context, stopPks []int64) ([]ListTripStopTimesByStopsRow, error) ListTripStopTimesForUpdate(ctx context.Context, tripPks []int64) ([]ListTripStopTimesForUpdateRow, error) ListTrips(ctx context.Context, arg ListTripsParams) ([]ListTripsRow, error) ListVehicles(ctx context.Context, arg ListVehiclesParams) ([]ListVehiclesRow, error) ListVehicles_Geographic(ctx context.Context, arg ListVehicles_GeographicParams) ([]ListVehicles_GeographicRow, error) MapAgencyPkToId(ctx context.Context, systemPk int64) ([]MapAgencyPkToIdRow, error) MapRouteIDToPkInSystem(ctx context.Context, arg MapRouteIDToPkInSystemParams) ([]MapRouteIDToPkInSystemRow, error) MapScheduledTripIDToPkInSystem(ctx context.Context, arg MapScheduledTripIDToPkInSystemParams) ([]MapScheduledTripIDToPkInSystemRow, error) MapScheduledTripIDToRoutePkInSystem(ctx context.Context, arg MapScheduledTripIDToRoutePkInSystemParams) ([]MapScheduledTripIDToRoutePkInSystemRow, error) MapStopIDAndPkToStationPk(ctx context.Context, arg MapStopIDAndPkToStationPkParams) ([]MapStopIDAndPkToStationPkRow, error) MapStopIDToPk(ctx context.Context, arg MapStopIDToPkParams) ([]MapStopIDToPkRow, error) MapStopPkToChildPks(ctx context.Context, stopPks []int64) ([]MapStopPkToChildPksRow, error) MapStopPkToDescendentPks(ctx context.Context, stopPks []int64) ([]MapStopPkToDescendentPksRow, error) MapTripIDToPkInSystem(ctx context.Context, arg MapTripIDToPkInSystemParams) ([]MapTripIDToPkInSystemRow, error) MapTripPkToVehicleID(ctx context.Context, arg MapTripPkToVehicleIDParams) ([]MapTripPkToVehicleIDRow, error) MarkFailedUpdate(ctx context.Context, arg MarkFailedUpdateParams) error MarkSkippedUpdate(ctx context.Context, arg MarkSkippedUpdateParams) error MarkSuccessfulUpdate(ctx context.Context, arg MarkSuccessfulUpdateParams) error MarkTripStopTimesPast(ctx context.Context, arg []MarkTripStopTimesPastParams) *MarkTripStopTimesPastBatchResults UpdateAgency(ctx context.Context, arg UpdateAgencyParams) error UpdateFeed(ctx context.Context, arg UpdateFeedParams) error UpdateRoute(ctx context.Context, arg UpdateRouteParams) error UpdateServiceMapConfig(ctx context.Context, arg UpdateServiceMapConfigParams) error UpdateStop(ctx context.Context, arg UpdateStopParams) error UpdateStop_Parent(ctx context.Context, arg UpdateStop_ParentParams) error UpdateSystem(ctx context.Context, arg UpdateSystemParams) error UpdateSystemStatus(ctx context.Context, arg UpdateSystemStatusParams) error UpdateTrip(ctx context.Context, arg []UpdateTripParams) *UpdateTripBatchResults UpdateTripStopTime(ctx context.Context, arg UpdateTripStopTimeParams) error }
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) CountAgenciesInSystem ¶
func (*Queries) CountFeedsInSystem ¶
func (*Queries) CountRoutesInSystem ¶
func (*Queries) CountStopsInSystem ¶
func (*Queries) CountTransfersInSystem ¶
func (*Queries) DeleteAlerts ¶
func (*Queries) DeleteScheduledServices ¶ added in v0.6.1
func (q *Queries) DeleteScheduledServices(ctx context.Context, arg DeleteScheduledServicesParams) error
func (*Queries) DeleteServiceMap ¶
func (q *Queries) DeleteServiceMap(ctx context.Context, arg DeleteServiceMapParams) error
func (*Queries) DeleteServiceMapConfig ¶
func (*Queries) DeleteShapes ¶ added in v0.6.1
func (q *Queries) DeleteShapes(ctx context.Context, arg DeleteShapesParams) error
func (*Queries) DeleteStaleAgencies ¶
func (q *Queries) DeleteStaleAgencies(ctx context.Context, arg DeleteStaleAgenciesParams) error
func (*Queries) DeleteStaleAlerts ¶
func (q *Queries) DeleteStaleAlerts(ctx context.Context, arg DeleteStaleAlertsParams) error
func (*Queries) DeleteStaleRoutes ¶
func (q *Queries) DeleteStaleRoutes(ctx context.Context, arg DeleteStaleRoutesParams) error
func (*Queries) DeleteStaleStops ¶
func (q *Queries) DeleteStaleStops(ctx context.Context, arg DeleteStaleStopsParams) error
func (*Queries) DeleteStaleTrips ¶
func (*Queries) DeleteStopHeadsignRules ¶
func (*Queries) DeleteTransfers ¶
func (*Queries) DeleteTripStopTimes ¶
func (*Queries) DeleteVehicles ¶ added in v0.6.1
func (q *Queries) DeleteVehicles(ctx context.Context, arg DeleteVehiclesParams) error
func (*Queries) EstimateHeadwaysForRoutes ¶
func (q *Queries) EstimateHeadwaysForRoutes(ctx context.Context, arg EstimateHeadwaysForRoutesParams) ([]EstimateHeadwaysForRoutesRow, error)
func (*Queries) GetAlertInSystem ¶
func (*Queries) GetDestinationsForTrips ¶
func (*Queries) GetScheduledService ¶ added in v0.6.1
func (q *Queries) GetScheduledService(ctx context.Context, arg GetScheduledServiceParams) (ScheduledService, error)
func (*Queries) GetScheduledTrip ¶ added in v0.6.1
func (q *Queries) GetScheduledTrip(ctx context.Context, arg GetScheduledTripParams) (ScheduledTrip, error)
func (*Queries) GetTrip ¶
func (q *Queries) GetTrip(ctx context.Context, arg GetTripParams) (GetTripRow, error)
func (*Queries) GetVehicle ¶
func (q *Queries) GetVehicle(ctx context.Context, arg GetVehicleParams) (GetVehicleRow, error)
func (*Queries) InsertAgency ¶
func (*Queries) InsertAlert ¶
func (*Queries) InsertAlertActivePeriod ¶
func (q *Queries) InsertAlertActivePeriod(ctx context.Context, arg InsertAlertActivePeriodParams) error
func (*Queries) InsertAlertAgency ¶
func (q *Queries) InsertAlertAgency(ctx context.Context, arg InsertAlertAgencyParams) error
func (*Queries) InsertAlertRoute ¶
func (q *Queries) InsertAlertRoute(ctx context.Context, arg InsertAlertRouteParams) error
func (*Queries) InsertAlertRouteType ¶ added in v0.6.1
func (q *Queries) InsertAlertRouteType(ctx context.Context, arg InsertAlertRouteTypeParams) error
func (*Queries) InsertAlertStop ¶
func (q *Queries) InsertAlertStop(ctx context.Context, arg InsertAlertStopParams) error
func (*Queries) InsertAlertTrip ¶ added in v0.6.1
func (q *Queries) InsertAlertTrip(ctx context.Context, arg InsertAlertTripParams) error
func (*Queries) InsertFeed ¶
func (q *Queries) InsertFeed(ctx context.Context, arg InsertFeedParams) error
func (*Queries) InsertRoute ¶
func (*Queries) InsertScheduledService ¶ added in v0.6.1
func (*Queries) InsertScheduledServiceAddition ¶ added in v0.6.1
func (q *Queries) InsertScheduledServiceAddition(ctx context.Context, arg InsertScheduledServiceAdditionParams) error
func (*Queries) InsertScheduledServiceRemoval ¶ added in v0.6.1
func (q *Queries) InsertScheduledServiceRemoval(ctx context.Context, arg InsertScheduledServiceRemovalParams) error
func (*Queries) InsertScheduledTrip ¶ added in v0.6.1
func (*Queries) InsertScheduledTripFrequency ¶ added in v0.6.1
func (q *Queries) InsertScheduledTripFrequency(ctx context.Context, arg InsertScheduledTripFrequencyParams) error
func (*Queries) InsertScheduledTripStopTime ¶ added in v0.6.1
func (*Queries) InsertServiceMap ¶
func (*Queries) InsertServiceMapConfig ¶
func (q *Queries) InsertServiceMapConfig(ctx context.Context, arg InsertServiceMapConfigParams) error
func (*Queries) InsertServiceMapStop ¶
func (*Queries) InsertShape ¶ added in v0.6.1
func (*Queries) InsertStop ¶
func (*Queries) InsertStopHeadSignRule ¶
func (q *Queries) InsertStopHeadSignRule(ctx context.Context, arg InsertStopHeadSignRuleParams) error
func (*Queries) InsertSystem ¶
func (*Queries) InsertTransfer ¶
func (q *Queries) InsertTransfer(ctx context.Context, arg InsertTransferParams) error
func (*Queries) InsertTrip ¶
func (*Queries) InsertTripStopTime ¶
func (*Queries) InsertVehicle ¶
func (q *Queries) InsertVehicle(ctx context.Context, arg InsertVehicleParams) error
func (*Queries) ListActiveAlertsForAgencies ¶
func (q *Queries) ListActiveAlertsForAgencies(ctx context.Context, arg ListActiveAlertsForAgenciesParams) ([]ListActiveAlertsForAgenciesRow, error)
func (*Queries) ListActiveAlertsForRoutes ¶
func (q *Queries) ListActiveAlertsForRoutes(ctx context.Context, arg ListActiveAlertsForRoutesParams) ([]ListActiveAlertsForRoutesRow, error)
ListActiveAlertsForRoutes returns preview information about active alerts for the provided routes.
func (*Queries) ListActiveAlertsForStops ¶
func (q *Queries) ListActiveAlertsForStops(ctx context.Context, arg ListActiveAlertsForStopsParams) ([]ListActiveAlertsForStopsRow, error)
func (*Queries) ListActivePeriodsForAlerts ¶
func (*Queries) ListAgencies ¶
func (*Queries) ListAgenciesByPk ¶
func (*Queries) ListAlertPksAndHashes ¶
func (q *Queries) ListAlertPksAndHashes(ctx context.Context, arg ListAlertPksAndHashesParams) ([]ListAlertPksAndHashesRow, error)
func (*Queries) ListAlertsInSystem ¶
func (*Queries) ListAlertsInSystemAndByIDs ¶
func (*Queries) ListAlertsWithActivePeriodsAndAllInformedEntities ¶ added in v0.6.1
func (*Queries) ListRoutes ¶
func (*Queries) ListRoutesByPk ¶
func (*Queries) ListRoutesInAgency ¶
func (*Queries) ListScheduledServices ¶ added in v0.6.1
func (*Queries) ListScheduledTripFrequencies ¶ added in v0.6.1
func (*Queries) ListScheduledTripStopTimes ¶ added in v0.6.1
func (*Queries) ListScheduledTrips ¶ added in v0.6.1
func (*Queries) ListServiceMapConfigsInSystem ¶
func (*Queries) ListServiceMapsConfigIDsForStops ¶
func (*Queries) ListServiceMapsForRoutes ¶
func (q *Queries) ListServiceMapsForRoutes(ctx context.Context, routePks []int64) ([]ListServiceMapsForRoutesRow, error)
TODO: make this better?
func (*Queries) ListServiceMapsForStops ¶
func (*Queries) ListShapes ¶ added in v0.6.1
func (*Queries) ListShapesAndTrips ¶ added in v0.6.1
func (*Queries) ListStopHeadsignRulesForStops ¶
func (*Queries) ListStopPksForRealtimeMap ¶
func (*Queries) ListStopsByPk ¶
func (*Queries) ListStopsTimesForTrip ¶
func (*Queries) ListStops_Geographic ¶
func (*Queries) ListTransfersFromStops ¶
func (*Queries) ListTransfersInSystem ¶
func (*Queries) ListTripPksInSystem ¶
func (q *Queries) ListTripPksInSystem(ctx context.Context, arg ListTripPksInSystemParams) ([]ListTripPksInSystemRow, error)
func (*Queries) ListTripStopTimesByStops ¶
func (*Queries) ListTripStopTimesForUpdate ¶
func (*Queries) ListTrips ¶
func (q *Queries) ListTrips(ctx context.Context, arg ListTripsParams) ([]ListTripsRow, error)
func (*Queries) ListVehicles ¶
func (q *Queries) ListVehicles(ctx context.Context, arg ListVehiclesParams) ([]ListVehiclesRow, error)
func (*Queries) ListVehicles_Geographic ¶
func (q *Queries) ListVehicles_Geographic(ctx context.Context, arg ListVehicles_GeographicParams) ([]ListVehicles_GeographicRow, error)
func (*Queries) MapAgencyPkToId ¶
func (*Queries) MapRouteIDToPkInSystem ¶
func (q *Queries) MapRouteIDToPkInSystem(ctx context.Context, arg MapRouteIDToPkInSystemParams) ([]MapRouteIDToPkInSystemRow, error)
func (*Queries) MapScheduledTripIDToPkInSystem ¶ added in v0.6.1
func (q *Queries) MapScheduledTripIDToPkInSystem(ctx context.Context, arg MapScheduledTripIDToPkInSystemParams) ([]MapScheduledTripIDToPkInSystemRow, error)
func (*Queries) MapScheduledTripIDToRoutePkInSystem ¶ added in v0.6.1
func (q *Queries) MapScheduledTripIDToRoutePkInSystem(ctx context.Context, arg MapScheduledTripIDToRoutePkInSystemParams) ([]MapScheduledTripIDToRoutePkInSystemRow, error)
func (*Queries) MapStopIDAndPkToStationPk ¶
func (q *Queries) MapStopIDAndPkToStationPk(ctx context.Context, arg MapStopIDAndPkToStationPkParams) ([]MapStopIDAndPkToStationPkRow, error)
func (*Queries) MapStopIDToPk ¶
func (q *Queries) MapStopIDToPk(ctx context.Context, arg MapStopIDToPkParams) ([]MapStopIDToPkRow, error)
func (*Queries) MapStopPkToChildPks ¶
func (*Queries) MapStopPkToDescendentPks ¶
func (*Queries) MapTripIDToPkInSystem ¶
func (q *Queries) MapTripIDToPkInSystem(ctx context.Context, arg MapTripIDToPkInSystemParams) ([]MapTripIDToPkInSystemRow, error)
func (*Queries) MapTripPkToVehicleID ¶ added in v0.6.1
func (q *Queries) MapTripPkToVehicleID(ctx context.Context, arg MapTripPkToVehicleIDParams) ([]MapTripPkToVehicleIDRow, error)
func (*Queries) MarkFailedUpdate ¶
func (q *Queries) MarkFailedUpdate(ctx context.Context, arg MarkFailedUpdateParams) error
func (*Queries) MarkSkippedUpdate ¶
func (q *Queries) MarkSkippedUpdate(ctx context.Context, arg MarkSkippedUpdateParams) error
func (*Queries) MarkSuccessfulUpdate ¶
func (q *Queries) MarkSuccessfulUpdate(ctx context.Context, arg MarkSuccessfulUpdateParams) error
func (*Queries) MarkTripStopTimesPast ¶
func (q *Queries) MarkTripStopTimesPast(ctx context.Context, arg []MarkTripStopTimesPastParams) *MarkTripStopTimesPastBatchResults
func (*Queries) UpdateAgency ¶
func (q *Queries) UpdateAgency(ctx context.Context, arg UpdateAgencyParams) error
func (*Queries) UpdateFeed ¶
func (q *Queries) UpdateFeed(ctx context.Context, arg UpdateFeedParams) error
func (*Queries) UpdateRoute ¶
func (q *Queries) UpdateRoute(ctx context.Context, arg UpdateRouteParams) error
func (*Queries) UpdateServiceMapConfig ¶
func (q *Queries) UpdateServiceMapConfig(ctx context.Context, arg UpdateServiceMapConfigParams) error
func (*Queries) UpdateStop ¶
func (q *Queries) UpdateStop(ctx context.Context, arg UpdateStopParams) error
func (*Queries) UpdateStop_Parent ¶
func (q *Queries) UpdateStop_Parent(ctx context.Context, arg UpdateStop_ParentParams) error
func (*Queries) UpdateSystem ¶
func (q *Queries) UpdateSystem(ctx context.Context, arg UpdateSystemParams) error
func (*Queries) UpdateSystemStatus ¶
func (q *Queries) UpdateSystemStatus(ctx context.Context, arg UpdateSystemStatusParams) error
func (*Queries) UpdateTrip ¶
func (q *Queries) UpdateTrip(ctx context.Context, arg []UpdateTripParams) *UpdateTripBatchResults
func (*Queries) UpdateTripStopTime ¶
func (q *Queries) UpdateTripStopTime(ctx context.Context, arg UpdateTripStopTimeParams) error
type ScheduledService ¶
type ScheduledServiceRemoval ¶
type ScheduledTrip ¶
type ScheduledTripFrequency ¶
type ScheduledTripStopTime ¶
type ScheduledTripStopTime struct { Pk int64 TripPk int64 StopPk int64 StopSequence int32 ContinuousDropOff string ContinuousPickup string DropOffType string ExactTimes bool Headsign pgtype.Text PickupType string ShapeDistanceTraveled pgtype.Float8 ArrivalTime pgtype.Int4 DepartureTime pgtype.Int4 }
type ServiceMap ¶
type ServiceMapConfig ¶
type ServiceMapVertex ¶
type StopHeadsignRule ¶
type TripStopTime ¶
type TripStopTime struct { Pk int64 StopPk int64 TripPk int64 ArrivalTime pgtype.Timestamptz ArrivalDelay pgtype.Int4 ArrivalUncertainty pgtype.Int4 DepartureTime pgtype.Timestamptz DepartureDelay pgtype.Int4 DepartureUncertainty pgtype.Int4 StopSequence int32 Track pgtype.Text Headsign pgtype.Text Past bool }
type UpdateAgencyParams ¶
type UpdateFeedParams ¶
type UpdateRouteParams ¶
type UpdateStopParams ¶
type UpdateStop_ParentParams ¶
type UpdateSystemParams ¶
type UpdateTripBatchResults ¶
type UpdateTripBatchResults struct {
// contains filtered or unexported fields
}
func (*UpdateTripBatchResults) Close ¶
func (b *UpdateTripBatchResults) Close() error
func (*UpdateTripBatchResults) Exec ¶
func (b *UpdateTripBatchResults) Exec(f func(int, error))
type UpdateTripParams ¶
type UpdateTripStopTimeParams ¶
type UpdateTripStopTimeParams struct { StopPk int64 ArrivalTime pgtype.Timestamptz ArrivalDelay pgtype.Int4 ArrivalUncertainty pgtype.Int4 DepartureTime pgtype.Timestamptz DepartureDelay pgtype.Int4 DepartureUncertainty pgtype.Int4 StopSequence int32 Track pgtype.Text Headsign pgtype.Text Pk int64 }
type Vehicle ¶
type Vehicle struct { Pk int64 ID pgtype.Text SystemPk int64 TripPk pgtype.Int8 Label pgtype.Text LicensePlate pgtype.Text CurrentStatus pgtype.Text Bearing pgtype.Float4 Odometer pgtype.Float8 Speed pgtype.Float4 CongestionLevel string UpdatedAt pgtype.Timestamptz CurrentStopPk pgtype.Int8 CurrentStopSequence pgtype.Int4 OccupancyStatus pgtype.Text FeedPk int64 OccupancyPercentage pgtype.Int4 Location types.Geography }
Source Files ¶
- agency_queries.sql.go
- alert_queries.sql.go
- batch.go
- copyfrom.go
- db.go
- feed_queries.sql.go
- models.go
- querier.go
- route_queries.sql.go
- schedule_queries.sql.go
- servicemap_queries.sql.go
- shape_queries.sql.go
- stop_headsign_queries.sql.go
- stop_queries.sql.go
- system_queries.sql.go
- transfer_queries.sql.go
- trip_queries.sql.go
- vehicle_queries.sql.go
Click to show internal directories.
Click to hide internal directories.