Geostreams

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

val ACCEPT: String

val ACCEPTED: Int

val ACCEPT_CHARSET: String

val ACCEPT_ENCODING: String

val ACCEPT_LANGUAGE: String

val ACCEPT_RANGES: String

val ACCESS_CONTROL_ALLOW_CREDENTIALS: String

val ACCESS_CONTROL_ALLOW_HEADERS: String

val ACCESS_CONTROL_ALLOW_METHODS: String

val ACCESS_CONTROL_ALLOW_ORIGIN: String

val ACCESS_CONTROL_EXPOSE_HEADERS: String

val ACCESS_CONTROL_MAX_AGE: String

val ACCESS_CONTROL_REQUEST_HEADERS: String

val ACCESS_CONTROL_REQUEST_METHOD: String

val AGE: String

val ALLOW: String

val AUTHORIZATION: String

val Accepted: Status

def AuthenticatedAction: ActionBuilder[UserRequest]

call code iff user is logged in

val BAD_GATEWAY: Int

val BAD_REQUEST: Int

val BINARY: String

val BadGateway: Status

val BadRequest: Status

val CACHE_CONTROL: String

val CHUNKED: String

val CONFLICT: Int

val CONNECTION: String

val CONTENT_DISPOSITION: String

val CONTENT_ENCODING: String

val CONTENT_LANGUAGE: String

val CONTENT_LENGTH: String

val CONTENT_LOCATION: String

val CONTENT_MD5: String

val CONTENT_RANGE: String

val CONTENT_TRANSFER_ENCODING: String

val CONTENT_TYPE: String

val CONTINUE: Int

val COOKIE: String

val CREATED: Int

def CSS(implicit codec: Codec): String

val Conflict: Status

val Created: Status

val DATE: String

def DisabledAction: ActionBuilder[UserRequest]

Disable a route without having to comment out the entry in the routes file.

val ETAG: String

def EVENT_STREAM(implicit codec: Codec): String

val EXPECT: String

val EXPECTATION_FAILED: Int

val EXPIRES: String

val EntityTooLarge: Status

val ExpectationFailed: Status

val FAILED_DEPENDENCY: Int

val FORBIDDEN: Int

def FORM(implicit codec: Codec): String

val FOUND: Int

val FROM: String

val FailedDependency: Status

val Forbidden: Status

def Found(url: String): SimpleResult

val GATEWAY_TIMEOUT: Int

val GONE: Int

val GatewayTimeout: Status

val Gone: Status

val HOST: String

def HTML(implicit codec: Codec): String

val HTTP_1_0: String

val HTTP_1_1: String

val HTTP_VERSION_NOT_SUPPORTED: Int

val HttpVersionNotSupported: Status

val IF_MATCH: String

val IF_MODIFIED_SINCE: String

val IF_NONE_MATCH: String

val IF_RANGE: String

val IF_UNMODIFIED_SINCE: String

val INSUFFICIENT_STORAGE: Int

val INTERNAL_SERVER_ERROR: Int

val InsufficientStorage: Status

val InternalServerError: Status

def JAVASCRIPT(implicit codec: Codec): String

def JSON(implicit codec: Codec): String

val LAST_MODIFIED: String

val LENGTH_REQUIRED: Int

val LOCATION: String

val LOCKED: Int

val Locked: Status

val MAX_FORWARDS: String

val METHOD_NOT_ALLOWED: Int

val MOVED_PERMANENTLY: Int

val MULTIPLE_CHOICES: Int

val MULTI_STATUS: Int

val MethodNotAllowed: Status

def MovedPermanently(url: String): SimpleResult

val MultiStatus: Status

val NON_AUTHORITATIVE_INFORMATION: Int

val NOT_ACCEPTABLE: Int

val NOT_FOUND: Int

val NOT_IMPLEMENTED: Int

val NOT_MODIFIED: Int

val NO_CONTENT: Int

val NoContent: SimpleResult

val NonAuthoritativeInformation: Status

val NotAcceptable: Status

val NotFound: Status

val NotImplemented: Status

val NotModified: SimpleResult

val OK: Int

val ORIGIN: String

val Ok: Status

val PARTIAL_CONTENT: Int

val PAYMENT_REQUIRED: Int

val PRAGMA: String

val PRECONDITION_FAILED: Int

val PROXY_AUTHENTICATE: String

val PROXY_AUTHENTICATION_REQUIRED: Int

val PROXY_AUTHORIZATION: String

val PartialContent: Status

def PermissionAction(permission: Permission, resourceRef: Option[ResourceRef] = None, affectedResource: Option[ResourceRef] = None): ActionBuilder[UserRequest]

call code iff user has right permission for resource

val PreconditionFailed: Status

