EC2Instance

def ! (cmd: String): Unit

Executes a command and throw an error if it doesn't return 0

def != (arg0: AnyRef): Boolean

def != (arg0: Any): Boolean

def !? (cmd: String): String

Execute a command on the remote machine and return stdout as a string.

def ## (): Int

def == (arg0: AnyRef): Boolean

def == (arg0: Any): Boolean

def appendFile (file: File, contents: String): Unit

Append to file on the remote machine with the given contents

def asInstanceOf [T0] : T0

var assignedServices : Set[Service]

The services that are assigned to be deployed to this remote machine.

def availabilityZone : String

def blockTillFileCreated (file: File): Unit

Block until the specified file is created on the remote machine.

def blockTillPortOpen (port: Int): Unit

Block until we can make a connection to the given port, checking every 5 seconds.

def blockUntilRunning (): Unit

Blocks the current thread until this instance is up and accepting ssh connections.

def bundleNewAMI (bucketName: String): String

Creates a new AMI based on this image using ec2-bundle-vol and ec2-upload-bundle.

def cacheFiles (localFiles: Seq[File]): Seq[File]

Caches this file on the instance (keyed by the hash of the file contents)

def catFile (remoteFile: File): String

Return the contents of the remote file as a string.

def clearAll : Unit

def clone (): AnyRef

def createFile (file: File, contents: String, mode: String = "644"): Unit

Create a file on the remote machine with the given contents

def currentState : Instance

def disableMonitoring (): Unit

def download (remoteFile: File, localDirectory: File): Unit

Downloads a file from the remote machine.

def enableMonitoring (): Unit

def eq (arg0: AnyRef): Boolean

def equals (other: Any): Boolean

def executeCommand (cmd: String, timeout: Long = 0): ExecuteResponse

Execute a command sync with a maximum timeout to wait for result and return the result as an ExecuteResponse

val fileCache : File

def finalize (): Unit

def fixHostname : Unit

def free : FreeStats

Returns the result of the command free.

val freeResponse : Regex

def getClass (): java.lang.Class[_]

def getHostname (): String

def getService (name: String, cmd: String): RemoteService

def halt : Unit

def hashCode (): Int

lazy val hostname : String

def imageId : String

val instanceId : String

def instanceState : String

def instanceType : String

def isInstanceOf [T0] : Boolean

def isPortAvailableToListen (port: Int): Boolean

Use netstat to check if a port is currently bound to a listening socket on the remote machine.

val javaCmd : File

The location of the java command on the remote machine

def jps : Seq[RemoteJavaProcess]

Return a list of all the java processes running on the remote machine.

def keyName : String

val logDir : File

val logger : Logger

def ls (dir: File): Seq[RemoteFile]

Return a list of RemoteFiles found in dir on the remote machine.

def md5 (remoteFile: File): String

returns an md5 hash of the specified remote file

def mkdir (remoteDir: File): Unit

create directories on the remote machine.

def ne (arg0: AnyRef): Boolean

def notify (): Unit

def notifyAll (): Unit

def prepareCommand (cmd: String): String

def privateDnsName : String

val privateKey : File

The private key used to authenticate with the remote ssh server

def ps : Seq[RemoteProcess]

lists the processes running on the remote machine.

def publicDnsName : String

def pushJars (jars: Seq[File]): Seq[File]

Upload all of the jars in the file .

val rootDirectory : File

The default root directory for operations (The user should have read write permissions to this directory)

val runitBinaryPath : File

lazy val runsvdirCmd : File

val serviceDir : File

lazy val serviceRoot : File

def services : List[RunitService]

def setup (): Unit

Runs pre-experiment setup like recording instance details in the database and making needed directories

def stopWatches (): Unit

Kill all processes currently tailing a file.

lazy val svCmd : File

lazy val svlogdCmd : File

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

object tags extends SeqForwarder[TagDescription]

def tail (remoteFile: File, numLines: Int = 20): String

return the last numLines from the specified file

implicit def toOption [A] (a: A): Option[A]

def toString (): String

def upload (localFile: File, remoteDirectory: File): Unit

Custom upload method that copies a file once to S3 and then from there to any number of EC2Instances.

def useConnection [ReturnType] (func: (Connection) ⇒ ReturnType, numTries: Int): ReturnType

Provide an ssh connection to the server.

val username : String

The username used to authenticate with the remote ssh server

def wait (): Unit

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

def wait (arg0: Long): Unit

def watch (remoteFile: File): Unit

run tail -F on the specifed file in a seperate thread.

def addService (service: Service): Unit