parent
0531cd6693
commit
6cfdd5f5fb
@ -0,0 +1 @@
|
||||
<mxfile host="app.diagrams.net" modified="2020-08-01T20:28:11.694Z" agent="5.0 (X11)" etag="I93ewyYqX50bTZPF7Vt3" version="13.5.8"><diagram id="HV9vB5DucQ4q6iQxLrTr" name="Page-1">7Vxbc5s4FP41nt19iAcQYPKYW7vdbWczm+0lj7KRjVKMPCDHSX/9SuIugY1tjJJMMp2pJSQB5/Kdi44Ygavl08cYroIvxEfhyDL8pxG4HlmWaU4M9h/veU57nImddixi7GeDyo47/Atlndm8xRr7KKkNpISEFK/qnTMSRWhGa30wjsmmPmxOwvpdV3CBlI67GQzV3u/Yp0Ha6zlG2f8nwosgv7NpZFeWMB+cdSQB9Mmm0gVuRuAqJoSmv5ZPVyjkxMvpks770HK1eLAYRbTLhJvH+69/kfkDvf32gP8mH/+hD1/ObDd7OPqcvzHyGQGyJolpQBYkguFN2XsZk3XkI76swVrlmM+ErFinyTofEKXPGTfhmhLWFdBlmF1N78lv1PouOa9hvEB02ws4BSmZDCKyRDR+ZhNjFEKKH+s3gJkwLIpxxdRbgtmtLSMXXC/jWia2tm3Ul0jIOp6hbFZJ9Ys4hs+VYSs+INnjPhOJidJ4sHU4+5E+QN6qkKTsEnKxh4xkxHuE4Toj5x1jC1UFJwyZVnIB2QSYorsVnPErGwYMTex/RDFFT9sFQOVrNsGp0yFvbkoVNXO9Cyrq6UlcrApChYj700iLGqEnTH9Uft/zpcZO1rp+ylYWjee8EbHX/VEO5M376rVymmjl87qrbKoZW2hldVXtk2i2LDpFe4dm96VNlqJN/yLopxZsjhfcVOKYWyocMrvHFosY25ksu/kAcMH+/UWmrIdzhHEJo0QRv7pwnV4h3TpVC1zbpZHuqTQSKHRWVTTyL7iLwFqzECYJnkn6daCu5HpZ6uJ9RUub9bJH/epqOq1mhlY45jQwLO87Ug2diWTJOqqhspBrSQsZ0kIpHU6mz44W5NeP4nZHKZucBsXtHf7Ziblu2wq8/BegSAiC8I2MDaSzAEeLRvH4DKcsTqqxFIZ4EXEkYpxAMevgcIxZIHKRXVhi30+lByX4F5yK9ThTMx+TLe5cjpzrbXieRUnZ5FERm1QFoF3KW8H/zBjbtgdqHDkznV6AolgntyxOfQUynyfoJDw+f30+XQ0LSmh4OWjgHYkGR7kEqs7erUJMq15U7m4lKzTDc+YQWMYDmbILV3wUnAXpEBSzRbhXxp7HMkiEkoAIpcfiKQLIXoUN5JGfQTZR4b8xfaSpA3eVNYQTRwPIZ2M+/CKepcmCGPliRRqIEajkjHim9JFg5Ff7A8iX+Ib4EmQuBuJI9Ed+6k7OSVy8yTEuI3NPwysSstX4XOA7yPNt1p/QmPxElSueNQWu24+TKUfLjXFfk9Niyt5FfzIFdKLEPh7mC/AZJh1Rwm5xTYeBiYkCE9+5LUfxWNj03/9o0ceabhm5gusOzEw5ZaQ/MmuIxN5VZpvB7KAywGiWgmFUBjSY1uYc4Wt0fkELHGXLG2PDdSfHObun92a9Ng4ZGxL/FF5MCV4scgn9HNd6dBPm3gzNZk1uwtRzeAqgF8gDkptQQKA2yDPVrN8HHCJBaRgtuKcnUzkgy+k6GcREACklajfQy2sg18my6WYfybvXGUh1dZFMrdk7cN68D7V39s6W8zjWsHkcUzVcB0uapnSv1VViWnI4w0iMvEFgy1jbVWKKDfZsIQAGlhhHkZhQkIVH9XKAUOzpzFO0F1s7r8+eShQ3tJtTt82cQt/XbEwlQCuQUpstVcPZIxDOZqF5BePGBgDbLSpr3KIYs3fhfr0SVU3qcdXY3GFpRUtesEcwzbV7N5q6bwJNgSktZA6MpmpY0k06xTZL193bupTtlLFC2q2qQTeGMuidXUC9Bl2uXDpYBOUE1dAieN4DQB4YOBwSpPSJdm5HUWspxXmXtP1Kf4w2t8VHIbNnmrMAkk1xdGcB8lc4RjE1wHKluPddWY7gvqVw/+vKhzQLq/jeynhkuSEj3+WURVXugv/6xPPH8XqV5zXRkfFWD3ply7kS7RswVq+1cftsjOi2d11zJSlB3nX4WB3uI7vWKGi7fPgehSZXzXehGUhoPFVGdG0Pb4/52raHhxTOrvkKqyVfMcz+sKUmTa95AmeJI27PN2n9U26wjQghnxcriVIsn7w4E96U1Bu4hsJUiPLSlcQc7RUa96kkXcNczUUUqlv2hfh4/tzI6tdXRbFdx86MMTNiVk3Pzo4sIT59VYWl7kTcMVrz0lHIqfFBxa4BQ3pHyu5aujcjrD42Iw60uoeAV58g1Dn2eE/r9qGZQOuRzFdWZQi6xjjg2OPWx1lIFT7uKOPM27CPLR56UWUo2UbzpdvGXKiqhdS5hx9yhVKyd6qxHNjRlysHi918fY6+GjlxB0OcPinKz7PzI0zLR2XtZnoWZEaWK7G3MGaNT/Q33reBmKZxFrOy+UAiIrEQJfrPEgPpbCjoWr95Mr8F7LdNHXFigksfJoEgm1knEe+/hZTxIBI9lgFGeQlP/pERa8uu4uSwbUXPtbfboYZajR5tTNcjYm0mZqDKRrkg4mD/Ry7RGNj/sS0VfaE47JYeU4FiCQEWsTi4Ks6Lpb3Z2RX9SCAfXnG0753YDXic1dFfff7EERQnFEXH7jtpqfM7k6ltaaf2i4gXlaI3w9UKpJ1zvpZWJO3rCw9FTfieX3jY+1tMUmXxRP6glvxc0rGJiVEbf5qPMdlqtdLNE9b7MSbJ0k20u2s5YzS5a2fG2DAndZ8twxCNpa2dYSMVMW0JKMkGnR+IGnIhtisfUTn1d2HUbP7XaBEzNZyv+eQkWFNffBvgLSQvnJadkzJ54dk1duThwMtNXzg9lJ9Va5BNq44IhmHrRgTrVSCC4kjIdqPz0SEJEiYdPxq0ryNhSY6E6w3gGDhqvPfxzaLNzq1E0/OsGg/yUuejv0YExufgvPLn1WHNG7vnRuVPusMhcMWa5Vdi0+Hlt3bBzf8=</diagram></mxfile>
|
@ -1,32 +0,0 @@
|
||||
//! A single running job
|
||||
use super::*;
|
||||
|
||||
use tokio::{
|
||||
sync::{
|
||||
mpsc,
|
||||
},
|
||||
};
|
||||
|
||||
/// Commands to interrupt jobs
|
||||
#[derive(Debug,PartialEq,Eq,Hash,Clone)]
|
||||
pub enum Command
|
||||
{
|
||||
/// Start graceful shutdown, wait for children.
|
||||
Stop,
|
||||
/// Stop immediately
|
||||
Abort,
|
||||
/// Interrupt the current iteration, and restart the iterator if needed
|
||||
Reseed(interval::Time),
|
||||
/// Run the command now
|
||||
Oneshot,
|
||||
/// Config reload
|
||||
Reload(context::Context),
|
||||
/// Just restart the iterator
|
||||
Restart,
|
||||
}
|
||||
|
||||
#[derive(Debug)]
|
||||
pub struct Job
|
||||
{
|
||||
handler: mpsc::Sender<Command>,
|
||||
}
|
Loading…
Reference in new issue