Getting Started

There are three ways to get this package.

1. Add it as a Maven dependency Your pom.xml will look something like:

    <dependencies>
        <dependency>
            <groupId>io.iron.ironworker</groupId>
            <artifactId>ironworker</artifactId>
            <version>LATEST</version>
        </dependency>
    </dependencies>

2. Download the jar from Maven Repo.

3. Build from source with Apache Buildr:

   buildr package

The .jar file will appear under the target directory.

Basic Usage

Visit http://iron.io for more details.

This is very basic guide. Note that this library supports all IronWorker API features, it just lacks documentation.

Create Client

It'll be used for all IronWorker interactions.

import io.iron.ironworker.client.Client;

Client client = new Client("IRON_IO_TOKEN", "IRON_IO_PROJECT_ID");

Set proxy

If you need to set up the proxy, create the client object as follows:

import org.apache.http.HttpHost;
import io.iron.ironworker.client.Client;

HttpHost httpProxy = new HttpHost(hostname, port, scheme);
Client client = new Client("IRON_IO_TOKEN", "IRON_IO_PROJECT_ID", httpProxy);

Create a worker and upload it

See here for how to build a Java worker and upload it to Iron.io: https://github.com/iron-io/dockerworker/tree/master/java

Run It

Prefered way is to use provided builders like Params or TaskOptions, but you can fall back and pass Map<String, Object> instead.

import io.iron.ironworker.client.entities.TaskEntity;
import io.iron.ironworker.client.builders.Params;
import io.iron.ironworker.client.builders.TaskOptions;

// specififying some options
TaskEntity t = client.createTask("MyWorker",
        Params.add("param", 13).add("another", "value"),
        TaskOptions.priority(1).delay(60));

// alternate params syntax
client.createTask("MyWorker", Params.create("param", 13, "another", "value"));

Setting Task Priority

You can specify priority of the task by setting the corresponding parameter of Client.createTask method.

// Run the task with highest priority
TaskEntity t = client.createTask("MyWorker", params, TaskOptions.priority(2));

There are 3 possible Options which could be set using TaskOptions:

• priority: Setting the priority of your job. Valid values are 0, 1, and 2. The default is 0.
• timeout: The maximum runtime of your task in seconds. No task can exceed 3600 seconds (60 minutes). The default is 3600 but can be set to a shorter duration.
• delay: The number of seconds to delay before actually queuing the task. Default is 0.
• label: Optional text label for your task.
• cluster: cluster name ex: "high-mem" or "dedicated". This is a premium feature for customers to have access to more powerful or custom built worker solutions. Dedicated worker clusters exist for users who want to reserve a set number of workers just for their queued tasks. If not set default is set to "default" which is the public IronWorker cluster.

Schedule Task

ScheduleEntity s = client.createSchedule("MyWorker",
        Params.add("param", 13).add("another", "value"),
        ScheduleOptions.delay(10));

There are several possible options which could be set using ScheduleOptions:

• runEvery: The amount of time, in seconds, between runs. By default, the task will only run once. run_every will return a 400 error if it is set to less than 60.
• endAt: The time tasks will stop being queued. Should be an instance of Date.
• runTimes: The number of times a task will run.
• priority: Setting the priority of your job. Valid values are 0, 1, and 2. The default is 0. Higher values means tasks spend less time in the queue once they come off the schedule.
• startAt: The time the scheduled task should first be run. Should be an instance of Date.
• label: Optional label for adding custom labels to scheduled tasks.
• cluster: cluster name ex: "high-mem" or "dedicated". If not set default is set to "default" which is the public IronWorker cluster.

Get Results

At the moment entities just hold data, you need to call client yourself.

  t = client.getTask(t.getId()); // update information
  String status = t.getStatus();

  String log = client.getTaskLog(t.getId());