Struct GenericPhotonBackend 

pub struct GenericPhotonBackend { /* private fields */ }

Unified backend — all storage adapters install this wrapping their port.

Implementations

impl GenericPhotonBackend

pub fn new(port: Arc<dyn StoragePort>, registry: TopicRegistry) -> Self

Wrap an existing storage port and topic registry.

pub const fn capabilities(&self) -> BackendCapabilities

Capabilities for contract tests and host introspection.

pub fn install_mem(ctx: BackendContext) -> Result<Arc<dyn PhotonBackend>>

Install the default mem tier from builder context.

Errors

Returns an error if the operation fails.

pub fn install_with_port( ctx: BackendContext, port: Arc<dyn StoragePort>, ) -> Result<Arc<dyn PhotonBackend>>

Install a custom storage port from builder context.

Errors

Returns an error if the operation fails.

Trait Implementations

impl PhotonBackend for GenericPhotonBackend

fn telemetry_label(&self) -> &'static str

Stable telemetry label for ops metrics (e.g. "mem", "nats").

fn capabilities(&self) -> BackendCapabilities

Adapter capabilities (replay window, get-by-id support, …).

fn publish<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, topic_name: &'life1 str, topic_key: Option<&'life2 str>, actor_json: Value, payload_json: Value, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

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

Append an event and return its event id.

fn subscribe( &self, topic_name: String, topic_key_filter: Option<String>, after_seq: Option<i64>, ) -> Pin<Box<dyn Stream<Item = Result<Event>> + Send>>

Stream events for a topic partition, optionally replaying after after_seq.

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

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

Load a single event by id.

fn registry(&self) -> &TopicRegistry

Inventory-discovered topic descriptors.

fn get_checkpoint_seq<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, subscription_name: &'life1 str, topic_name: &'life2 str, topic_key: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<Option<i64>>> + Send + 'async_trait>>

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

Load the last committed checkpoint seq for a subscription partition.

fn set_checkpoint<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, subscription_name: &'life1 str, topic_name: &'life2 str, topic_key: Option<&'life3 str>, last_seq: i64, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Persist the high-water checkpoint seq for a subscription partition.