[logdog] Replace Tumble with push queues.

logdog/api/endpoints/coordinator/services/v1/tasks.proto

Index: logdog/api/endpoints/coordinator/services/v1/tasks.proto
diff --git a/logdog/api/endpoints/coordinator/services/v1/tasks.proto b/logdog/api/endpoints/coordinator/services/v1/tasks.proto
index e06a510737ec4324377d7f71d5dcdae0e2d4c61f..7dfc62ee145cde9c7ef3d130e89762968ef18a27 100644
--- a/logdog/api/endpoints/coordinator/services/v1/tasks.proto
+++ b/logdog/api/endpoints/coordinator/services/v1/tasks.proto
@@ -9,6 +9,35 @@ package logdog;
 import "google/protobuf/duration.proto";
 import "google/protobuf/timestamp.proto";
 
+// ArchiveDispatchTask is an internal task used by the Coordinator to schedule
+// an archival dispatch.
+message ArchiveDispatchTask {
+  // The hash ID for the log stream to archive.
+  string id = 1;
+
+  // The type of archival task.
+  enum Tag {
+    TERMINATED = 0;
+    EXPIRED = 1;
+  }
+  Tag tag = 2;
+
+  // Don't waste time archiving the log stream until it is at least this old.
+  //
+  // This is in place to prevent overly-aggressive archivals from wasting time
+  // trying, then failing, becuase the log stream data is still being collected
+  // into intermediate storage.
+  google.protobuf.Duration settle_delay = 3;
+
+  // The amount of time after the task was created that log stream completeness
+  // will be used as a success criteria. If the task's age is older than this
+  // value, completeness will not be enforced.
+  //
+  // The task's age can be calculated by subtracting its lease expiration time
+  // (leaseTimestamp) from its enqueued timestamp (enqueueTimestamp).
+  google.protobuf.Duration complete_period = 4;
+}
+
 // ArchiveTask is a task queue task description for the archival of a single
 // log stream.
 message ArchiveTask {