obeli-sk-db-common 0.37.6

Common types and utilities shared between database implementations
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

//! Notification types for database events.

use chrono::{DateTime, Utc};
use concepts::{
    ExecutionId, FunctionFqn, SupportedFunctionReturnValue, component_id::ComponentDigest,
    storage::ResponseWithCursor,
};

/// Notification data for when an execution becomes pending.
#[derive(Debug)]
pub struct NotifierPendingAt {
    pub scheduled_at: DateTime<Utc>,
    pub ffqn: FunctionFqn,
    pub component_input_digest: ComponentDigest,
}

/// Notification data for when an execution finishes.
#[derive(Debug)]
pub struct NotifierExecutionFinished {
    pub execution_id: ExecutionId,
    pub retval: SupportedFunctionReturnValue,
}

/// Aggregated notifications to send after an append operation.
#[derive(Debug, Default)]
pub struct AppendNotifier {
    pub pending_at: Option<NotifierPendingAt>,
    pub execution_finished: Option<NotifierExecutionFinished>,
    pub response: Option<(ExecutionId, ResponseWithCursor)>,
}