Functions — github.com/catenarytransit/catenary-backend

hub / github.com/catenarytransit/catenary-backend / functions

Functions1,097 in github.com/catenarytransit/catenary-backend

⨍ Functions 1,097◇ Types & classes 658

↓ 2 callersFunctionconvert_to_gtfs_rt

( vehicles: Vec<BridgeportVehicle>, stops_cache: &AHashMap<i32, Vec<BridgeportStop>>, // route_id -> s

src/alpenrose/custom_rt_feeds/bridgeport.rs:223

↓ 2 callersFunctionconvert_to_output

(input: &AspenisedVehiclePosition)

src/birch/aspenised_data_over_https.rs:57

↓ 2 callersFunctioncount_services

(gtfs: &Gtfs)

src/maple_syrup/service_optimisation.rs:153

↓ 2 callersFunctiondeduplicate_alerts

( alerts: AHashMap<String, AspenisedAlert>, )

src/aspen/alerts_processing.rs:127

↓ 2 callersFunctiondelete_attempt_objects_elasticsearch

( feed_id: &str, attempt_id: &str, elasticsearch: &Elasticsearch, )

src/maple/cleanup.rs:16

↓ 2 callersFunctiondelete_overlapping_feeds

(input: ReturnDmfrAnalysis)

src/maple/delete_overlapping_feeds_dmfr.rs:5

↓ 2 callersFunctiondelete_stale_attempts_for_feed

( feed_id: &str, valid_attempt_ids: &[String], pool: Arc<CatenaryPostgresPool>, )

src/maple/cleanup.rs:136

↓ 2 callersFunctiondelete_tile_storage_for_bbox_and_category_zoom

( conn: &mut bb8::PooledConnection< '_, diesel_async::pooled_connection::AsyncDieselConnec

src/shape_fetcher/mod.rs:24

↓ 2 callersFunctiondelete_zip_files

(dir_path: &str)

src/maple/gtfs_handlers/flatten.rs:70

↓ 2 callersFunctiondensify_polyline_metric

Densify a polyline in metric space by adding points (max_spacing_m).

src/globeflower/geometry_utils.rs:116

↓ 2 callersFunctiondist_sq

Simple distance function

src/aspen/import_alpenrose.rs:3509

↓ 2 callersFunctiondownload_file

(client: &Client, url: &str, path: &PathBuf)

src/osm_extractor/main.rs:414

↓ 2 callersFunctionedge_type_to_string

(et: &Option<EdgeType>)

src/linnaea/main.rs:39

↓ 2 callersMethodedges_near_point

Find edges near a point within a radius (in meters)

src/globeflower/osm_loader.rs:321

↓ 2 callersMethodend_stop_chateau

(&self)

src/routing_common/api.rs:177

↓ 2 callersMethodend_stop_id

(&self)

src/routing_common/api.rs:163

↓ 2 callersMethodevaluate_edge

( &self, edge: &QueryEdge, current_time: u64, graph_manager: &GraphManager,

src/edelweiss/query_graph.rs:473

↓ 2 callersFunctionextract_name_translations

Extract multilingual names from tags

src/osmstationimport/main.rs:414

↓ 2 callersFunctionextract_station_code

(stop_ref: &str)

src/aspen/track_number/sncf_siri.rs:18

↓ 2 callersFunctionfaster_stop_time_reader_injection

( gtfs: Gtfs, stop_times_path: &Path, )

src/maple/gtfs_process.rs:2513

↓ 2 callersFunctionfeed_id_to_chateau_id_pivot_table

reverses the chateau association to get HashMap<FeedId, ChateauId>

src/maple/chateau_postprocess.rs:9

↓ 2 callersFunctionfetch_alert_page_data

( url: &str, client: &reqwest::Client, )

src/custom_alerts/metrolink_alerts.rs:334

↓ 2 callersFunctionfetch_chunk_intermediates

( context: NearbyDeparturesContext, params: NearbyFromCoordsV3, station_groups: HashMap<(String, S

src/spruce/nearby_departures.rs:1103

↓ 2 callersFunctionfetch_flixbus_data

( etcd: &mut etcd_client::KvClient, feed_id: &str, aggregator: &Aggregator, )

src/alpenrose/custom_rt_feeds/flixbus.rs:6

↓ 2 callersFunctionfetch_routes

( client: &reqwest::Client, )

src/alpenrose/custom_rt_feeds/bridgeport.rs:87

↓ 2 callersFunctionfetch_stops_for_route

( client: &reqwest::Client, route_id: i32, )

src/alpenrose/custom_rt_feeds/bridgeport.rs:124

↓ 2 callersFunctionfetch_trip_information

( chateau: String, query: QueryTripInformationParams, pool: Arc<CatenaryPostgresPool>, etcd_co

src/trip_logic.rs:488

↓ 2 callersFunctionfetch_trip_rt_update

( chateau: String, query: QueryTripInformationParams, etcd_connection_ips: Arc<EtcdConnectionIps>,

src/trip_logic.rs:279

↓ 2 callersFunctionfetch_vehicles_for_route

( client: &reqwest::Client, route_id: i32, )

src/alpenrose/custom_rt_feeds/bridgeport.rs:104

↓ 2 callersMethodfind_or_create_node

Find existing node or create new one (Distance Only Merge)

src/globeflower/support_graph.rs:362

↓ 2 callersMethodfind_path_internal

( &self, from: AtomicEdgeId, to: AtomicEdgeId, dist_only: bool, )

src/globeflower/map_matcher.rs:409

↓ 2 callersFunctionfix_foreground_colour_rgb_feed

( feed_id: &str, background: Option<RGB<u8>>, foreground: Option<RGB<u8>>, )

src/maple/gtfs_handlers/colour_correction.rs:274

↓ 2 callersMethodflip

(self, search_dir: Direction)

src/routing_common/types.rs:75

↓ 2 callersFunctionfrequencies_to_protobuf

( frequencies: &Vec<gtfs_structures::Frequency>, )

src/lib.rs:266

↓ 2 callersMethodfrom

(input: gtfs_realtime::Alert)

src/gtfs_rt_rough_hash/mod.rs:33

↓ 2 callersMethodgeometry

(&self)

src/routing_common/api.rs:254

↓ 2 callersFunctionget_alert_single_trip

( aspen_client: &crate::aspen::lib::AspenRpcClient, chateau: String, trip_id: String, route_id

src/trip_logic.rs:158

↓ 2 callersFunctionget_all_service_ids

(gtfs: &Gtfs)

src/maple_syrup/service_optimisation.rs:164

↓ 2 callersMethodget_all_trips_with_ids

( self, _ctx: context::Context, chateau_id: String, trip_ids: Vec<String>,

src/aspen/main.rs:358

↓ 2 callersFunctionget_and_convert_lirr

( client: &reqwest::Client, )

src/alpenrose/custom_rt_feeds/mta.rs:14

↓ 2 callersFunctionget_aspen_socket

( chateau_id: &str, etcd_ips: &EtcdConnectionIps, etcd_opts: &Option<etcd_client::ConnectOptions>,

src/spruce/trajectories.rs:31

↓ 2 callersFunctionget_clean_name

Apply name overrides

src/osmstationimport/main.rs:406

↓ 2 callersMethodget_cost

(&self, node: NodeIdx, level: Level)

src/routing_common/dijkstra.rs:121

↓ 2 callersFunctionget_feed_metadata

( arc_conn_pool: Arc<CatenaryPostgresPool>, )

src/alpenrose/get_feed_metadata.rs:29

↓ 2 callersFunctionget_local_bearing

(line: &[(f64, f64)], dist_m: f64)

src/globeflower/geometry_utils.rs:604

↓ 2 callersMethodget_nonscheduled_trips_updates_from_stop_ids

( self, _: context::Context, chateau_id: String, stop_ids: Vec<String>, )

src/aspen/main.rs:277

↓ 2 callersMethodget_or_load_region

(&self, region_id: &str)

src/routing_common/graph_loader.rs:98

↓ 2 callersFunctionget_raw_gtfs_rt

( client: &reqwest::Client, )

src/lib.rs:429

↓ 2 callersFunctionget_station_type

Determine station type from tags

src/osmstationimport/main.rs:194

↓ 2 callersMethodget_string

(&self, offset: &StringOffset)

src/routing_common/timetable.rs:220

↓ 2 callersFunctiongtfs_rt_alerts_from_metrolink_website

( client: &reqwest::Client, )

src/custom_alerts/metrolink_alerts.rs:593

↓ 2 callersMethodguess_order

Guess whether line A should come before line B on an edge. Walks through adjacent settled edges to make the decision. Matches C++ loom's GreedyOptimiz

src/harebell/optimizer.rs:3146

↓ 2 callersFunctionhaversine_distance

/ Calculates the Haversine distance between two points (in metres).

src/hull.rs:37

↓ 2 callersFunctionhull_from_gtfs

(gtfs: &gtfs_structures::Gtfs, feed_id: &str)

src/maple/gtfs_handlers/hull_from_gtfs.rs:39

↓ 2 callersFunctioninsert_stop_to_stop_geometry

( feed_id: &str, attempt_id: &str, chateau_id: &str, route: &gtfs_structures::Route, direc

src/maple/gtfs_ingestion_sequence/extra_stop_to_stop_shapes_into_postgres.rs:7

↓ 2 callersFunctioninterpolate_along_polyline_metric_dist

(coords: &[(f64, f64)], dist: f64)

src/globeflower/geometry_utils.rs:613

↓ 2 callersFunctioninvalidate_etcd_client

( etcd_reuser: &tokio::sync::RwLock<Option<etcd_client::Client>>, )

src/lib.rs:1058

↓ 2 callersFunctionis_accessible_bus

(t: &OsmTags, is_node: bool)

src/routing_common/extract.rs:253

↓ 2 callersFunctionis_accessible_bus_penalty

(t: &OsmTags, is_node: bool)

src/routing_common/extract.rs:273

↓ 2 callersFunctionis_accessible_foot

(t: &OsmTags, is_node: bool)

src/routing_common/extract.rs:145

↓ 2 callersMethodis_active_rail

Check if this mode should be included in the track graph

src/globeflower/osm_types.rs:109

↓ 2 callersMethodis_bike_accessible

(&self)

src/routing_common/ways.rs:30

↓ 2 callersFunctionis_null_island

(x: f64, y: f64)

src/lib.rs:488

↓ 2 callersMethodis_sidewalk_separate

(&self)

src/routing_common/ways.rs:61

↓ 2 callersMethodis_trip_active

( &self, trip: &CompressedTrip, context: &ServiceContext, exceptions: &[Servic

src/edelweiss/query_graph.rs:992

↓ 2 callersMethodlast_updated_time_ms_for_chateau

( self, _context: tarpc::context::Context, chateau_id: String, )

src/aspen/main.rs:1588

↓ 2 callersFunctionload_bincode

Generic helper to load any Serde-compatible struct from a file using bincode.

src/routing_common/transit_graph.rs:49

↓ 2 callersFunctionload_exclude_polygons

Embed the exclusion polygons at compile time to avoid runtime paths issues.

src/osmstationimport/main.rs:92

↓ 2 callersFunctionmake_calendar_structure_from_pg_single_chateau

( services_calendar_lookup_queries_to_perform: Vec<crate::models::Calendar>, services_calendar_dates_l

src/lib.rs:551

↓ 2 callersFunctionmake_hashmaps_of_children_stop_info

( gtfs: &gtfs_structures::Gtfs, )

src/maple/gtfs_handlers/stops_associated_items.rs:52

↓ 2 callersFunctionmake_index_and_mappings

( client: &Elasticsearch, )

src/elasticutils/mod.rs:64

↓ 2 callersFunctionmake_weekdays

Kyler Chin Iterator Optimisation by https://github.com/Priyansh4444 Priyash Sash

src/lib.rs:531

↓ 2 callersMethodmatch_location

Find the nearest way candidates to a lat/lng query point.

src/routing_common/lookup.rs:86

↓ 2 callersMethodmax_speed_s_per_m

(&self)

src/routing_common/ways.rs:115

↓ 2 callersFunctionmetrlink_coord_to_f32

(coord: &CompactString)

src/aspen/import_alpenrose.rs:148

↓ 2 callersFunctionmetrolink_station_schedule_decode

( response: Vec<MetrolinkTrackData>, stop_codes_to_use: MetrolinkOrAmtrakStopCodes, )

src/aspen/track_number/mod.rs:124

↓ 2 callersFunctionmetrolink_unix_fix

Metrolink date fix

src/lib.rs:760

↓ 2 callersFunctionmnr_trip_id_fixer

(gtfs: &Gtfs, input: gtfs_realtime::FeedMessage)

src/alpenrose/custom_rt_feeds/mta.rs:175

↓ 2 callersMethodn_ways

(&self)

src/routing_common/ways.rs:523

↓ 2 callersMethodnode_position

Get node coordinates

src/globeflower/osm_loader.rs:375

↓ 2 callersFunctionnormalize_color

Normalize a color string to 6-char RRGGBB (no '#'). Rules: - Strip all non-hex chars (this removes '#'). - Uppercase A–F. - If exactly 6 chars: keep

src/maple/gtfs_handlers/route_file_fixer.rs:75

↓ 2 callersFunctionnormalize_name_for_comparison

(name: &str)

src/osmstationimport/main.rs:856

↓ 2 callersFunctionnormalize_train_num

(s: &str)

src/aspen/track_number/sncf_siri.rs:14

↓ 2 callersMethodoneway_car

(mut self, v: bool)

src/routing_common/ways.rs:157

↓ 2 callersFunctionoptimise_services

Main function to reduce and optimize services

src/maple_syrup/service_optimisation.rs:21

↓ 2 callersMethodparking

(mut self, v: bool)

src/routing_common/ways.rs:185

↓ 2 callersFunctionparse_sncf_siri

(xml: &str)

src/aspen/track_number/sncf_siri.rs:34

↓ 2 callersFunctionperform_leader_job

( etcd: &mut etcd_client::Client, arc_conn_pool: Arc<CatenaryPostgresPool>, last_set_of_active_nod

src/alpenrose/leader_job.rs:10

↓ 2 callersFunctionpickup_dropoff_to_i16

(x: &gtfs_structures::PickupDropOffType)

src/maple/gtfs_process.rs:2440

↓ 2 callersFunctionprocess_shape

(shape: &Shape, options: &ShapeOptions)

src/birch/shapes.rs:38

↓ 2 callersFunctionprocess_train

( lookup: &mut HashMap<String, HashMap<String, String>>, train: &ViaRailArrivalDeparture, stop_nam

src/aspen/track_number/viarail.rs:119

↓ 2 callersMethodproject

Project (lon, lat) to (x, y) meters

src/globeflower/geometry_utils.rs:36

↓ 2 callersMethodrandom_proxy_client

( &self, )

src/proxy_pool.rs:83

↓ 2 callersFunctionraw_with_header_csv_to_strings

( raw_input: &str, )

src/ip_to_location/mod.rs:100

↓ 2 callersFunctionrdp_indices

(projected: &[[f64; 2]], epsilon_sq: f64)

src/spruce/trajectories.rs:124

↓ 2 callersFunctionrefresh_metadata_assignments

( dmfr_result: &ReturnDmfrAnalysis, chateau_result: &HashMap<String, Chateau>, pool: Arc<catenary:

src/maple/refresh_metadata_tables.rs:22

↓ 2 callersMethodreplace_vehicle_label_with_vehicle_id

(self)

src/aspen_dataset.rs:862

↓ 2 callersFunctionresolve_active_dates

( gtfs: &Gtfs, service_id: &str, )

src/maple_syrup/service_optimisation.rs:178

↓ 2 callersFunctionroute_abbr_to_gtfs_id

()

src/alpenrose/custom_rt_feeds/bridgeport.rs:66

↓ 2 callersMethodroute_id

(&self)

src/routing_common/api.rs:184

← previous next →201–300 of 1,097, ranked by callers