Coverage updates (#33)

kcl-http4s/src/main/scala/kinesis4cats/kcl/http4s/KCLService.scala

@@ -30,6 +30,8 @@ import software.amazon.kinesis.coordinator.WorkerStateChangeListener.WorkerState
 
 import kinesis4cats.kcl.http4s.generated.{Response, ServiceNotReadyError}
 
+// $COVERAGE-OFF$
+
 /** A simple [[https://http4s.org/ Http4s]] service for KCL users. Often times
   * users need to deploy their consumers as a part of an orchestration service,
   * such as Kubernetes. Those orchestration services typically depend on some
@@ -129,3 +131,4 @@ object KCLService {
         .build
     }
 }
+// $COVERAGE-ON$

kcl-tests/src/main/scala/kinesis4cats/kcl/http4s/TestKCLService.scala

@@ -26,6 +26,7 @@ import kinesis4cats.ciris.CirisReader
 import kinesis4cats.kcl.localstack.LocalstackKCLConsumer
 import kinesis4cats.kcl.logging.instances.show._
 
+// $COVERAGE-OFF$
 object TestKCLService extends ResourceApp.Forever {
   override def run(args: List[String]): Resource[IO, Unit] = for {
     streamName <- CirisReader.read[String](List("test", "stream")).resource[IO]
@@ -38,3 +39,4 @@ object TestKCLService extends ResourceApp.Forever {
   } yield ()
 
 }
+// $COVERAGE-ON$

kpl-tests/src/it/scala/kinesis4cats/kpl/KPLProducerSpec.scala

@@ -37,13 +37,25 @@ abstract class KPLProducerSpec(implicit LE: KPLProducer.LogEncoders)
     LocalstackKPLProducer.producerWithStream(streamName, shardCount)
   )
 
-  fixture("test1", 1).test("It should produce successfully") { producer =>
+  fixture("test1", 1).test("It should run commands successfully") { producer =>
     val testData = Arbitrary.arbitrary[TestData].one
     val testDataBB = ByteBuffer.wrap(testData.asJson.noSpaces.getBytes())
 
-    producer.put(new UserRecord("test1", "partitionKey", testDataBB)).map {
-      result =>
-        assert(result.isSuccessful())
-    }
+    for {
+      _ <- producer
+        .put(new UserRecord("test1", "partitionKey", testDataBB))
+        .map { result =>
+          assert(result.isSuccessful())
+        }
+      _ <- producer.put("test1", "partitionKey", None, testDataBB)
+      _ <- producer.getOutstandingRecordsCount()
+      _ <- producer.getOldestRecordTimeInMillis()
+      _ <- producer.getMetrics()
+      _ <- producer.getMetrics(1)
+      _ <- producer.getMetrics("foo")
+      _ <- producer.getMetrics("foo", 1)
+      _ <- producer.flush("test1")
+      _ <- producer.flush()
+    } yield ()
   }
 }

kpl/src/main/scala/kinesis4cats/kpl/KPLProducer.scala

@@ -189,7 +189,8 @@ class KPLProducer[F[_]] private (
             stream,
             partitionKey,
             explicitHashKey.orNull,
-            data
+            data,
+            schema
           )
         )
       )