Skip to content

Commit

Permalink
Update java-api.md
Browse files Browse the repository at this point in the history
  • Loading branch information
terrywbrady authored Mar 22, 2024
1 parent 82acd2d commit 8b1f7e7
Showing 1 changed file with 17 additions and 3 deletions.
20 changes: 17 additions & 3 deletions design/queue-2023/java-api.md
Original file line number Diff line number Diff line change
Expand Up @@ -86,7 +86,14 @@ abstract public class QueueItem
public int intProperty(ZooKeeper client, ZKKey key) throws MerrittZKNodeInvalid;
public long longProperty(ZooKeeper client, ZKKey key) throws MerrittZKNodeInvalid;
public void setData(ZooKeeper client, ZKKey key, Object data) throws MerrittZKNodeInvalid;

public abstract String dir();
public abstract String prefix();
public abstract IngestState initState();
public abstract IngestState[] states();
public String path();
public String prefixPath();

public static String serialize(Object data);
public static String createId(ZooKeeper client, String prefix);
public JSONObject statusObject(IngestState status);
Expand All @@ -104,9 +111,11 @@ public class Batch extends QueueItem {

public boolean hasFailure();

public static String dir();
public static String prefix();
public static String prefixPath();
public String dir();
public String prefix();
public IngestState initState();
public IngestState[] states();

public static Batch createBatch(ZooKeeper client, JSONObject submission);

public void delete(ZooKeeper client) throws MerrittStateError;
Expand All @@ -122,6 +131,11 @@ public class Job extends QueueItem {
private String jobStatePath;
private String batchStatePath;

public String dir();
public String prefix();
public IngestState initState();
public IngestState[] states();

public Job(String id, String bid);
public Job(String id, String bid, JSONObject data);

Expand Down

0 comments on commit 8b1f7e7

Please sign in to comment.