There are three ways to get this package.
- 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>
The .jar file will appear under the target directory.
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.
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");
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
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.
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.
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());