Lines Matching defs:self

89     pub(crate) fn execute(&self, sql: &str) -> Result<(), i32> {  in execute()
100 pub(crate) fn execute(&self, sql: &str) -> Result<(), i32> { in execute()
110 pub(crate) fn query_integer<T: TryFrom<i64> + Default>(&self, sql: &str) -> Vec<T> in query_integer()
133 pub(crate) fn query_integer<T: TryFrom<i64> + Default>(&self, sql: &str) -> Vec<T> in query_integer()
145 pub(crate) fn contains_task(&self, task_id: u32) -> bool { in contains_task()
160 pub(crate) fn query_task_token_id(&self, task_id: u32) -> Result<u64, i32> { in query_task_token_id()
175 pub(crate) fn insert_task(&self, task: RequestTask) -> bool { in insert_task()
208 pub(crate) fn insert_task(&self, task: RequestTask) -> bool { in insert_task()
270 pub(crate) fn update_task(&self, task_id: u32, update_info: UpdateInfo) { in update_task()
288 pub(crate) fn clear_invalid_records(&self) { in clear_invalid_records()
298 pub(crate) fn query_task_uid(&self, task_id: u32) -> Option<u64> { in query_task_uid()
304 pub(crate) fn update_task(&self, task_id: u32, update_info: UpdateInfo) { in update_task()
316 pub(crate) fn update_task_state(&self, task_id: u32, state: State, reason: Reason) { in update_task_state()
327 pub(crate) fn update_task_sizes(&self, task_id: u32, sizes: &Vec<i64>) { in update_task_sizes()
336 pub(crate) fn get_task_info(&self, task_id: u32) -> Option<TaskInfo> { in get_task_info()
350 pub(crate) fn get_task_info(&self, task_id: u32) -> Option<TaskInfo> { in get_task_info()
392 pub(crate) fn get_task_config(&self, task_id: u32) -> Option<TaskConfig> { in get_task_config()
406 pub(crate) fn get_task_config(&self, task_id: u32) -> Option<TaskConfig> { in get_task_config()
461 pub(crate) fn delete_early_records(&self) { in delete_early_records()
475 pub(crate) fn get_task_qos_info(&self, task_id: u32) -> Option<TaskQosInfo> { in get_task_qos_info()
500 pub(crate) fn get_task_qos_info(&self, task_id: u32) -> Option<TaskQosInfo> { in get_task_qos_info()
520 pub(crate) fn get_app_task_qos_infos_inner(&self, sql: &str) -> Vec<TaskQosInfo> { in get_app_task_qos_infos_inner()
545 pub(crate) fn get_app_task_qos_infos(&self, uid: u64) -> Vec<TaskQosInfo> { in get_app_task_qos_infos()
558 &self, in get_task()