aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/xyz/driver/core/rest
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/scala/xyz/driver/core/rest')
-rw-r--r--src/main/scala/xyz/driver/core/rest/DnsDiscovery.scala11
-rw-r--r--src/main/scala/xyz/driver/core/rest/HttpRestServiceTransport.scala4
-rw-r--r--src/main/scala/xyz/driver/core/rest/ServiceDescriptor.scala16
3 files changed, 29 insertions, 2 deletions
diff --git a/src/main/scala/xyz/driver/core/rest/DnsDiscovery.scala b/src/main/scala/xyz/driver/core/rest/DnsDiscovery.scala
new file mode 100644
index 0000000..38880d4
--- /dev/null
+++ b/src/main/scala/xyz/driver/core/rest/DnsDiscovery.scala
@@ -0,0 +1,11 @@
+package xyz.driver.core
+package rest
+
+class DnsDiscovery(transport: HttpRestServiceTransport, overrides: Map[String, String]) {
+
+ def discover[A](implicit descriptor: ServiceDescriptor[A]): A = {
+ val url = overrides.getOrElse(descriptor.name, s"https://{descriptor.name}")
+ descriptor.connect(transport, url)
+ }
+
+}
diff --git a/src/main/scala/xyz/driver/core/rest/HttpRestServiceTransport.scala b/src/main/scala/xyz/driver/core/rest/HttpRestServiceTransport.scala
index e60998f..e31635b 100644
--- a/src/main/scala/xyz/driver/core/rest/HttpRestServiceTransport.scala
+++ b/src/main/scala/xyz/driver/core/rest/HttpRestServiceTransport.scala
@@ -17,8 +17,8 @@ import scala.util.{Failure, Success}
class HttpRestServiceTransport(
applicationName: Name[App],
applicationVersion: String,
- actorSystem: ActorSystem,
- executionContext: ExecutionContext,
+ val actorSystem: ActorSystem,
+ val executionContext: ExecutionContext,
reporter: Reporter)
extends ServiceTransport {
diff --git a/src/main/scala/xyz/driver/core/rest/ServiceDescriptor.scala b/src/main/scala/xyz/driver/core/rest/ServiceDescriptor.scala
new file mode 100644
index 0000000..646fae8
--- /dev/null
+++ b/src/main/scala/xyz/driver/core/rest/ServiceDescriptor.scala
@@ -0,0 +1,16 @@
+package xyz.driver.core
+package rest
+import scala.annotation.implicitNotFound
+
+@implicitNotFound(
+ "Don't know how to communicate with service ${S}. Make sure an implicit ServiceDescriptor is" +
+ "available. A good place to put one is in the service's companion object.")
+trait ServiceDescriptor[S] {
+
+ /** The service's name. Must be unique among all services. */
+ def name: String
+
+ /** Get an instance of the service. */
+ def connect(transport: HttpRestServiceTransport, url: String): S
+
+}