groovyとshipyardでcontainerを再起動する

groovyとshipyardでcontainerを再起動するには、以下のサンプルコードのようにX-Service-Keyにサービスキーを設定して/api/containers/<container-id>/restartにアクセスします。

サンプルコード

@Grab(group='org.apache.httpcomponents', module='httpclient', version='4.3.6')
import org.apache.http.client.methods.*
import org.apache.http.impl.client.*
import org.apache.http.message.*
import org.apache.http.auth.*
import org.apache.http.entity.*
import groovy.json.*

def host = "192.168.1.212" // replace this
def port = 8080
def serviceKey = "your-service-key"
def containerId = "your-container-id"

def httpclient = new DefaultHttpClient()
httpclient.withCloseable {

  def method = new HttpGet(
    "http://${host}:${port}/api/containers/${containerId}/restart"
  )
  method.setHeader("X-Service-Key", serviceKey)
  def response = httpclient.execute(method)
  println response.getStatusLine().getStatusCode()
}

関連情報

• groovyとshipyardでservice keyを取得する

groovyとshipyardでcontainerのログを取得する

groovyとshipyardでcontainerのログを取得するには、以下のサンプルコードのようにX-Service-Keyにサービスキーを設定して/api/containers/<container-id>/logsにアクセスします。

サンプルコード

@Grab(group='org.apache.httpcomponents', module='httpclient', version='4.3.6')
import org.apache.http.client.methods.*
import org.apache.http.impl.client.*
import org.apache.http.message.*
import org.apache.http.auth.*
import org.apache.http.entity.*
import groovy.json.*

def host = "192.168.1.212" // replace this
def port = 8080
def serviceKey = "your-service-id"
def containerId = "your-container-id"

def httpclient = new DefaultHttpClient()
httpclient.withCloseable {

  def method = new HttpGet(
    "http://${host}:${port}/api/containers/${containerId}/logs"
  )
  method.setHeader("X-Service-Key", serviceKey)
  def response = httpclient.execute(method)
  println response.getStatusLine().getStatusCode()
  println response.getEntity().getContent().text
}

関連情報

• groovyとshipyardでservice keyを取得する

groovyとshipyardでcontainerを停止する

groovyとshipyardでcontainerを停止するには、以下のサンプルコードのようにX-Service-Keyにサービスキーを設定して/api/containers/<container-id>/stopにアクセスします。

サンプルコード

@Grab(group='org.apache.httpcomponents', module='httpclient', version='4.3.6')
import org.apache.http.client.methods.*
import org.apache.http.impl.client.*
import org.apache.http.message.*
import org.apache.http.auth.*
import org.apache.http.entity.*
import groovy.json.*

def host = "192.168.1.212" // replace this
def port = 8080
def serviceKey = "your-service-key"
def containerId = "your-container-id"

def httpclient = new DefaultHttpClient()
httpclient.withCloseable {

  def method = new HttpGet(
    "http://${host}:${port}/api/containers/${containerId}/stop"
  )
  method.setHeader("X-Service-Key", serviceKey)
  def response = httpclient.execute(method)
  println response.getStatusLine().getStatusCode()
}

関連情報

• groovyとshipyardでservice keyを取得する

groovyとshipyardでengineを作成する

groovyとshipyardでengineを作成する groovyとshipyardでengineを作成するには、以下のサンプルコードのようにX-Service-Keyにサービスキーを設定して/api/enginesにPOSTします。

サンプルコード

@Grab(group='org.apache.httpcomponents', module='httpclient', version='4.3.6')
import org.apache.http.client.methods.*
import org.apache.http.impl.client.*
import org.apache.http.message.*
import org.apache.http.auth.*
import org.apache.http.entity.*
import groovy.json.*

def host = "192.168.1.212" // replace this
def port = 8080
def serviceKey = "your-service-key"
def id = "test_engine"

def httpclient = new DefaultHttpClient()
httpclient.withCloseable {

  def method = new HttpPost(
    "http://${host}:${port}/api/engines"
  )
  method.setHeader("X-Service-Key", serviceKey)
  def json = new JsonBuilder()
  json (
    "ssl_cert": "",
    "ssl_key": "",
    "ca_cert": "",
    engine:[
      "id":id,
      "cpus": 1.0,
      "memory": 1024.0,
      "addr":"http://docker-host:4243",
      "labels":["default"]
    ]
  )
  method.setHeader("Content-Type", "application/json; charset=utf-8")
  method.setEntity(new StringEntity(json.toString(), "UTF-8"))
  def response = httpclient.execute(method)
  println response.getStatusLine().getStatusCode()
  println response.getEntity().getContent().text
}

関連情報

• groovyとshipyardでservice keyを取得する

RethinkDBとgroovyで指定したPrimary Keyのドキュメントを取得する

RethinkDBとgroovyで指定したPrimary Keyのドキュメントを取得するには、以下のサンプルコードのようにgetメソッドを使用します。

サンプルコード

@GrabConfig(systemClassLoader=true)
@Grab(group='com.rethinkdb', module='rethink-java-driver', version='0.3')
import com.rethinkdb.*
import com.rethinkdb.model.*

def hostname = "192.168.1.211" // replace this
def dbName = "test"
def tableName = "testtable0"
def pk = 123

RethinkDB r = RethinkDB.r
def conn = r.connect(hostname)
r.db(dbName).table(tableName).get(pk).run(conn).each {
  println it
}
conn.close()

groovyとshipyardでengineを削除する

groovyとshipyardでengineを削除するには、以下のサンプルコードのようにX-Service-Keyにサービスキーを設定してDELETEします。

サンプルコード

@Grab(group='org.apache.httpcomponents', module='httpclient', version='4.3.6')
import org.apache.http.client.methods.*
import org.apache.http.impl.client.*
import org.apache.http.message.*
import org.apache.http.auth.*
import org.apache.http.entity.*
import groovy.json.*

def host = "192.168.1.212" // replace this
def port = 8080
def serviceKey = "your-service-key"
def engineId = "your-engine-id"

def httpclient = new DefaultHttpClient()
httpclient.withCloseable {

  def method = new HttpDelete(
    "http://${host}:${port}/api/engines/${engineId}"
  )
  method.setHeader("X-Service-Key", serviceKey)
  def response = httpclient.execute(method)
  println response.getStatusLine().getStatusCode()
}

関連情報

• groovyとshipyardでservice keyを取得する

groovyとDocker Remote APIでcontainerを停止する

groovyとDocker Remote APIでcontainerを停止するには、以下のようなコードを実行します。

サンプルコード

@Grab(group='org.apache.httpcomponents', module='httpclient', version='4.3.5')
import org.apache.http.client.methods.*
import org.apache.http.impl.client.*
import org.apache.http.message.*
import org.apache.http.auth.*
import org.apache.http.entity.*
import groovy.json.*

def host = "192.168.1.215" // replace this
def port = 4243
def containerId = "your-container-id"
def t2k = 10 // wait 10sec

def httpclient = new DefaultHttpClient()
httpclient.withCloseable {

  def method = new HttpPost(
    "http://${host}:${port}/containers/${containerId}/stop?t=${t2k}"
  )

  def response = httpclient.execute(method)
  println response.getStatusLine().getStatusCode()
}

Docker Remote APIを使用可能にする方法
ubuntuの場合、/etc/default/dockerに以下のように記述します。
DOCKER_OPTS="-H tcp://0.0.0.0:4243 -H unix:///var/run/docker.sock -d"
そのあと、dockerを再起動します。
sudo service docker restart

動作環境
Docker 1.2.0