surrealdb-core 3.2.3

A scalable, distributed, collaborative, document-graph database, for the realtime web
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
33
34
35
36

//! Composer extension trait for supplying an [`ExecutionObserver`] at startup.

use std::sync::Arc;

use super::observer::{ExecutionObserver, NoopObserver};
use crate::CommunityComposer;

/// Composer extension trait for supplying an [`ExecutionObserver`] at startup.
///
/// The [`CommunityComposer`] returns [`NoopObserver`] by default; the server
/// crate wraps it with the real metrics observer separately. Enterprise
/// composers override this to return an audit observer which, in turn, wraps
/// the community metrics observer so both concerns fan out from a single
/// dispatch site.
pub trait ObservabilityProvider: requirements::ObservabilityProviderRequirements {
	/// Create the observer to install on the datastore at startup.
	fn create_observer(&self) -> Arc<dyn ExecutionObserver>;
}

/// Platform-specific auto-trait bounds required of [`ObservabilityProvider`]
/// implementations.
pub mod requirements {
	#[cfg(target_family = "wasm")]
	pub trait ObservabilityProviderRequirements {}

	#[cfg(not(target_family = "wasm"))]
	pub trait ObservabilityProviderRequirements: Send + Sync + 'static {}
}

impl requirements::ObservabilityProviderRequirements for CommunityComposer {}

impl ObservabilityProvider for CommunityComposer {
	fn create_observer(&self) -> Arc<dyn ExecutionObserver> {
		Arc::new(NoopObserver)
	}
}