//#flag

//#complex_flag

val addr = flag("bind", new InetSocketAddress(0), "Bind address")

val durations = flag("alarms", (1.second, 5.second), "2 alarm durations")

//#complex_flag

//#stats

val counter = statsReceiver.counter("requests_counter")

//#stats

//#fail_fast

override def failfastOnFlagsNotParsed: Boolean = true

//#fail_fast

val service = new Service[Request, Response] {

def apply(request: Request) = {

//#log_usage

debug("Received a request at " + Time.now)

//#log_usage

//#stats_usage

counter.incr()

//#stats_usage

val response = Response(request.version, Status.Ok)

response.contentString = what() + "\n"

Future.value(response)

}

}

def main(): Unit = {

// We could create a new http server but in this case we use the

// one already started for /admin/* endpoints.

// The `TwitterServer` trait exposes an `adminHttpServer` that serve all routes

// registered in the HttpMuxer object, we just have to add our own.

//#registering_http_service

HttpMuxer.addHandler("/echo", service)

HttpMuxer.addHandler("/echo/", service)

//#registering_http_service

// And wait on the server

Await.ready(adminHttpServer)

}