diff options
Diffstat (limited to 'service-monitor')
-rw-r--r-- | service-monitor/src/test/scala/PrintInstanceObservables.scala | 33 | ||||
-rw-r--r-- | service-monitor/src/test/scala/PrintServiceStates.scala | 24 |
2 files changed, 0 insertions, 57 deletions
diff --git a/service-monitor/src/test/scala/PrintInstanceObservables.scala b/service-monitor/src/test/scala/PrintInstanceObservables.scala deleted file mode 100644 index b35fac6efe1..00000000000 --- a/service-monitor/src/test/scala/PrintInstanceObservables.scala +++ /dev/null @@ -1,33 +0,0 @@ -// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -import com.yahoo.config.subscription.ConfigSourceSet -import com.yahoo.vespa.applicationmodel.{ApplicationInstance, ApplicationInstanceReference} -import com.yahoo.vespa.service.monitor.config.InstancesObservables - -import org.json4s.native.Serialization -import org.json4s.{CustomKeySerializer, NoTypeHints} - - -/** - * @author tonytv - */ -object PrintInstanceObservables { - def main(args: Array[String]): Unit = { - val sourceSet = new ConfigSourceSet("tcp/test1-node:19070") - - val observables = new InstancesObservables(sourceSet) - - observables.servicesPerInstance.subscribe(prettyPrint _) - observables.slobroksPerInstance.subscribe(println(_)) - val subscription = observables.connect() - - Thread.sleep(100000) - subscription.unsubscribe() - } - - private def prettyPrint(map: Map[ApplicationInstanceReference, ApplicationInstance[Void]]): Unit = { - implicit val formats = Serialization.formats(NoTypeHints) + - new CustomKeySerializer[Object](formats => ({case string => ???} , { case ref: AnyRef => ref.toString })) - - println(Serialization.writePretty(map)) - } -} diff --git a/service-monitor/src/test/scala/PrintServiceStates.scala b/service-monitor/src/test/scala/PrintServiceStates.scala deleted file mode 100644 index 02a9f5d89ec..00000000000 --- a/service-monitor/src/test/scala/PrintServiceStates.scala +++ /dev/null @@ -1,24 +0,0 @@ -// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -import com.yahoo.config.subscription.ConfigSourceSet -import com.yahoo.vespa.config.GenerationCounter -import com.yahoo.vespa.applicationmodel.HostName -import com.yahoo.vespa.service.monitor.SlobrokAndConfigIntersector - -/** - * Quick hack to just see some results. - * - * @author bakksjo - */ -object PrintServiceStates { - def main(args: Array[String]): Unit = { - val intersector = new SlobrokAndConfigIntersector( - new ConfigSourceSet("tcp/test1-node:19070"), - multiTenantConfigServerHostNames = Set("config-server1", "config-server2").map(s => new HostName(s)), - new GenerationCounter { - override def increment = ??? - override def get = 1L - }) - Thread.sleep(100000) - intersector.deconstruct() - } -} |