)]}'
{
  "commit": "c185ba86c8b484198d71068057e73d7a5eedae8c",
  "tree": "ed93fc9a732f917a3b61a8fd5ca547b99acfbf43",
  "parents": [
    "c11d71b30d444f0a5fbe90b924ad0a9b4216dca2"
  ],
  "author": {
    "name": "Cole Greer",
    "email": "cole@colegreer.ca",
    "time": "Mon May 25 13:45:20 2026 -0700"
  },
  "committer": {
    "name": "Cole Greer",
    "email": "cole@colegreer.ca",
    "time": "Mon May 25 13:45:20 2026 -0700"
  },
  "message": "Add streaming backpressure via bounded queue in gremlin-driver\n\nBound the ByteBufQueueInputStream queue and use Netty\u0027s setAutoRead(false)\nto apply TCP backpressure when the client cannot keep up with the server\u0027s\nstreaming rate.\n\nWhen the queue is full, the handler pauses channel reads and blocks briefly\nto enqueue the current chunk. The consumer resumes reads when the queue\ndrains below half capacity via a callback dispatched to the event loop.\n\nThe buffer size defaults to 256 chunks and is configurable via\nCluster.Builder.streamBufferSize().\n",
  "tree_diff": [
    {
      "type": "modify",
      "old_id": "59b9d02365c0a4ec819be49247396a4c389d0f84",
      "old_mode": 33188,
      "old_path": "gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/Channelizer.java",
      "new_id": "4d23aa356130242c5f5eb3d4d89ebe53ef255dd5",
      "new_mode": 33188,
      "new_path": "gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/Channelizer.java"
    },
    {
      "type": "modify",
      "old_id": "d4a3967f0292aaef833e14d3ac63ad72e50ce9b9",
      "old_mode": 33188,
      "old_path": "gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/Cluster.java",
      "new_id": "40644df4d6da84a41ae24048d58f43b4f3647bfd",
      "new_mode": 33188,
      "new_path": "gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/Cluster.java"
    },
    {
      "type": "modify",
      "old_id": "12a1de646c8abc9703d638899bfdab715c181a96",
      "old_mode": 33188,
      "old_path": "gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/Connection.java",
      "new_id": "8228c5b03205336ea904f2988e8870ae3d0f9f41",
      "new_mode": 33188,
      "new_path": "gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/Connection.java"
    },
    {
      "type": "modify",
      "old_id": "907909c71a9edc49d669989b7f24442d19a470a9",
      "old_mode": 33188,
      "old_path": "gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/Settings.java",
      "new_id": "b204f8181a908a1a7b44a93ccf3df6218420a732",
      "new_mode": 33188,
      "new_path": "gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/Settings.java"
    },
    {
      "type": "modify",
      "old_id": "607fd6bdf94e667381a614ffdebe0caf2900c520",
      "old_mode": 33188,
      "old_path": "gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/handler/HttpStreamingResponseHandler.java",
      "new_id": "c2968b72b9389e736a196d616b5c2d7af95df604",
      "new_mode": 33188,
      "new_path": "gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/handler/HttpStreamingResponseHandler.java"
    },
    {
      "type": "modify",
      "old_id": "757b2821cb067e9804ec82a9d1383ccc773c43da",
      "old_mode": 33188,
      "old_path": "gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/stream/ByteBufQueueInputStream.java",
      "new_id": "a613c7b13b3e75ae1a896b0732a0d8340242b3eb",
      "new_mode": 33188,
      "new_path": "gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/stream/ByteBufQueueInputStream.java"
    },
    {
      "type": "modify",
      "old_id": "91ba9cf28a4abec3d5de1d015c10587dde04cb3d",
      "old_mode": 33188,
      "old_path": "gremlin-driver/src/test/java/org/apache/tinkerpop/gremlin/driver/handler/ByteBufQueueInputStreamTest.java",
      "new_id": "9c0378b6d5da11cb06fe176bd382bb06b9b846f5",
      "new_mode": 33188,
      "new_path": "gremlin-driver/src/test/java/org/apache/tinkerpop/gremlin/driver/handler/ByteBufQueueInputStreamTest.java"
    },
    {
      "type": "modify",
      "old_id": "fdd37818a4473704a70f5a1cbe7a885980a8b4c4",
      "old_mode": 33188,
      "old_path": "gremlin-driver/src/test/java/org/apache/tinkerpop/gremlin/driver/handler/HttpStreamingResponseHandlerTest.java",
      "new_id": "a9b61ee0070852b6deb6c93fe89fdccb308ac1d4",
      "new_mode": 33188,
      "new_path": "gremlin-driver/src/test/java/org/apache/tinkerpop/gremlin/driver/handler/HttpStreamingResponseHandlerTest.java"
    }
  ]
}