def PrivateServerAction: ActionBuilder[UserRequest]

Use when you want to require the user to be logged in on a private server or the server is public.

val RANGE: String

val REFERER: String

val REQUESTED_RANGE_NOT_SATISFIABLE: Int

val REQUEST_ENTITY_TOO_LARGE: Int

val REQUEST_TIMEOUT: Int

val REQUEST_URI_TOO_LONG: Int

val RESET_CONTENT: Int

val RETRY_AFTER: String

def Redirect(call: Call): SimpleResult

def Redirect(url: String, queryString: Map[String, Seq[String]], status: Int): SimpleResult

def Redirect(url: String, status: Int): SimpleResult

val RequestTimeout: Status

val ResetContent: SimpleResult

val SEE_OTHER: Int

val SERVER: String

val SERVICE_UNAVAILABLE: Int

val SET_COOKIE: String

val SET_COOKIE2: String

val SWITCHING_PROTOCOLS: Int

def SeeOther(url: String): SimpleResult

def ServerAdminAction: ActionBuilder[UserRequest]

call code iff user is a server admin

val ServiceUnavailable: Status

def Status(code: Int): Status

val TE: String

val TEMPORARY_REDIRECT: Int

def TEXT(implicit codec: Codec): String

val TODO: Action[AnyContent]

val TOO_MANY_REQUEST: Int

val TRAILER: String

val TRANSFER_ENCODING: String

def TemporaryRedirect(url: String): SimpleResult

val TooManyRequest: Status

val UNAUTHORIZED: Int

val UNPROCESSABLE_ENTITY: Int

val UNSUPPORTED_MEDIA_TYPE: Int

val UPGRADE: String

val USER_AGENT: String

val USE_PROXY: Int

val Unauthorized: Status

val UnprocessableEntity: Status

val UnsupportedMediaType: Status

val UriTooLong: Status

def UserAction(needActive: Boolean): ActionBuilder[UserRequest]

get user if logged in

val VARY: String

val VIA: String

val WARNING: String

val WWW_AUTHENTICATE: String

def XML(implicit codec: Codec): String

val X_FORWARDED_FOR: String

val X_FORWARDED_HOST: String

val X_FORWARDED_PORT: String

val X_FORWARDED_PROTO: String

def addDatapoint(invalidateCache: Boolean): Action[JsValue]

def addDatapoints(invalidateCache: Boolean): Action[JsValue]

def addHeaders(row: JsArray, headers: ListBuffer[Header], ignore: Array[String], prefix: String, prefixSeperator: String, hidePrefix: Boolean, fixGeometry: Boolean): Unit

Helper function to create list of headers

def addHeaders(row: JsObject, headers: ListBuffer[Header], ignore: Array[String], prefix: String, prefixSeperator: String, hidePrefix: Boolean, fixGeometry: Boolean): Unit

Helper function to create list of headers

final def asInstanceOf[T0]: T0

def binData(data: PeekIterator[JsObject], time: String, depth: Double, keepRaw: Boolean): Option[JsObject]

Compute the average value for a sensor.

def binDatapoints(time: String, depth: Double, keepRaw: Boolean, since: Option[String], until: Option[String], geocode: Option[String], stream_id: Option[String], sensor_id: Option[String], sources: List[String], attributes: List[String]): Action[AnyContent]

def cacheFetch(description: JsObject): Option[Enumerator[Array[Byte]]]

Checks to see if a file with the MD5(description) exists, if so this will return a Enumerator of that file, otherwise it will return None.

def cacheFetchAction(filename: String): Action[AnyContent]

Return the file with the given name.

def cacheInvalidate(sensor_id: Option[String] = None, stream_id: Option[String] = None): (Array[String], Array[String])

Removes all files from the cache, or the files associated with either sensor_id or stream_id as query parameters.

def cacheInvalidate(description: JsObject): Unit

Remove the file with the MD5(description) from the cache as well as the associated json file.

def cacheInvalidateAction(sensor_id: Option[String] = None, stream_id: Option[String] = None): Action[AnyContent]

Removes all files from the cache

def cacheListAction(): Action[AnyContent]

Return a list of all files and their descriptions in the cache.

def cacheWrite(description: JsObject, data: Enumerator[String]): Enumerator[String]

Write the file to cache, filename in cache is based on MD5(description).

def calculate(operator: String, data: Iterator[JsObject], window_start: Option[String], window_end: Option[String], semiGroup: Boolean, binning: String): Iterator[JsObject]

def chunk(trailers: Option[Iteratee[Array[Byte], Seq[(String, String)]]]): Enumeratee[Array[Byte], Array[Byte]]

def chunk: Enumeratee[Array[Byte], Array[Byte]]

def clone(): AnyRef

def computeAverage(data: PeekIterator[JsObject]): Option[JsObject]

