mirror of
https://github.com/tursodatabase/libsql.git
synced 2025-01-09 16:56:05 +00:00
23 lines
525 B
Rust
23 lines
525 B
Rust
use std::sync::Arc;
|
|
|
|
use tokio::sync::oneshot;
|
|
|
|
use crate::connection::program::Program;
|
|
use crate::namespace::NamespaceName;
|
|
|
|
use super::error::Error;
|
|
use super::handle::JobHandle;
|
|
use super::MigrationJobStatus;
|
|
|
|
pub enum SchedulerMessage {
|
|
ScheduleMigration {
|
|
schema: NamespaceName,
|
|
migration: Arc<Program>,
|
|
ret: oneshot::Sender<Result<JobHandle, Error>>,
|
|
},
|
|
GetJobStatus {
|
|
job_id: i64,
|
|
ret: oneshot::Sender<Result<(MigrationJobStatus, Option<String>), Error>>,
|
|
},
|
|
}
|