Scala thin client for com.scaledinference.amp_v2.Amp
Two example files to illustrate usage of the api are provided.
AmpSingleSession.scala
This creates an amp object, a session object and makes a single call. The objects are created with default values and use only the required parameters (such as the project Key for the amp object) to successfully create them.
AmpMultipleSession.scala This creates an amp object, and two session objects and makes a single call on each objects. The objects are created with non default values to override the api defaults.
The scala thin client itself can be compiled by running "sbt compile" or packaged by running "sbt package" from the command line in the directory containing this README file.
In order to run the example AmpSingleSession via a command line in the directory containing this README file
sbt "test:runMain com.scaledinference.amp_v2.AmpSingleSession 98f3c5cdb920c361 http://localhost:8100"
where 98f3c5cdb920c361 should be replaced with your project key, and http://localhost:8100 should be replaced with the address of you amp-agent.
After running it, you should get output that looks something like
firstSession = Session(Amp(98f3c5cdb920c361,Vector(http://localhost:8100),10 seconds,30 minutes,false),y7DIcN7imEOrvbP3,y33qgotryZMyNkWP,20 seconds,30 minutes,)
Calling firstSession.decideWithContext, with a 3 seconds timeout
decisionAndToken = DecideResponse(Map(color -> red, count -> 10),Gk8FGg4GAExeRxpYICwRL1oZGSokFxgGNVBNSEcBDwwdEU1RRxdXVhIICxEAGDc9DSEAMj5GSUEfDwALQ1dSTVcNVg1RBgcNXVdCAl5GRU1HRx4QHBMKRl9QICAgMStJSUwXERBNXlRHVVlETFlSVFpVVlFDRgkbBwgEHQIOR1RVXVNfVFVCTU8ZGgsOHQsXR1kURlVFUV8UTV5bVghVBFtZXFERVwkSQlleVFcCBFZWVgdDQ1dACRI=,false,None)
Returned ampToken Gk8FGg4GAExeRxpYICwRL1oZGSokFxgGNVBNSEcBDwwdEU1RRxdXVhIICxEAGDc9DSEAMj5GSUEfDwALQ1dSTVcNVg1RBgcNXVdCAl5GRU1HRx4QHBMKRl9QICAgMStJSUwXERBNXlRHVVlETFlSVFpVVlFDRgkbBwgEHQIOR1RVXVNfVFVCTU8ZGgsOHQsXR1kURlVFUV8UTV5bVghVBFtZXFERVwkSQlleVFcCBFZWVgdDQ1dACRI=
of length 248
Returned decision: Map(color -> red, count -> 10)
Decision successfully obtained from amp-agent
Calling firstSession.observe with default timeout
Returned ampToken Gk8FGg4GAExeRxpYICwRL1oZGSokFxgGNVBNSEcBDwwdEU1RRxdXVhIICxEAGDc9DSEAMj5GSUEfDwALQ1dSTVcNVg1RBgcNXVdCAl5GRU1HRx4QHBMKRl9QICAgMStJSUwXERBNXlRHVVlETFlSVFpVVlFDRgkbBwgEHQIOR1RVXVNfVFVCTU8ZGgsOHQsXR1kURlVFUV8UTV5bVghVBFtZXFERVwkSQlleVFcCBFZWVgdDQ1dACRI=
of length 248
Observe successfully sent to amp-agent.
The analogous documentation for AmpMultipleSession is
sbt "test:runMain com.scaledinference.amp_v2.AmpMultipleSession 98f3c5cdb920c361 http://localhost:8100"
with output something like
session1: Session(Amp(98f3c5cdb920c361,Vector(http://localhost:8100),10 seconds,15 minutes,false),neHoDsl1tVytGTyD,uqGSJQ9V6P6Dg59O,1 second,1 hour,)
Calling session1.decideWithContext
Returned ampToken
Gk8FGg4GAExeRw0KLAo2EgFBADkSESkwHCdNSEcBDwwdEU1RRxsVIjAlNVwkVz1GMAheXCFGSUEfDwALQ1dSTVcNVg1RBgcNXVdCAl5GRU1HRx4QHBMKRl9QICAgMStJSUwXERBNXlRHVVlETV5eUFhVV1dDRgkbBwgEHQIOR1RXU1NfVFVCTU8ZGgsOHQsXR1kURlVFUV8UTV5bVghVBFtZXFERVwkSQlleVFcCBFZWVgdDQ1dACRI=
of length 248
Returned decision: Map(color -> red, count -> 10)
Decision successfully obtained from amp-agent
Calling session1.observe, with default timeout
Returned ampToken
Gk8FGg4GAExeRw0KLAo2EgFBADkSESkwHCdNSEcBDwwdEU1RRxsVIjAlNVwkVz1GMAheXCFGSUEfDwALQ1dSTVcNVg1RBgcNXVdCAl5GRU1HRx4QHBMKRl9QICAgMStJSUwXERBNXlRHVVlETV5eUFhVV1dDRgkbBwgEHQIOR1RXU1NfVFVCTU8ZGgsOHQsXR1kURlVFUV8UTV5bVghVBFtZXFERVwkSQlleVFcCBFZWVgdDQ1dACRI=
of length 248
Observe successfully sent to amp-agent.
AmpSingleSession can be used to to some troubleshooting
If the domain host is wrong, e.g. "http://localhost1:8100", you will be seeing a UnknownHostException. The output will look something like
Failure: Error occurred while connecting to Amp agent http://localhost1:8100. Cause java.net.UnknownHostException: localhost1 (of class java.lang.String)
scala.MatchError: Error occurred while connecting to Amp agent http://localhost1:8100. Cause java.net.UnknownHostException: localhost1 (of class java.lang.String)
at com.scaledinference.amp_v2.Amp$.$anonfun$create$1(Amp.scala:47)
at scala.util.Try$.apply(Try.scala:209)
at com.scaledinference.amp_v2.Amp$.create(Amp.scala:41)
at com.scaledinference.amp_v2.AmpSingleSession$.main(AmpSingleSession.scala:9)
at com.scaledinference.amp_v2.AmpSingleSession.main(AmpSingleSession.scala)
If the domain port is wrong, e.g. "http://localhost:9000", you will be seeing a ConnectException. The output will look something like
Failure: Error occurred while connecting to Amp agent http://localhost:9000. Cause java.net.ConnectException: Connection refused (Connection refused) (of class java.lang.String)
scala.MatchError: Error occurred while connecting to Amp agent http://localhost:9000. Cause java.net.ConnectException: Connection refused (Connection refused) (of class java.lang.String)
at com.scaledinference.amp_v2.Amp$.$anonfun$create$1(Amp.scala:47)
at scala.util.Try$.apply(Try.scala:209)
at com.scaledinference.amp_v2.Amp$.create(Amp.scala:41)
at com.scaledinference.amp_v2.AmpSingleSession$.main(AmpSingleSession.scala:9)
at com.scaledinference.amp_v2.AmpSingleSession.main(AmpSingleSession.scala)
If the domain is correct, but the project key is incorrect, e.g. "Incorrect project key", the output will look something like
Failure: Error occurred while connecting to Amp agent http://localhost:8100. Cause java.lang.Error: Failed to call AmpAgent http://localhost:8100: 400 with reason Bad Request (of class java.lang.String)
scala.MatchError: Error occurred while connecting to Amp agent http://localhost:8100. Cause java.lang.Error: Failed to call AmpAgent http://localhost:8100: 400 with reason Bad Request (of class java.lang.String)
at com.scaledinference.amp_v2.Amp$.$anonfun$create$1(Amp.scala:47)
at scala.util.Try$.apply(Try.scala:209)
at com.scaledinference.amp_v2.Amp$.create(Amp.scala:41)
at com.scaledinference.amp_v2.AmpSingleSession$.main(AmpSingleSession.scala:9)
at com.scaledinference.amp_v2.AmpSingleSession.main(AmpSingleSession.scala)