Struct PostgresTarget 

pub struct PostgresTarget<E>
where
    E: PluginEvent,
{ /* private fields */ }

PostgreSQL notification target.

Holds a cloneable deadpool_postgres::Pool rather than a Mutex<Option<Pool>> so that clone_box does not duplicate connection state. The optional QueueStore provides at-least-once delivery semantics consistent with the other built-in targets.

When tls_adapter is Some, the target participates in the coordinated TLS hot-reload system driven by TlsReloadAdapter, and the inline fingerprint check in send_body is skipped. When None, the legacy inline fingerprint check is used as a fallback.

Implementations

impl<E> PostgresTarget<E>

where E: PluginEvent,

pub fn clone_box(&self) -> Box<dyn Target<E> + Send + Sync>

pub fn new(id: String, args: PostgresArgs) -> Result<Self, TargetError>

Trait Implementations

impl<E> ReloadableTargetTls for PostgresTarget<E>

where E: PluginEvent,

type Material = Pool<Manager>

The rebuilt connection/client/pool object this target uses.

fn tls_input_set(&self) -> TargetTlsInputSet

Returns the TLS file paths this target reads.

fn build_tls_material<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Self::Material, TargetError>> + Send + 'async_trait>>

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

Build a fresh TLS material object from current files on disk.

fn apply_tls_material<'life0, 'async_trait>( &'life0 self, _generation: TargetTlsGeneration, material: Arc<Self::Material>, _mode: ReloadApplyMode, ) -> Pin<Box<dyn Future<Output = Result<(), TargetError>> + Send + 'async_trait>>

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

Atomically apply new TLS material, replacing the current active connection state.

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

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

Optional pre-check: validate that TLS files on disk are self-consistent (cert/key pair parseable, CA loadable) before attempting build_tls_material. Default implementation returns Ok(()).

impl<E> Target<E> for PostgresTarget<E>

where E: PluginEvent,

fn id(&self) -> TargetID

Returns the ID of the target

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

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

Checks if the target is active and reachable

fn save<'life0, 'async_trait>( &'life0 self, event: Arc<EntityTarget<E>>, ) -> Pin<Box<dyn Future<Output = Result<(), TargetError>> + Send + 'async_trait>>

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

Saves an event (either sends it immediately or stores it for later).

fn send_raw_from_store<'life0, 'async_trait>( &'life0 self, key: Key, body: Vec<u8>, meta: QueuedPayloadMeta, ) -> Pin<Box<dyn Future<Output = Result<(), TargetError>> + Send + 'async_trait>>

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

Sends an event from the store using the queued raw body and metadata.

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

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

Closes the target and releases resources

fn store( &self, ) -> Option<&(dyn Store<QueuedPayload, Error = StoreError, Key = Key> + Send + Sync)>

Returns the store associated with the target (if any)

fn clone_dyn(&self) -> Box<dyn Target<E> + Send + Sync>

Returns the type of the target

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

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

Initialize the target, such as establishing a connection, etc.

fn is_enabled(&self) -> bool

Check if the target is enabled

fn delivery_snapshot(&self) -> TargetDeliverySnapshot

Returns a read-only delivery snapshot for metrics collection.

fn record_final_failure(&self)

Records a final, non-retryable delivery failure for metrics collection.

fn name(&self) -> String

Returns the name of the target

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

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

Returns a credential-free, machine-readable health result.

fn send_from_store<'life0, 'async_trait>( &'life0 self, key: Key, ) -> Pin<Box<dyn Future<Output = Result<(), TargetError>> + Send + 'async_trait>>

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

Sends an event from the store.

fn failed_store(&self) -> Option<&dyn FailedEventStore>

Returns the failed-events store capability when the target records terminal failures.

fn handle_terminal_failure<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _store: &'life1 (dyn Store<QueuedPayload, Error = StoreError, Key = Key> + Send), _key: &'life2 Key, _error: &'life3 TargetError, _retry_count: u32, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

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

Moves a terminally failed entry to the target’s failed-events store, returning true when the entry was handled. A target without a terminal-failure store declines the move and the entry stays live.