Struct ScheduleExecutor 

pub struct ScheduleExecutor { /* private fields */ }

SQL 스케줄 실행 엔진

Implementations

impl ScheduleExecutor

pub fn new() -> Self

새 ScheduleExecutor 생성

pub fn register(&self, schedule: Schedule) -> DbxResult<()>

스케줄 등록

pub fn unregister(&self, name: &str) -> DbxResult<()>

스케줄 해제

pub fn list_schedules(&self) -> Vec<String>

등록된 모든 스케줄 목록

pub fn get_schedule(&self, name: &str) -> Option<Schedule>

특정 스케줄 조회

pub fn enable(&self, name: &str) -> DbxResult<()>

스케줄 활성화

pub fn disable(&self, name: &str) -> DbxResult<()>

스케줄 비활성화

pub fn execute(&self, db: &Database, name: &str) -> DbxResult<()>

스케줄 실행

지정된 스케줄의 SQL body를 실행합니다.

인자

• db - Database 인스턴스
• name - 실행할 스케줄 이름

에러

• 스케줄이 존재하지 않으면 에러 반환
• 스케줄이 비활성화 상태면 실행하지 않음
• SQL 실행 실패 시 에러 반환

pub fn start_scheduler(&self, db_weak: Weak<Database>) -> DbxResult<()>

백그라운드 스케줄러 시작

인자

• db_weak - Database Weak 포인터 (순환 참조 방지)

pub fn stop_scheduler(&self) -> DbxResult<()>

백그라운드 스케줄러 중지

pub fn is_scheduler_running(&self) -> bool

스케줄러가 실행 중인지 확인

Trait Implementations

impl Default for ScheduleExecutor

fn default() -> Self

Returns the “default value” for a type.