apalis-board-web 1.0.0-rc.8

Frontend components for managing Apalis task queues.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

use apalis_board_types::LogEntry;
use futures::{StreamExt, future::ready};
use leptos::{prelude::*, reactive::spawn_local};
use leptos_meta::Title;

use crate::{pages::tasks::single::LogViewer, use_sse_provider};

#[component]
pub fn LogsPage() -> impl IntoView {
    let logs = RwSignal::new(Vec::new());

    let sse = use_sse_provider();

    spawn_local(async move {
        let ev = sse.event_source();
        let mut stream = ev
            .to_stream()
            .filter(move |log: &LogEntry| ready(log.span.is_some()))
            .boxed_local();
        while let Some(next) = stream.next().await {
            logs.update(|list| {
                list.push(next);
            });
        }
    });
    view! {
        <Title text="Logs" />
        <div class="h-full w-full overflow-y-auto scrollbar-thin scrollbar-track-transparent scrollbar-thumb-charcoal-700 hover:scrollbar-thumb-charcoal-600">
            <LogViewer items=logs title="Logs" show_id=true />
        </div>
    }
}