update upgrade script

misc/stf-1.x-to-2.x.sql

@@ -1,5 +1,36 @@
 -- migrate from non-clustered stf storage to clustered.
 
+CREATE TABLE config (
+    varname VARCHAR(127) NOT NULL PRIMARY KEY,
+    varvalue TEXT
+) ENGINE=InnoDB;
+
+REPLACE INTO config (varname, varvalue)
+    VALUES ("stf.drone.AdaptiveThrottler.instances", 1);
+REPLACE INTO config (varname, varvalue)
+    VALUES ("stf.drone.Replicate.instances", 8);
+REPLACE INTO config (varname, varvalue)
+    VALUES ("stf.drone.RepairObject.instances", 4);
+REPLACE INTO config (varname, varvalue)
+    VALUES ("stf.drone.DeleteBucket.instances", 2);
+REPLACE INTO config (varname, varvalue)
+    VALUES ("stf.drone.DeleteObject.instances", 2);
+REPLACE INTO config (varname, varvalue)
+    VALUES ("stf.drone.RepairStorage.instances", 1);
+REPLACE INTO config (varname, varvalue)
+    VALUES ("stf.drone.ContinuousRepair.instances", 1);
+REPLACE INTO config (varname, varvalue)
+    VALUES ("stf.drone.StorageHealth.instances", 1);
+REPLACE INTO config (varname, varvalue)
+    VALUES ("stf.drone.Notify.instances", 1);
+
+REPLACE INTO config (varname, varvalue)
+    VALUES ("stf.worker.RepairObject.throttle.auto_adapt", 1);
+REPLACE INTO config (varname, varvalue)
+    VALUES ("stf.worker.RepairObject.throttle.threshold", 300);
+REPLACE INTO config (varname, varvalue)
+    VALUES ("stf.worker.RepairObject.throttle.current_threshold", 0);
+
 CREATE TABLE storage_cluster (
     id INT NOT NULL PRIMARY KEY,
     name VARCHAR(128),
@@ -17,3 +48,63 @@ CREATE TABLE object_cluster_map (
     FOREIGN KEY (object_id) REFERENCES object (id) ON DELETE CASCADE,
     FOREIGN KEY (cluster_id) REFERENCES storage_cluster (id) ON DELETE CASCADE
 ) ENGINE=InnoDB;
+
+CREATE TABLE worker_election (
+    id BIGINT AUTO_INCREMENT PRIMARY KEY,
+    drone_id VARCHAR(255) NOT NULL,
+    expires_at INT NOT NULL,
+    UNIQUE KEY (drone_id),
+    KEY (expires_at)
+) ENGINE=InnoDB DEFAULT CHARACTER SET = 'utf8';
+
+CREATE TABLE worker_instances (
+    drone_id VARCHAR(255) NOT NULL,
+    worker_type VARCHAR(255) NOT NULL,
+    instances INT NOT NULL DEFAULT 1,
+    PRIMARY KEY(drone_id, worker_type),
+    FOREIGN KEY(drone_id) REFERENCES worker_election (drone_id) ON DELETE CASCADE
+) ENGINE=InnoDB DEFAULT CHARACTER SET = 'utf8';
+
+CREATE TABLE notification (
+    id BIGINT AUTO_INCREMENT PRIMARY KEY,
+    ntype CHAR(40) NOT NULL,
+    /* source of this notification. should include file + linu num */
+    source TEXT NOT NULL,
+    /* severity of this notification: critical, info ? anything else? */
+    severity VARCHAR(32) NOT NULL DEFAULT 'info',
+    message TEXT NOT NULL,
+    created_at INT NOT NULL,
+    KEY(created_at),
+    KEY(ntype)
+) ENGINE=InnoDB DEFAULT CHARACTER SET = 'utf8';
+
+CREATE TABLE notification_rule (
+    id BIGINT AUTO_INCREMENT PRIMARY KEY,
+
+    /* status: 0 -> suspended, won't execute. status: 1 -> will execute */
+    status TINYINT NOT NULL DEFAULT 1,
+
+    /* operation type, "eq", "ne", "==", "!=", "<=", ">=", "=~" */
+    operation CHAR(2) NOT NULL,
+    /* which notificiation object field to apply thie operation against */
+    op_field  VARCHAR(255) NOT NULL DEFAULT "ntype",
+    /* user-defined operand.
+       e.g., op_field = "ntype", operation = "=~", op_arg = "^foo"
+             yields "ntype" =~ /^foo/
+    */
+    op_arg    VARCHAR(255) NOT NULL,
+    /* user-defined extra set of arguments that are required by
+       the notifier to complete the notification. e.g.
+       Ikachan notification requires "channel", email notification
+       requires "to" address.
+       encoded as JSON string
+    */
+    extra_args TEXT,
+    /* which notifier to invoke upon rule match. Must be able to
+       look this up via container->get. e.g. API::Notification::Email
+    */
+    notifier_name VARCHAR(255) NOT NULL,
+    KEY(status)
+) ENGINE=InnoDB DEFAULT CHARACTER SET = 'utf8';
+
+