Expose configuration of interceptors via LedgerFactory (digital-asset…

…#6224)
kgeonw · Jun 4, 2020 · 60b46bb · 60b46bb
1 parent 8e3e296
commit 60b46bb
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/...tils/app/src/main/scala/com/daml/ledger/participant/state/kvutils/app/LedgerFactory.scala b/...tils/app/src/main/scala/com/daml/ledger/participant/state/kvutils/app/LedgerFactory.scala
@@ -19,6 +19,7 @@ import com.daml.platform.configuration.{
 }
 import com.daml.platform.indexer.{IndexerConfig, IndexerStartupMode}
 import com.daml.resources.ResourceOwner
+import io.grpc.ServerInterceptor
 import scopt.OptionParser
 
 trait ConfigProvider[ExtraConfig] {
@@ -78,6 +79,9 @@ trait ConfigProvider[ExtraConfig] {
   def authService(config: Config[ExtraConfig]): AuthService =
     AuthServiceWildcard
 
+  def interceptors(config: Config[ExtraConfig]): List[ServerInterceptor] =
+    List.empty
+
   def createMetrics(
       participantConfig: ParticipantConfig,
       config: Config[ExtraConfig],

diff --git a/...ate/kvutils/app/src/main/scala/com/daml/ledger/participant/state/kvutils/app/Runner.scala b/...ate/kvutils/app/src/main/scala/com/daml/ledger/participant/state/kvutils/app/Runner.scala
@@ -94,6 +94,7 @@ final class Runner[T <: ReadWriteService, Extra](
                 transformIndexService = service => new TimedIndexService(service, metrics),
                 metrics = metrics,
                 timeServiceBackend = factory.timeServiceBackend(config),
+                otherInterceptors = factory.interceptors(config),
                 engine = sharedEngine,
                 lfValueTranslationCache = lfValueTranslationCache,
               ).acquire()