add show_time_lag to subscription stats function

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:

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 {

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]]