Struct RuntimeDashboardQueryService 

pub struct RuntimeDashboardQueryService { /* private fields */ }

Implementations

impl RuntimeDashboardQueryService

pub fn new( runtime: Arc<InMemoryRuntime>, control_plane: ControlPlaneSdk<CompositeControlPlaneStore<InMemoryDeliveryEndpointStore, InMemoryClusterNodeStore>>, ) -> Self

pub fn from_runtime_composition(runtime: RuntimeComposition) -> Self

Trait Implementations

impl Clone for RuntimeDashboardQueryService

fn clone(&self) -> RuntimeDashboardQueryService

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl DashboardQueryService for RuntimeDashboardQueryService

fn dashboard<'life0, 'async_trait>( &'life0 self, inspect: Option<InspectEntity>, ) -> Pin<Box<dyn Future<Output = Result<DashboardDto>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn jobs_stream<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<UiListPanel<JobRowDto>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn outbox_stream<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<UiListPanel<OutboxEventRowDto>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn endpoint_stream<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<UiListPanel<EndpointRowDto>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn recurring_stream<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<UiListPanel<RecurringDefinitionRowDto>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn cluster_stream<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<ClusterMapDto>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn scheduler_materialize_now<'life0, 'life1, 'async_trait>( &'life0 self, scheduler_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn scheduler_process_queue_once<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, queue: &'life1 str, worker_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn scheduler_publish_pending_now<'life0, 'async_trait>( &'life0 self, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn scheduler_replay_dead_letter_now<'life0, 'life1, 'async_trait>( &'life0 self, job_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn workflow_save<'life0, 'async_trait>( &'life0 self, request: WorkflowSaveRequest, ) -> Pin<Box<dyn Future<Output = Result<WorkflowSaveResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn workflow_execute<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, workflow_id: &'life1 str, queue: &'life2 str, worker_id: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<WorkflowExecuteResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn workflow_run_draft<'life0, 'async_trait>( &'life0 self, request: WorkflowRunDraftRequest, ) -> Pin<Box<dyn Future<Output = Result<WorkflowRunDraftResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn workflow_reflect_source<'life0, 'life1, 'async_trait>( &'life0 self, source: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<WorkflowSourceReflection>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn workflow_modules_search<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<WorkflowModuleSearchReflection>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn workflow_module_info<'life0, 'life1, 'async_trait>( &'life0 self, module_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<WorkflowModuleInfoReflection>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn workflow_module_types<'life0, 'life1, 'async_trait>( &'life0 self, module_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<WorkflowModuleTypesReflection>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn workflow_saved_revision_summary<'life0, 'life1, 'async_trait>( &'life0 self, workflow_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<WorkflowSavedRevisionSummary>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn workflow_lsp_diagnostics<'life0, 'life1, 'async_trait>( &'life0 self, source: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<WorkflowDiagnosticsResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn inspect<'life0, 'async_trait>( &'life0 self, entity: InspectEntity, ) -> Pin<Box<dyn Future<Output = Result<InspectorView>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,