add show_time_lag to subscription stats function (#200)

* add show_time_lag to subscription stats function Signed-off-by: Roisin Jin <[email protected]> Co-authored-by: Roisin Jin <[email protected]>
zalando-nakadi · Sep 9, 2022 · 4d38d7d · 4d38d7d
1 parent 48c3236
commit 4d38d7d
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 3 deletions.
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -1,7 +1,7 @@
 version: '2'
 services:
   nakadi:
-    image: docker.pkg.github.com/adyach/nakadi-docker/nakadi:latest
+    image: adyach/nakadi-docker:3.3.8
     ports:
      - "8080:8080"
     depends_on:

diff --git a/src/main/scala/org/zalando/kanadi/api/Subscriptions.scala b/src/main/scala/org/zalando/kanadi/api/Subscriptions.scala
@@ -1625,12 +1625,17 @@ case class Subscriptions(baseUri: URI, oAuth2TokenProvider: Option[OAuth2TokenPr
     *   operational troubleshooting and log analysis.
     * @return
     */
-  def stats(subscriptionId: SubscriptionId)(implicit
+  def stats(subscriptionId: SubscriptionId, showTimeLag: Boolean = false)(implicit
       flowId: FlowId = randomFlowId(),
       executionContext: ExecutionContext
   ): Future[Option[SubscriptionStats]] = {
+    val showTimeLagQuery: Query = if (showTimeLag) {
+      Query("show_time_lag" -> showTimeLag.toString)
+    } else Query.Empty
+
     val uri = baseUri_
       .withPath(baseUri_.path / "subscriptions" / subscriptionId.id.toString / "stats")
+      .withQuery(showTimeLagQuery)
 
     for {
       headers <- oAuth2TokenProvider match {

diff --git a/src/main/scala/org/zalando/kanadi/api/SubscriptionsInterface.scala b/src/main/scala/org/zalando/kanadi/api/SubscriptionsInterface.scala
@@ -125,7 +125,7 @@ trait SubscriptionsInterface {
 
   def closeHttpConnection(subscriptionId: SubscriptionId, streamId: StreamId): Boolean
 
-  def stats(subscriptionId: SubscriptionId)(implicit
+  def stats(subscriptionId: SubscriptionId, showTimeLag: Boolean = false)(implicit
       flowId: FlowId = randomFlowId(),
       executionContext: ExecutionContext
   ): Future[Option[SubscriptionStats]]