Compute the average value for a sensor.

def computeAverageArea(data: List[JsObject], geocode: Option[String]): List[JsObject]

Compute the average values over an area.

def computeCountSensor(data: List[JsObject]): List[JsObject]

Compute the number of times a specific property is found in the data.

def computeTrends(data: PeekIterator[JsObject], since: DateTime, until: DateTime, semiGroup: Boolean, binning: String): Option[JsObject]

Compute the average value for each sensor.

def counts(): Action[AnyContent]

def createSensor(): Action[JsValue]

def createStream(): Action[JsValue]

implicit val datapoints: Reads[(String, Option[String], String, List[Double], JsValue, String)]

implicit val datapointsBulk: Reads[(String, Option[String], String, JsValue, JsValue)]

implicit val datapointsGeoJSON: Reads[(String, Option[String], String, JsValue, JsValue, String)]

def dechunk: Enumeratee[Array[Byte], Array[Byte]]

def deleteAll(): Action[AnyContent]

def deleteDatapoint(id: String): Action[AnyContent]

def deleteSensor(id: String): Action[AnyContent]

def deleteStream(id: String): Action[AnyContent]

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def filterDataBySemi(obj: JsObject, semi: Option[String]): Boolean

def finalize(): Unit

implicit def flash(implicit request: RequestHeader): Flash

def formatResult(data: Iterator[JsObject], format: String): Enumerator[String]

final def getClass(): Class[_]

def getConfig: Action[AnyContent]

def getDatapoint(id: String): Action[AnyContent]

def getHeader(key: Any, prefix: String, prefixSeperator: String, hidePrefix: Boolean, fixGeometry: Boolean): String

Helper function to create the text that is printed as header

def getPrefix(key: Any, prefix: String, prefixSeperator: String): String

Helper function to create a new prefix based on the key, and current prefix

def getSensor(id: String): Action[AnyContent]

def getSensorStatistics(id: String): Action[AnyContent]

def getSensorStreams(id: String): Action[AnyContent]

def getStream(id: String): Action[AnyContent]

def getUser[A](request: Request[A]): UserRequest[A]

Return user based on request object

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

def jsonToCSV(data: Iterator[JsObject]): Enumerator[String]

Returns the JSON formatted as CSV.

def jsonp(data: Enumerator[String], request: Request[Any]): SimpleResult

Tries to transform a response into a JavaScript expression.

def jsonp(data: JsValue, request: Request[Any]): SimpleResult

Returns the request potentially as jsonp

def jsonp(data: String, request: Request[Any]): SimpleResult

Returns the request potentially as jsonp

implicit def lang(implicit request: RequestHeader): Lang

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

object parse

def patchStreamMetadata(id: String): Action[JsValue]

val pluginNotEnabled: SimpleResult

def printHeader(headers: ListBuffer[Header]): String

Helper function to recursively print the header

def printRow(row: JsArray, headers: ListBuffer[Header], prefix: String, prefixSeperator: String): String

Helper function to print data row of JSON Array.

def printRow(row: JsObject, headers: ListBuffer[Header], prefix: String, prefixSeperator: String): String

Helper function to print data row of JSON Object.

def searchDatapoints(operator: String, since: Option[String], until: Option[String], geocode: Option[String], stream_id: Option[String], sensor_id: Option[String], sources: List[String], attributes: List[String], format: String, semi: Option[String], onlyCount: Boolean, window_start: Option[String] = None, window_end: Option[String] = None, binning: String, geojson: Option[String]): Action[AnyContent]

def searchSensors(geocode: Option[String], sensor_name: Option[String], geojson: Option[String]): Action[AnyContent]

def searchStreams(geocode: Option[String], stream_name: Option[String], geojson: Option[String]): Action[AnyContent]

implicit val sensors: Reads[(String, String, List[Double], JsValue)]

implicit val sensorsGeoJSON: Reads[(String, String, JsValue, JsValue)]

implicit def session(implicit request: RequestHeader): Session

implicit val streams: Reads[(String, String, List[Double], JsValue, String)]

implicit val streamsGeoJSON: Reads[(String, String, JsValue, JsValue, String)]

final def synchronized[T0](arg0: ⇒ T0): T0

def timeBins(time: String, startTime: DateTime, endTime: DateTime): Map[String, JsObject]

def toString(): String

def updateSensorMetadata(id: String): Action[JsValue]

def updateStatisticsSensor(id: String): Action[AnyContent]

def updateStatisticsStream(id: String): Action[AnyContent]

def updateStatisticsStreamSensor(): Action[AnyContent]

val userservice: UserService

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

def withCharset(mimeType: String)(implicit codec: Codec): String

def Async(promise: Future[Result]): AsyncResult