MCPcopy Create free account

hub / github.com/GitBrincie212/ChronoGrapher / functions

Functions474 in github.com/GitBrincie212/ChronoGrapher

⨍ Functions 474◇ Types & classes 172
Functionlinear_backoff_clamped_at_max
()
tests/src/task/frames/retry_taskframe_test.rs:322
Functionlinear_backoff_delays_grow
()
tests/src/task/frames/retry_taskframe_test.rs:293
Functionmain
()
benches/src/time_wheel.rs:5
Functionmain
(attrs: TokenStream, item: TokenStream)
proc/src/lib.rs:889
Functionmain
()
tests/ui/every_errors.rs:3
Functionmain
()
bin/src/main.rs:18
Functionmain
(scheduler: DefaultLiveScheduler<String>)
bin/src/test3.rs:4
Functionmain
()
bin/src/test2.rs:1
Functionmain
()
bin/src/test.rs:6
Functionmain_loop_logic
( engine: &Arc<C::SchedulerEngine>, hot_workers: &Arc<Vec<CachePadded<SchedulerWorkerHot<C>>>>, co
base/src/scheduler/impls/utils/main_loop.rs:9
Methodnew
(tokens: &'a [Token])
utils/src/cron_parser.rs:33
Methodnew
(frame: T1, schedule: impl TaskSchedule)
base/src/task.rs:80
Methodnew
(initial_time: SystemTime)
base/src/scheduler/clock/virtual_clock.rs:15
Methodnew
(task: &ErasedTask<impl TaskError>)
base/src/task/frames.rs:67
Methodnew
(hook: Arc<T>)
base/src/task/hooks.rs:464
Methodnew
Method creates a new [`TaskFrameBuilder`] by wrapping the given [`TaskFrame`], this is the only entry point for constructing a builder for the workflo
base/src/task/frame_builder.rs:162
Methodnew
(primary: T, secondary: T2)
base/src/task/frames/fallbackframe.rs:11
Methodnew
(frame: T, max_duration: Duration)
base/src/task/frames/timeoutframe.rs:20
Methodnew
(frame: T, max_duration: Duration)
base/src/task/frames/delayframe.rs:23
Methodnew
(index: usize, error: Box<dyn TaskError>)
base/src/task/frames/collectionframe.rs:19
Methodnew
(duration: Duration)
base/src/task/frames/retryframe.rs:43
Methodnew
(func: T)
base/src/task/frames/dynamicframe.rs:14
Methodnew
Constructs a new [`TaskScheduleCron`] instance from the provided [`CronField`]. This constructor should rarely be used, it is much preferred to use [c
base/src/task/schedule/cron.rs:481
Methodnew
(value: u32)
base/src/task/schedule/calendar.rs:33
Methodnew
(input: ParseStream<'a>)
proc/src/workflow/utils.rs:82
Methodnew
(value: usize)
tests/src/task/hooks/taskhook_shared_data_test.rs:10
Methodnew_decorrelated
(strat: T, factor: f64, max: f64)
base/src/task/frames/retryframe.rs:149
Methodnew_equal
(strat: T, factor: f64)
base/src/task/frames/retryframe.rs:141
Methodnew_full
(strat: T, factor: f64)
base/src/task/frames/retryframe.rs:133
Methodnew_with
(frame: T, function: impl Fn() -> Duration + Send + Sync + 'static)
base/src/task/frames/timeoutframe.rs:27
Methodnew_with
(frame: T, function: impl Fn() -> Duration + Send + Sync + 'static)
base/src/task/frames/delayframe.rs:30
Methodnew_with
(factor: f64, max_duration: Duration)
base/src/task/frames/retryframe.rs:62
Functionnew_worker
(notify: Arc<Notify>)
base/src/scheduler/impls/live.rs:50
Functionno_fallback_primary_succeed
()
tests/src/task/frames/fallback_taskframe_test.rs:72
Functionnoop_task_frame_execution_test
()
tests/src/task/frames/noop_operation_taskframe_test.rs:36
Methodnot
(self)
base/src/task/dependency.rs:165
Methodnow
(&self)
base/src/scheduler/clock/progressive_clock.rs:29
Functionok_frame
( counter: &Arc<AtomicUsize>, )
tests/src/task/frames/mod.rs:16
Methodon_event
(&self, _ctx: &TaskHookContext, _payload: &OnTaskStartPayload<'_>)
tests/src/task/hooks/taskhook_test.rs:18
Methodparallel
(taskframes: Vec<Arc<dyn ErasedTaskFrame<()>>>, policy: P)
base/src/task/frames/collectionframe.rs:296
Functionparallel_all_fail_returns_error
()
tests/src/task/frames/collectionframe_test.rs:191
Functionparallel_quit_on_failure_returns_error_on_first_fail
()
tests/src/task/frames/collectionframe_test.rs:213
Functionparallel_quit_on_success_returns_early
()
tests/src/task/frames/collectionframe_test.rs:114
Methodparse
(input: ParseStream)
proc/src/taskframe.rs:43
Methodparse
(input: ParseStream)
proc/src/workflow.rs:63
Methodparse
(input: ParseStream)
proc/src/every.rs:53
Methodparse
(input: ParseStream)
proc/src/workflow/condition.rs:15
Methodparse
(input: ParseStream)
proc/src/workflow/dependency.rs:265
Methodparse
(input: ParseStream)
proc/src/workflow/timeout.rs:10
Methodparse
(input: ParseStream)
proc/src/workflow/threshold.rs:14
Methodparse
(input: ParseStream)
proc/src/workflow/delay.rs:10
Methodparse
(input: ParseStream)
proc/src/workflow/retry.rs:16
Methodparse
(input: ParseStream)
proc/src/workflow/fallback.rs:10
Methodparse_remaining
(&mut self)
proc/src/workflow/utils.rs:146
Functionproxy
(request: NextRequest)
website/proxy.ts:9
Functionpure_tokio
(tasks: usize, exec: Duration)
bin/src/main_pure.rs:5
Functionretry_exhausted_returns_err
()
tests/src/task/frames/retry_taskframe_test.rs:77
Functionretry_skipped_on_success
()
tests/src/task/frames/retry_taskframe_test.rs:94
Functionretry_succeeds_eventually
()
tests/src/task/frames/retry_taskframe_test.rs:59
Functionretry_when_filter_always_true_exhausts_retries
()
tests/src/task/frames/retry_taskframe_test.rs:130
Functionretry_when_filter_inspects_error_value_stops_on_match
()
tests/src/task/frames/retry_taskframe_test.rs:171
Functionretry_when_filter_retries_past_matching_errors
()
tests/src/task/frames/retry_taskframe_test.rs:190
Functionretry_when_filter_stops_retry
()
tests/src/task/frames/retry_taskframe_test.rs:110
Functionreturns_error_when_dep_unresolved
()
tests/src/task/frames/dependency_taskframe_test.rs:34
Functionreturns_ok_when_all_deps_resolved
()
tests/src/task/frames/dependency_taskframe_test.rs:19
Functionrewrites
()
website/next.config.mjs:9
Functionrun_delayed
(delay: Duration)
tests/src/task/frames/delay_taskframe_test.rs:16
Methodruns
(task: &Task<impl TaskFrame>, value: NonZeroU16)
base/src/task/dependency.rs:68
Methodschedule
( &self, id: &SchedulerKey<C>, time: SystemTime, )
base/src/scheduler/engine/default.rs:79
Methodschedule
(&self, time: SystemTime)
base/src/task/schedule/cron.rs:738
Methodschedule
(&self, now: SystemTime)
base/src/task/schedule/calendar.rs:274
Methodschedule
(&self, time: SystemTime)
base/src/task/schedule/interval.rs:333
Methodschedule
(&self, time: SystemTime)
base/src/task/schedule/immediate.rs:59
Functionscheduler_handle_instructions_logic
( instruct_queue: &Arc<(SegQueue<SchedulerHandlePayload>, Notify)>, dispatcher: &Arc<C::SchedulerTaskD
base/src/scheduler/impls/utils/scheduler_handle.rs:49
Methodselect
(&self, _ctx: &RestrictTaskFrameContext)
tests/src/task/frames/collectionframe_test.rs:16
Methodselection
(taskframes: Vec<Arc<dyn ErasedTaskFrame<()>>>, accessor: S)
base/src/task/frames/collectionframe.rs:305
Functionselection_exec_out_of_bounds_returns_error
()
tests/src/task/frames/collectionframe_test.rs:154
Functionselection_exec_runs_selected_frame_only
()
tests/src/task/frames/collectionframe_test.rs:136
Functionselection_exec_selects_failing_frame_returns_error
()
tests/src/task/frames/collectionframe_test.rs:235
Methodsequential
(taskframes: Vec<Arc<dyn ErasedTaskFrame<()>>>)
base/src/task/frames/collectionframe.rs:285
Functionsequential_fails_on_first_error
()
tests/src/task/frames/collectionframe_test.rs:90
Functionsequential_quit_on_failure_returns_indexed_error
()
tests/src/task/frames/collectionframe_test.rs:44
Functionsequential_quit_on_first_frame_returns_indexed_error
()
tests/src/task/frames/collectionframe_test.rs:22
Functionsequential_silent_runs_all_frames
()
tests/src/task/frames/collectionframe_test.rs:68
Functionsimulate_duration
(interval: TaskScheduleInterval)
tests/src/macros/every_macro_test.rs:5
Methodskip
(&mut self, to: u8)
base/src/utils/timing_wheel/timing_wheel_shard.rs:29
Functionspawn_task
( key: SchedulerKey<C>, hot_workers: &Arc<Vec<CachePadded<SchedulerWorkerHot<C>>>>, cold_workers:
base/src/scheduler/impls/utils.rs:28
Functionstop_on_first_failing_dep
()
tests/src/task/frames/dependency_taskframe_test.rs:54
Methodstrategy
(&self)
base/src/task/frames/collectionframe.rs:275
Functionsub_threshold_runs_do_not_trigger_reach_behaviour
()
tests/src/task/frames/threshold_taskframe_test.rs:110
Methodsuccesses
(&self)
tests/src/task/utils.rs:19
Methodsuccessful_runs
(task: &Task<impl TaskFrame>, value: NonZeroU16)
base/src/task/dependency.rs:77
Functiontask
(attr: TokenStream, item: TokenStream)
proc/src/lib.rs:230
Functiontask
(attr: TokenStream, item: TokenStream)
proc/src/task.rs:18
Functiontask_execution_returns_ok
()
tests/src/task/frames/delay_taskframe_test.rs:56
Functiontask_execution_with_delay_and_failing_frame_returns_error
()
tests/src/task/frames/delay_taskframe_test.rs:72
Functiontask_finishing_after_timeout_returns_error
()
tests/src/task/frames/timeout_taskframe_test.rs:36
Functiontask_finishing_before_timeout_returns_ok
()
tests/src/task/frames/timeout_taskframe_test.rs:18
Functiontask_returning_error_before_timeout_returns_error
()
tests/src/task/frames/timeout_taskframe_test.rs:54
Functiontaskframe
(attrs: TokenStream, item: TokenStream)
proc/src/lib.rs:361
← previousnext →301–400 of 474, ranked by callers