Packages

class JVMSharedServer extends Logging

Linear Supertypes
Logging, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. JVMSharedServer
  2. Logging
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new JVMSharedServer(name: String, host: String, port: Int, maxAttempts: Int, handleResponseErrors: Boolean)

Type Members

  1. type Body = HTTPRequestData
  2. type Exchange = HttpExchange
  3. type ID = String
  4. type Request = (Body, Exchange)

Value Members

  1. val address: String
  2. def getRequests(start: Long, end: Long): IndexedSeq[(ID, Body)]
  3. def incrementCurrentBatch(): Unit
  4. val machine: String
  5. def respond(batch: Long, uuid: String, response: HTTPResponseData): Unit
  6. val serverIdentity: String
  7. def stop(): Unit
  8. def trimBatchesBefore(batch: Long): Unit
  9. def updateCurrentBatch(currentOffset: Long): Unit
  10. def updateNPartitions(n: Int): Unit