| mod flow_channel pub |
paqarirqan feat(shipote): data plane + DAG fan-in/out + stats + lifecycle (fases F-I) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| mod logbuf pub |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| mod persist pub |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| mod pipeline pub |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| mod stats pub |
paqarirqan feat(shipote): data plane + DAG fan-in/out + stats + lifecycle (fases F-I) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| enum CoreError pub |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| struct WorkspaceState pub |
silq'uyninpi t'ikrakurqan feat(shipote): collision detection + stats history server-side (fase O) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| def STATS_HISTORY_CAP |
paqarirqan feat(shipote): collision detection + stats history server-side (fase O) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| struct CommandState pub |
silq'uyninpi t'ikrakurqan feat(shipote): data plane + DAG fan-in/out + stats + lifecycle (fases F-I) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| enum LogStream pub |
paqarirqan feat(shipote): data plane + DAG fan-in/out + stats + lifecycle (fases F-I) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| struct WorkspaceManager pub |
silq'uyninpi t'ikrakurqan feat(shipote): throughput card + rate-limit + snapshot incremental (fase Q) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| struct Inner |
silq'uyninpi t'ikrakurqan feat(shipote): quota enforce + cgroup memory.max + pipeline restart (fase L) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| struct PipelineSupervisor pub |
silq'uyninpi t'ikrakurqan feat(shipote): pipeline backoff + quota card + logs follow (fase M) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| struct RestartSpec |
paqarirqan feat(shipote): multi-core CPU% + quota report + restart-on-failure (fase K) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| struct CommandSummary pub |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| struct HealthCounts pub |
paqarirqan feat(shipote): health endpoint + audit log + token-bucket real (fase R) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| struct CommandInfo pub |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn read_proc_rss |
paqarirqan feat(shipote): quota enforce + cgroup memory.max + pipeline restart (fase L) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn spawn_log_drainer |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| trait OwnedFdFromRawCompat |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn from_raw_fd_compat |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn new pub |
ukhunpi t'ikrakurqan feat(shipote): throughput card + rate-limit + snapshot incremental (fase Q) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn mark_dirty |
paqarirqan feat(shipote): throughput card + rate-limit + snapshot incremental (fase Q) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn is_dirty pub |
paqarirqan feat(shipote): throughput card + rate-limit + snapshot incremental (fase Q) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn register_pipeline_supervisor pub |
ukhunpi t'ikrakurqan feat(shipote): throughput card + rate-limit + snapshot incremental (fase Q) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn register_pipeline_supervisor_with_state pub |
paqarirqan feat(shipote): pipeline backoff + quota card + logs follow (fase M) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn take_pending_restarts pub |
ukhunpi t'ikrakurqan feat(shipote): pipeline backoff + quota card + logs follow (fase M) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn register_pipeline_commands pub |
paqarirqan feat(shipote): data plane + DAG fan-in/out + stats + lifecycle (fases F-I) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn stop_pipeline pub |
paqarirqan feat(shipote): data plane + DAG fan-in/out + stats + lifecycle (fases F-I) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn retain_pipeline_flows pub |
paqarirqan feat(shipote): data plane + DAG fan-in/out + stats + lifecycle (fases F-I) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn health_counts pub |
paqarirqan feat(shipote): health endpoint + audit log + token-bucket real (fase R) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn list_flow_pipelines pub |
paqarirqan feat(shipote): data plane + DAG fan-in/out + stats + lifecycle (fases F-I) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn flow_throughput pub |
paqarirqan feat(shipote): throughput + stats persistente + auth peer (fase P) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn drop_pipeline_flows pub |
paqarirqan feat(shipote): data plane + DAG fan-in/out + stats + lifecycle (fases F-I) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn incarnator pub |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn incarnator_handle pub |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn save_pipeline pub |
ukhunpi t'ikrakurqan feat(shipote): throughput card + rate-limit + snapshot incremental (fase Q) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn list_saved_pipelines pub |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn get_saved_pipeline pub |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn drop_saved_pipeline pub |
ukhunpi t'ikrakurqan feat(shipote): throughput card + rate-limit + snapshot incremental (fase Q) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn workspace_label pub |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn workspace_quota pub |
paqarirqan feat(shipote): multi-core CPU% + quota report + restart-on-failure (fase K) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn workspace_stats pub |
ukhunpi t'ikrakurqan feat(shipote): collision detection + stats history server-side (fase O) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn workspace_stats_history pub |
paqarirqan feat(shipote): collision detection + stats history server-side (fase O) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn create pub |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn create_with_id pub |
ukhunpi t'ikrakurqan feat(shipote): throughput card + rate-limit + snapshot incremental (fase Q) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn list pub |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn stop pub |
ukhunpi t'ikrakurqan feat(shipote): data plane + DAG fan-in/out + stats + lifecycle (fases F-I) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn stop_with_grace pub |
ukhunpi t'ikrakurqan feat(shipote): throughput card + rate-limit + snapshot incremental (fase Q) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn run pub |
ukhunpi t'ikrakurqan feat(shipote): multi-core CPU% + quota report + restart-on-failure (fase K) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn run_with_options pub |
paqarirqan feat(shipote): multi-core CPU% + quota report + restart-on-failure (fase K) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn get_command_logs pub |
silq'uyninpi t'ikrakurqan feat(shipote): data plane + DAG fan-in/out + stats + lifecycle (fases F-I) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn list_commands pub |
ukhunpi t'ikrakurqan feat(shipote): data plane + DAG fan-in/out + stats + lifecycle (fases F-I) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn run_pipeline pub |
ukhunpi t'ikrakurqan feat(shipote): data plane + DAG fan-in/out + stats + lifecycle (fases F-I) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn reap_dead pub |
ukhunpi t'ikrakurqan feat(shipote): quota enforce + cgroup memory.max + pipeline restart (fase L) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| struct WorkspaceSnapshot pub |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn short_ulid |
paqarirqan shell | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| mod tests |
silq'uyninpi t'ikrakurqan feat(shipote): collision detection + stats history server-side (fase O) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn ttl_auto_stops_workspace |
ukhunpi t'ikrakurqan feat(shipote): quota enforce + cgroup memory.max + pipeline restart (fase L) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn create_and_list_workspace |
ukhunpi t'ikrakurqan feat(shipote): quota enforce + cgroup memory.max + pipeline restart (fase L) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn run_captures_stdout_to_log |
ukhunpi t'ikrakurqan feat(shipote): quota enforce + cgroup memory.max + pipeline restart (fase L) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn run_captures_stderr_separately |
ukhunpi t'ikrakurqan feat(shipote): quota enforce + cgroup memory.max + pipeline restart (fase L) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn restart_on_failure_relaunches_failing_command |
ukhunpi t'ikrakurqan feat(shipote): quota enforce + cgroup memory.max + pipeline restart (fase L) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn pipeline_supervisor_queues_restart_on_failure |
ukhunpi t'ikrakurqan feat(shipote): pipeline backoff + quota card + logs follow (fase M) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn quota_enforce_nproc_kill_terminates_commands |
paqarirqan feat(shipote): quota enforce + cgroup memory.max + pipeline restart (fase L) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn workspace_stats_history_accumulates |
paqarirqan feat(shipote): collision detection + stats history server-side (fase O) | sergio · |
⟲ Sutichaypa ñawpa willaynin |
| fn run_true_in_workspace |
ukhunpi t'ikrakurqan feat(shipote): quota enforce + cgroup memory.max + pipeline restart (fase L) | sergio · |
⟲ Sutichaypa ñawpa willaynin |