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 callersFunctionrt_stop_matches_scheduled_simple

Simpler version of stop matching for handlers without mapping access. Falls back to underscore suffix pattern matching only.

src/stop_matching.rs:42

↓ 2 callersFunctionscore_and_tier_stations

( stations: &[&'a OsmStation], platform_counts: &HashMap<i64, i32>, stops_counts: &HashMap<i64, i3

src/osm_station_rank_and_clean/main.rs:167

↓ 2 callersFunctionsend_mta_rail_to_aspen

( etcd: &mut etcd_client::KvClient, railroad: MtaRailroad, vehicle_position: Vec<u8>, trip_upd

src/alpenrose/custom_rt_feeds/mta.rs:418

↓ 2 callersFunctionshape_to_colour

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

src/maple/gtfs_handlers/shape_colour_calculator.rs:12

↓ 2 callersFunctionshapes_into_postgres

( gtfs: &gtfs_structures::Gtfs, shape_to_color_lookup: &HashMap<std::string::String, RGB<u8>>, sha

src/maple/gtfs_ingestion_sequence/shapes_into_postgres.rs:20

↓ 2 callersMethodsmaller_than_at

Determine if line A should come before line B based on already-settled edges. Returns (decision, cost): decision: 1 = A < B, -1 = B < A, 0 = undecided

src/harebell/optimizer.rs:3065

↓ 2 callersMethodsorted_tile_keys

(&self)

src/globeflower/corridor.rs:720

↓ 2 callersMethodstart_stop_chateau

(&self)

src/routing_common/api.rs:170

↓ 2 callersMethodstart_stop_id

(&self)

src/routing_common/api.rs:156

↓ 2 callersFunctionstops_into_postgres_and_elastic

( gtfs: &gtfs_structures::Gtfs, feed_id: &str, arc_conn_pool: Arc<CatenaryPostgresPool>, chate

src/maple/gtfs_ingestion_sequence/stops_into_postgres.rs:44

↓ 2 callersMethodtag_node

(&mut self, node_id: SupportNodeId, feature: &crate::osm_loader::OsmPtFeature)

src/globeflower/support_graph.rs:664

↓ 2 callersFunctiontile_y_to_lat

(y: u32, n: f64)

src/osm_extractor/main.rs:401

↓ 2 callersMethodto_feed_message

(&self)

src/compact_formats.rs:90

↓ 2 callersMethodto_seconds_per_meter

(self)

src/routing_common/types.rs:189

↓ 2 callersMethodto_stop_time_event

(&self, ref_epoch: u64)

src/compact_formats.rs:272

↓ 2 callersMethodtriplet_cmp_key

(&self)

src/aspen/alerts_processing.rs:292

↓ 2 callersFunctiontruncate_f64

(f: f64, n: usize)

src/birch/server.rs:495

↓ 2 callersFunctiontry_to_download

( feed_id: &str, client: &reqwest::Client, url: &str, parsed_url: &Url, )

src/maple/transitland_download.rs:332

↓ 2 callersMethodunproject

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

src/globeflower/geometry_utils.rs:45

↓ 2 callersMethoduntangle_rule_1

Implement Untangling Rules 1 & 2

src/harebell/optimizer.rs:884

↓ 2 callersFunctionwarm_up_homepage

Visits the homepage of a URL first to obtain cookies and warm up the session This helps bypass anti-bot systems that require a valid session

src/maple/transitland_download.rs:203

↓ 2 callersMethodwrite_tile

(&self, z: u8, x: u32, y: u32, tile: mvt::Tile)

src/harebell/generator.rs:112

↓ 1 callersMethodadd_node

(&mut self, pos: Point, props: NodeProperties)

src/routing_common/ways.rs:570

↓ 1 callersMethodadd_start

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

src/routing_common/dijkstra.rs:108

↓ 1 callersMethodadd_way

( &mut self, props: WayProperties, nodes: Vec<NodeIdx>, distances: Vec<u16>,

src/routing_common/ways.rs:581

↓ 1 callersFunctionalpenrose_process_threads

( alpenrose_to_process_queue: Arc<Injector<ProcessAlpenroseData>>, authoritative_gtfs_rt_store: Arc<Sc

src/aspen/async_threads_alpenrose.rs:26

↓ 1 callersMethodapply_env_overrides

(&mut self)

src/catenaryconfig.rs:157

↓ 1 callersFunctionapply_route_type_overrides

( realtime_feed_id: &str, vehicle_pos: &VehiclePosition, pos_aspenised: &mut AspenisedVehiclePosit

src/aspen/route_type_overrides.rs:4

↓ 1 callersFunctionaspen_leader_thread

( workers_nodes: Arc<Mutex<Vec<String>>>, feeds_list: Arc<Mutex<Option<ChateauxLeaderHashMap>>>, t

src/aspen/leader_thread.rs:10

↓ 1 callersFunctionassign_chateaus

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

src/aspen/aspen_assignment.rs:16

↓ 1 callersFunctionassign_production_tables

( feed_id: &str, attempt_id: &str, arc_conn_pool: Arc<CatenaryPostgresPool>, bbox: Option<geo:

src/maple/assign_production_tables.rs:24

↓ 1 callersFunctionassign_trips_for_dresden

( authoritative_gtfs_rt: &Arc<SccHashMap<(String, GtfsRtType), CompactFeedMessage>>, conn: &mut diesel

src/aspen/trip_id_assigner_with_known_route_and_known_trip_updates.rs:153

↓ 1 callersMethodastar

A* pathfinding between nodes

src/globeflower/map_matcher.rs:451

↓ 1 callersMethodbbox_expanded

Get bounding box for this cell, expanded by a margin for overlap

src/maple/osm_station_matching.rs:184

↓ 1 callersFunctionbezier_points

Generate cubic bezier curve points p0: start point, cp1: control point 1, cp2: control point 2, p1: end point

src/harebell/tile_gen.rs:1217

↓ 1 callersFunctionbg_fetch_nyct_consists

Background task to fetch subway consists from the Helium API.

src/aspen/consist_cache_and_conversion.rs:53

↓ 1 callersFunctionbikes_allowed_to_int

(bikes_allowed: &BikesAllowedType)

src/enum_to_int.rs:71

↓ 1 callersMethodbuild_corridors_to_disk

Build corridors and write directly to disk tiles

src/globeflower/corridor.rs:146

↓ 1 callersMethodbuild_global

( &mut self, start_pid: u32, end_pid: u32, global_index: &GlobalPatternIndex,

src/edelweiss/query_graph.rs:244

↓ 1 callersFunctionbuild_land_masses

Build land masses from connected components

src/globeflower/export.rs:280

↓ 1 callersFunctionbuild_osm_stations_query

(z: u8, x: u32, y: u32)

src/birch/postgis_download.rs:775

↓ 1 callersFunctionbuild_osm_stations_ranked_query

(z: u8, x: u32, y: u32)

src/birch/postgis_download.rs:890

↓ 1 callersFunctioncalculate_centroid

Calculate centroid of a group of stops

src/globeflower/station.rs:316

↓ 1 callersFunctioncalculate_covering_tiles

(boundary: &geo::MultiPolygon<f64>, zoom: u8)

src/osm_extractor/main.rs:361

↓ 1 callersFunctioncalculate_delay

( trip_update_delay: Option<i32>, trip_start_date: &Option<String>, scheduled_stop_ids_hashset: &O

src/aspen/delay_calculation.rs:11

↓ 1 callersFunctioncalculate_exceptions

( cal: &Calendar, target_dates: &HashSet<NaiveDate>, )

src/maple_syrup/service_optimisation.rs:305

↓ 1 callersMethodcalculate_quality

Calculate match quality as fraction of shape covered

src/globeflower/map_matcher.rs:589

↓ 1 callersMethodcalculate_relative_arrival_time

Helper methods copied/adapted from Router

src/edelweiss/query_graph.rs:955

↓ 1 callersFunctioncheck_alert_for_html

(chateau_id: &str, alert_id: &str, alert: &AspenisedAlert)

examples/check_alerts_html.rs:116

↓ 1 callersFunctionchoose_primary_route_type

(route_types: &[i16])

src/maple/gtfs_ingestion_sequence/stops_into_postgres.rs:26

↓ 1 callersMethodcleanup

(&self)

src/globeflower/corridor.rs:685

↓ 1 callersMethodclear

(&mut self)

src/globeflower/map_matcher.rs:51

↓ 1 callersMethodclockwise_edges

Get edges around a node in clockwise order, starting from the "noon" edge. Matches C++ loom's OptGraph::clockwEdges

src/harebell/optimizer.rs:2934

↓ 1 callersMethodcluster_group

Process a group of edges (same mode) in a local tangent plane

src/globeflower/corridor.rs:239

↓ 1 callersFunctioncluster_gtfs_stops

Cluster GTFS stops by proximity

src/globeflower/main.rs:379

↓ 1 callersMethodcntr_id

(&self)

src/osm_station_rank_and_clean/main.rs:140

↓ 1 callersFunctioncollect_file_hashes_sip_zero

( base_path: &Path, current_path: &Path, file_hashes: &mut FileHashMap, )

src/hashfolder.rs:76

↓ 1 callersMethodcompatible_gtfs_types

Map to GTFS route_type ranges for compatibility

src/globeflower/osm_types.rs:123

↓ 1 callersFunctioncompute_file_hash

Compute SHA256 hash of a file

src/osmstationimport/main.rs:74

↓ 1 callersFunctioncompute_shape_envelope

( reader: &MmapShapeReader, shape_ids: I, )

src/maple/large_gtfs_insertion.rs:183

↓ 1 callersFunctioncompute_shape_envelope

( reader: &MmapShapeReader, shape_ids: I, )

src/maple/gtfs_process.rs:2473

↓ 1 callersFunctionconnections_lookup

( input_chateau: &str, input_route: &str, input_route_type: i16, stop_positions: Vec<(String,

src/connections_lookup.rs:30

↓ 1 callersMethodcontains_point

(&self, p: &Point<f64>)

src/osm_station_rank_and_clean/main.rs:133

↓ 1 callersFunctionconvert_to_output

(input: &AspenisedVehiclePosition)

src/spruce/map_coordinator.rs:56

↓ 1 callersFunctionconvert_to_street_data

( buffer: ChunkBuffer, x: u32, y: u32, z: u8, )

src/osm_extractor/main.rs:178

↓ 1 callersMethodcoordinates

(&self)

src/routing_common/timetable.rs:137

↓ 1 callersMethodcount_inversions

Count inversions in a sequence (used for crossing count)

src/harebell/optimizer.rs:3427

↓ 1 callersMethodcreate_leg_info

( &self, edge: &QueryEdge, start_time: u64, end_time: u64, graph_manag

src/edelweiss/query_graph.rs:772

↓ 1 callersFunctioncreate_pointed_buffer

Generates a buffered line segment with pointed (triangular) caps

src/maple/gtfs_handlers/hull_from_gtfs.rs:302

↓ 1 callersMethodcutting_rule_1_single_line_cut

(&self, graph: &mut RenderGraph)

src/harebell/optimizer.rs:2447

↓ 1 callersMethodcutting_rule_2_terminus_detachment

(&self, graph: &mut RenderGraph)

src/harebell/optimizer.rs:2579

↓ 1 callersFunctiondata_public_lu_latest_resource

copied luxembourg api parser from https://github.com/public-transport/transitous/blob/main/src/region_helpers.py

src/maple/transitland_download.rs:58

↓ 1 callersFunctiondatabase_url_for_env

(postgres_config: &catenaryconfig::PostgresConfig)

src/postgres_tools/mod.rs:58

↓ 1 callersFunctiondecompress_zlib

(input: &[u8])

src/lib.rs:226

↓ 1 callersFunctiondelete_feed_elasticsearch

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

src/maple/cleanup.rs:93

↓ 1 callersMethoddestination

(mut self, v: bool)

src/routing_common/ways.rs:151

↓ 1 callersFunctiondetermine_cause

(header: &str, desc: Option<&str>)

src/custom_alerts/metrolink_alerts.rs:471

↓ 1 callersFunctiondetermine_effect

(header: &str, desc: Option<&str>)

src/custom_alerts/metrolink_alerts.rs:504

↓ 1 callersFunctiondiesel_multi_polygon_to_geo

( multipolygon_diesel: postgis_diesel::types::MultiPolygon<postgis_diesel::types::Point>, )

src/postgis_to_diesel.rs:36

↓ 1 callersFunctiondownload_return_eligible_feeds

( gtfs_temp_storage: &str, transitland_meta: &ReturnDmfrAnalysis, pool: &Arc<CatenaryPostgresPool>

src/maple/transitland_download.rs:542

↓ 1 callersMethodedge_bearing_from_center

Calculate bearing of edge from a center point

src/globeflower/station.rs:206

↓ 1 callersMethodedges_at_node

Get edges adjacent to a node

src/globeflower/osm_loader.rs:360

↓ 1 callersMethodenrich_with_stations

(&mut self, pt_index: &OsmPtIndex, config: &SupportGraphConfig)

src/globeflower/support_graph.rs:553

↓ 1 callersMethodentrance

(mut self, v: bool)

src/routing_common/ways.rs:354

↓ 1 callersFunctionestimate_service_date

Estimate if a realtime trip update matches a valid scheduled trip's service date

src/spruce/departures_shared.rs:716

↓ 1 callersMethodexcluded_connections_at_node

Generate excluded_conn list for a node

src/globeflower/restrictions.rs:86

↓ 1 callersMethodexcluded_transitions_at_node

Generate excluded transitions list for a node (returning raw edge IDs)

src/globeflower/restrictions.rs:157

↓ 1 callersMethodexpected_pbf_name

Get the expected OSM PBF filename for this region Returns patterns like "railonly-europe-latest.osm.pbf"

src/globeflower/regions.rs:82

↓ 1 callersFunctionexport_binary

Export to binary format for harebell

src/globeflower/export.rs:145

↓ 1 callersFunctionexport_geojson

Export the support graph to GeoJSON format matching the paper's spec

src/globeflower/export.rs:17

↓ 1 callersFunctionextract_osm_graph

Extract an OSM PBF file and build a complete disk-backed `RoutingGraph`.

src/routing_common/extract.rs:420

↓ 1 callersMethodextract_transitions

Extract transition tuples from edge sequence

src/globeflower/map_matcher.rs:549

↓ 1 callersMethodferry_accessible

(mut self, v: bool)

src/routing_common/ways.rs:241

↓ 1 callersFunctionfetch_alerts_from_root_metrolink

( client: &reqwest::Client, )

src/custom_alerts/metrolink_alerts.rs:421

↓ 1 callersFunctionfetch_amtrak_data

( etcd: &mut etcd_client::KvClient, feed_id: &str, gtfs: &gtfs_structures::Gtfs, client: &reqw

src/alpenrose/custom_rt_feeds/amtrak.rs:5

↓ 1 callersFunctionfetch_bridgeport_data

( etcd: &mut etcd_client::KvClient, feed_id: &str, client: &reqwest::Client, gtfs: &gtfs_struc

src/alpenrose/custom_rt_feeds/bridgeport.rs:295

↓ 1 callersFunctionfetch_chateau_data

( pool: Arc<CatenaryPostgresPool>, chateau: String, stop_ids: Vec<String>, departure_time_chro

src/birch/nearby_departuresv3.rs:620

↓ 1 callersFunctionfetch_chateau_data_optimized

( pool: Arc<CatenaryPostgresPool>, chateau_id: String, stop_ids: Vec<String>, include_shapes:

src/birch/departures_at_osm_station.rs:1252

↓ 1 callersFunctionfetch_chateau_intermediate

( pool: Arc<CatenaryPostgresPool>, chateau: String, stop_ids: Vec<String>, departure_time_chro

src/spruce/nearby_departures.rs:400

↓ 1 callersMethodfetch_cycle

(&mut self, ctx: &mut Context<Self>)

src/spruce/map_coordinator.rs:416

← previous next →301–400 of 1,097, ranked by callers