Packages

  • package root
    Definition Classes
    root
  • package com
    Definition Classes
    root
  • package opendatagroup
    Definition Classes
    com
  • package fastscore

    An example interaction with FastScore

    An example interaction with FastScore

    scala> import com.opendatagroup.fastscore.fleet._
    scala> implicit val proxy = new Proxy("https://localhost:8000")
    scala> val connect = new Connect()
    scala> import com.opendatagroup.fastscore.assets._
    scala> val model = Model.fromFile("./preprocessor.R")
    scala> val modelmanage = connect.lookup("model-manage") match { case l: List[ModelManage] if l.length == 1 => l(0) }
    scala> modelmanage.models.put("preprocessor", model)
    Definition Classes
    opendatagroup
  • package swagger
    Definition Classes
    fastscore
  • package api1
    Definition Classes
    swagger
  • ConnectApi
  • EngineApi
  • LoginApi
  • ModelManageApi

class EngineApi extends AnyRef

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

Instance Constructors

  1. new EngineApi(defBasePath: String = "https://localhost/api/1/service", defApiInvoker: ApiInvoker = ApiInvoker)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def activeSensorAttach(instance: String, desc: Any): Option[InlineResponse2001]

    instance

    instance name

    desc

    sensor descriptor

    returns

    InlineResponse2001

  5. def activeSensorAvailable(instance: String): Option[List[String]]

    instance

    instance name

    returns

    List[String]

  6. def activeSensorDescribe(instance: String, tapId: Integer): Option[InlineResponse2002]

    instance

    instance name

    tapId

    The identifier of the sensor connection

    returns

    InlineResponse2002

  7. def activeSensorDetach(instance: String, tapId: Integer): Any

    instance

    instance name

    tapId

    The identifier of the sensor connection

    returns

    void

  8. def activeSensorList(instance: String): Option[List[InlineResponse200]]

    instance

    instance name

    returns

    List[InlineResponse200]

  9. def addHeader(key: String, value: String): HashMap[String, String]
  10. var apiInvoker: ApiInvoker
  11. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  12. var basePath: String
  13. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  14. val defBasePath: String
  15. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  17. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  18. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  19. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  20. def healthGet(instance: String): Option[HealthInfo]

    instance

    instance name

    returns

    HealthInfo

  21. def inputStreamSet(instance: String, stream: Any): Any

    instance

    instance name

    stream

    The input stream descriptor

    returns

    void

  22. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  23. def jobDelete(instance: String): Any

    instance

    instance name

    returns

    void

  24. def jobIoInput(instance: String, data: String, slot: String): Any

    instance

    instance name

    data

    Input data

    slot

    The stream slot

    returns

    void

  25. def jobIoInput0(instance: String): Any

    instance

    instance name

    returns

    void

  26. def jobIoOutput(instance: String, slot: String): Option[String]

    instance

    instance name

    slot

    The stream slot

    returns

    String

  27. def jobIoOutput1(instance: String): Any

    instance

    instance name

    returns

    void

  28. def jobSampleCpu(instance: String, duration: Option[Integer] = None): Option[CpuUsageInfo]

    instance

    instance name

    duration

    The number of seconds to sample CPU usage for (optional)

    returns

    CpuUsageInfo

  29. def jobScale(instance: String, n: Integer): Any

    instance

    instance name

    n

    The number of jets to scale model to

    returns

    void

  30. def jobStateRestore(instance: String, state: String): Any

    instance

    instance name

    state

    The model state blob

    returns

    void

  31. def jobStatus(instance: String, fields: Option[String] = None): Option[ManifoldInfo]

    instance

    instance name

    fields

    A comma-separated list of field names (slots, jets, snapshots, state) (optional)

    returns

    ManifoldInfo

  32. def modelLoad(instance: String, data: String, dryRun: Option[Boolean] = None, _contentType: Option[String] = None, contentDisposition: Option[String] = None): Option[VerifyInfo]

    instance

    instance name

    data

    model+attachments

    dryRun

    verificaton only (optional)

    _contentType

    model MIME type (optional)

    contentDisposition

    pass model name (optional)

    returns

    VerifyInfo

  33. def modelUnload(instance: String): Any

    instance

    instance name

    returns

    void

  34. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  35. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  36. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  37. def outputStreamSet(instance: String, stream: String): Any

    instance

    instance name

    stream

    The output stream descriptor

    returns

    void

  38. def policyGet(instance: String, accept: Option[String] = None): Option[String]

    instance

    instance name

    accept

    Force Accept header value (optional)

    returns

    String

  39. def policyPut(instance: String, policy: String, _contentType: Option[String] = None): Any

    instance

    instance name

    policy

    The policy content

    _contentType

    model MIME type (optional)

    returns

    void

  40. def scoopDebugOutput(instance: String): Option[List[String]]

    instance

    instance name

    returns

    List[String]

  41. def streamAttach(instance: String, slot: String, stream: String): Any

    instance

    instance name

    slot

    The stream slot

    stream

    The input/output stream descriptor

    returns

    void

  42. def streamRate(instance: String, stream: String): Option[List[InlineResponse2003]]

    instance

    instance name

    stream

    The stream descriptor to measure data rate

    returns

    List[InlineResponse2003]

  43. def streamSample(instance: String, desc: String, n: Option[Integer] = None): Option[List[String]]

    instance

    instance name

    desc

    The stream descriptor to get sample data from

    n

    The number of data items to read from the stream (optional)

    returns

    List[String]

  44. def swaggerGet(instance: String, accept: Option[String] = None): Option[Any]

    instance

    instance name

    accept

    Force Accept header value (optional)

    returns

    Any

  45. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  46. def toString(): String
    Definition Classes
    AnyRef → Any
  47. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  48. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  49. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped