feat(ingest): receive Cloud Logging entries from GCP Pub/Sub push

apps/ingest/Cargo.toml

@@ -60,6 +60,9 @@ tokio-postgres = "0.7"
 deadpool-postgres = "0.14"
 tokio-postgres-rustls = "0.13"
 rustls = { version = "0.23", features = ["ring"] }
+# RS256 signatures of the ID tokens Pub/Sub signs its GCP pushes with. Already
+# in the tree through rustls.
+ring = "0.17"
 webpki-roots = "0.26"
 # Opt-in profiler (https://hotpath.rs). Every macro is a no-op and no profiler
 # code is compiled unless `--features hotpath` is passed; the `tokio` and

apps/ingest/alchemy.run.ts

@@ -616,6 +616,7 @@ export const createMapleIngest = ({ stage, region, domains, profile, dbLogin }:
 				...(yield* optionalPlain("INGEST_BATCH_MAX_WAIT_MS")),
 				...(yield* optionalPlain("INGEST_ORG_QUEUE_MAX_BYTES")),
 				...(yield* optionalPlain("INGEST_ORG_MAX_IN_FLIGHT")),
+				...(yield* optionalPlain("INGEST_GCP_ORG_MAX_IN_FLIGHT")),
 				...(yield* optionalPlain("INGEST_REQUEST_TIMEOUT_SECS")),
 				...(yield* optionalPlain("INGEST_QUEUE_MAX_AGE_SECS")),
 				...(yield* optionalPlain("INGEST_MAX_REQUEST_BODY_BYTES")),