Logflare / logflare / d99ab0b7ccc6a752f60e98d214cb418b67812833

81%

Build Type

push

github

Committed by web-flow

Commit Message

BQ storage write api - Mint pool (#3272)

* feat: Add gRPC supervised channel pool for Mint adapter

Upgrades grpc ~> 0.11.0 and adds a persistent, supervised
round-robin channel pool using the built-in Mint adapter
to replace the per-call GRPC.Stub.connect
(backed by the custom Finch adapter).

- Add GrpcPool supervisor with per-index GrpcChannelMonitor GenServers;
  channels are registered in a per-pool Registry and selected via an
  atomic counter for lock-free round-robin dispatch
- Add GrpcAuthInterceptor: fetches a fresh Goth token per call and
  injects it as gRPC metadata, replacing the per-call auth header on
  the channel
- Remove local Google.Rpc.* protobuf definitions now provided by the
  googleapis transitive dep (pulled in by grpc 0.11.x)
- Add GRPC.Client.Supervisor to Networking.pools/0 (required by
  grpc 0.11.x for outbound connections)
- google_api_client: use GrpcPool.get_channel/1 and remove Goth.fetch;
  auth is now handled transparently by the interceptor

* Add tests for pool, interceptor and channel monitor

* Improve channel monitor tests

* fix: GRPC.Server.Supervisor setup

* fix: Leaking channel processes

* fix: proper response stream handling

* temp: Compare implementations

* Remove Finch-based GRPC Write API, fix tests

* feat: Make Grpc Write API pool size configurable

* fix: apply lint rule

* fix tests

Coverage Stats

57 of 69 new or added lines in 6 files covered. (82.61%)

5 existing lines in 3 files now uncovered.

11760 of 15171 relevant lines covered (77.52%)

4901.48 hits per line