Struct CheckpointNotifier 

pub struct CheckpointNotifier { /* private fields */ }

Publishes model checkpoint notifications to Redis pub/sub.

Used by the backward service after saving a new checkpoint file.

Implementations

impl CheckpointNotifier

pub fn new(config: CheckpointNotifierConfig) -> Self

Create a new notifier. Does not open a Redis connection yet — connections are created on each publish call to keep the notifier lightweight and resilient to transient failures.

pub fn channel(&self) -> &str

The Redis channel this notifier publishes to.

pub async fn publish(&self, notification: &CheckpointNotification) -> Result<()>

Publish a checkpoint notification.

If the notifier is disabled or the Redis connection fails, the error is returned but should generally be treated as non-fatal by callers (the checkpoint was already saved to disk).